2

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

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，并且正在测试多种方法以了解它们的工作原理。

谢谢你。- 蟒蛇菜鸟

4

1 回答 1

1

您的代码有效，因为sendtoTCP 套接字的第二个参数被忽略。

为了使您的想法生效，您必须实际阅读服务器上的某些内容。但首先，让我们看看其他明显的问题：

您正在服务器上创建恰好 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()

这是整个代码。

于 2014-01-10T11:52:20.793 回答