使用Python简单实现客户端界面

服务端实现

import threading
import timeimport wx
from socket import socket, AF_INET, SOCK_STREAMclass LServer(wx.Frame):def __init__(self):wx.Frame.__init__(self, None, id=1002, title='L服务器端界面', pos=wx.DefaultPosition, size=(400, 450))# 窗口中添加面板pl = wx.Panel(self)# 创建一个盒子box = wx.BoxSizer(wx.VERTICAL)# 创建可伸缩的网格布局fgz1 = wx.FlexGridSizer(wx.HSCROLL)  # 水平方向布局# 创建按钮start_server_btn = wx.Button(pl, size=(133, 40), label='启动服务')record_btn = wx.Button(pl, size=(133, 40), label='保存记录')stop_server_btn = wx.Button(pl, size=(133, 40), label='停止服务')# 将按钮添加到网络布局中fgz1.Add(start_server_btn, 1, wx.TOP | wx.LEFT)fgz1.Add(record_btn, 1, wx.TOP | wx.CENTRE)fgz1.Add(stop_server_btn, 1, wx.TOP | wx.RIGHT)# 将可伸缩的网格布局添加到box中box.Add(fgz1, 1, wx.ALIGN_CENTRE)# 只读文本框,用于显示聊天内容self.show_text = wx.TextCtrl(pl, size=(400, 410), style=wx.TE_MULTILINE | wx.TE_READONLY)box.Add(self.show_text, 1, wx.ALIGN_CENTRE)# 把盒子放到面板中pl.SetSizer(box)'''-----------------------------以上代码为界面的绘制代码-----------------------------------''''''------------------------------设置服务器功能实现的必要属性----------------------------------'''self.isOn = False  # 存储服务器的启动状态,默认False没有启动# 服务器端绑定的IP地址和端口self.host_port = ('', 8888)  # 空的字符串代表的是本机的所有IP# 创建Socket对象self.server_socket = socket(AF_INET, SOCK_STREAM)# 绑定IP地址和端口self.server_socket.bind(self.host_port)# 监听self.server_socket.listen(5)# 创建一个字典,存储与客户端对话的会话线程self.session_thread_dict = {}  # key-value(客户端的名称key:绘画线程value)'''----------------------------------------------------------------'''# 当鼠标点击'启动服务'按钮时,需要执行的操作self.Bind(wx.EVT_BUTTON, self.start_server, start_server_btn)self.Bind(wx.EVT_BUTTON, self.save_record, record_btn)self.Bind(wx.EVT_BUTTON, self.stop_server, stop_server_btn)def stop_server(self,event):#print('服务器已停止服务')self.isOn=Falsedef save_record(self,event):#获取只读文本框的内容record_data=self.show_text.GetValue()with open('record.log','w',encoding='utf-8') as file:file.write(record_data)def start_server(self, event):# 判断服务器是否已经启动,只有服务器没有启动时菜启动if not self.isOn:  # 等监狱self.isOn==False# 启动服务self.isOn = True# 创建主线程对象,函数式创建主线程main_thread = threading.Thread(target=self.do_work)# 设置守护线程,父线程执行结束(窗口界面)子线程也自动关闭main_thread.daemon = True# 启动主线程main_thread.start()def do_work(self):while self.isOn:# 接收客户端的连接请求session_socket, client_addr = self.server_socket.accept()# 客户端发送连接请求后,发送过啊里的第一条数据为客户端名称,客户端的名称去作为字典中的键user_name = session_socket.recv(1024).decode('utf-8')# 创建一个会话线程对象session_thread = SessionThread(session_socket, user_name, self)# 存储到字典中self.session_thread_dict[user_name] = session_thread# 启动会话线程session_thread.start()# 输出服务器的提示信息self.show_info_and_send_client('服务器通知', f'欢迎{user_name}进入聊天室!',time.strftime('%Y-%m-%d %H:%M:%S', time.localtime()))# 当self.isOn的值为False时,执行关闭Socket对象self.server_socket.close()def show_info_and_send_client(self, data_source, data, data_time):# 字符串拼接操作send_data = f'{data_source}:{data}\n时间:{data_time}'# 只读文本框self.show_text.AppendText('-' * 40 + '\n' + send_data + '\n')# 每一个客户端都发送一次for client in self.session_thread_dict.values():# 判断当前的会话是否为开启状态if client.isOn:client.client_socket.send(send_data.encode('utf-8'))class SessionThread(threading.Thread):def __init__(self, client_socket, user_name, server):# 调用父类的初始化方法threading.Thread.__init__(self)self.client_socket = client_socketself.user_name = user_nameself.server = serverself.isOn = True  # 会话线程是否启动,当创建SessionThread对象是,会话线程就启动了,所以当前默认为True#def run(self):print(f'客户端:{self.user_name}已经与服务端建立连接.')while self.isOn:# 从客户端接收数据data = self.client_socket.recv(1024).decode('utf-8');# 如果客户端点击断开按钮,先给服务器发送断开连接,消息自定义 C-DISCONNECT-S 自定义结束词if data == 'C-DISCONNECT-S':self.isOn = False# 发送一条服务器通知# 其他聊天信息显示给所有客户端,包含服务器显示self.server.show_info_and_send_client('服务器通知', f'{self.user_name}离开了聊天室',time.strftime('%Y-%m-%d %H:%M:%S', time.localtime()))else:# 其他聊天信息显示给所有客户端,包含服务器显示self.server.show_info_and_send_client(self.user_name, data,time.strftime('%Y-%m-%d %H:%M:%S', time.localtime()))# 关闭socketself.client_socket.close()if __name__ == '__main__':# 初始化App()app = wx.App()# 创建自己的客户端界面对象client = LServer()client.Show()  # 可以改成LServer().Show()# 循环刷新显示app.MainLoop()

