python - Python 中的聊天模拟器无法按预期工作

Question

我想做的基本上是使用线程模拟客户端-服务器-客户端聊天。这是到目前为止的代码:

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 菜鸟

Answer 1

您的代码自 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()

Here is the entire code .