現在、複数のクライアント コンピューターからの複数の接続を受け入れることができる C# ソケット サーバーを開発中です。サーバーの目的は、クライアントがサーバー イベントから「サブスクライブ」および「サブスクライブ解除」できるようにすることです。
これまでのところ、私はここをよく見てみました: http://msdn.microsoft.com/en-us/library/5w7b7x5f(v=VS.100).aspxおよびhttp://msdn.microsoft.com/アイデアについては、 en-us/library/fx6588te.aspxを参照してください。
送信するすべてのメッセージは暗号化されているため、送信したい文字列メッセージを取得し、それを byte[] 配列に変換してからデータを暗号化してから、メッセージの長さをデータに追加して接続経由で送信します.
問題として私を襲う 1 つのことはこれです: 受信側では、メッセージの半分しか受信されていないときに Socket.EndReceive() (または関連するコールバック) が返される可能性があるようです。各メッセージが「完全」に受信され、一度に 1 つのメッセージのみが受信されるようにする簡単な方法はありますか?
編集:たとえば、.NET / Windows ソケットは、Socket.Send() で送信された単一のメッセージが 1 つの Socket.Receive() 呼び出しで受信されるようにメッセージを「ラップ」しませんか? それともそうですか？
これまでの私の実装：
private void StartListening()
{
IPHostEntry ipHostInfo = Dns.GetHostEntry(Dns.GetHostName());
IPEndPoint localEP = new IPEndPoint(ipHostInfo.AddressList[0], Constants.PortNumber);
Socket listener = new Socket(localEP.Address.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
listener.Bind(localEP);
listener.Listen(10);
while (true)
{
// Reset the event.
this.listenAllDone.Reset();
// Begin waiting for a connection
listener.BeginAccept(new AsyncCallback(this.AcceptCallback), listener);
// Wait for the event.
this.listenAllDone.WaitOne();
}
}
private void AcceptCallback(IAsyncResult ar)
{
// Get the socket that handles the client request.
Socket listener = (Socket) ar.AsyncState;
Socket handler = listener.EndAccept(ar);
// Signal the main thread to continue.
this.listenAllDone.Set();
// Accept the incoming connection and save a reference to the new Socket in the client data.
CClient client = new CClient();
client.Socket = handler;
lock (this.clientList)
{
this.clientList.Add(client);
}
while (true)
{
this.readAllDone.Reset();
// Begin waiting on data from the client.
handler.BeginReceive(client.DataBuffer, 0, client.DataBuffer.Length, 0, new AsyncCallback(this.ReadCallback), client);
this.readAllDone.WaitOne();
}
}
private void ReadCallback(IAsyncResult asyn)
{
CClient theClient = (CClient)asyn.AsyncState;
// End the receive and get the number of bytes read.
int iRx = theClient.Socket.EndReceive(asyn);
if (iRx != 0)
{
// Data was read from the socket.
// So save the data
byte[] recievedMsg = new byte[iRx];
Array.Copy(theClient.DataBuffer, recievedMsg, iRx);
this.readAllDone.Set();
// Decode the message recieved and act accordingly.
theClient.DecodeAndProcessMessage(recievedMsg);
// Go back to waiting for data.
this.WaitForData(theClient);
}
}