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

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

2020-08-18 10:09火星大熊猫 Python

这篇文章主要介绍了python socket多线程通讯方法,以聊天室程序实例分析了Python基于Socket实现多线程通信的相关技巧,需要的朋友可以参考下

本文实例讲述了python socket 多线程通讯方法。分享给大家供大家参考，具体如下：

									#!/usr/bin/evn python

									"""

									这是一个Socket+多进程的例子（聊天服务端）

									"""

									import socket

									import threading

									# 处理中文数据用的

									encoding = "GBK"

									def HKServer(client, addr):

									 """

									 与客户端时实通讯函数

									 加入encoding是为了处理输入中文数据

									 client 客户socket

									 addr  客户address

									 """

									 # 通知已有的每个客户，有新的成员加入

									 for c in clients: c.send(bytes("[%s]加入\r\n" % addr[1], encoding))

									 # 接受客户端数据

									 say = b""

									 while True:

									  data = client.recv(1024)

									  if not data: break

									  # 如果不是回车键

									  if data != b'\r\n':

									   say += data #.encode(encoding)

									   continue

									  # 把客户端发来的内容发给所有的客户端

									  for c in clients:

									   c.send(bytes("[%s]:%s\r\n" % (addr[1], say.decode(encoding)), encoding))

									  # 内容归\x0

									  say = b""

									 # 客户离开后，从客户列表中移队当前客户，关闭socket连接

									 clients.remove(client)

									 client.close()

									 # 通知已有的每个客户，有成员离开

									 for c in clients: 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)

									# 循环等待

									while True:

									 # 接受客户

									 client, addr = s.accept()

									 # 启动新的进程与客户通信

									 thread = threading.Thread(target=HKServer, args=(client, addr))

									 thread.start()

									 # 记录新的客户

									 clients.append(client)