如何用Python搭建聊天室

项目实战（服务器端）

1.服务器类

首先需要一个聊天服务器，这里继承asyncore的dispatcher类来实现，代码如下

class ChatServer(dispatcher):"""聊天服务器"""def __init__(self, port):dispatcher.__init__(self)self.create_socket(socket.AF_INET, socket.SOCK_STREAM)self.set_reuse_addr()self.bind(('', port))self.listen(5)self.users = {}self.main_room = ChatRoom(self)def handle_accept(self):conn, addr = self.accept()ChatSession(self, conn)

2.会话类

有了服务器类还需要能维护每个用户的连接会话，这里继承asynchat的async_chat类来实现，代码如下：

class ChatSession(async_chat):"""负责和单用户通信"""def __init__(self, server, sock):async_chat.__init__(self, sock)self.server = serverself.set_terminator('\n')self.data = []self.name = Noneself.enter(LoginRoom(server))def enter(self, room):'从当前房间移除自身，然后添加到指定房间'try:cur = self.roomexcept AttributeError:passelse:cur.remove(self)self.room = roomroom.add(self)def collect_incoming_data(self, data):'接受客户端的数据'self.data.append(data)def found_terminator(self):'当客户端的一条数据结束时的处理'line = ''.join(self.data)self.data = []try:self.room.handle(self, line)except EndSession:self.handle_close()def handle_close(self):async_chat.handle_close(self)self.enter(LogoutRoom(self.server))

3.命令解释器

现在就需要一个命令解释器能够解释用户的命令，例如登录、查询在线用户和发消息等，代码如下：

class CommandHandler:"""命令处理类"""def unknown(self, session, cmd):'响应未知命令'session.push('Unknown command: %s\n' % cmd)def handle(self, session, line):'命令处理'if not line.strip():returnparts = line.split(' ', 1)cmd = parts[0]try:line = parts[1].strip()except IndexError:line = ''meth = getattr(self, 'do_' + cmd, None)try:meth(session, line)except TypeError:self.unknown(session, cmd)

4.房间

接下来就需要实现聊天室的房间了，这里我们定义了三种房间，分别是用户刚登录时的房间、聊天的房间和退出登录的房间，这三种房间都有一个公共的父类，代码如下：

session.push('Login Success')self.broadcast(session.name + ' has entered the room.\n')self.server.users[session.name] = sessionRoom.add(self, session)def remove(self, session):'广播用户离开'Room.remove(self, session)self.broadcast(session.name + ' has left the room.\n')def do_say(self, session, line):'客户端发送消息'self.broadcast(session.name + ': ' + line + '\n')def do_look(self, session, line):'查看在线用户'session.push('Online Users:\n')for other in self.sessions:session.push(other.name + '\n')class LogoutRoom(Room):"""用户退出时的房间"""def add(self, session):'从服务器中移除'try:del self.server.users[session.name]except KeyError:pass

5.服务器端完整代码

