C＃套接字问题

Question

我在C＃中创建套接字服务器，并在PHP中创建客户端。客户端和服务器之间的会话是这样的：

1. 客户端连接
2. 服务器发送欢迎消息
3. 客户端发送数据
4. 服务器发送响应
5. （重复步骤3 - 4，直到客户端断开连接）

它一直工作到第3步。服务器收到来自客户端的数据。但是，客户端会一直等到服务器发送响应并最终超时。

下面是相关的C＃代码：

class Program 
{ 
    private const int CONNECT_QUEUE_LENGTH = 4; 

    static void ListenForRequests() 
    { 
     Socket listenSock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 
     listenSock.Bind(new IPEndPoint(IPAddress.Any, 9999)); 
     listenSock.Listen(CONNECT_QUEUE_LENGTH); 
     listenSock.Blocking = true; 

     byte[] data = new byte[1024]; 

     while (true) 
     { 
      Socket newConnection = listenSock.Accept(); 
      newConnection.Blocking = true; 

      // Create new thread for each request 
      var t = new Thread(() => new RequestHandler(newConnection)); 
      t.Start(); 
     } 
    } 
} 

class RequestHandler 
{ 
    public RequestHandler(Socket socket) 
    { 
     Util.WriteToSocket("A message", socket); 
     Console.WriteLine("Received: " + Util.ReadSocketToEnd(socket).Length); 
     Util.WriteToSocket("Fin!", socket); 
    } 
}  

static class Util 
{ 
    public static string ReadSocketToEnd(Socket newConnection) 
    { 
     var sb = new StringBuilder(); 

     byte[] data = new byte[1024]; 
     int receivedDataLength = newConnection.Receive(data); 

     while (receivedDataLength > 0) 
     { 
      try 
      { 
       sb.Append(Encoding.UTF8.GetString(data, 0, receivedDataLength)); 
       receivedDataLength = newConnection.Receive(data); 
      } 
      catch (SocketException) 
      { 
       break; 
      } 
     } 

     return sb.ToString(); 
    } 

    public static void WriteToSocket(string message, Socket client) 
    { 
     byte[] data = Encoding.UTF8.GetBytes(message); 
     client.Send(data, SocketFlags.None); 
    } 
} 

这里是简单的PHP客户端，没有任何错误处理等：

<?php 

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); 
$result = socket_connect($socket, '127.0.0.1', 9999); 

print 'receiving: ' . chr(10); 
print socket_read ($socket, 10) . chr(10); 
print 'receive end' . chr(10); 


$message = str_repeat("Message to sent", 1000); 
socket_write($socket, $message, strlen($message)); 
print 'message sent' . chr(10); 


print 'reading fin' . chr(10); // This is printed, but a response is never received 
print socket_read ($socket, 10) . chr(10); 
print 'fin read!' . chr(10); 

socket_shutdown($socket); 

Answer 1

你从套接字读取直到所有数据已被读取 - 意思是“直到套接字关闭之前的所有数据”。您的PHP客户端正在写入数据，但未关闭套接字 - 所以服务器正在等待。

TCP套接字提供了一个流的数据。没有关于“当前消息的结束”的概念，它看起来像你想要的。

处理这种情况的三种方法通常是：

• 一个消息分隔符（例如，换行）
（就在消息本身之前的消息中的字节数）的消息长度的前缀
• 使用为每个请求/响应对不同的连接

您可以潜在地使用的读出以超时，并且假设如果你在过去的5秒内没有看到更多的数据，那么你已经得到了整个信息 - 但这很脆弱，效率低下，而且通常是一个糟糕的主意。