Python将两个客户端连接到一个服务器会导致第一个客户端中断

Question

我试图创建一个简单的python聊天界面，但是当两个客户端连接到服务器时，第一个客户端控制台会尽快打印空白，并导致最大递归深度错误，而第二个客户端仍然可以正常工作。服务器代码只在非空时发送数据，所以我不确定它为什么会这样做。

服务器代码：

import socket
from threading import Thread
from socketserver import ThreadingMixIn

class ClientThread(Thread):

    def __init__(self,ip,port):
        Thread.__init__(self)
        self.ip = ip
        self.port = port
        print("[+] New thread started for "+ip+": "+str(port))

    def run(self):
        while True:
            data = conn.recv(1024).decode()
            if not data: break
            if data == "/exit":
                print("Connection for "+ip+" closed.")
                data = "Connection closed."
                conn.send(data.encode())
                break
            else:
                print("received data: ", data)
            if data != " ":
                conn.send(data.encode())
        print("connection "+ip+" force closed.")

TCP_IP = socket.gethostname()
TCP_PORT = 994
BUFFER_SIZE = 1024

tcpsock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcpsock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
tcpsock.bind((TCP_IP, TCP_PORT))
threads = []

while True:
    tcpsock.listen(4)
    (conn, (ip,port)) = tcpsock.accept()
    newthread = ClientThread(ip,port)
    newthread.start()
    threads.append(newthread)

for t in threads:
    t.join()

客户代码：

import socket
import threading
from threading import Thread

TCP_IP = socket.gethostname()
TCP_PORT = 994
BUFFER_SIZE = 1024

name = str(input("Input username: "))

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((TCP_IP, TCP_PORT))

def recv():
    while True:
        data = s.recv(BUFFER_SIZE).decode()
        if not data: break
        print(data)
    recv()

def send():
    message = str(input())
    if message != "/exit":
        message = name + ": " + message
    s.send(message.encode())
    send()

if __name__ == "__main__":
    Thread(target = recv).start()
    Thread(target = send).start()

错误出现在客户机代码的第19行（接收和打印服务器发送的任何数据），如有任何帮助，将不胜感激。

Answer 1

最可能的原因是发送和接收例程中的递归，我将它们改为循环。

def recv():
    while True:
        data = s.recv(BUFFER_SIZE).decode()
        if not data: break
        print(data)

def send():
    while True:
        message = str(input())
        if message != "/exit":
            message = name + ": " + message
        s.send(message.encode())

这里给出了关闭这些线程的解决方案：有没有办法在Python中杀死线程？

但是在这个场景中，没有必要在客户端的单个线程中运行发送和接收。

编辑：我再次仔细阅读你的代码。在客户端中，您将发送和接收方法作为线程启动。发送线程不会在线程中为其消息字符串获取任何输入，因为您循环它，它会向服务器发送空消息，或者（在我的情况下）以错误退出。