#!/usr/bin/python
# encoding: utf-8from asyncore import dispatcher
from asynchat import async_chat
import socket, asyncorePORT = 6666 #端口class EndSession(Exception):"""自定义会话结束时的异常"""passclass CommandHandler:"""命令处理类"""def unknown(self, session, cmd):'响应未知命令'session.push('Unknown command: %s\n' % cmd)def handle(self, session, line):'命令处理'if not line.strip():returnparts = line.split(' ', 1)cmd = parts[0]try:line = parts[1].strip()except IndexError:line = ''meth = getattr(self, 'do_' + cmd, None)try:meth(session, line)except TypeError:self.unknown(session, cmd)class Room(CommandHandler):"""包含多个用户的环境，负责基本的命令处理和广播"""def __init__(self, server):self.server = serverself.sessions = []def add(self, session):'一个用户进入房间'self.sessions.append(session)def remove(self, session):'一个用户离开房间'self.sessions.remove(session)def broadcast(self, line):'向所有的用户发送指定消息'for session in self.sessions:session.push(line)def do_logout(self, session, line):'退出房间'raise EndSessionclass LoginRoom(Room):"""刚登录的用户的房间"""def add(self, session):'用户连接成功的回应'Room.add(self, session)session.push('Connect Success')def do_login(self, session, line):'登录命令处理'name = line.strip()if not name:session.push('UserName Empty')elif name in self.server.users:session.push('UserName Exist')else:session.name = namesession.enter(self.server.main_room)class ChatRoom(Room):"""聊天用的房间"""def add(self, session):'广播新用户进入'session.push('Login Success')self.broadcast(session.name + ' has entered the room.\n')self.server.users[session.name] = sessionRoom.add(self, session)def remove(self, session):'广播用户离开'Room.remove(self, session)self.broadcast(session.name + ' has left the room.\n')def do_say(self, session, line):'客户端发送消息'self.broadcast(session.name + ': ' + line + '\n')def do_look(self, session, line):'查看在线用户'session.push('Online Users:\n')for other in self.sessions:session.push(other.name + '\n')class LogoutRoom(Room):"""用户退出时的房间"""def add(self, session):'从服务器中移除'try:del self.server.users[session.name]except KeyError:passclass ChatSession(async_chat):"""负责和单用户通信"""def __init__(self, server, sock):async_chat.__init__(self, sock)self.server = serverself.set_terminator('\n')self.data = []self.name = Noneself.enter(LoginRoom(server))def enter(self, room):'从当前房间移除自身，然后添加到指定房间'try:cur = self.roomexcept AttributeError:passelse:cur.remove(self)self.room = roomroom.add(self)def collect_incoming_data(self, data):'接受客户端的数据'self.data.append(data)def found_terminator(self):'当客户端的一条数据结束时的处理'line = ''.join(self.data)self.data = []try:self.room.handle(self, line)except EndSession:self.handle_close()def handle_close(self):async_chat.handle_close(self)self.enter(LogoutRoom(self.server))class ChatServer(dispatcher):"""聊天服务器"""def __init__(self, port):dispatcher.__init__(self)self.create_socket(socket.AF_INET, socket.SOCK_STREAM)self.set_reuse_addr()self.bind(('', port))self.listen(5)self.users = {}self.main_room = ChatRoom(self)def handle_accept(self):conn, addr = self.accept()ChatSession(self, conn)if __name__ == '__main__':s = ChatServer(PORT)try:asyncore.loop()except KeyboardInterrupt:print

三、项目实战（客户端）

完成了服务器端后，就需要实现客户端了，这里客户端连接服务器使用了telnetlib模块。

1.登录窗口

这里的图形界面包选择了wxPython，前面有安装说明，登录窗口通过继承wx.Frame类来实现，代码如下：

class LoginFrame(wx.Frame):"""登录窗口"""def __init__(self, parent, id, title, size):'初始化，添加控件并绑定事件'wx.Frame.__init__(self, parent, id, title)self.SetSize(size)self.Center()self.serverAddressLabel = wx.StaticText(self, label = "Server Address", pos = (10, 50), size = (120, 25))self.userNameLabel = wx.StaticText(self, label = "UserName", pos = (40, 100), size = (120, 25))self.serverAddress = wx.TextCtrl(self, pos = (120, 47), size = (150, 25))self.userName = wx.TextCtrl(self, pos = (120, 97), size = (150, 25))self.loginButton = wx.Button(self, label = 'Login', pos = (80, 145), size = (130, 30))self.loginButton.Bind(wx.EVT_BUTTON, self.login)self.Show()def login(self, event):'登录处理'try:serverAddress = self.serverAddress.GetLineText(0).split(':')con.open(serverAddress[0], port = int(serverAddress[1]), timeout = 10)response = con.read_some()if response != 'Connect Success':self.showDialog('Error', 'Connect Fail!', (95, 20))returncon.write('login ' + str(self.userName.GetLineText(0)) + '\n')response = con.read_some()if response == 'UserName Empty':self.showDialog('Error', 'UserName Empty!', (135, 20))elif response == 'UserName Exist':self.showDialog('Error', 'UserName Exist!', (135, 20))else:self.Close()ChatFrame(None, -2, title = 'ShiYanLou Chat Client', size = (500, 350))except Exception:self.showDialog('Error', 'Connect Fail!', (95, 20))def showDialog(self, title, content, size):'显示错误信息对话框'dialog = wx.Dialog(self, title = title, size = size)dialog.Center()wx.StaticText(dialog, label = content)dialog.ShowModal()

2.聊天窗口

聊天窗口中最主要的就是向服务器发消息并接受服务器的消息，这里通过子线程来接受，代码如下：

