python实现简单的聊天小程序

概要

这是一个使用python实现一个简单的聊天室的功能,里面包含群聊,私聊两种聊天方式.实现的方式是使用套接字编程的一个使用TCP协议 c/s结构的聊天室

实现思路

x01 服务端的建立

首先,在服务端,使用socket进行消息的接受,每接受一个socket的请求,就开启一个新的线程来管理消息的分发与接受,同时,又存在一个handler来管理所有的线程,从而实现对聊天室的各种功能的处理

x02 客户端的建立

客户端的建立就要比服务端简单多了,客户端的作用只是对消息的发送以及接受,以及按照特定的规则去输入特定的字符从而实现不同的功能的使用,因此,在客户端这里,只需要去使用两个线程,一个是专门用于接受消息,一个是专门用于发送消息的

至于为什么不用一个呢,那是因为,只用一个的话,当接受了消息,在发送之前接受消息的处于阻塞状态,同理,发送消息也是,那么要是将这两个功能放在一个地方实现,就会导致没有办法连续发送或者接受消息了

实现方式

服务端实现

服务端类图
服务端流程图

import json
import threading
from socket import *
from time import ctimeclass PyChattingServer:__socket = socket(AF_INET, SOCK_STREAM, 0)__address = ('', 12231)__buf = 1024def __init__(self):self.__socket.bind(self.__address)self.__socket.listen(20)self.__msg_handler = ChattingHandler()def start_session(self):print('等待客户连接...\r\n')try:while True:cs, caddr = self.__socket.accept()# 利用handler来管理线程,实现线程之间的socket的相互通信self.__msg_handler.start_thread(cs, caddr)except socket.error:passclass ChattingThread(threading.Thread):__buf = 1024def __init__(self, cs, caddr, msg_handler):super(ChattingThread, self).__init__()self.__cs = csself.__caddr = caddrself.__msg_handler = msg_handler# 使用多线程管理会话def run(self):try:print('...连接来自于:', self.__caddr)data = '欢迎你到来PY_CHATTING！请输入你的很cooooool的昵称(不能带有空格哟`)\r\n'self.__cs.sendall(bytes(data, 'utf-8'))while True:data = self.__cs.recv(self.__buf).decode('utf-8')if not data:breakself.__msg_handler.handle_msg(data, self.__cs)print(data)except socket.error as e:print(e.args)passfinally:self.__msg_handler.close_conn(self.__cs)self.__cs.close()class ChattingHandler:__help_str = "[ SYSTEM ]\r\n" \"输入/ls,即可获得所有登陆用户信息\r\n" \"输入/h,即可获得帮助\r\n" \"输入@用户名 (注意用户名后面的空格)+消息,即可发动单聊\r\n" \"输入/i,即可屏蔽群聊信息\r\n" \"再次输入/i,即可取消屏蔽\r\n" \"所有首字符为/的信息都不会发送出去"__buf = 1024__socket_list = []__user_name_to_socket = {}__socket_to_user_name = {}__user_name_to_broadcast_state = {}def start_thread(self, cs, caddr):self.__socket_list.append(cs)chat_thread = ChattingThread(cs, caddr, self)chat_thread.start()def close_conn(self, cs):if cs not in self.__socket_list:return# 去除socket的记录nickname = "SOMEONE"if cs in self.__socket_list:self.__socket_list.remove(cs)# 去除socket与username之间的映射关系if cs in self.__socket_to_user_name:nickname = self.__socket_to_user_name[cs]self.__user_name_to_socket.pop(self.__socket_to_user_name[cs])self.__socket_to_user_name.pop(cs)self.__user_name_to_broadcast_state.pop(nickname)nickname += " "# 广播某玩家退出聊天室self.broadcast_system_msg(nickname + "离开了PY_CHATTING")# 管理用户输入的信息def handle_msg(self, msg, cs):js = json.loads(msg)if js['type'] == "login":if js['msg'] not in self.__user_name_to_socket:if ' ' in js['msg']:self.send_to(json.dumps({'type': 'login','success': False,'msg': '账号不能够带有空格'}), cs)else:self.__user_name_to_socket[js['msg']] = csself.__socket_to_user_name[cs] = js['msg']self.__user_name_to_broadcast_state[js['msg']] = Trueself.send_to(json.dumps({'type': 'login','success': True,'msg': '昵称建立成功,输入/ls可查看所有在线的人,输入/help可以查看帮助(所有首字符为/的消息都不会发送)'}), cs)# 广播其他人,他已经进入聊天室self.broadcast_system_msg(js['msg'] + "已经进入了聊天室")else:self.send_to(json.dumps({'type': 'login','success': False,'msg': '账号已存在'}), cs)# 若玩家处于屏蔽模式,则无法发送群聊消息elif js['type'] == "broadcast":if self.__user_name_to_broadcast_state[self.__socket_to_user_name[cs]]:self.broadcast(js['msg'], cs)else:self.send_to(json.dumps({'type': 'broadcast','msg': '屏蔽模式下无法发送群聊信息'}), cs)elif js['type'] == "ls":self.send_to(json.dumps({'type': 'ls','msg': self.get_all_login_user_info()}), cs)elif js['type'] == "help":self.send_to(json.dumps({'type': 'help','msg': self.__help_str}), cs)elif js['type'] == "sendto":self.single_chatting(cs, js['nickname'], js['msg'])elif js['type'] == "ignore":self.exchange_ignore_state(cs)def exchange_ignore_state(self, cs):if cs in self.__socket_to_user_name:state = self.__user_name_to_broadcast_state[self.__socket_to_user_name[cs]]if state:state = Falseelse:state = Trueself.__user_name_to_broadcast_state.pop(self.__socket_to_user_name[cs])self.__user_name_to_broadcast_state[self.__socket_to_user_name[cs]] = stateif self.__user_name_to_broadcast_state[self.__socket_to_user_name[cs]]:msg = "通常模式"else:msg = "屏蔽模式"self.send_to(json.dumps({'type': 'ignore','success': True,'msg': '[TIME : %s]\r\n[ SYSTEM ] : %s\r\n' % (ctime(), "模式切换成功,现在是" + msg)}), cs)else:self.send_to({'type': 'ignore','success': False,'msg': '切换失败'}, cs)def single_chatting(self, cs, nickname, msg):if nickname in self.__user_name_to_socket:msg = '[TIME : %s]\r\n[ %s CHATTING TO %s ] : %s\r\n' % (ctime(), self.__socket_to_user_name[cs], nickname, msg)self.send_to_list(json.dumps({'type': 'single','msg': msg}), self.__user_name_to_socket[nickname], cs)else:self.send_to(json.dumps({'type': 'single','msg': '该用户不存在'}), cs)print(nickname)def send_to_list(self, msg, *cs):for i in range(len(cs)):self.send_to(msg, cs[i])def get_all_login_user_info(self):login_list = "[ SYSTEM ] ALIVE USER : \r\n"for key in self.__socket_to_user_name:login_list += self.__socket_to_user_name[key] + ",\r\n"return login_listdef send_to(self, msg, cs):if cs not in self.__socket_list:self.__socket_list.append(cs)cs.sendall(bytes(msg, 'utf-8'))def broadcast_system_msg(self, msg):data = '[TIME : %s]\r\n[ SYSTEM ] : %s\r\n' % (ctime(), msg)js = json.dumps({'type': 'system_msg','msg': data})# 屏蔽了群聊的玩家也可以获得系统的群发信息for i in range(len(self.__socket_list)):if self.__socket_list[i] in self.__socket_to_user_name:self.__socket_list[i].sendall(bytes(js, 'utf-8'))def broadcast(self, msg, cs):data = '[TIME : %s]\r\n[%s] : %s\r\n' % (ctime(), self.__socket_to_user_name[cs], msg)js = json.dumps({'type': 'broadcast','msg': data})# 没有的登陆的玩家无法得知消息,屏蔽了群聊的玩家也没办法获取信息for i in range(len(self.__socket_list)):if self.__socket_list[i] in self.__socket_to_user_name \and self.__user_name_to_broadcast_state[self.__socket_to_user_name[self.__socket_list[i]]]:self.__socket_list[i].sendall(bytes(js, 'utf-8'))def main():server = PyChattingServer()server.start_session()main()

