python基于socketserver实现并发,验证客户端的合法性

import socketserver  # 引入模块
import time
​
​
# 类名随便定义，但是必须继承socketserver.BaseRequestHandler此类。
class Myserver(socketserver.BaseRequestHandler):
​
 def handle(self):  # handle方法，固定名字
  conn = self.request  # conn相当于每个客户端连接过来的，客户端信息
  '''
  以下就是基于conn客户端信息，对每个客户端链接到服务端必须做的操作
  conn——>等于客户端的连接信息
  以此实现并发连接
  '''
  while True:
try:
 content = conn.recv(1024).decode('utf-8')
 conn.send(content.upper().encode('utf-8'))
 time.sleep(1)
except ConnectionResetError:
 break
​
​
# 对 socketserver.ThreadingTCPServer 类实例化对象，将IP地址，端口号，以及自己定义的类名传入，并返回一个对象
server = socketserver.ThreadingTCPServer(('127.0.0.1', 4444), Myserver)
server.serve_forever()# 执行对象server_forever方法，开启服务端

import socket
​
sk = socket.socket()
sk.connect(('127.0.0.1', 4444))
​
while True:
 sk.send(b'heelo')
 content = sk.recv(1024).decode('utf-8')
 print(content)

import socket
import hashlib
import os
​
# 设置双方都拥有的秘钥
secret = '秘钥'.encode('utf-8')
​
sk = socket.socket()
sk.bind(('127.0.0.1', 4444))
​
sk.listen()
conn, _ = sk.accept()
​
# 给服务端发送32位随机字节串
count = os.urandom(32)
conn.send(count)
​
# 并对字节串进行加盐加密
hs = hashlib.sha1(secret)
hs.update(count)
info_server = hs.hexdigest()
​
# 接收客户端发送的对字节串加密后的信息
info_client = conn.recv(1024).decode('utf-8')
​
# 客户端加密后的信息和服务端加密后的信息做对比
if info_server == info_client:
 # 相等则连接合法，继续操作
 print('合法连接')
else:
 # 不相等则断开链接
 print('非合法用户')
 conn.close()

import socket
import hashlib
​
# 双方共有的秘钥
secret = '秘钥'.encode('utf-8')
​
sk = socket.socket()
sk.connect(('127.0.0.1', 4444))
​
# 接收服务端发送的随机字节
count = sk.recv(1024)
​
# 对随机字节进行加密
hs = hashlib.sha1(secret)
hs.update(count)
info = hs.hexdigest().encode('utf-8')
​
# 把加密后的字节发送回服务端做判断
sk.send(info)