class ChatFrame(wx.Frame):"""聊天窗口"""def __init__(self, parent, id, title, size):'初始化，添加控件并绑定事件'wx.Frame.__init__(self, parent, id, title)self.SetSize(size)self.Center()self.chatFrame = wx.TextCtrl(self, pos = (5, 5), size = (490, 310), style = wx.TE_MULTILINE | wx.TE_READONLY)self.message = wx.TextCtrl(self, pos = (5, 320), size = (300, 25))self.sendButton = wx.Button(self, label = "Send", pos = (310, 320), size = (58, 25))self.usersButton = wx.Button(self, label = "Users", pos = (373, 320), size = (58, 25))self.closeButton = wx.Button(self, label = "Close", pos = (436, 320), size = (58, 25))self.sendButton.Bind(wx.EVT_BUTTON, self.send)self.usersButton.Bind(wx.EVT_BUTTON, self.lookUsers)self.closeButton.Bind(wx.EVT_BUTTON, self.close)thread.start_new_thread(self.receive, ())self.Show()def send(self, event):'发送消息'message = str(self.message.GetLineText(0)).strip()if message != '':con.write('say ' + message + '\n')self.message.Clear()def lookUsers(self, event):'查看当前在线用户'con.write('look\n')def close(self, event):'关闭窗口'con.write('logout\n')con.close()self.Close()def receive(self):'接受服务器的消息'while True:sleep(0.6)result = con.read_very_eager()if result != '':self.chatFrame.AppendText(result)

3.客户端完整代码

#!/usr/bin/python
# encoding: utf-8import wx
import telnetlib
from time import sleep
import threadclass LoginFrame(wx.Frame):"""登录窗口"""def __init__(self, parent, id, title, size):'初始化，添加控件并绑定事件'wx.Frame.__init__(self, parent, id, title)self.SetSize(size)self.Center()self.serverAddressLabel = wx.StaticText(self, label = "Server Address", pos = (10, 50), size = (120, 25))self.userNameLabel = wx.StaticText(self, label = "UserName", pos = (40, 100), size = (120, 25))self.serverAddress = wx.TextCtrl(self, pos = (120, 47), size = (150, 25))self.userName = wx.TextCtrl(self, pos = (120, 97), size = (150, 25))self.loginButton = wx.Button(self, label = 'Login', pos = (80, 145), size = (130, 30))self.loginButton.Bind(wx.EVT_BUTTON, self.login)self.Show()def login(self, event):'登录处理'try:serverAddress = self.serverAddress.GetLineText(0).split(':')con.open(serverAddress[0], port = int(serverAddress[1]), timeout = 10)response = con.read_some()if response != 'Connect Success':self.showDialog('Error', 'Connect Fail!', (95, 20))returncon.write('login ' + str(self.userName.GetLineText(0)) + '\n')response = con.read_some()if response == 'UserName Empty':self.showDialog('Error', 'UserName Empty!', (135, 20))elif response == 'UserName Exist':self.showDialog('Error', 'UserName Exist!', (135, 20))else:self.Close()ChatFrame(None, -2, title = 'ShiYanLou Chat Client', size = (500, 350))except Exception:self.showDialog('Error', 'Connect Fail!', (95, 20))def showDialog(self, title, content, size):'显示错误信息对话框'dialog = wx.Dialog(self, title = title, size = size)dialog.Center()wx.StaticText(dialog, label = content)dialog.ShowModal()class ChatFrame(wx.Frame):"""聊天窗口"""def __init__(self, parent, id, title, size):'初始化，添加控件并绑定事件'wx.Frame.__init__(self, parent, id, title)self.SetSize(size)self.Center()self.chatFrame = wx.TextCtrl(self, pos = (5, 5), size = (490, 310), style = wx.TE_MULTILINE | wx.TE_READONLY)self.message = wx.TextCtrl(self, pos = (5, 320), size = (300, 25))self.sendButton = wx.Button(self, label = "Send", pos = (310, 320), size = (58, 25))self.usersButton = wx.Button(self, label = "Users", pos = (373, 320), size = (58, 25))self.closeButton = wx.Button(self, label = "Close", pos = (436, 320), size = (58, 25))self.sendButton.Bind(wx.EVT_BUTTON, self.send)self.usersButton.Bind(wx.EVT_BUTTON, self.lookUsers)self.closeButton.Bind(wx.EVT_BUTTON, self.close)thread.start_new_thread(self.receive, ())self.Show()def send(self, event):'发送消息'message = str(self.message.GetLineText(0)).strip()if message != '':con.write('say ' + message + '\n')self.message.Clear()def lookUsers(self, event):'查看当前在线用户'con.write('look\n')def close(self, event):'关闭窗口'con.write('logout\n')con.close()self.Close()def receive(self):'接受服务器的消息'while True:sleep(0.6)result = con.read_very_eager()if result != '':self.chatFrame.AppendText(result)'程序运行'
if __name__ == '__main__':app = wx.App()con = telnetlib.Telnet()LoginFrame(None, -1, title = "Login", size = (280, 200))app.MainLoop()

四、小结

