C#巧用服务器实现客户端之间通信

发布时间：2023-06-03 16:00:27 所属栏目：语言来源：互联网

导读： 　　在分布式调度系统中，要实现调度服务器与多个计算节点服务器之间的通信，socket是一种实现方法，下面，就跟错新技术频道小编一起去学C#利用服务器实现客户端之间通信吧！

　　首

　　在分布式调度系统中，要实现调度服务器与多个计算节点服务器之间的通信，socket是一种实现方法，下面，就跟错新技术频道小编一起去学C#利用服务器实现客户端之间通信吧！

　　首先在服务端新建一个serverSocket，对其进行初始化（一般包含AddressFamily:IP地址类型，SocketType:Socket传输数据方式，ProtoType:传输协议）;

　　接着我们要设置server端要绑定的IP:port;然后开始监听，并设置最多同时监听多少个Client.

　　这时，服务端就在等待状态，直到某一个Client连接到这个ip:port上，这时serverSocket.Accept()工作，获得这个连接。（此时的连接是有地址信息的哦！记得保存）

　　获得连接之后，server就可以和这个Client进行通信了,当加入第二个Client（我们称其为ClientB）时，Server接收到ClientB的消息，可以将这个消息转发给前一个Client（我们称其为ClientA），当受到ClientA的消息，也可以转发给ClientB。这样就实现了Clients之间的通信了。（重点在保存连接信息！！）

　　那么现在贴上代码讲解：

　　Server端代码

　　namespace SocketServer{ class Program { private static byte[] result = new byte[1024]; static Socket serverSocket; private static string client; private static Socket clientSocket; //我这里存了两个Client，因为自己电脑开了两个Client，不会有多的 //理论上应该开一个Socket[]来保存信息，最好用一个二元组将client的信息和连接绑定起来 //这样就可以实现断开连接后下次登陆还是可以识别是这个Client private static Socket clientSocketA=null; private static Socket clientSocketB=null; static void Main(string[] args) { Program.SetPort(8885); } private static void SetPort(int port) { IPAddress ip = IPAddress.Parse("127.0.0.1");//set ip serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//initialize serverSocket.Bind(new IPEndPoint(ip, port));//bind serverSocket.Listen(10); //进入监听状态 Console.WriteLine("监听{0}成功", serverSocket.LocalEndPoint.ToString()); //开启一个线程来监听客户端连接 Thread myThread = new Thread(ListenClientConnect); myThread.Start(); Console.ReadLine(); } /// <summary> /// 监听客户端连接 /// </summary> private static void ListenClientConnect() { while (true) { //Client连接上后得到这个连接 clientSocket = serverSocket.Accept(); //这里我因为只有两个Client，所以就简单写了 if (clientSocketA == null) { clientSocketA = clientSocket; } else if (clientSocketB == null) { clientSocketB = clientSocket; } else { //当其中一个断开了，又重新连接时，需要再次保存连接 if (clientSocketB.IsBound) { clientSocketA = clientSocketB; clientSocketB = clientSocket; } else { clientSocketB = clientSocketA; clientSocketA = clientSocket; } } clientSocket.Send(Encoding.ASCII.GetBytes("say hello")); //开个线程接收Client信息 Thread receivedThread = new Thread(ReceiveMessage); receivedThread.Start(clientSocket); } } private static void ReceiveMessage(object clientSocket) { Socket myClientSocket = (Socket) clientSocket; while (true) { try { int revceiveNumber = myClientSocket.Receive(result); //Console.WriteLine("接受客户端{0}消息{1}", myClientSocket.RemoteEndPoint.ToString() // , Encoding.ASCII.GetString(result, 0, revceiveNumber)); Console.WriteLine(Encoding.ASCII.GetString(result, 0, revceiveNumber)); if (myClientSocket == clientSocketA) { Console.WriteLine("receive from A"); if (clientSocketB!=null&&clientSocketB.IsBound) { Console.WriteLine("a IS BOUND"); clientSocketB.Send(result, 0, revceiveNumber, SocketFlags.None); } else { myClientSocket.Send(Encoding.ASCII.GetBytes("the people is not online! Send Failed!")); Console.WriteLine("对方不在线上，发送失败！"); } } else { Console.WriteLine("receive from B"); if (clientSocketA != null && clientSocketA.IsBound) { Console.WriteLine("a IS BOUND"); clientSocketA.Send(result, 0, revceiveNumber, SocketFlags.None); } else { myClientSocket.Send(Encoding.ASCII.GetBytes("the people is not online! Send Failed!")); Console.WriteLine("对方不在线上，发送失败！"); } } } catch(Exception ex) { Console.WriteLine(ex.Message); myClientSocket.Shutdown(SocketShutdown.Both); myClientSocket.Close(); break; } } } }}

　　Client端代码(因为都差不多就只贴一个了)

　　namespace SocketClient{ class Program { private static byte[] result = new byte[1024]; private static Socket clientSocket; private static void ListenServer() { while (true) { result = new byte[1024]; int receiveLength = clientSocket.Receive(result); Console.WriteLine("{0}", Encoding.ASCII.GetString(result, 0, receiveLength)); } } static void Main(string[] args) { IPAddress ip = IPAddress.Parse("127.0.0.1"); clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); try { clientSocket.Connect(ip, 8885); Console.WriteLine("连接成功！"); } catch (Exception e) { Console.WriteLine("连接失败！"); return; } Thread threadRead = new Thread(ListenServer); threadRead.Start(); while(true) { try { Thread.Sleep(1000); string sendMessage = Console.ReadLine(); clientSocket.Send(Encoding.ASCII.GetBytes("Sylvia:"+sendMessage)); } catch (Exception ex) { clientSocket.Shutdown(SocketShutdown.Both); clientSocket.Close(); break; } } Console.WriteLine("发送完毕按回车退出"); Console.ReadKey(); } }}

　　写的时候要特别注意一下Send信息的时候，注意byte[]的传输大小，很容易变成byte[]数组的大小而不是内容的大小。

（编辑：南京站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!