python - 客户端离开时套接字服务器不再工作
问题描述
在客户离开之前,我的程序运行良好。客户端离开后,我收到主机服务器上的错误,
以下是我正在尝试的代码:
import socket
import threading
class ChatServer:
clients_list = []
last_received_message = ""
def __init__(self):
self.server_socket = None
self.create_listening_server()
def create_listening_server(self):
self.server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
local_ip = '127.0.0.1'
local_port = 10319
# this will allow you to immediately restart a TCP server
self.server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
# this makes the server listen to requests coming from other computers on the network
self.server_socket.bind((local_ip, local_port))
print("Listening for incoming messages..")
self.server_socket.listen(5)
self.receive_messages_in_a_new_thread()
def receive_messages(self, so):
while True:
incoming_buffer = so.recv(256)
if not incoming_buffer:
break
self.last_received_message = incoming_buffer.decode('utf-8')
self.broadcast_to_all_clients(so) # send to all clients
so.close()
def broadcast_to_all_clients(self, senders_socket):
for client in self.clients_list:
socket, (ip, port) = client
if socket is not senders_socket:
socket.sendall(self.last_received_message.encode('utf-8'))
def receive_messages_in_a_new_thread(self):
while True:
client = so, (ip, port) = self.server_socket.accept()
self.add_to_clients_list(client)
print('Connected to ', ip, ':', str(port))
t = threading.Thread(target=self.receive_messages, args=(so,))
t.start()
def add_to_clients_list(self, client):
if client not in self.clients_list:
self.clients_list.append(client)
if __name__ == "__main__":
ChatServer()
错误 (ConnectionResetError) 位于incoming_buffer = so.recv(256)
.
有谁知道上面的代码有什么问题?
解决方案
代码没有问题。您只需要使用try
/except
来捕获此错误并跳出循环。
Python 有一个socketserver
内置的模块可以处理大部分开销。
推荐阅读
- r - 如何在 R 编程中为我的输出创建 csv
- java - 我正在尝试将 MySQL 连接器从版本 5 升级到版本 8,但出现以下错误。休眠 3 不支持 MySQL 8 吗?
- javascript - Ace 编辑器,toUpperCase 函数有效,但 toggleCommentLines 无效
- server - 连接到服务器 Pixel Streaming Unreal Engine 后出错
- python - 如何获取硒元素的屏幕坐标?[Python]
- node.js - NodeJS(Loopback):带有多部分/表单数据(FormData)的环回连接器休息
- python - NameError:名称“文件”未定义为 isinstance 参数
- api - 不和谐.js | 如何检测 API 是否返回 null?
- dictionary - 我无法使用以下代码创建和更新字典
- azure - 在 ADF 部署时将 ADLS Gen1 转换为 Gen2