客户端实现

# coding:utf-8
import threadingimport wx
from socket import socket, AF_INET, SOCK_STREAMclass LClinet(wx.Frame):def __init__(self, clent_name):# 调用父类的初始化方法# None:没有父级窗口# id:表示当前窗口的一个编号# title:窗口标题# pos:窗体的打开位置# size:窗体的大小;单位是像素,400宽,450高wx.Frame.__init__(self, None, id=1001, title=clent_name + '的客户端界面', pos=wx.DefaultPosition,size=(400, 600))# 创建面板对象pl = wx.Panel(self)# 在面板中放上盒子box = wx.BoxSizer(wx.VERTICAL)  # 垂直方向布局# 可伸缩的网格布局fgz1 = wx.FlexGridSizer(wx.HSCROLL)  # 水平方向布局# 创建连个按钮connect_btn = wx.Button(pl, size=(200, 40), label='连接')disconnect_btn = wx.Button(pl, size=(200, 40), label='断开')# 把两个按钮放到可伸缩的网格布局fgz1.Add(connect_btn, 1, wx.TOP | wx.LEFT)fgz1.Add(disconnect_btn, 1, wx.TOP | wx.RIGHT)# 可伸缩的网格布局添加到box中box.Add(fgz1, 1, wx.ALIGN_CENTRE)# 只读文本框,用于显示聊天内容self.show_text = wx.TextCtrl(pl, size=(400, 210), style=wx.TE_MULTILINE | wx.TE_READONLY)box.Add(self.show_text, 1, wx.ALIGN_CENTRE)# 创建聊天内容的文本框self.chat_text = wx.TextCtrl(pl, size=(400, 210), style=wx.TE_MULTILINE)box.Add(self.chat_text, 1, wx.ALIGN_CENTRE)# 可伸缩的网格布局fgz2 = wx.FlexGridSizer(wx.HSCROLL)  # 水平方向布局# 创建连个按钮reset_btn = wx.Button(pl, size=(200, 40), label='重置')send_btn = wx.Button(pl, size=(200, 40), label='发送')# 把两个按钮放到可伸缩的网格布局fgz2.Add(reset_btn, 1, wx.TOP | wx.LEFT)fgz2.Add(send_btn, 1, wx.TOP | wx.LEFT)# 可伸缩的网格布局添加到box中box.Add(fgz2, 1, wx.ALIGN_CENTRE)# 将盒子放到面板中pl.SetSizer(box)'''------------------以上代码时客户端界面的绘制---------------------'''self.Bind(wx.EVT_BUTTON, self.connect_to_server, connect_btn)# 实例属性设置self.client_name = clent_nameself.isConnected = False  # 存储客户端连接服务器的状态,默认False未连接self.client_socket = None  # 设置客户端的socket对象为空self.Bind(wx.EVT_BUTTON, self.send_to_server, send_btn)self.Bind(wx.EVT_BUTTON, self.disconnect_to_server, disconnect_btn)self.Bind(wx.EVT_BUTTON, self.reset, reset_btn)def reset(self,event):# 清空文本框self.chat_text.SetValue('')def disconnect_to_server(self,event):#发送断开的信息self.client_socket.send('C-DISCONNECT-S'.encode('utf-8'))# 改变连接状态self.isConnected=Falsedef send_to_server(self, event):# 判断连接状态if self.isConnected:# 从可写文本框中获取输入的内容input_data = self.chat_text.GetValue()if input_data != '':# 向服务器发送数据self.client_socket.send(input_data.encode('utf-8'))# 发送完数据后清空文本框self.chat_text.SetValue('')def connect_to_server(self, event):print(f'客户端{self.client_name}连接服务器成功')# 如果客户端没有连接服务器,则开始连接if not self.isConnected:  # 等价与self.isConnected==False# TCP编程步骤server_host_port = ('127.0.0.1', 8888)# 创建socket对象self.client_socket = socket(AF_INET, SOCK_STREAM)# 发送连接请求self.client_socket.connect(server_host_port)# 只要连接成功,发送一条数据self.client_socket.send(self.client_name.encode('utf-8'))# 启动一个线程,客户端的线程与服务器的会话线程进行会话client_thread = threading.Thread(target=self.recv_data)# 设置线程守护,窗体关闭后,子线程也关闭client_thread.daemon = True# 修改连接状态self.isConnected = True# 启动线程client_thread.start()def recv_data(self):# 判断是否是连接状态while self.isConnected:# 接收服务器的数据data = self.client_socket.recv(1024).decode('utf-8')# 显示到文本框中self.show_text.AppendText('-' * 40 + '\n' + data + '\n')if __name__ == '__main__':# 初始化App()app = wx.App()name = input('请输入客户端名称:')# 创建自己的客户端界面对象client = LClinet(name)client.Show()  # 可以改成LClinet('LL').Show()# 循环刷新显示app.MainLoop()