问题:
当我做这样的事情时:
for (int i = 0; i < 100; i++)
{
SendMessage( sometSocket, i.ToString());
Thread.Sleep(250); // works with this, doesn't work without
}
无论是否处于睡眠状态,服务器都会记录单独消息的发送。然而,如果没有睡眠,客户端最终会在单个 OnDataReceived 中接收多条消息,因此客户端将收到如下消息:
0,
1、
2、
34、
5、
678、
9 ....
服务器发送代码:
private void SendMessage(Socket socket, string message)
{
logger.Info("SendMessage: Preparing to send message:" + message);
byte[] byteData = Encoding.ASCII.GetBytes(message);
if (socket == null) return;
if (!socket.Connected) return;
logger.Info("SendMessage: Sending message to non " +
"null and connected socket with ip:" + socket.RemoteEndPoint);
// Record this message so unit testing can very this works.
socket.Send(byteData);
}
客户端接收代码:
private void OnDataReceived(IAsyncResult asyn)
{
logger.Info("OnDataReceived: Data received.");
try
{
SocketPacket theSockId = (SocketPacket)asyn.AsyncState;
int iRx = theSockId.Socket.EndReceive(asyn);
char[] chars = new char[iRx + 1];
System.Text.Decoder d = System.Text.Encoding.UTF8.GetDecoder();
int charLen = d.GetChars(theSockId.DataBuffer, 0, iRx, chars, 0);
System.String szData = new System.String(chars);
logger.Info("OnDataReceived: Received message:" + szData);
InvokeMessageReceived(new SocketMessageEventArgs(szData));
WaitForData(); // .....
套接字数据包:
public class SocketPacket
{
private Socket _socket;
private readonly int _clientNumber;
private byte[] _dataBuffer = new byte[1024]; ....
我的预感是这与缓冲区大小有关,或者只是在 OnDataReceived 和 EndReceive 之间我们收到多条消息。
更新:事实证明,当我将 Thread.Sleep 放在 OnDataReceived 的开头时,它会获取每条消息。将我的消息包装在长度前缀和表示结束的字符串中是唯一的解决方案吗?