最后就可以运行程序进行聊天了，注意需要先启动服务器再启动客户端。这个项目中使用了asyncore的dispatcher来实现服务器，asynchat的asyn_chat来维护用户的连接会话，用wxPython来实现图形界面，用telnetlib来连接服务器，在子线程中接受服务器发来的消息，由此一个简单的聊天室程序就完成了。

更多资源见123云盘，提取码：AQGl  https://www.123pan.com/s/f83gjv-nvWod

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/753634.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

使用verilog设计有限状态机实现的跳一跳游戏及其testbench仿真测试

使用verilog设计有限状态机实现的跳一跳游戏及其testbench仿真测试

设计跳一跳游戏的有限状态机可以分为以下几个主要步骤： 确定状态及状态转移条件： 确定游戏中可能存在的状态，如等待开始、准备跳跃、跳跃中、检查落地等。 确定不同状态之间的转移条件，例如何时从等待开始状态转移到准备跳跃状态，如何触发跳跃动作，跳跃是否成功等。 定…
阅读更多...
可视化场景（5）：生产监控，比摄像头好用多了。

可视化场景（5）：生产监控，比摄像头好用多了。

hello，我是贝格前端工场，本期分享可视化大屏在生产监控场景的应用，如需要定制，可以与我们联络，开始了。 实时监控 可视化大屏可以实时展示生产线上的各种关键指标和数据，如生产速度、设备状态、产量、质量…
阅读更多...
html密码访问单页自定义跳转页面源码

html密码访问单页自定义跳转页面源码

内容目录 一、详细介绍二、效果展示1.部分代码2.效果图展示 三、学习资料下载 一、详细介绍 密码访问单页自定义跳转页面，修改了的密码访问单页，添加了js自定义密码跳转页面。需要正确输入密码才能跳转目标网址。 二、效果展示 1.部分代码 代码如下&…
阅读更多...
亚马逊、速卖通如何实现批量注册自动养号？

亚马逊、速卖通如何实现批量注册自动养号？

亚马逊和速卖通作为全球领先的跨境电商平台，其账号对于卖家而言具有重要的商业价值。随着跨境电商行业的蓬勃发展，越来越多的人对亚马逊、速卖通账号的需求日益增长，这也催生了批量注册和自动养号的需求。 跨境智星作为一款集成了批量注册账号…
阅读更多...
JAVA基础 数组，字符串与正则表达式

JAVA基础 数组，字符串与正则表达式

数组 数组的概念 将相同类型的数据按一定顺序排列构成的大小确定的集合 数组元素类型可以为基本数据类型，也可以为引用类型 Java语言内存分配 栈内存：基本数据类型的变量或者引用类型的变量，超出作用域将自动释放 堆内存：存…
阅读更多...
每日五道java面试题之mybatis篇（二）

每日五道java面试题之mybatis篇（二）

目录： 第一题. Mybatis优缺点第二题. Hibernate 和 MyBatis 的区别?第三题. MyBatis编程步骤是什么样的？第四题. 请说说MyBatis的工作原理第五题. MyBatis的功能架构是怎样的? 第一题. Mybatis优缺点 优点 与传统的数据库访问技术相比，ORM…
阅读更多...
Leetcode 3.18

Leetcode 3.18

Leetcode hot100 二叉树1.路径总和 III2.路径总和 II3.二叉树的所有路径4.二叉树的最近公共祖先 回溯1.电话号码的字母组合 二叉树 1.路径总和 III 路径总和 III 思路：我们访问每一个节点 node，检测以 node 为起始节点且向下延深的路径有多少种。递归遍…
阅读更多...
【Linux】Ubuntu22.04中使用ssh、scp时报错：Their offer: ssh-rsa

【Linux】Ubuntu22.04中使用ssh、scp时报错：Their offer: ssh-rsa

1、问题描述 使用scp拷贝文件时报错： Unable to negotiate with xxx port 22: no matching host key type found. Their offer: ssh-rsa lost connection2、原因分析 查看OpenSSH版本 ssh -V OpenSSH_8.9p1 Ubuntu-3ubuntu0.6, OpenSSL 3.0.2 15 Mar 2022查看官网的说明：…
阅读更多...
【ACL2023获奖论文】比你想的更弱：对弱监督学习的批判性审视

【ACL2023获奖论文】比你想的更弱：对弱监督学习的批判性审视

【ACL 2023获奖论文】主题论文奖：7.Weaker Than You Think: A Critical Look at Weakly Supervised Learning 写在最前面引言正文问题1：对WSL来说，clean data是否必要？问题2：WSL需要多少的clean data？问题3…
阅读更多...
elasticsearch基础学习

elasticsearch基础学习

