python socket多线程通讯实例分析(聊天室)

2024-03-20 05:49:02 532

#!/usr/bin/evnpython """ 这是一个Socket+多进程的例子（聊天服务端） """ importsocket importthreading #处理中文数据用的 encoding="GBK" defHKServer(client,addr): """ 与客户端时实通讯函数加入encoding是为了处理输入中文数据 client客户socket addr客户address """ #通知已有的每个客户，有新的成员加入 forcinclients:c.send(bytes("[%s]加入\r\n"%addr[1],encoding)) #接受客户端数据 say=b"" whileTrue: data=client.recv(1024) ifnotdata:break #如果不是回车键 ifdata!=b'\r\n': say+=data#.encode(encoding) continue #把客户端发来的内容发给所有的客户端 forcinclients: c.send(bytes("[%s]:%s\r\n"%(addr[1],say.decode(encoding)),encoding)) #内容归\x0 say=b"" #客户离开后，从客户列表中移队当前客户，关闭socket连接 clients.remove(client) client.close() #通知已有的每个客户，有成员离开 forcinclients:c.send(bytes("[%s]离开\r\n"%addr[1],encoding)) #客户端列表 clients=[] #设置IP地址与端口 HOST='' PORT=9999 #初始化socket s=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #绑定IP地址与端口 s.bind((HOST,PORT)) #开始监听 s.listen(1) #循环等待 whileTrue: #接受客户 client,addr=s.accept() #启动新的进程与客户通信 thread=threading.Thread(target=HKServer,args=(client,addr)) thread.start() #记录新的客户 clients.append(client)

python socket多线程通讯实例分析(聊天室)

热门推荐

随机推荐