并发实例

并发服务端:

import pickle
import hashlib
import socketserver
class Myserver(socketserver.BaseRequestHandler):
    def handle(self):

        while 1:
            content_long=self.request.recv(4)
            pickle_content=self.request.recv(1024)
            pickle_loads_content=pickle.loads(pickle_content)
            # {'work': 'as', 'file': 'a.txt', 'long': 17}
            # print(pickle_loads_content)
            self.request.send(b'ok')
            sended=0
            s=b''
            total_long=pickle_loads_content['long']
            md5=hashlib.md5()
            i=0
            while sended<int(pickle_loads_content['long']):
                i+=1
                # print(i)
                data=self.request.recv(1024)
                md5.update(data)
                s+=data
                sended+=len(data)+1
                # print(sended)
            self.request.send(md5.hexdigest().encode('utf-8'))
            break
server=socketserver.ThreadingTCPServer(('192.168.13.137', 8027),Myserver)
# 创建套接字对象
# bind
# listen
server.serve_forever()

并发客户端

import pickle
import hashlib
import socketserver
class Myserver(socketserver.BaseRequestHandler):
    def handle(self):

        while 1:
            content_long=self.request.recv(4)
            pickle_content=self.request.recv(1024)
            pickle_loads_content=pickle.loads(pickle_content)
            # {'work': 'as', 'file': 'a.txt', 'long': 17}
            # print(pickle_loads_content)
            self.request.send(b'ok')
            sended=0
            s=b''
            total_long=pickle_loads_content['long']
            md5=hashlib.md5()
            i=0
            while sended<int(pickle_loads_content['long']):
                i+=1
                # print(i)
                data=self.request.recv(1024)
                md5.update(data)
                s+=data
                sended+=len(data)+1
                # print(sended)
            self.request.send(md5.hexdigest().encode('utf-8'))
            break
server=socketserver.ThreadingTCPServer(('192.168.13.137', 8027),Myserver)
# 创建套接字对象
# bind
# listen
server.serve_forever()