我正在尝试使用 python 制作一个基于终端的基本聊天应用程序。我使用 select() 来更新可读/可写连接。然而，在来自每个客户端的两条消息之后，服务器返回一个空的可读列表 (sockets_list)。

我已经尝试从我的套接字列表中删除删除连接的代码。

这是 server.py

import socket
import select
import time

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# host, port
host = 'localhost'
port = 5555

# bind and listen for connections
sock.bind((host, port))
sock.listen(2)

print('Server started on. {} {}'.format(host, port))

# select lists
sockets_list = [sock]
outputs = []

clients = {}


def receive_message(conn):
    try:
        msg = conn.recv(4096)

        if not len(msg):
            return False

        return msg

    except conn.error as e:
        return False


while True:
    print('\n waiting for the next event')

    readable, writable, exceptions = select.select(sockets_list, outputs, [], 10)

    print(readable, writable)

    for s in readable:
        if s == sock:
            connection, address = s.accept()

            user = receive_message(connection)

            if user is False:
                continue

            sockets_list.append(connection)
            clients[connection] = user

            print(f'Accepted new connection from {user.decode()}')
        else:
            arr = s.recv(4096).decode().split(':')
            if len(arr) < 2:
                arr = s.recv(4096).decode().split(':')

            elif len(arr) >= 2:
                message = arr[1]
                # if message is False:
                #     print(f'Connection closed with {s}')
                #
                #     sockets_list.remove(s)
                #     del clients[s]
                #
                #     continue
                user = clients[s]
                print(f'Received message from {user.decode()}: {message}')

                for client in clients:
                    # But don't sent it to sender
                    if client != s:
                        # Send user and message (both with their headers)
                        # client.send(user['header'] + user['data'] + message['header'] + message['data'])
                        client.send(f"{user.decode()}:{message}".encode())
                        print(f'Sending {message} to {clients[client].decode()}')

这是client.py:

import socket
import select
import errno
import sys

IP = "localhost"
PORT = 5555
current_user = input("Username: ")

client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

client.connect((IP, PORT))

# client.setblocking(False)

username = current_user.encode()
client.send(username)

while True:
    message = input(f'{current_user} > ')
    if message:
        # Encode message to bytes, prepare header and convert to bytes, like for username above, then send
        client.send(f'{current_user}:{message}'.encode())

    try:
        while True:

            arr = client.recv(4096).decode().split(':')
            username = arr[0]
            if not username:
                print('Connection closed by the server')
                sys.exit()

            message = arr[1]
            # Print message
            print(f'{username} > {message}')
            message = input(f'{current_user} > ')

    except IOError as e:
        print(e)
        sys.exit()

    except Exception as e:
        print(e)

我希望服务器从两个客户端接收/发送消息。这意味着无论客户端 1 发送什么，客户端 2 都会看到。

最佳答案

问题是我没有与客户端正确发送/接收数据。所以我稍微调整了一下，现在可以用了!

while True:
    message = input(f'{current_user} > ')
    if message:
        client.send(f'{current_user}:{message}'.encode())

    arr = client.recv(4096).decode().split(':')

    if arr:
        username = arr[0]
        message = arr[1]
        # Print message
        print(f'{username} > {message}')

将永远循环放在永远循环中没有意义，所以我放弃了它。

我用 if arr: 检查客户端是否收到数据并打印数据。由于 arr 处于永远循环中，因此它总是检查数据。

要发送数据，非常简单，获取输入，通过套接字发送。

关于python - 在来自每个客户端的几条消息后，Select 返回空套接字列表，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/57399143/