C#利用服务器实现客户端之间通信
先来讲述下我自己对于整个Socket通信过程的理解，毕竟初学，说错见谅，知道错了会改正~
首先在服务端新建一个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端代码
namespaceSocketServer
{
classProgram
{
privatestaticbyte[]result=newbyte[1024];
staticSocketserverSocket;
privatestaticstringclient;
privatestaticSocketclientSocket;
//我这里存了两个Client，因为自己电脑开了两个Client，不会有多的
//理论上应该开一个Socket[]来保存信息，最好用一个二元组将client的信息和连接绑定起来
//这样就可以实现断开连接后下次登陆还是可以识别是这个Client
privatestaticSocketclientSocketA=null;
privatestaticSocketclientSocketB=null;
staticvoidMain(string[]args)
{
Program.SetPort(8885);
}
privatestaticvoidSetPort(intport)
{
IPAddressip=IPAddress.Parse("127.0.0.1");//setip
serverSocket=newSocket(AddressFamily.InterNetwork,
SocketType.Stream,ProtocolType.Tcp);//initialize
serverSocket.Bind(newIPEndPoint(ip,port));//bind
serverSocket.Listen(10);
//进入监听状态
Console.WriteLine("监听{0}成功",serverSocket.LocalEndPoint.ToString());
//开启一个线程来监听客户端连接
ThreadmyThread=newThread(ListenClientConnect);
myThread.Start();
Console.ReadLine();
}
///<summary>
///监听客户端连接
///</summary>
privatestaticvoidListenClientConnect()
{
while(true)
{
//Client连接上后得到这个连接
clientSocket=serverSocket.Accept();
//这里我因为只有两个Client，所以就简单写了
if(clientSocketA==null)
{
clientSocketA=clientSocket;
}
elseif(clientSocketB==null)
{
clientSocketB=clientSocket;
}
else
{
//当其中一个断开了，又重新连接时，需要再次保存连接
if(clientSocketB.IsBound)
{
clientSocketA=clientSocketB;
clientSocketB=clientSocket;
}
else
{
clientSocketB=clientSocketA;
clientSocketA=clientSocket;
}
}
clientSocket.Send(Encoding.ASCII.GetBytes("sayhello"));
//开个线程接收Client信息
ThreadreceivedThread=newThread(ReceiveMessage);
receivedThread.Start(clientSocket);
}
}
privatestaticvoidReceiveMessage(objectclientSocket)
{
SocketmyClientSocket=(Socket)clientSocket;
while(true)
{
try
{
intrevceiveNumber=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("receivefromA");
if(clientSocketB!=null&&clientSocketB.IsBound)
{
Console.WriteLine("aISBOUND");
clientSocketB.Send(result,0,revceiveNumber,SocketFlags.None);
}
else
{
myClientSocket.Send(Encoding.ASCII.GetBytes("thepeopleisnotonline!SendFailed!"));
Console.WriteLine("对方不在线上，发送失败！");
}
}
else
{
Console.WriteLine("receivefromB");
if(clientSocketA!=null&&clientSocketA.IsBound)
{
Console.WriteLine("aISBOUND");
clientSocketA.Send(result,0,revceiveNumber,SocketFlags.None);
}
else
{
myClientSocket.Send(Encoding.ASCII.GetBytes("thepeopleisnotonline!SendFailed!"));
Console.WriteLine("对方不在线上，发送失败！");
}
}
}
catch(Exceptionex)
{
Console.WriteLine(ex.Message);
myClientSocket.Shutdown(SocketShutdown.Both);
myClientSocket.Close();
break;
}
}
}
}
}
Client端代码(因为都差不多就只贴一个了)
namespaceSocketClient
{
classProgram
{
privatestaticbyte[]result=newbyte[1024];
privatestaticSocketclientSocket;
privatestaticvoidListenServer()
{
while(true)
{
result=newbyte[1024];
intreceiveLength=clientSocket.Receive(result);
Console.WriteLine("{0}",Encoding.ASCII.GetString(result,0,receiveLength));
}
}
staticvoidMain(string[]args)
{
IPAddressip=IPAddress.Parse("127.0.0.1");
clientSocket=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);
try
{
clientSocket.Connect(ip,8885);
Console.WriteLine("连接成功！");
}
catch(Exceptione)
{
Console.WriteLine("连接失败！");
return;
}
ThreadthreadRead=newThread(ListenServer);
threadRead.Start();
while(true)
{
try
{
Thread.Sleep(1000);
stringsendMessage=Console.ReadLine();
clientSocket.Send(Encoding.ASCII.GetBytes("Sylvia:"+sendMessage));
}
catch(Exceptionex)
{
clientSocket.Shutdown(SocketShutdown.Both);
clientSocket.Close();
break;
}
}
Console.WriteLine("发送完毕按回车退出");
Console.ReadKey();
}
}
}
写的时候要特别注意一下Send信息的时候，注意byte[]的传输大小，很容易变成byte[]数组的大小而不是内容的大小。
这个大家就自己尝试吧。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。