这篇文章主要介绍了怎么用python代码实现简易聊天室的相关知识，内容详细易懂，操作简单快捷，具有一定借鉴价值，相信大家阅读完这篇怎么用python代码实现简易聊天室文章都会有所收获，下面我们一起来看看吧。
创新互联是一家专注于网站制作、网站设计与策划设计,莒南网站建设哪家好?创新互联做网站,专注于网站建设十余年,网设计领域的专业建站公司;建站业务涵盖:莒南等地区。莒南做网站价格咨询:18980820575
1.有人进入聊天室需要输入姓名，姓名不能重复
2.有人进入聊天室，其他人会受到通知
xxx进入聊天室
3.一个人发消息，其他人会受到消息
xxx：xxxxxxxx
4.有人退出聊天室，其他人也会收到通知
xxx退出聊天室
5.扩展功能：服务端消息公告，服务端发送消息所有人都能收到
管理员消息：xxxxxxxx
1.服务端和客户端
服务端处理请求，发送管理员消息
客户端执行各种功能
2.套接字选择：udp套接字
3.消息发送模型：转发
客户端 ~> 服务端 ~> 其他客户端
4.存储用户信息：{name：addr}
5.处理收发关系：多进程分别处理收发
1.设计封装方案
2.写一个功能模块测试一个模块
3.注意注释的添加
#coding =utf-8
"""
chat room
env:python3.5
exc:socket and fork
name:mianmabb
email:mianmabb@163.com
服务端功能:
1.搭建网络通信
2.处理进入聊天室
* 接收姓名
* 判断是否允许进入
* 将结果反馈给客户端
* 如果不允许则结束，允许则将用户插入数据结构
* 给其他人发送通知
3.处理聊天
* 接收消息，判断消息类型,分为L(输入姓名),C(发消息),Q(退出聊天室)
* 将消息转发
4.处理退出聊天室
5.发送管理员消息
"""
from socket import *
from os import *
from sys import *
user = {} #创建空字典用来存储用户的昵称和地址
#处理登录
def do_login(s,name,addr):
if name in user: #判断昵称是否已经存在
s.sendto("该昵称已被占用".encode(),addr)
return
else: #昵称不存在,则发送约定好的"OK"
s.sendto(b"OK",addr)
#功能:有人进入聊天室,其他人会收到消息
msg = "
欢迎 %s 进入聊天室 "%name
for i in user: #发送该条消息给其他用户
s.sendto(msg.encode(),user[i])
user[name] = addr #将该用户插入数据结构(字典)
#处理聊天
def do_chat(s,name,text):
msg = "%s : %s"%(name,text) #设置消息显示格式
for i in user:
s.sendto(msg.encode(),user[i])
#处理退出
def do_quit(s,name):
msg = "%s 退出了聊天室"%name
for i in user:
if i != name: #给其他人发送该用户退出的消息
s.sendto(msg.encode(),user[i])
else: #给该用户客户端发送约定好的EXIT让父进程退出
s.sendto(b"EXIT",user[i])
del user[name] #删除字典中该用户
#处理请求
def do_request(s):
#循环接受所有客户请求
while True:
try:
data,addr = s.recvfrom(1024)
except KeyboardInterrupt: #捕获父进程直接退出错误
exit("服务端退出!")
# print(data.decode())
msgList = data.decode().split() #按空格拆分为列表,方便索引
if msgList[0] == "L": #判断消息类型
do_login(s,msgList[1],addr)
elif msgList[0] == "C":
text = " ".join(msgList[2:]) #将消息中可能有的空格加回来
do_chat(s,msgList[1],text)
elif msgList[0] == "Q":
do_quit(s,msgList[1])
def main():
s = socket(AF_INET,SOCK_DGRAM)
ADDR = ("0.0.0.0",8888)
s.bind(ADDR)
#创建进程
pid = fork()
if pid < 0:
print("Error")
elif pid == 0: #子进程用来发送管理员消息
while True:
try:
text = input("管理员 : ")
except KeyboardInterrupt: #捕获子进程直接退出错误
exit()
msg ="C 管理员 %s"%text
s.sendto(msg.encode(),ADDR)
else: #父进程用来处理请求
do_request(s)
main()客户端功能：
""" 1.搭建通信 2.进入聊天室 * 输入姓名 * 发送给服务器 * 接收服务器反馈 * 不允许则重新输入，允许则进入聊天室 * 创建新的进程用于消息收发 3.聊天 * 循环发送消息 消息类型分为L(输入姓名),C(发消息),Q(退出聊天室) * 循环接收消息 4.退出聊天室 5.接受管理员消息 """ from socket import * from os import * from sys import * ADDR = ("127.0.0.1",8888) #填写服务端地址 #循环发送消息 def send_msg(s,name): while True: try: text = input() #客户输入要发送的消息 except KeyboardInterrupt: #子进程 防止用户Ctrl+C直接退出 text = "quit" if text.strip() == "quit": #规定输入quit退出 msg = "Q " + name #消息类型,姓名 s.sendto(msg.encode(),ADDR) exit("您已退出聊天室") else: msg = "C %s %s"%(name,text) #消息类型,姓名,消息 s.sendto(msg.encode(),ADDR) #循环接收信息 def recv_msg(s): while True: try: data,addr = s.recvfrom(1024) except KeyboardInterrupt: #父进程 防止用户Ctrl+C直接退出 exit() if data.decode() =="EXIT": #当用户退出,无需再收消息,约定EXIT让父进程退出 exit() #退出父进程 print(data.decode()) #创建网络连接 def main(): s = socket(AF_INET,SOCK_DGRAM) while True: name = input("请输入昵称:") #输入姓名 if not name: return msg = "L " +name #发送请求 s.sendto(msg.encode(),ADDR) #等待回复 data,addr = s.recvfrom(1024) if data.decode() == "OK": print("您已进入聊天室") break else: #登录失败 print(data.decode()) #直接打印服务端的错误信息 #创建进程 pid = fork() if pid < 0: print("Error") elif pid == 0: #子进程发消息 send_msg(s,name) else: #父进程收消息 recv_msg(s) main()
先运行服务端,再运行客户端
关于“怎么用python代码实现简易聊天室”这篇文章的内容就介绍到这里，感谢各位的阅读！相信大家对“怎么用python代码实现简易聊天室”知识都有一定的了解，大家如果还想学习更多知识，欢迎关注创新互联行业资讯频道。
