局域网聊天软件
多个电脑之间需要穿一些文件，发一些文本，想从网上找一找有没有局域网即时聊天软件。找了好一会儿，飞秋，飞鸽，在网上都不好下载。电脑也是Ubuntu Windows Mac，要找就需要这几个系统都要下，都要安装。不管了，咱是开发者，了解自己的需求，不就是传几个文字还有发送简单的文件吗？还要我费劲安装软件，用U盘拷贝，不允许。
徒手写一段写“两三行代码”搞定。
源码见附录。
需要的文件就一个main.py，将附录代码复制进去，运行即可。
python main.py需要的三方库：
仅tkinter需要安装，其他的好像不用另外安装，如果没有 pip install。。。或者百度怎么安装
运行效果：
支持即时聊天，文件发送，
站消息过滤：用字符串表示，不同站，消息会被过滤，因此即使同一个网络下设置自己的站ID，就不会被别人打扰了，简陋做的，没有添加其他站消息接入等内容
删除联系人功能简陋，添加也是简陋，自己用无所谓。
发送消息前需要点击前面的复选框，否则提示未勾选发送人
开发环境：
python3.8，Windows
测试环境：
安装python3.x tkinter的Mac，Ubuntu，Win11。使用同一套代码即可
源码位置：
自取，不出意外，应该不会更新，以代码段即可正常运行 Cancy126/pythonMI: 使用python开发一款局域网即时通信软件，需要支持win，ubuntu，mac之类的桌面系统
import tkinter as tk
from tkinter import ttk, filedialog, messagebox
import os
import json
import socket
import threading
import time
import uuid
from datetime import datetimeclass ChatApp:def __init__(self, root):self.root = rootself.root.title("聊天程序")self.root.geometry("1200x800")# 设置主题样式style = ttk.Style()style.configure("Chat.TFrame", background="#f0f0f0")style.configure("Header.TLabel", font=("微软雅黑", 12, "bold"))style.configure("Peer.TFrame", relief="solid", borderwidth=1)# 网络设置self.DEFAULT_UDP_PORT = 8859self.BROADCAST_PORT = 8850self.UDP_PORT = self.DEFAULT_UDP_PORTself.socket = Noneself.broadcast_socket = Noneself.is_online = Falseself.hostname = socket.gethostname()self.local_ips = self.get_all_local_ips()self.uuid = self.generate_uuid()self.station_id = "default-station" # 添加站ID，默认值self.peers = {} # 存储对端信息# 线程控制self.running = Falseself.message_thread = Noneself.broadcast_thread = Noneself.broadcast_timer = None# 创建主框架self.main_frame = ttk.Frame(self.root, padding="10", style="Chat.TFrame")self.main_frame.grid(row=0, column=0, sticky=(tk.W, tk.E, tk.N, tk.S))self.root.grid_columnconfigure(0, weight=1)self.root.grid_rowconfigure(0, weight=1)# 创建设置面板self.create_settings_panel()# 左侧面板（对端列表）self.create_left_panel()# 右侧面板（聊天区域）self.create_right_panel()# 绑定回车键发送消息self.input_field.bind('<Return>', lambda e: self.send_message())def generate_uuid(self):try:# 使用启动时间生成UUIDreturn str(uuid.uuid5(uuid.NAMESPACE_DNS, str(datetime.now().timestamp())))except Exception as e:print(f"无法生成UUID: {e}")# 如果生成失败，使用随机UUIDreturn str(uuid.uuid4())def get_all_local_ips(self):ips = set() # 使用set避免重复IPtry:# 方法1：通过socket获取主机名解析hostname = socket.gethostname()try:host_ips = socket.gethostbyname_ex(hostname)[2]for ip in host_ips:if not ip.startswith('127.'): # 排除本地回环地址ips.add(ip)except Exception as e:print(f"通过主机名获取IP失败: {e}")# 方法2：通过创建UDP socket获取try:temp_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)temp_sock.settimeout(0.1)# 尝试连接一个公共DNS服务器（这里不会真正建立连接）temp_sock.connect(('8.8.8.8', 80))ip = temp_sock.getsockname()[0]if not ip.startswith('127.'):ips.add(ip)temp_sock.close()except Exception as e:print(f"通过UDP socket获取IP失败: {e}")# 方法3：遍历所有网络接口try:for family, socktype, proto, canonname, sockaddr in socket.getaddrinfo(hostname, None):if family == socket.AF_INET: # 只获取IPv4地址ip = sockaddr[0]if not ip.startswith('127.'):ips.add(ip)except Exception as e:print(f"通过getaddrinfo获取IP失败: {e}")# 如果还是没有获取到IP，尝试最后的方法if not ips:try:# 在某些系统上，这个方法可能更可靠temp_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)temp_sock.connect(('10.255.255.255', 1))ip = temp_sock.getsockname()[0]if not ip.startswith('127.'):ips.add(ip)temp_sock.close()except Exception as e:print(f"通过备用方法获取IP失败: {e}")except Exception as e:print(f"获取IP地址时发生错误: {e}")# 如果所有方法都失败，至少返回本地回环地址if not ips:print("警告: 无法获取有效的IP地址，使用本地回环地址")ips.add('127.0.0.1')# 转换为列表并排序，确保结果的一致性return sorted(list(ips))def create_settings_panel(self):# 设置面板self.settings_frame = ttk.LabelFrame(self.main_frame, text="本机设置", padding="5")self.settings_frame.grid(row=0, column=0, columnspan=3, sticky=(tk.W, tk.E), pady=(0, 10))# 本机信息host_info = ttk.Frame(self.settings_frame)host_info.pack(fill=tk.X, pady=5)ttk.Label(host_info, text="本机名：").pack(side=tk.LEFT)ttk.Label(host_info, text=self.hostname).pack(side=tk.LEFT, padx=(0, 20))ttk.Label(host_info, text="UUID：").pack(side=tk.LEFT)ttk.Label(host_info, text=self.uuid[:8]).pack(side=tk.LEFT, padx=(0, 20))# 站ID设置station_frame = ttk.Frame(self.settings_frame)station_frame.pack(fill=tk.X, pady=5)ttk.Label(station_frame, text="站ID：").pack(side=tk.LEFT)self.station_entry = ttk.Entry(station_frame, width=20)self.station_entry.insert(0, self.station_id)self.station_entry.pack(side=tk.LEFT, padx=(0, 20))# IP地址显示ip_frame = ttk.Frame(self.settings_frame)ip_frame.pack(fill=tk.X, pady=5)ttk.Label(ip_frame, text="本机IP：").pack(side=tk.LEFT)for ip in self.local_ips:ttk.Label(ip_frame, text=ip).pack(side=tk.LEFT, padx=(0, 10))# 端口设置port_frame = ttk.Frame(self.settings_frame)port_frame.pack(fill=tk.X, pady=5)ttk.Label(port_frame, text="UDP端口：").pack(side=tk.LEFT)self.port_entry = ttk.Entry(port_frame, width=10)self.port_entry.insert(0, str(self.DEFAULT_UDP_PORT))self.port_entry.pack(side=tk.LEFT, padx=(0, 10))# 按钮区域button_frame = ttk.Frame(self.settings_frame)button_frame.pack(fill=tk.X, pady=5)self.online_button = ttk.Button(button_frame, text="上线", command=self.go_online)self.online_button.pack(side=tk.LEFT, padx=5)self.refresh_button = ttk.Button(button_frame, text="刷新", command=self.refresh_peers)self.refresh_button.pack(side=tk.LEFT, padx=5)self.add_contact_button = ttk.Button(button_frame, text="添加联系人", command=self.show_add_contact_dialog)self.add_contact_button.pack(side=tk.LEFT, padx=5)self.delete_contact_button = ttk.Button(button_frame, text="删除联系人", command=self.delete_selected_contact)self.delete_contact_button.pack(side=tk.LEFT, padx=5)def create_left_panel(self):self.left_panel = ttk.Frame(self.main_frame, style="Peer.TFrame")self.left_panel.grid(row=1, column=0, sticky=(tk.W, tk.E, tk.N, tk.S), padx=(0, 10))self.main_frame.grid_columnconfigure(1, weight=1)self.main_frame.grid_rowconfigure(1, weight=1)# 对端列表标题self.peers_header = ttk.Label(self.left_panel, text="通信列表", style="Header.TLabel")self.peers_header.pack(fill=tk.X, padx=5, pady=5)# 对端列表columns = ('hostname', 'ip', 'port', 'uuid')self.peers_list = ttk.Treeview(self.left_panel, columns=columns, height=20, selectmode='none', show='tree headings')# 设置列标题self.peers_list.heading('#0', text='√') # 复选框列self.peers_list.heading('hostname', text='主机名')self.peers_list.heading('ip', text='IP地址')self.peers_list.heading('port', text='端口')self.peers_list.heading('uuid', text='UUID')# 设置列宽度self.peers_list.column('#0', width=30, stretch=False) # 复选框列self.peers_list.column('hostname', width=100, stretch=True)self.peers_list.column('ip', width=130, stretch=True)self.peers_list.column('port', width=50, stretch=False)self.peers_list.column('uuid', width=70, stretch=False)# 添加滚动条scrollbar = ttk.Scrollbar(self.left_panel, orient="vertical", command=self.peers_list.yview)self.peers_list.configure(yscrollcommand=scrollbar.set)# 使用grid布局管理器self.peers_list.pack(side=tk.LEFT, fill=tk.BOTH, expand=True, padx=5, pady=5)scrollbar.pack(side=tk.RIGHT, fill=tk.Y, pady=5)# 创建复选框图片self.checked_img = tk.PhotoImage(width=13, height=13)self.unchecked_img = tk.PhotoImage(width=13, height=13)# 绘制复选框self.checked_img.put(('black',), to=(2, 2, 10, 3)) # 顶边self.checked_img.put(('black',), to=(2, 9, 10, 10)) # 底边self.checked_img.put(('black',), to=(2, 2, 3, 10)) # 左边self.checked_img.put(('black',), to=(9, 2, 10, 10)) # 右边self.checked_img.put(('black',), to=(3, 5, 8, 7)) # 对勾的横线self.checked_img.put(('black',), to=(3, 7, 3, 8)) # 对勾的竖线self.unchecked_img.put(('black',), to=(2, 2, 10, 3)) # 顶边self.unchecked_img.put(('black',), to=(2, 9, 10, 10)) # 底边self.unchecked_img.put(('black',), to=(2, 2, 3, 10)) # 左边self.unchecked_img.put(('black',), to=(9, 2, 10, 10)) # 右边# 存储选中状态self.checked_items = set()# 绑定点击事件self.peers_list.bind('<Button-1>', self.on_click)def on_click(self, event):# 获取点击的区域region = self.peers_list.identify_region(event.x, event.y)if region == "tree": # 只处理复选框列的点击item = self.peers_list.identify_row(event.y)if item: # 确保点击在有效行上if item in self.checked_items:self.checked_items.remove(item)self.peers_list.item(item, image=self.unchecked_img)else:self.checked_items.add(item)self.peers_list.item(item, image=self.checked_img)def delete_selected_contact(self):if not self.checked_items:messagebox.showwarning("提示", "请勾选要删除的联系人")returnif messagebox.askyesno("确认", "确定要删除勾选的联系人吗？"):for peer_id in list(self.checked_items): # 使用list创建副本，因为我们会在循环中修改setself.peers_list.delete(peer_id)if peer_id in self.peers:del self.peers[peer_id]self.checked_items.remove(peer_id) # 从勾选集合中移除def refresh_peers(self):if not self.is_online:messagebox.showwarning("提示", "请先上线！")returnself.broadcast_presence(force=True)def go_online(self):if self.is_online:self.go_offline()returntry:# 获取并验证站IDself.station_id = self.station_entry.get().strip()if not self.station_id:self.station_id = "default-station"self.station_entry.insert(0, self.station_id)port = int(self.port_entry.get())if port < 1024 or port > 65535:raise ValueError("端口号必须在1024-65535之间")# 创建消息socketself.UDP_PORT = portself.socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)self.socket.bind(('0.0.0.0', self.UDP_PORT))# 创建广播socketself.broadcast_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)self.broadcast_socket.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)self.broadcast_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)self.broadcast_socket.bind(('0.0.0.0', self.BROADCAST_PORT))self.is_online = Trueself.running = Trueself.online_button.config(text="下线")self.port_entry.config(state='disabled')self.station_entry.config(state='disabled') # 上线后禁用站ID输入# 启动网络线程self.start_network_threads()messagebox.showinfo("提示", "上线成功！")except Exception as e:messagebox.showerror("错误", f"上线失败: {str(e)}")self.go_offline()def go_offline(self):self.running = Falseself.is_online = False# 取消定时广播if self.broadcast_timer:self.root.after_cancel(self.broadcast_timer)self.broadcast_timer = None# 关闭socketif self.socket:try:self.socket.shutdown(socket.SHUT_RDWR)except:passtry:self.socket.close()except:passself.socket = Noneif self.broadcast_socket:try:self.broadcast_socket.shutdown(socket.SHUT_RDWR)except:passtry:self.broadcast_socket.close()except:passself.broadcast_socket = None# 等待线程结束if self.message_thread and self.message_thread.is_alive():self.message_thread.join(timeout=1.0)if self.broadcast_thread and self.broadcast_thread.is_alive():self.broadcast_thread.join(timeout=1.0)self.message_thread = Noneself.broadcast_thread = None# 更新UIself.online_button.config(text="上线")self.port_entry.config(state='normal')self.station_entry.config(state='normal') # 下线后启用站ID输入# 清空联系人列表for item in self.peers_list.get_children():self.peers_list.delete(item)self.peers.clear()self.checked_items.clear()def show_add_contact_dialog(self):dialog = tk.Toplevel(self.root)dialog.title("添加联系人")dialog.geometry("300x200")dialog.transient(self.root)ttk.Label(dialog, text="主机名:").grid(row=0, column=0, padx=5, pady=5)hostname_entry = ttk.Entry(dialog)hostname_entry.grid(row=0, column=1, padx=5, pady=5)ttk.Label(dialog, text="IP地址:").grid(row=1, column=0, padx=5, pady=5)ip_entry = ttk.Entry(dialog)ip_entry.grid(row=1, column=1, padx=5, pady=5)ttk.Label(dialog, text="端口:").grid(row=2, column=0, padx=5, pady=5)port_entry = ttk.Entry(dialog)port_entry.insert(0, str(self.DEFAULT_UDP_PORT))port_entry.grid(row=2, column=1, padx=5, pady=5)def add_contact():try:hostname = hostname_entry.get().strip()ip = ip_entry.get().strip()port = int(port_entry.get().strip())if not hostname or not ip:raise ValueError("主机名和IP地址不能为空")if port < 1024 or port > 65535:raise ValueError("端口号必须在1024-65535之间")peer_id = f"{hostname}_{ip}"peer_info = {'hostname': hostname,'ip': ip,'port': port,'uuid': str(uuid.uuid4()) # 为手动添加的联系人生成随机UUID}if peer_id not in self.peers:self.peers[peer_id] = peer_infoself.peers_list.insert('', 'end', peer_id, values=(hostname, ip, port, peer_info['uuid'][:8]),image=self.unchecked_img) # 添加未选中的复选框图片dialog.destroy()else:messagebox.showwarning("警告", "该联系人已存在！")except Exception as e:messagebox.showerror("错误", str(e))ttk.Button(dialog, text="添加", command=add_contact).grid(row=3, column=0, columnspan=2, pady=20)def send_message(self):if not self.is_online:messagebox.showwarning("提示", "请先上线！")returnmessage = self.input_field.get().strip()if not message:returnselected_peers = self.checked_itemsif not selected_peers:messagebox.showwarning("提示", "请选择至少一个接收方")returnmessage_data = {'type': 'message','from': self.hostname,'uuid': self.uuid,'station_id': self.station_id, # 添加站ID'content': message,'timestamp': datetime.now().timestamp()}for peer_id in selected_peers:peer = self.peers[peer_id]try:self.socket.sendto(json.dumps(message_data).encode(), (peer['ip'], peer['port']))except Exception as e:messagebox.showerror("发送失败", f"发送消息到 {peer['hostname']} 失败: {str(e)}")self.update_chat_display(message_data, is_self=True)self.input_field.delete(0, tk.END)def send_file(self):if not self.is_online:messagebox.showwarning("提示", "请先上线！")returnselected_peers = self.checked_itemsif not selected_peers:messagebox.showwarning("提示", "请选择至少一个接收方")returnfile_path = filedialog.askopenfilename()if not file_path:returnfile_name = os.path.basename(file_path)file_size = os.path.getsize(file_path)# 发送文件信息file_info = {'type': 'file','from': self.hostname,'uuid': self.uuid,'station_id': self.station_id, # 添加站ID'content': {'filename': file_name,'filesize': file_size},'timestamp': datetime.now().timestamp()}for peer_id in selected_peers:peer = self.peers[peer_id]try:# 发送文件信息self.socket.sendto(json.dumps(file_info).encode(), (peer['ip'], peer['port']))time.sleep(0.1) # 等待接收方准备好# 开始发送文件内容self.progress_label.config(text=f"正在发送: {file_name}")self.progress['value'] = 0with open(file_path, 'rb') as f:sent_size = 0chunk_size = 8192 # 8KB chunkswhile sent_size < file_size:chunk = f.read(chunk_size)if not chunk:breakself.socket.sendto(chunk, (peer['ip'], peer['port']))sent_size += len(chunk)progress = (sent_size / file_size) * 100self.progress['value'] = progressself.root.update()time.sleep(0.001) # 防止发送过快self.progress['value'] = 100self.progress_label.config(text=f"文件发送完成: {file_name}")self.update_chat_display({'from': self.hostname,'content': f"文件 {file_name} 发送完成"}, is_self=True)except Exception as e:messagebox.showerror("发送失败", f"发送文件到 {peer['hostname']} 失败: {str(e)}")self.progress_label.config(text="文件发送失败")finally:self.root.after(2000, lambda: self.progress_label.config(text=""))self.root.after(2000, lambda: self.progress.configure(value=0))def update_chat_display(self, message, is_self=False):self.chat_display.config(state='normal')timestamp = datetime.now().strftime("%H:%M:%S")if message.get('type') == 'system':# 系统消息使用不同的格式显示self.chat_display.insert(tk.END, f"[{timestamp}] 系统: {message['content']}\n")else:# 普通消息显示prefix = "你" if is_self else message.get('from', 'Unknown')content = message.get('content', '')if isinstance(content, str): # 只显示字符串类型的内容self.chat_display.insert(tk.END, f"[{timestamp}] {prefix}: {content}\n")self.chat_display.see(tk.END)self.chat_display.config(state='disabled')def handle_file(self, message, addr):# 检查站ID是否匹配sender_station_id = message.get('station_id', 'default-station')if sender_station_id != self.station_id:print(f"忽略来自不同站的文件: {sender_station_id}")return# 检查发送者是否在联系人列表中sender_info = message.get('from', 'Unknown')sender_uuid = message.get('uuid')if sender_uuid and sender_uuid != self.uuid: # 确保不是自己发的消息peer_id = f"{sender_info}_{addr[0]}"if peer_id not in self.peers:# 添加新联系人peer_info = {'hostname': sender_info,'ip': addr[0],'port': addr[1],'uuid': sender_uuid,'station_id': sender_station_id # 保存对方的站ID}self.peers[peer_id] = peer_infoself.peers_list.insert('', 'end', peer_id,values=(sender_info, addr[0], addr[1], sender_uuid[:8]),image=self.unchecked_img)content = message['content']filename = content['filename']filesize = content['filesize']# 创建接收目录save_dir = os.path.join(os.path.expanduser("~"), "Downloads", "ChatFiles")os.makedirs(save_dir, exist_ok=True)save_path = os.path.join(save_dir, filename)self.update_chat_display({'from': sender_info,'content': f"正在接收文件: {filename} ({filesize} 字节)"})# 开始接收文件内容try:with open(save_path, 'wb') as f:received_size = 0self.progress_label.config(text=f"正在接收: {filename}")while received_size < filesize:chunk, _ = self.socket.recvfrom(8192)if not chunk:breakf.write(chunk)received_size += len(chunk)progress = (received_size / filesize) * 100self.progress['value'] = progressself.root.update()self.progress['value'] = 100self.progress_label.config(text=f"文件接收完成: {filename}")self.update_chat_display({'from': sender_info,'content': f"文件 {filename} 接收完成，保存在: {save_path}"})except Exception as e:messagebox.showerror("接收失败", f"接收文件 {filename} 失败: {str(e)}")self.progress_label.config(text="文件接收失败")if os.path.exists(save_path):os.remove(save_path)finally:self.root.after(2000, lambda: self.progress_label.config(text=""))self.root.after(2000, lambda: self.progress.configure(value=0))def handle_message(self, message, addr):# 检查站ID是否匹配sender_station_id = message.get('station_id', 'default-station')if sender_station_id != self.station_id:print(f"忽略来自不同站的消息: {sender_station_id}")return# 检查发送者是否在联系人列表中sender_info = message.get('from', 'Unknown')sender_uuid = message.get('uuid')if sender_uuid and sender_uuid != self.uuid: # 确保不是自己发的消息peer_id = f"{sender_info}_{addr[0]}"if peer_id not in self.peers:# 添加新联系人peer_info = {'hostname': sender_info,'ip': addr[0],'port': addr[1],'uuid': sender_uuid,'station_id': sender_station_id # 保存对方的站ID}self.peers[peer_id] = peer_infoself.peers_list.insert('', 'end', peer_id,values=(sender_info, addr[0], addr[1], sender_uuid[:8]),image=self.unchecked_img)# 显示系统消息self.update_chat_display({'type': 'system','content': f"新联系人已添加: {sender_info} ({addr[0]})"})self.update_chat_display(message)def broadcast_presence(self, force=False):if not self.is_online:return# 为每个本地IP发送广播for ip in self.local_ips:message = {'type': 'broadcast','content': {'ip': ip,'port': self.UDP_PORT,'hostname': self.hostname,'uuid': self.uuid,'station_id': self.station_id # 添加站ID到广播消息}}try:self.broadcast_socket.sendto(json.dumps(message).encode(), ('<broadcast>', self.BROADCAST_PORT))if force:time.sleep(0.1)self.broadcast_socket.sendto(json.dumps(message).encode(), ('<broadcast>', self.BROADCAST_PORT))except Exception as e:if self.running:print(f"广播错误: {e}")self.broadcast_timer = self.root.after(10000, self.broadcast_presence)def start_network_threads(self):# 启动消息接收线程self.message_thread = threading.Thread(target=self.receive_messages, daemon=True)self.message_thread.start()# 启动广播接收线程self.broadcast_thread = threading.Thread(target=self.receive_broadcast, daemon=True)self.broadcast_thread.start()# 发送广播self.broadcast_presence()def receive_messages(self):while self.running:if not self.socket:breaktry:self.socket.settimeout(1.0) # 设置超时，以便能够检查running标志data, addr = self.socket.recvfrom(65535)try:message = json.loads(data.decode())message_type = message.get('type', '')if message_type == 'message':self.handle_message(message, addr)elif message_type == 'file':self.handle_file(message, addr)elif message_type == 'broadcast_reply':# 处理广播回复消息，但不显示在聊天区域content = message.get('content', {})sender_info = message.get('from', 'Unknown')sender_uuid = message.get('uuid')if sender_uuid and sender_uuid != self.uuid: # 确保不是自己的消息peer_id = f"{sender_info}_{content.get('ip')}"if peer_id not in self.peers:# 添加新联系人peer_info = {'hostname': sender_info,'ip': content.get('ip'),'port': content.get('port'),'uuid': sender_uuid}self.peers[peer_id] = peer_infoself.peers_list.insert('', 'end', peer_id,values=(sender_info, content.get('ip'), content.get('port'), sender_uuid[:8]),image=self.unchecked_img)except json.JSONDecodeError:# 如果不是JSON格式，认为是文件内容continueexcept socket.timeout:continueexcept Exception as e:if self.running: # 只在running为True时打印错误print(f"接收消息错误: {e}")def handle_broadcast_reply(self, message, addr):# 处理广播回复消息content = message.get('content', {})sender_info = message.get('from', 'Unknown')sender_uuid = message.get('uuid')if sender_uuid and sender_uuid != self.uuid: # 确保不是自己的消息peer_id = f"{sender_info}_{content.get('ip')}"if peer_id not in self.peers:# 添加新联系人peer_info = {'hostname': sender_info,'ip': content.get('ip'),'port': content.get('port'),'uuid': sender_uuid}self.peers[peer_id] = peer_infoself.peers_list.insert('', 'end', peer_id,values=(sender_info, content.get('ip'), content.get('port'), sender_uuid[:8]),image=self.unchecked_img)def receive_broadcast(self):while self.running:if not self.broadcast_socket:breaktry:self.broadcast_socket.settimeout(1.0) # 设置超时，以便能够检查running标志data, addr = self.broadcast_socket.recvfrom(65535)try:message = json.loads(data.decode())if message['type'] == 'broadcast':self.handle_broadcast(message, addr)except json.JSONDecodeError:continueexcept socket.timeout:continueexcept Exception as e:if self.running: # 只在running为True时打印错误print(f"接收广播错误: {e}")def handle_broadcast(self, message, addr):content = message['content']if content['uuid'] == self.uuid:return # 忽略自己的广播# 检查站ID是否匹配sender_station_id = content.get('station_id', 'default-station')if sender_station_id != self.station_id:print(f"忽略来自不同站的广播: {sender_station_id}")returnpeer_id = f"{content['hostname']}_{content['ip']}"if peer_id not in self.peers:content['station_id'] = sender_station_id # 保存对方的站IDself.peers[peer_id] = contentself.peers_list.insert('', 'end', peer_id, values=(content['hostname'], content['ip'], content['port'], content['uuid'][:8]),image=self.unchecked_img)# 可以添加一个状态栏消息或者在聊天框中显示系统消息self.update_chat_display({'type': 'system','content': f"新联系人已添加: {content['hostname']} ({content['ip']})"})# 回复一个消息给对方，告知本机在线reply_message = {'type': 'broadcast_reply','from': self.hostname,'uuid': self.uuid,'station_id': self.station_id, # 添加站ID到回复消息'content': {'ip': self.local_ips[0], # 使用第一个本地IP'port': self.UDP_PORT,'hostname': self.hostname}}try:self.socket.sendto(json.dumps(reply_message).encode(), (content['ip'], content['port']))except Exception as e:print(f"发送广播回复消息失败: {e}")def create_right_panel(self):# 右侧面板（聊天区域）self.right_panel = ttk.Frame(self.main_frame)self.right_panel.grid(row=1, column=1, columnspan=2, sticky=(tk.W, tk.E, tk.N, tk.S))# 聊天显示区域self.chat_display = tk.Text(self.right_panel, height=25, width=70, font=("微软雅黑", 10))self.chat_display.pack(fill=tk.BOTH, expand=True, pady=(0, 10))self.chat_display.config(state='disabled')# 创建滚动条scrollbar = ttk.Scrollbar(self.chat_display.master, orient='vertical', command=self.chat_display.yview)scrollbar.pack(side=tk.RIGHT, fill=tk.Y)self.chat_display['yscrollcommand'] = scrollbar.set# 底部控制面板self.control_panel = ttk.Frame(self.right_panel)self.control_panel.pack(fill=tk.X, pady=(0, 5))# 输入框和按钮self.input_frame = ttk.Frame(self.control_panel)self.input_frame.pack(fill=tk.X)self.input_field = ttk.Entry(self.input_frame, font=("微软雅黑", 10))self.input_field.pack(side=tk.LEFT, fill=tk.X, expand=True, padx=(0, 5))self.send_button = ttk.Button(self.input_frame, text="发送", command=self.send_message, width=10)self.send_button.pack(side=tk.LEFT, padx=5)self.file_button = ttk.Button(self.input_frame, text="发送文件", command=self.send_file, width=10)self.file_button.pack(side=tk.LEFT)# 进度条框架self.progress_frame = ttk.Frame(self.control_panel)self.progress_frame.pack(fill=tk.X, pady=5)self.progress_label = ttk.Label(self.progress_frame, text="")self.progress_label.pack(side=tk.LEFT)self.progress = ttk.Progressbar(self.progress_frame, length=300, mode='determinate')self.progress.pack(side=tk.LEFT, fill=tk.X, expand=True, padx=5)if __name__ == "__main__":root = tk.Tk()app = ChatApp(root)root.mainloop()