elasticsearch简介 什么是elasticsearch elasticsearch（简称es），其核心是 Elastic Stack，es是一个基于 Apache Lucene（TM）的开源的高扩展的分布式全文检索引擎，它可以近乎实时的存储、检索数据…
阅读更多...
如何在开放麒麟系统安装cpolar内网穿透实现公网环境下SSH远程连接

如何在开放麒麟系统安装cpolar内网穿透实现公网环境下SSH远程连接

文章目录 1. 安装SSH服务2. 本地SSH连接测试3. openKylin安装Cpolar4. 配置 SSH公网地址5. 公网远程SSH连接小结 6. 固定SSH公网地址7. SSH固定地址连接 openKylin是中国首个基于Linux 的桌面操作系统开发者平台，通过开放操作系统源代码的方式，打造具有自…
阅读更多...
裸金属租赁的意义

裸金属租赁的意义

裸金属，这个名词听起来好“硬核”，如果对于一个新手来讲，怎么也不会将这个概念和IT行业、计算机、服务器等内容进行关联，它可能更应该是工业领域的一种产品或者物质，可真正关联到其实际概念恰恰与当前的主流行业如&…
阅读更多...
论文阅读——Align before Fuse

论文阅读——Align before Fuse

Align before Fuse: Vision and Language Representation Learning with Momentum Distillation image-text contrastive learning(ITC)用在单模态，masked language modeling (MLM) and image-text matching (ITM) 用在多模态。 单模态编码器的表示上引入了中间图像…
阅读更多...
机器学习中的基础问题总结

机器学习中的基础问题总结

介绍：总结面试经常问到的一些机器学习知识点（必会🌟） 基础知识点梳理 模型评估一、L1、L2正则化1、L1正则与L2正则有何不同？2、为什么正则化可以防止过拟合？3、为什么L1正则具有稀疏性？&#xf…
阅读更多...
JMeter之IP欺骗技术（模拟不同的IP地址并发请求）

JMeter之IP欺骗技术（模拟不同的IP地址并发请求）

我们在做压力测试时，有这样的场景和需求，希望模拟的批量用户来自不同的IP地址。如果小伙伴用LR是很容易实现的，用IP欺骗即可实现。那么对于用JMeter小伙伴是不是就不能享受这一技术了呢，答案是否定的，JMeter一样可以实…
阅读更多...
【晴问算法】入门篇—贪心算法—整数配对

【晴问算法】入门篇—贪心算法—整数配对

题目描述 有两个正整数集合S、T，其中S中有n个正整数，T中有m个正整数。定义一次配对操作为：从两个集合中各取出一个数a和b，满足a∈S、b∈T、a≤b，配对的数不能再放回集合。问最多可以进行多少次这样的配对操作。 输入描…
阅读更多...
Elasticsearch：调整近似 kNN 搜索

Elasticsearch：调整近似 kNN 搜索

在我之前的文章 “Elasticsearch：调整搜索速度”，我详细地描述了如何调整正常的 BM25 的搜索速度。在今天的文章里，我们来进一步探讨如何提高近似 kNN 的搜索速度。希望对广大的向量搜索开发者有一些启示。 Elasticsearch 支持近似 k 最近邻…
阅读更多...
一、yocto 编译raspberrypi 4B并启动

一、yocto 编译raspberrypi 4B并启动

yocto 编译raspberrypi 4B并启动 yocto 编译raspberrypi 4B并启动环境准备代码下载编译及配置烧录 yocto 编译raspberrypi 4B并启动 本篇文章为基于raspberrypi 4B单板的yocto实战系列的开篇之作。 环境准备 最近到手一个树莓派4B，准备拿来玩一玩，下面…
阅读更多...
Docker部署Django项目——基础

Docker部署Django项目——基础

1.服务器配置 1.1centos7 系统的安装 centos-7-isos-x86_64安装包下载) VMware安装自定义配置 选择对应的系统镜像 一般选择内核4核、内存8g、硬盘80g 相关配置 1.2.网络配置 1.2.1查看win电脑虚拟机VMnet8的ip 使用ipconfig查看虚拟机的ip 1.2.2配置虚拟机VMnet8的ip…
阅读更多...
152.乐理基础-广义的、实际的原位与转位、转位的意义

152.乐理基础-广义的、实际的原位与转位、转位的意义

内容参考于：三分钟音乐社 上一个内容：151.和弦固定标记法（二）转位和弦，斜杠（slash）和弦 上一个内容里练习的答案：斜杠左边的有多个写法，如果与下图不一样，那…
阅读更多...
最新文章

Copyright @ 2022~2023