我想做的基本上是使用线程模拟客户端-服务器-客户端聊天。这是到目前为止的代码:
from socket import *
from threading import Thread
import threading
import time
from random import randint
clients = []
HOST = 'localhost'
PORT = 8000
class Server():
def __init__(self):
self.addr = (HOST,PORT)
global clients
self.start()
for i in range(5): Thread(target=self.clientHandler).start()
self.s.close()
def clientHandler(self):
conn, addr = self.s.accept()
clients.append(addr)
print addr[1], "is Connected"
while 1:
time.sleep(5)
# message=repr(data)
# message=message[1:-1].split(':')
message='test' #for debug
conn.sendto(message, clients[1]) #for debug
# conn.sendto(message[1], clients[int(message[0])])
def start(self):
self.s = socket(AF_INET, SOCK_STREAM)
self.s.bind((HOST, PORT))
self.s.listen(5)
print "Server is running......"
class Client(threading.Thread):
global clients
def sendMessage(self):
if len(clients)>1:
to=randint(0, len(clients)-1)
message = str(to)+':hello from '+self.name
print message
self.ss.send(message)
def receiveMessage(self):
while 1:
reply=self.ss.recv(1024)
if reply != '':
print self.name+" received ", repr(reply)
break
def run(self):
self.ss = socket(AF_INET, SOCK_STREAM)
self.ss.connect((HOST, PORT)) # client-side, connects to a host
self.name=self.ss.getsockname()[1]
while True:
# time.sleep(randint(1,5))
# self.sendMessage()
self.receiveMessage()
server=Server()
client1=Client()
client2=Client()
client3=Client()
client1.start()
client2.start()
client3.start()
这个想法是一个客户端应该一遍又一遍地向另一个随机客户端(还没有考虑排除自己)发送一条消息。为此，消息的格式为 dest: message，其中 dest 是用于从 clients 列表中选择客户端的随机索引。
经过数小时的“调试”，我发现 sendto() 方法将消息发送给所有客户端，而不仅仅是具有指定地址的客户端(如上面的代码所做的那样)。我用错了吗？
此外，当我让客户端发送消息时，他们只会立即收到返回的消息。我做错了什么？
我知道这很乱，对此感到抱歉。我刚开始使用 Python，我正在测试多种方法以了解它们的工作原理。
谢谢。 - Python 菜鸟
请您参考如下方法:
您的代码自 sendto 的第二个参数起有效对于 TCP 套接字将被忽略。
要使您的想法生效，您必须实际读取服务器上的内容。但首先，让我们看看其他明显的问题:
您在服务器上恰好创建了 5 个线程。这目前还没有害处，但将来可能会造成危害。相反，只需在需要时创建一个线程，如
class Server(threading.Thread):
def __init__(self):
super(Server, self).__init__()
self.addr = (HOST,PORT)
self.start()
def run(self):
self.s = socket(AF_INET, SOCK_STREAM)
self.s.bind((HOST, PORT))
self.s.listen(5)
print "Server is running......"
while True:
conn, addr = self.s.accept()
threading.Thread(target=self.clientHandler, args=(conn, addr)).start()
然后，不存储地址，存储套接字:
def clientHandler(self, conn, addr):
clients.append(conn)
此外，在clientHandler中，从套接字中读取:
def clientHandler(self, conn, addr):
clients.append(conn)
while True:
msg = read_from_socket(conn)
id_str, _, msg = msg.partition(b':')
clients[int(id_str.decode('ascii'))].sendall(msg)
read_from_socket 必须是读取消息格式的函数。由于 TCP 是无数据包的(将其想象成一个无限流，直到远程端关闭)，您必须定义一种消息格式。让我们现在开始，等待换行 b'\n':
def read_from_socket(conn):
buf = bytearray(0)
while True:
b = conn.recv(1)
buf.extend(b)
if b == b'\n':
return bytes(buf)
然后我们只需调整客户端以添加一个\n字节:
class Client(threading.Thread):
def sendMessage(self):
if len(clients)>1:
to = randint(0, len(clients) - 1)
message = ('%s:hello from %s\n' % (to, self.name)).encode('utf-8')
print(message)
self.ss.send(message)
最后，确保实际发送消息(目前，您没有):
server=Server()
client1=Client()
client2=Client()
client3=Client()
client1.start()
client2.start()
client3.start()
time.sleep(1)
client1.sendMessage()
