基于Python Tkiner、thread与socket实现的简单多人聊天室，在Python中创建TCP服务器与客户端进行通信
完整代码下载地址：基于Python Tkiner、thread与socket实现的简单多人聊天室
运行效果图
服务端
客户端
客户端源代码
# codeing=utf-8# @Time : -09-05# @Site :# @Title : Python中创建TCP服务器与客户端进行通信:Tk、thread与socket组合。# @Url:# @Details : Python中创建TCP服务器与客户端进行通信:Tk、thread与socket组合。# @Other : OS X 10.14.6# Python 3.8# VSCode#################################### Python中创建TCP服务器与客户端进行通信:Tk、thread与socket组合。###################################import jsonimport randomimport socketimport sysimport threadingimport tkinter as tkfrom tkinter import messagebox # 导入提示窗口包CHATCONTENT = 'chatcontent' # 聊天内容CHAT_EXIT = '|exit|' # 退出聊天室CHAT_USERS = 'chatusers' # 聊天室用户列表CHAT_REG_USERNAME = 'reg_username' # 注册用昵称CHAT_ONETOONE = 'onetoone' # 私聊标识class Gui_Client:'''聊天室客户端GUI构建'''def __init__(self):self.clist = {} # 存放接入的socket客户端 以客户端用户名保存为字典self.namelist = list() # 存放tk.listbox中的用户名称列表self.t = 0self.go()def go(self):'''构建GUI'''self.root = tk.Tk() # 整个窗口self.root.title("欢迎光临Python江湖大佬聊天室客户端 1.0 By Python代码大全")self.info_frame = tk.Frame(self.root) # 存放用户列表，聊天室交流信息部件self.info_frame.pack(fill=tk.X, side=tk.TOP)self.server_frame = tk.LabelFrame(self.root, text="聊天室设置", padx=5, pady=5) # 存放聊天室服务器设置相关信息部件，服务器启动，暂停按钮。self.server_frame.pack(fill=tk.X, side=tk.TOP)# 用户列表框self.name_var = tk.StringVar() # 绑定listbox的列表值self.lb = tk.Listbox(self.info_frame, listvariable=self.name_var, width=20, selectmode=tk.EXTENDED)self.lb.bind('<ButtonRelease-1>', self.onetoonethat) # 绑定鼠标左键点击事件。self.lb.pack(fill=tk.Y, side=tk.LEFT)# test 测试列表用# self.name_var.set(('aa', 'bb', 'cc', 'dd', 'ee'))# 创建打印聊天信息的text# 分别创建一个横向，一个坚向的滚动条，self.ybar = tk.Scrollbar(self.info_frame)self.ybar.pack(fill=tk.Y, side=tk.RIGHT)# self.xbar = tk.Scrollbar(self.info_frame, orient=tk.HORIZONTAL) # orient=tk.HORIZONTAL表示为坚向滚动# self.xbar.pack(fill=tk.X, side=tk.BOTTOM, )self.out = tk.Text(self.info_frame, width=80, font=("Symbol", 14), yscrollcommand=self.ybar.set, )insert_text(self.out, '欢迎光临Python江湖聊天室！')self.out.pack(fill=tk.Y, side=tk.LEFT)self.top_server = tk.Frame(self.server_frame, )self.top_server.pack(fill=tk.X, side=tk.TOP)# 设置IP文本框self.ip_var = tk.StringVar()self.ip_var.set('192.168.0.88')self.ip_entry = tk.Entry(self.top_server, textvariable=self.ip_var, width=12)self.ip_entry.pack(fill=tk.X, side=tk.LEFT)# 设置端口文本框self.port_var = tk.IntVar()self.port_var.set(18888)self.port_entry = tk.Entry(self.top_server, textvariable=self.port_var, width=5)self.port_entry.pack(side=tk.LEFT)self.start_btn = tk.Button(self.top_server, text="连接服务器", width=18, command=self.client_Start).pack(side=tk.LEFT)self.down_server = tk.Frame(self.server_frame, )self.down_server.pack(fill=tk.X, side=tk.BOTTOM)# 聊天窗口self.that_var = tk.StringVar()self.that_var.set('拜见各位python江湖大佬!')self.that = tk.Entry(self.down_server, textvariable=self.that_var, width=40)self.that.pack(fill=tk.X, side=tk.LEFT)# 信息发送按钮self.end_btn = tk.Button(self.down_server, text="发送消息", width=18, command=self.sendMsg).pack(side=tk.LEFT)self.root.protocol('WM_DELETE_WINDOW', self.close_window)self.root.mainloop()def close_window(self):"""窗口关闭，关闭所有连接:return:"""print('窗口准备开始关闭************')if self.t:data = {'protocol': CHAT_EXIT, 'data': '|exit|'}data1 = json.dumps(data)try:self.t.s.send(data1.encode('utf-8'))self.root.destroy()except:self.root.destroy()sys.exit()# if self.t.send_json(data):#print('已发送退出聊天室的申请')# else:#print("提示", "请先连接服务器再尝试聊天.")# self.root.destroy()else:self.root.destroy()def client_Start(self):'''启动客户端'''try:self.t = TcpClient(self.ip_var.get(), self.port_var.get(), self.name_var, self.namelist, self.out,self.clist, getName())self.t.setDaemon(True) # 这里很重要，不加程序界面会卡死！self.t.start()insert_text(self.out, "线程开始————————————\n")print('线程开始————————————')except Exception as e:messagebox.showinfo("提示", "服务器没有开启或无法连接!")print(e, '服务器没有开启或无法连接')def sendMsg(self):'''这里发送消息，可以对消息进行判断私聊内容 头部应该包括 @+昵称，用来判断是否发送私聊。'''msg = self.that.get() # 获取聊天窗口里的消息# 私聊判断，组装私聊的json并发送if msg.find("@") == 0: # 如果是私聊data = retOneToOneJsonData(msg)outmsg = '你悄悄的对'+data['name']+'说到:'+data['data']if self.t:if self.t.send_json(data):insert_text(self.out,outmsg)else:# 公共聊天信息发送data = {'protocol': CHATCONTENT, 'data': msg}if self.t:if self.t.send_json(data):insert_text(self.out, msg)else:print("提示", "请先连接服务器再尝试聊天.")else:messagebox.showinfo("提示", "请先连接服务器再尝试聊天.")print("提示", "请先连接服务器再尝试聊天.")def onetoonethat(self, event):'''列表中点击名称进行私聊'''items = self.lb.curselection()for k in items:print(self.lb.get(k))firstmsg = '@' + self.lb.get(k) + ' ' # 私聊标识 @昵称+空格msg = '你好，可以私聊一会吗？'self.that_var.set(firstmsg + msg)class TcpClient(threading.Thread):def __init__(self, addr, port, name_var, namelist, out, clist, name):threading.Thread.__init__(self)self.addr = addrself.port = portself.name_var = name_varself.namelist = namelist # 在线列表self.out = outself.clist = clistself.s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)self.s.connect((self.addr, self.port))self.stop_flag = Falseself.name = nameself.msgdata = ''self.isOk = 1def run(self):self.inThat() # 进入聊天室# 发送客户端用户名，保存在服务器端列表中# 此处还有修改昵称等功能,若昵称相同服务器则会返回一个新昵称,然后用户自己可以再次修改def inThat(self):while not self.stop_flag:if self.isOk:self.isNameOk()try:msg = self.rece_json(self.s.recv(1024).decode())print(type(msg))if msg['protocol'] == CHAT_EXIT: # 退出断开连接insert_text(self.out, msg)breakif msg['protocol'] == CHAT_USERS: # 接收新的用户列表print('接收用户列表')self.namelist.clear()self.namelist = msg['data']self.name_var.set(self.namelist)print('保存用户列表成功')if msg['protocol'] == CHATCONTENT: # 接收聊天内容insert_text(self.out, msg['data'])print('接收服务器的消息：', msg['data'])except Exception as e:print('收消息线程已关闭', e)breakmsg = '服务器已断开，或是您已退出聊天室。'insert_text(self.out, msg)self.stop()def isNameOk(self):'''用户昵称验证方法'''# 发送昵称到服务器print('验证昵称')while True:if self.isOk:usernamedata = {'protocol': CHAT_REG_USERNAME, 'data': self.name}self.send_json(usernamedata) # 发送昵称到服务器验证self.isOk = 0tempjson = self.rece_json(self.s.recv(1024))if tempjson['protocol'] == CHAT_REG_USERNAME: # 昵称正常的话跳出昵称验证的循环,开始正常接收消息self.name = getName()self.isOk = 1print('验证昵称失败，重新发送了新昵称验证')elif tempjson['protocol'] == CHAT_USERS: # 接收用户列表并展示print('接收用户列表')self.namelist.clear()self.namelist = tempjson['data']self.name_var.set(self.namelist)print('验证昵称成功，保存用户列表成功')breakdef send_json(self, msg):'''发送json格式的消息到服务器:param msg: str 消息内容:return: bool'''data = json.dumps(msg)try:self.s.send(data.encode('utf-8'))return 1except:messagebox.showinfo("提示", "请先连接服务器再尝试聊天.")return 0def rece_json(self, data):''':param data: 收到的json数据:return:python对象'''jsondata = json.loads(data)print(jsondata, type(jsondata))return jsondatadef stop(self):self.s.close()self.stop_flag = Truedef retOneToOneJsonData(msg):'''返回私聊发送的数据'''# 获取用户名name = msg.split(" ")[0].lstrip("@")# 获取聊天内容skey = msg.split(" ")[0]data = msg.replace(skey+" ", "")return {'protocol': CHAT_ONETOONE, 'data': data, 'name': name, }def insert_text(out, msg):'''添加聊天记录到text部件。:param msg: str:return:'''out.insert(tk.END, msg + '\n')out.see(tk.END)def main():Gui_Client()# 私聊发送测试# print(retOneToOneJsonData('@aaa hahah,hahah hfhfh oasdf @'))def getName():'''生成聊天室的昵称'''n = 'python大佬'id = random.randint(999, 9999)name = n + str(id)return nameif __name__ == '__main__':main()
完整代码下载地址：基于Python Tkiner、thread与socket实现的简单多人聊天室
