我正在创建一个简单的客户端-服务器聊天系统。我使用TCP,我知道TCP是end。但我正在尝试将从一个客户端接收的数据转发到阵列中的下一个客户端。但是在下面的代码中,我试图将它发送到所有客户端(即使失败了:D) 这是我的密码:
from socket import *
from os import *
from threading import *
def multipleClients():
all_clients = []
conn, addr = s.accept()
all_clients.append(conn)
print "is connected :D :)", addr
while True:
data= conn.recv(1024)
if not data:
break
print "message is :", repr(data)
for c in all_clients:
c.send(data)
host='localhost'
port=12000
s=socket(AF_INET, SOCK_STREAM)
s.bind((host, port))
s.listen(5)
print "Server is Running :D :p "
for i in range (5):
Thread(target=multipleClients).start()
TCP是一种流协议。你可能需要某种消息协议。
recv
最多可以接收1024个字节,可以是一条消息、一条消息的一部分,也可以同时接收多条消息。你知道吗每个线程只有一个客户机,因为您只有一个
accept
。您可能希望使用select
来管理多个连接。你知道吗相关问题 更多 >
编程相关推荐