利用Python打造一个多人聊天室的示例详解

num=0

def chat(service_client_socket,addr):# 等待接收客户端消息存放在2个变量service_client_socket和addr里if not addr in user:print('Accept new connection from %s:%s...' % addr)# 如果addr不在user字典里则执行以下代码for scs in serv_clie_socket:serv_clie_socket[scs].send(data +' 进入聊天室...'.encode('utf-8'))# 发送user字典的data和address到客户端user[addr] = data.decode('utf-8') #data 是最新进入聊天室的客户，解压后放入user serv_clie_socket[addr] = service_client_socket #将服务器与服务器端口号为addr的套接字放入字典# 接收的消息解码成utf-8并存在字典user里,键名定义为addr#print("可以开始聊天了>>>>>>")# 如果addr在user字典里，跳过本次循环while True:d = service_client_socket.recv(1024) if (('EXIT'.lower() in d.decode('utf-8'))|(d.decode('utf-8') == 'error1')):#如果EXIT在发送的data里name = user[addr]#user字典addr键对应的值赋值给变量name user.pop(addr) serv_clie_socket.pop(addr)#删除user里的addr for scs in serv_clie_socket:#从user取出address serv_clie_socket[scs].send((name + ' 离开了聊天室...').encode('utf-8'))#发送name和address到客户端print('Connection from %s:%s closed.' % addr) global num num = num-1 break else:print('"%s" from %s:%s' %(d.decode('utf-8'), addr[0], addr[1])) for scs in serv_clie_socket:#从user遍历出address if serv_clie_socket[scs] != service_client_socket:#address不等于addr时，执行下面的代码serv_clie_socket[scs].send(d)#发送data到客户端

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 创建socket对象

addr = ('127.0.0.1', 9999) s.bind(addr) # 绑定地址和端口

s.listen(128)

print('TCP Server on', addr[0], ":",addr[1],"......")

user = {} # 存放字典{addr:name}serv_clie_socket = {} #存放{socket:不同线程的套接字}while True:try:print("等待接收客户端的连接请求....") service_client_socket, addr = s.accept() # 等待接收客户端的连接请求print("接收到客户端的连接请求....") except ConnectionResetError:print('Someone left unexcept.') data = service_client_socket.recv(1024) if data.decode()=='error1':print(addr,"关闭了登录窗口。。。") continue print("data = ",data.decode())

#为服务器分配线程num=num+1 r = threading.Thread(target=chat, args=(service_client_socket,addr), daemon=True) r.start() print("聊天室人数：",num)

string=''def my_string(s_input):string = s_input.get()

def Send(sock):'''发送数据的方法

参数：

sock：定义一个实例化socket对象server：传递的服务器IP和端口'''if string!='':message = name + ' : ' + string data = message.encode('utf-8') sock.send(data) if string.lower() == 'EXIT'.lower():exit()

def recv(sock):sock.send(name.encode('utf-8')) while True:data = sock.recv(1024)#加一个时间戳time_tuple = time.localtime(time.time()) str = ("{}点{}分".format(time_tuple[3],time_tuple[4])) rrecv = tkinter.Label(t,text=data.decode('utf-8'),width=40,anchor='w',bg='pink')#接收的消息靠左边rrecv.pack()

def left():global string string = rv1.get() Send(s) if string!='':rleft = tkinter.Label(t,text=string,width=40,anchor='e')#发送的消息靠右边rleft.pack() rv1.set('')

def Creat():global name name = n.get()

#接收进程tr = threading.Thread(target=recv, args=(s,), daemon=True)# daemon=True 表示创建的子线程守护主线程，主线程退出子线程直接销毁tr.start()

l.destroy() e.destroy() b.destroy() t.title("聊天室") t.geometry("500x600") rL0 = tkinter.Label(t,text='%s的聊天室'%name,width=40) rL0.pack() rL1 = tkinter.Label(t,text='请输入消息：',width=20, height=1) rL1.place(x=0,y=450) rE1 = tkinter.Entry(t, textvariable = rv1) rE1.place(x=200,y=450) rB1 = tkinter.Button(t, text="发送",command=left) rB1.place(x=380,y=450)#发送进程

def JieShu():tkinter.messagebox.showwarning(title='你确定退出吗？', message='刚才你点击了关闭按钮') s.send("error1".encode('utf-8')) exit(0)

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server = ('10.100.207.40', 9999) s.connect(server)#建立连接t=tkinter.Tk() t.title("多人聊天室") t.geometry("300x200+500+200") l = tkinter.Label(t,text='多人聊天室欢迎您，请输入你的名称',width=40, height=8) l.pack() n = tkinter.StringVar() e = tkinter.Entry(t, width=15,textvariable = n) e.pack() rv1 = tkinter.StringVar() name = n.get()

b = tkinter.Button(t, text="登录",width=40, height=10,command=Creat)

b.pack() t.protocol("WM_DELETE_WINDOW", JieShu) t.mainloop()