客户端的实现

客户端类图
客户端流程图

import json
import threading
from socket import *is_login = False
is_broadcast = Trueclass ClientReceiveThread(threading.Thread):__buf = 1024def __init__(self, cs):super(ClientReceiveThread, self).__init__()self.__cs = csdef run(self):self.receive_msg()def receive_msg(self):while True:msg = self.__cs.recv(self.__buf).decode('utf-8')if not msg:breakjs = json.loads(msg)if js['type'] == "login":if js['success']:global is_loginis_login = Trueprint(js['msg'])elif js['type'] == "ignore":if js['success']:global is_broadcastif is_broadcast:is_broadcast = Falseelse:is_broadcast = Trueprint(js['msg'])else:if not is_broadcast:print("[现在处于屏蔽模式]")print(js['msg'])class ClientSendMsgThread(threading.Thread):def __init__(self, cs):super(ClientSendMsgThread, self).__init__()self.__cs = csdef run(self):self.send_msg()# 根据不同的输入格式来进行不同的聊天方式def send_msg(self):while True:js = Nonemsg = input()if not is_login:js = json.dumps({'type': 'login','msg': msg})elif msg[0] == "@":data = msg.split(' ')if not data:print("请重新输入")breaknickname = data[0]nickname = nickname.strip("@")if len(data) == 1:data.append(" ")js = json.dumps({'type': 'sendto','nickname': nickname,'msg': data[1]})elif msg == "/help":js = json.dumps({'type': 'help','msg': None})elif msg == "/ls":js = json.dumps({'type': 'ls','msg': None})elif msg == "/i":js = json.dumps({'type': 'ignore','msg': None})else:if msg[0] != '/':js = json.dumps({'type': 'broadcast','msg': msg})if js is not None:self.__cs.sendall(bytes(js, 'utf-8'))def main():buf = 1024# 改变这个的地址,变成服务器的地址,那么只要部署到服务器上就可以全网使用了address = ("127.0.0.1", 12231)cs = socket(AF_INET, SOCK_STREAM, 0)cs.connect(address)data = cs.recv(buf).decode("utf-8")if data:print(data)receive_thread = ClientReceiveThread(cs)receive_thread.start()send_thread = ClientSendMsgThread(cs)send_thread.start()while True:passmain()

