JAVA与C#的TCP通信——JAVA客户端，C#线程池服务端

小小示例，用于java与C#的TCP通信，java作为client，C#作为Server，Server用线程池。

主要功能为，client可以发送数据到Server，然后Server发送数据到client，断开；

相当于client发出请求，Server给予回应。

 

JAVA Client:

 

 

package com.cn.test;
import java.net.*;
import java.io.*;

public class TCPClient2 {
    public static void main(String[] args) throws Exception {
    TCPClient();
    }

    public static void TCPClient(){
        String s="";
        Socket mysocket;
        InputStreamReader in=null;
        OutputStreamWriter out=null;

        try{
            mysocket=new Socket("127.0.0.1",8002);
            in = new InputStreamReader(mysocket.getInputStream(),"UTF8");
            out = new OutputStreamWriter(mysocket.getOutputStream()); 
            //从控制台输入数据
              String sendMsg = "";
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            System.out.println("Enter your value:");
            sendMsg = br.readLine();


            out.write(sendMsg);        //通过 out向服务器写入信息。
              out.flush();
            int c =0;             

             while((c = in.read())>-1){
//           System.out.print((char)c);//通过使用in读取服务器写入输出流的信息。堵塞状态，
                s += (char)c;                
              }

            //除非读取到信息。                 
             System.out.println("客户收到服务器数据---->"+s);
             in.close();
             out.close();
             mysocket.close();  
           }
         catch(IOException e)
           { 
              System.out.println(e.toString());
           }

    }
}

 

 

C# Server:

 

 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.Net;
using System.Threading;

namespace TCPServer
{
    class Program
    {
        static private System.Net.IPAddress MyIP = System.Net.IPAddress.Parse("127.0.0.1");
        static private TcpListener listener = new TcpListener(MyIP, 8002);
        static private String msg;
        static void Main(string[] args)
        {
            ThreadPool.SetMaxThreads(10, 5);
            ThreadPool.SetMinThreads(5, 5);
            listener.Start();
            //接收数据
            while (true)
            {
                //测试是否有数据
                try
                {
                    TcpClient client = listener.AcceptTcpClient();
                    ThreadPool.QueueUserWorkItem(callbackPoc, client);

                }
                catch (Exception re)
                {
                    Console.WriteLine(re.Message);
                }
       }
            listener.Stop();
        }

        //线程池回调函数
        static void  callbackPoc(Object k)
        {
            TcpClient client = (TcpClient)k;
            NetworkStream ns = client.GetStream();
            //StreamReader sr = new StreamReader(ns);//流读写器
            //字组处理
            while (true)
            {
                try
                {

                    byte[] bytes = new byte[1024];
                    int bytesread = ns.Read(bytes, 0, bytes.Length);
                    msg = Encoding.Default.GetString(bytes, 0, bytesread);
                    //显示
                    //MessageBox.Show(msg);
                    Console.WriteLine(msg);
                    //将收到的数据回传给客户端，实际中，应该经过解析，将相应的数据回传给客户端。
                    NetworkStream sendStream = client.GetStream();
                    String msga = Console.ReadLine();
                    Byte[] sendBytes = Encoding.Default.GetBytes(msga);
                    sendStream.Write(sendBytes, 0, sendBytes.Length);
                    sendStream.Flush();
                    ns.Flush();
                    ns.Close();
                    sendStream.Close();
                }
                catch (Exception ex)
                {
                    client.Close();
                    Console.WriteLine(ex.Message);
                    break;
                }
            }
        }

    }
}

 

 

另外，有四个C#方面TCPServer例子程序可供学习研究，下载地址

http://download.csdn.net/source/3232338