Python Socket 异步收发设计

Question

我正在编写一个 python 套接字客户端

1. 每 5 秒发送一次 message one（例如 Hello），每 15 秒发送一次 message two（例如 15 秒）
2. 随时接收消息

我的意思是在不同的线程中进行发送和接收。但是，它仍然处于阻塞状态。 有人有建议吗？

线程#1

threading.Thread(target=Thread2, args=(sock)).start()
sock.recv(1024)

线程#2

def Thread2(sock):
    count = 0
    while True:
        sleep(5)
        count = count + 5
        sock.send('Hello')
        if count % 15 == 0
            sock.send('15 seconds')

Answer 1

它没有阻塞。只是你的主线程在第一个sock.recv(1024) 之后什么都不做。你必须告诉它不断收集数据：

主线

threading.Thread(target=Thread2, args=(sock,)).start()
while True:
    data = sock.recv(1024)
    if not data:
        break
    print data

请注意，您将无法轻易中断该过程。为此，您需要将线程设置为守护进程：

主线

t = threading.Thread(target=Thread2, args=(sock,))
t.daemon = True
t.start()
while True:
    data = sock.recv(1024)
    if not data:
        break
    print data

当你传递args 时，记得传递一个元组，即args=(sock,) 而不是args=(sock)。对于 Python，args=(sock) 等价于 args=sock。这可能是罪魁祸首！

我在您的代码中看不到更多问题。