从一个套接字接收两个函数
从一个套接字接收两个函数
提问于 2020-11-10 09:54:04
我希望创建一个套接字客户端，并希望在一个函数中发送消息时接收答案，但同时也希望随时侦听所有传入的数据。
问题是，如果两者都执行，代码就会停止执行，因为recv()似乎是一个阻塞函数。
这是一个简单的概述：
Server.py
import socket
HOST = "127.0.0.1"
PORT = 6543
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen()
conn, addr = s.accept()
with conn:
print("Connected by ", addr)
while True:
data = conn.recv(1024)
conn.sendall(data)Client.py
import socket
import time
import multiprocessing
HOST = "127.0.0.1"
PORT = 6543
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
def keepAlive():
while True:
s.send(b"Keep Alive to be handled in keepAlive")
print(s.recv(1024), "received from keepAlive")
time.sleep(1)
def send():
while True:
s.send(b"Random message to be handled in listen")
time.sleep(1)
def listen():
while True:
print(s.recv(1024), "received from listen")
if __name__ == "__main__":
keepAliveProc = multiprocessing.Process(target=keepAlive)
listenProc = multiprocessing.Process(target=listen)
sendProc = multiprocessing.Process(target=send)
keepAliveProc.start()
listenProc.start()
sendProc.start()但这将阻止和代码不再继续。有人能帮忙吗？
回答 2
Stack Overflow用户
发布于 2020-11-10 11:09:33
我认为您不需要服务器块中的res = socket.recv(1024)。您不需要客户机(listen())的响应，因为客户端没有发送任何内容。
Stack Overflow用户
发布于 2020-11-10 11:06:23
我对python编程没有经验，但我最近确实用java开发了套接字通信。如果recv阻塞程序，那么它会阻塞直到收到一些数据。我认为您需要从多进程处理转变为线程，因为多进程处理是CPU绑定的，而且您的通信是基于网络的。
也许这能帮上忙：Python socket recv in thread
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/64766564
复制相关文章
相似问题
腾讯云开发者
