Python套接字不接收而不发送

Question

我从 python 文档中复制了 echo 服务器示例，它工作正常。但是当我编辑代码时，它不会将数据发送回客户端，第二次调用 socket.recv() 方法时不会返回。

import socket

HOST = ''
PORT = 50007 
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(1)

conn, addr = s.accept()
print('Connected by', addr)

while True:
    data = conn.recv(1024)
    if not data: break
conn.sendall(b'ok')
conn.close()

在 python 文档的原始版本中，while 循环略有不同：

while True:
    data = conn.recv(1024)
    if not data: break
    conn.sendall(data)

客户代码：

import socket

HOST = 'localhost'
PORT = 50007
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
s.sendall(b'Hello, world')
data = s.recv(1024)
s.close()
print('Received', repr(data))

Answer 1

TCP 套接字是数据流。在一侧发送呼叫和在另一侧接收呼叫之间没有一对一的关联。根据您实施的协议，存在更高级别的相关性。在原始代码中，规则是服务器将准确发送它收到的内容，直到客户端关闭连接的传入端。然后服务器关闭了套接字。

随着你的改变，规则也改变了。现在服务器继续接收和丢弃数据，直到客户端关闭连接的传入端。然后服务器发送“ok”并关闭套接字。

使用第一条规则的客户端挂起，因为它在关闭套接字之前需要数据。如果它想使用这个新的服务器规则，它必须关闭它的输出端来告诉服务器它完成了，然后它可以得到返回数据。

我已更新客户端和服务器以关闭部分连接，并让客户端执行多次接收以防传入数据碎片化。不太完整的实现似乎适用于小型有效负载，因为您不太可能出现碎片，但在实际生产代码中会严重中断。

服务器

import socket

HOST = ''
PORT = 50007 
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.bind((HOST, PORT))
s.listen(1)

conn, addr = s.accept()
print('Connected by', addr)

while True:
    data = conn.recv(1024)
    if not data: break
conn.sendall(b'ok')
conn.shutdown(socket.SHUT_WR)
conn.close()

客户

import socket

HOST = 'localhost'
PORT = 50007
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
s.sendall(b'Hello, world')
s.shutdown(socket.SHUT_WR)
data = b''
while True:
    buf = s.recv(1024)
    if not buf:
        break
    data += buf
s.close()
print('Received', repr(data))

Answer 2

接收和发送操作的数量必须匹配，因为它们是阻塞的。这是您的代码的流程图：

Server listen 
Client connect 
Server receive (this waits until a message arrives at the server) [1] 
Client send 'Hello world' (received by [1])
Server receive (because there was data received) [2]
Client receive [3]

因为现在服务器和客户端都被阻塞了，所以没有程序可以继续下去了。

解决方法是删除客户端的接收调用，因为您删除了服务器的发送调用。