Python TCPServer 多线程多客户端通信的实现

Python  /  管理员 发布于 7年前   162

最简单、原始的TCP通信demo

服务端Http请求：

import socket# 创建一个servicesockeserviceSocket = 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# 创建客户端socketclientSocket = 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, ThreadingTCPServerfrom socketserver import TCPServer, StreamRequestHandler, ThreadingMixInimport 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 socketimport timeclass 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工具来作为客户端，这里是用代码实现模拟的客户端。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。