套接字上的 BrokenPipeError
BrokenPipeError on socket
我使用 Python Socket 创建了一个 Messenger,当我使用两个客户端时,例如,当一个用户离开聊天时,第二个用户可以再发送 1-2 条消息,之后服务器停止接受来自其他用户的消息,这是一个众所周知的错误 Broken pipe 32。我理解错误的术语,也许错误在于我的服务器在 While True 循环中(一个循环包括用户执行的所有操作他们之间),因为有一个很棒的代码形式:
if not data:
print(f'User {name1} leave')
break
但是我需要它,因为没有它,服务器会直接飞走,如果做一个类似的机制,服务器仍然可以接收用户的信息。
希望相互理解,任何帮助都会被接受和感激。服务器和客户端代码如下:
server:
import socket
import threading
import time
HOST = '127.0.0.1'
PORT = 8888
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind((HOST, PORT))
server.listen(15)
print(f'Server {HOST}:{PORT} start.')
users = []
sort = []
def crypto(text, key):
encrypt = ''
for i in text:
encrypt += chr(ord(i) + key)
return encrypt
def listen_decode(user, addr):
print(f'User IP-address {addr[0]} login..')
sort.append(user)
user.send('Encode'.encode('utf-8'))
user.send('Name'.encode('utf-8'))
name1 = user.recv(1024).decode('utf-8')
users.append(name1)
while True:
data = user.recv(1024).decode('utf-8')
b1 = time.ctime()
atribute = ' | '
data_crypto = crypto(data, 4)
print(f'{name1} sent message: {data_crypto} ' + atribute + '' + b1 + ' ')
for i in sort:
if(i != server and i != user):
i.sendall(f'{name1} > {data}'.encode('utf-8'))
if not data:
print(f'User {name1} leave')
break
def start_server():
while True:
user_socket, addr = server.accept()
potok_info = threading.Thread(target=listen_decode, args=(user_socket, addr))
potok_info.start()
if __name__ == '__main__':
start_server()
客户:
from tkinter import messagebox
from tkinter import *
import _tkinter
import socket
import threading
import os
window = Tk()
window.title('Login')
window.geometry('320x200')
window.resizable(True, True)
HOST = '127.0.0.1'
PORT = 8888
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect((HOST, PORT))
name = StringVar()
password = StringVar()
def encrypt(text, key):
encrypt1 = ''
for i in text:
encrypt1 += chr(ord(i) - key)
return encrypt1
def send_message():
while True:
data = client.recv(1024)
print('\r\r' + data.decode('utf-8') + '\n' + f'you: ', end='')
def chat():
string_name = name.get()
if('Name' in client.recv(1024).decode('utf-8')):
name1 = string_name
client.send(name1.encode('utf-8'))
potok = threading.Thread(target=send_message)
potok.start()
while True:
msg = input('you: ')
client.send(msg.encode('utf-8'))
def crypt():
string_name = name.get()
string_password = password.get()
try:
user_encryption_selection = (encryption_listbox.get(encryption_listbox.curselection()))
except _tkinter.TclError:
messagebox.showerror('Error', 'Enter type message')
if string_name == 'John':
if string_password == '5555':
if user_encryption_selection == 'Use Encrypted':
window.after(1000, lambda: window.destroy())
menu = Tk()
menu.title('Menu Chat')
menu.geometry('500x350')
menu.resizable(False, False)
menu_button = Button(menu, text='Global chat', command=chat, height=1, width=18)
menu_button.grid(padx=150)
menu.mainloop()
else:
messagebox.showerror('Error', 'Error password')
else:
messagebox.showerror('Error', 'Error name')
entry = Entry(window, textvariable=name, width=10)
entry.grid(column=1, pady=7, padx=4)
label = Label(window, text='Enter name: ')
label.grid(row=0, padx=1)
entry1 = Entry(window, textvariable=password, width=10)
entry1.grid(column=1, pady=7, padx=2)
label1 = Label(window, text='Enter password: ')
label1.grid(row=1, padx=1)
listbox = Listbox(window, selectmode=SINGLE, width=12, height=2)
listbox.grid(column=1, row=2, pady=7, padx=2)
encryption_options = ['Use Encrypted']
encryption_listbox = Listbox(window, selectmode=SINGLE, width=10, height=1)
encryption_listbox.grid(column=1, row=2, pady=7, padx=2)
for i in encryption_options:
encryption_listbox.insert(END, i)
label_crypto = Label(window, text='Type message: ', bg='black', fg='red')
label_crypto.grid(row=2)
button = Button(window, text='Enter', command=crypt)
button.grid(pady=30)
window.mainloop()
perhaps the error lies on my server in a While True loop (a loop that includes all the actions that users carry out among themselves), because there is a fabulous code in the form:
if not data:
print(f'User {name1} leave')
break
您已经找到错误原因的位置。发生错误是因为服务器不断尝试发送给断开连接的客户端(在该代码上方的循环中)。要停止服务器尝试此操作,您只需在识别断开连接的那个地方从 sort
(连接的客户端列表)中删除客户端,即。 e.在 break
.
之前插入 sort.remove(user)
我使用 Python Socket 创建了一个 Messenger,当我使用两个客户端时,例如,当一个用户离开聊天时,第二个用户可以再发送 1-2 条消息,之后服务器停止接受来自其他用户的消息,这是一个众所周知的错误 Broken pipe 32。我理解错误的术语,也许错误在于我的服务器在 While True 循环中(一个循环包括用户执行的所有操作他们之间),因为有一个很棒的代码形式:
if not data:
print(f'User {name1} leave')
break
但是我需要它,因为没有它,服务器会直接飞走,如果做一个类似的机制,服务器仍然可以接收用户的信息。
希望相互理解,任何帮助都会被接受和感激。服务器和客户端代码如下:
server:
import socket
import threading
import time
HOST = '127.0.0.1'
PORT = 8888
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind((HOST, PORT))
server.listen(15)
print(f'Server {HOST}:{PORT} start.')
users = []
sort = []
def crypto(text, key):
encrypt = ''
for i in text:
encrypt += chr(ord(i) + key)
return encrypt
def listen_decode(user, addr):
print(f'User IP-address {addr[0]} login..')
sort.append(user)
user.send('Encode'.encode('utf-8'))
user.send('Name'.encode('utf-8'))
name1 = user.recv(1024).decode('utf-8')
users.append(name1)
while True:
data = user.recv(1024).decode('utf-8')
b1 = time.ctime()
atribute = ' | '
data_crypto = crypto(data, 4)
print(f'{name1} sent message: {data_crypto} ' + atribute + '' + b1 + ' ')
for i in sort:
if(i != server and i != user):
i.sendall(f'{name1} > {data}'.encode('utf-8'))
if not data:
print(f'User {name1} leave')
break
def start_server():
while True:
user_socket, addr = server.accept()
potok_info = threading.Thread(target=listen_decode, args=(user_socket, addr))
potok_info.start()
if __name__ == '__main__':
start_server()
客户:
from tkinter import messagebox
from tkinter import *
import _tkinter
import socket
import threading
import os
window = Tk()
window.title('Login')
window.geometry('320x200')
window.resizable(True, True)
HOST = '127.0.0.1'
PORT = 8888
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect((HOST, PORT))
name = StringVar()
password = StringVar()
def encrypt(text, key):
encrypt1 = ''
for i in text:
encrypt1 += chr(ord(i) - key)
return encrypt1
def send_message():
while True:
data = client.recv(1024)
print('\r\r' + data.decode('utf-8') + '\n' + f'you: ', end='')
def chat():
string_name = name.get()
if('Name' in client.recv(1024).decode('utf-8')):
name1 = string_name
client.send(name1.encode('utf-8'))
potok = threading.Thread(target=send_message)
potok.start()
while True:
msg = input('you: ')
client.send(msg.encode('utf-8'))
def crypt():
string_name = name.get()
string_password = password.get()
try:
user_encryption_selection = (encryption_listbox.get(encryption_listbox.curselection()))
except _tkinter.TclError:
messagebox.showerror('Error', 'Enter type message')
if string_name == 'John':
if string_password == '5555':
if user_encryption_selection == 'Use Encrypted':
window.after(1000, lambda: window.destroy())
menu = Tk()
menu.title('Menu Chat')
menu.geometry('500x350')
menu.resizable(False, False)
menu_button = Button(menu, text='Global chat', command=chat, height=1, width=18)
menu_button.grid(padx=150)
menu.mainloop()
else:
messagebox.showerror('Error', 'Error password')
else:
messagebox.showerror('Error', 'Error name')
entry = Entry(window, textvariable=name, width=10)
entry.grid(column=1, pady=7, padx=4)
label = Label(window, text='Enter name: ')
label.grid(row=0, padx=1)
entry1 = Entry(window, textvariable=password, width=10)
entry1.grid(column=1, pady=7, padx=2)
label1 = Label(window, text='Enter password: ')
label1.grid(row=1, padx=1)
listbox = Listbox(window, selectmode=SINGLE, width=12, height=2)
listbox.grid(column=1, row=2, pady=7, padx=2)
encryption_options = ['Use Encrypted']
encryption_listbox = Listbox(window, selectmode=SINGLE, width=10, height=1)
encryption_listbox.grid(column=1, row=2, pady=7, padx=2)
for i in encryption_options:
encryption_listbox.insert(END, i)
label_crypto = Label(window, text='Type message: ', bg='black', fg='red')
label_crypto.grid(row=2)
button = Button(window, text='Enter', command=crypt)
button.grid(pady=30)
window.mainloop()
perhaps the error lies on my server in a While True loop (a loop that includes all the actions that users carry out among themselves), because there is a fabulous code in the form:
if not data: print(f'User {name1} leave') break
您已经找到错误原因的位置。发生错误是因为服务器不断尝试发送给断开连接的客户端(在该代码上方的循环中)。要停止服务器尝试此操作,您只需在识别断开连接的那个地方从 sort
(连接的客户端列表)中删除客户端,即。 e.在 break
.
sort.remove(user)