这样一个简单的聊天室就建立了

总结

在这个实现聊天室当中,我使用的是json格式的字符串信息来编写的协议,或许,也可以使用一些更加简单的方式去实现

其实这个聊天室也就是一个最基本的socket编程的实现方案,也是一些属于网络方面的比较简单的编写吧

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

如若内容造成侵权/违法违规/事实不符，请联系瞎胡闹网进行投诉反馈，一经查实，立即删除！

相关文章

小程序即时聊天服务器wss,Socket/WS/WSS和小程序

小程序即时聊天服务器wss,Socket/WS/WSS和小程序

Socket 通信 Socket 不属于网络协议范畴，而是在应用层和传输层之间的一个抽象层，它把 TCP/IP 层复杂的操作抽象为几个简单的接口供应用层调用。通过调用 Socket 使得程序员可以更方便地使用 TCP/IP 协议栈。 Socket 连接是长连接，理论上客户端和服务器端一旦建立连接将不会主…
阅读更多...
用Python写一个模拟qq聊天小程序的代码实例

用Python写一个模拟qq聊天小程序的代码实例

前言 今天小编就为大家分享一篇关于用Python写一个模拟qq聊天小程序的代码实例，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧 Python 超简单的聊天程序 客户端: 服务器: 模拟qq聊…
阅读更多...
支付宝小程序平台的IM聊天插件

支付宝小程序平台的IM聊天插件

文章目录 前言一、用户端1.基本展示2.难处理的点二、另一用户端1.前端websocket的整合2.手机息屏websocket断线问题2.websocket服务端配置3.后端整合websocket作为服务端，传输消息给前端 总结 前言 最近工作需求来了个项目，前景为在支付宝平台上发布一个…
阅读更多...
微信小程序——聊天小程序（从搭建到结束）

微信小程序——聊天小程序（从搭建到结束）

具体效果展示： 微信小程序——聊天功能（一、环境搭建） 微信小程序——聊天功能（一、环境搭建）_星^0^星的博客-CSDN博客 微信小程序——聊天功能（二、账号的注册与登录） 微信聊天小程序——&a…
阅读更多...
Java-多人聊天小程序

Java-多人聊天小程序

