Python TCPServer 多线程多客户端通信的实现
更新时间:2020年5月6日 14:16 点击:1841
最简单、原始的TCP通信demo
服务端Http请求:
import socket # 创建一个servicesocke serviceSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 给服务器绑定地址(ip地址,端口号) serviceSocket.bind(("192.168.171.1", 80)) print("等待客户端接入") # sock 是客户端的socket信息 # addr 是客户端的地址(ip,端口) sock, addr = serviceSocket.accept() print(f"sock from client:{sock}") print(f"addr of client:{addr}") while True: # 接收客户端的请求 recvData = sock.recv(1024) print("客户端说:%s" % (recvData.decode("utf-8"))) sendData = input("服务器说:") # 发送(回复)数据给客户端 sock.send(sendData.encode("utf-8"))
客户端Http请求:
import socket # 创建客户端socket clientSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 连接服务器 clientSocket.connect(("192.168.171.1", 80)) while True: # 发送消息给服务器 sendData = input("客户端说:") if sendData == "bye": clientSocket.send(sendData.encode("utf-8")) # 编码:将数据装换成二进制形式 break clientSocket.send(sendData.encode("utf-8")) recvData = clientSocket.recv(1024) print("服务器说:%s" % (recvData.decode("utf-8"))) # 解码:将二进制转换成字符
1、在TCP中,客户端的实现流程:
创建客户端的socket对象建立与服务器之间的联系发送请求接收数据关闭连接
2、服务端的实现流程:
创建服务端的socket对象绑定服务端的地址设置监听器等待客户端的连接接收客户端的请求返回处理的结果到客户端
ThreadingTCPServer 多线程多客户端通信自动重连demo
socketserver继承图:
TCPServer
# from socketserver import TCPServer, BaseRequestHandler, ThreadingTCPServer from socketserver import TCPServer, StreamRequestHandler, ThreadingMixIn import traceback # class MyBaseRequestHandler(BaseRequestHandler): class MyBaseRequestHandler(StreamRequestHandler): def handle(self): self.addr = self.request.getpeername() self.server.users[self.addr[1]] = self.request message = "IP " + self.addr[0] + ":" + str(self.addr[1]) + " Connected..." print(message) while True: try: data = self.request.recv(1024).decode('UTF-8', 'ignore').strip() print(f'receive from {self.client_address}:{data}') back_data = (f"response\"" + data + "\":\n").encode("utf8") self.request.sendall(back_data) except: traceback.print_exc() break # 源码:class ThreadingTCPServer(ThreadingMixIn, TCPServer): pass # 从ThreadingMixIn和TCPServer继承,实现多线程 class MyThreadingTCPServer(ThreadingMixIn, TCPServer): def __init__(self, server_address, RequestHandlerClass): TCPServer.__init__(self, server_address, RequestHandlerClass) self.users = {} class MyTCPserver(): def __init__(self, server_addr='192.168.1.109', server_port=23): self.server_address = server_addr self.server_port = server_port self.server_tuple = (self.server_address, self.server_port) def run(self): # server = TCPServer(self.server_tuple, MyBaseRequestHandler) server = MyThreadingTCPServer(self.server_tuple, MyBaseRequestHandler) server.serve_forever() if __name__ == '__main__': myserver = MyTCPserver() myserver.run()
在telnet 下开启开启两个客户端,本电脑的IP为192.168.1.109,开两个客户端后,TCPServer的终端出现同一个IP但是不同端口的连接:
TCPClient
import socket import time class MyClient: host = '192.168.1.109' port = 23 bufsiz = 1024 addr = None skt = None def __init__(self, host=None, port=None): if host != None: self.host = host if port != None: self.port = port if self.addr == None: self.addr = (self.host, self.port) self.doConnection() def doConnection(self): try: self.skt = socket.socket(socket.AF_INET, socket.SOCK_STREAM) self.skt.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) print(self.addr) self.skt.connect(self.addr) except: pass def run(self): while True: try: _time = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()) self.skt.sendall(f'{_time}:i am clent1 '.encode('utf-8')) data = self.skt.recv(self.bufsiz) print(data.decode('utf-8', 'ignore')) if not data: break print(data.strip()) time.sleep(5) except socket.error: print('socket error, reconnection') # 自动重连 time.sleep(3) self.doConnection() except: print('other error') self.skt.close() myclient = MyClient() myclient.run()
上面用的是telnet工具来作为客户端,这里是用代码实现模拟的客户端。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持猪先飞。
相关文章
- 这篇文章主要介绍了python-opencv-画外接矩形框的实例代码,代码简单易懂,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-09-04
Python astype(np.float)函数使用方法解析
这篇文章主要介绍了Python astype(np.float)函数使用方法解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-06-08- 2022虎年新年即将来临,小编为大家带来了一个利用Python编写的虎年烟花特效,堪称全网最绚烂,文中的示例代码简洁易懂,感兴趣的同学可以动手试一试...2022-02-14
- 在本篇文章里小编给大家分享的是一篇关于python中numpy.empty()函数实例讲解内容,对此有兴趣的朋友们可以学习下。...2021-02-06
python-for x in range的用法(注意要点、细节)
这篇文章主要介绍了python-for x in range的用法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-05-10- 这篇文章主要介绍了Python 图片转数组,二进制互转操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-09
- 这篇文章主要介绍了Python中的imread()函数用法说明,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-16
- 这篇文章主要介绍了python如何实现b站直播自动发送弹幕,帮助大家更好的理解和学习使用python,感兴趣的朋友可以了解下...2021-02-20
python Matplotlib基础--如何添加文本和标注
这篇文章主要介绍了python Matplotlib基础--如何添加文本和标注,帮助大家更好的利用Matplotlib绘制图表,感兴趣的朋友可以了解下...2021-01-26- 这篇文章主要介绍了解决python 使用openpyxl读写大文件的坑,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-13
- 今天小编就为大家分享一篇python 计算方位角实例(根据两点的坐标计算),具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-04-27
- 在本篇文章里小编给大家整理的是一篇关于python中使用np.delete()的实例方法,对此有兴趣的朋友们可以学习参考下。...2021-02-01
- 这篇文章主要为大家详细介绍了python实现双色球随机选号,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2020-05-02
- 这篇文章主要介绍了使用Python的pencolor函数实现渐变色功能,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-03-09
Python getsizeof()和getsize()区分详解
这篇文章主要介绍了Python getsizeof()和getsize()区分详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-11-20- 这篇文章主要介绍了python自动化办公操作PPT的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-05
- 这篇文章主要介绍了解决python 两个时间戳相减出现结果错误的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-12
- 这篇文章主要为大家详细介绍了python实现学生通讯录管理系统,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-02-25
- 这篇文章主要介绍了PyTorch一小时掌握之迁移学习篇,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-09-08
- 这篇文章主要介绍了python进行相关性分析并绘制散点图,具有一定借鉴价值,需要的朋友可以参考下,希望能够给你带来帮助...2021-09-18