上图啦！！！ 首先运行： Server.java 然后启动： Client.java 最后退出客户端： 代码实现 Client package chat;import javax.swing.*;public class Client {public static void main(String[] args) {// 使用…
阅读更多...
7步搞懂手写数字识别Mnist

7步搞懂手写数字识别Mnist

大家好啊，我是董董灿。 图像识别有很多入门项目，其中Mnist 手写数字识别绝对是最受欢迎的。 该项目以数据集小、神经网络简单、任务简单为优势，并且集合了CNN网络中该有的东西，可谓麻雀虽小，五脏俱全。 非常适合新手…
阅读更多...
二开项目权限应用全流程-按钮级控制

二开项目权限应用全流程-按钮级控制

二开项目权限应用全流程-按钮级控制 员工A和员工B都可以访问同一个页面（以员工管理为例），但是员工A可以导出excel，员工B就不可以导出excel(看不到按钮) 思路 用户登陆成功后，用户可以访问的按钮级别权限保存在point…
阅读更多...
VISIO使用技巧汇总

VISIO使用技巧汇总

0.连接线拐弯或者连接不合适 0-0.Goal ​​​​​​​ 0-1. Automatic connection 0-3.Resolvent 0-3-0.ALTF9选项，取消粘附位置调整 0-3-1.选中线段-选中中心点-shift增加直角调整合适位置
阅读更多...
Microsoft Visio 直线连接线

Microsoft Visio 直线连接线

Microsoft Visio 直线连接线 1. 连接线 2. 直线连接线 3. 直线连接线图 References https://yongqiang.blog.csdn.net/
阅读更多...
visio画太极图

visio画太极图

步骤一 添加两个圆，且大圆的半径是小圆的2倍。 步骤二 往小圆添加一条直线作为直径 步骤三 选中小圆和直径,依次点击开发工具–操作–连接，然后选中连接后的小圆，再依次点击开发工具–操作–修建，可以分离出如下所示的两个…
阅读更多...
visio 2007 画直线和矩形

visio 2007 画直线和矩形

visio 2007 画直线和矩形 1.问题描述 在一些图形中如果直接用连接线，会直接连到一些不理想的位置，而2007中不像2013及其以后那些版本中，有侧边栏能够直接画直线。 2.解决方式 直接选择工具栏中的红圈中的图标 能够生成红圈中的工具栏 然…
阅读更多...
Visio对mysql怎么画er图_怎么用Visio画ER图

Visio对mysql怎么画er图_怎么用Visio画ER图

展开全部 画法如下： 1、由于Visio 2003默认的绘图模板并没有32313133353236313431303231363533e4b893e5b19e31333339653661E-R图这一项，但是画E-R图必须的基本图形Visio 2003还是有的，所以就得先把必要的图形添加到“我的模板”。以添加椭圆和…
阅读更多...
Visio2010中设置线为直线

Visio2010中设置线为直线

Visio2010中设置线为直线 在Visio2010中默认的线不是直线而是曲线，在画图中需要使用直线时要进行设置，下面介绍Visio2010中设置直线的方法。 1、打开Visio2010，然后点击设计： 2、点击调整大小下面的三角： 3、进入页面…
阅读更多...
visio绘制流程图连接线总拐弯

visio绘制流程图连接线总拐弯

描述 如图所示绘制流程图的连接线总拐弯 很让我强迫症发作 可以看到垂直的连接线总是会自动拐个弯 相关技巧 有说连接线中间点可以控制和增加中间点 或者按住shift 进行调整 这个还没研究明白咋操作不过没解决本质问题 此外还可以右键修改连接线属性 还可以在设计中进行调…
阅读更多...
visio插入箭头_visio流程图中画箭头

visio插入箭头_visio流程图中画箭头

visio流程图中画箭头 随着社会和经济的发展，电脑visio 2019软件已经成为我们生活中必不可少的一部分。visio 2019软件常常被我们使用于流程图的制作，很多第一次接触的朋友们不知道怎么在visio 2019软件制作流程图，接下来就让小编来教你们吧。 具体如下： 1. 第一步，打开电脑…
阅读更多...
visio绘图小技巧

visio绘图小技巧

1.如何在图框的任意位置添加点？ 先选中x点指令，再按住ctrl键，即可在任意位置画点 2.如何画出锯齿形线段？ visio里面好像没有现成的锯齿形线段，所以可以利用直线反复折画，但是这里有个小技巧，就…
阅读更多...
Visio简单画图使用方法

Visio简单画图使用方法

Visio使用方法 相信有很多初学者跟我一样，只会使用Word进行简单的画图。本章主要讲述如何使用Visio来画图（版本为2010） 一、系统流程图、数据流程图、ER图画法 1.打开Visio软件，创建简单模板 2.根据需求点击左侧"基本流程…
阅读更多...
设计模式之~外观模式

设计模式之~外观模式

定义： 为子系统中的一组接口提供一个一致的界面，此模式定义了一个高层接口，这个接口使得这一子系统更加容易使用。 结构图： 区分中介模式： 门面模式对外提供一个接口 中介模式对内提供一个接口 优点： 松耦…
阅读更多...
【xv6操作系统】安装、运行与调试

【xv6操作系统】安装、运行与调试

一、构建、装入过程 1.编写“启动代码主体代码”（在下载的xv6的原始代码上进行修改） 2.源代码进行编译、链接生成系统镜像（elf格式的目标文件） 3.将系统镜像保存起来（如保存到磁盘、flash或者网络服务器上&#xff…
阅读更多...
spring入门（面试题）

spring入门（面试题）

Spring框架的核心：IoC容器和AOP模块。通过IoC容器管理POJO对象以及他们之间的耦合关系；通过AOP以动态非侵入的方式增强服务。 IoC让相互协作的组件保持松散的耦合，而AOP编程允许你把遍布于应用各层的功能分离出来形成可重用的功能组件。 IO…
阅读更多...
最新文章

Copyright @ 2022~2023