1. 服务端:
  3. import socketserver
  5. class Myserver(socketserver.BaseRequestHandler):  #来一个链接产生一个实例
  6.     def handle(self):  #定义了一个通信循环的功能
  7.         print(\'conn是:\',self.request)  #相当于conn  既accept接收到的连接
  8.         print(self.client_address) #相当于addr 既accept接收到的addr地址
  9.         while True:
  10.             try:
  11.                 #收消息
  12.                 data = self.request.recv(1024)
  13.                 if not data: break
  14.                 print(\'收到客户端的消息是：\',data,self.client_address)
  16.                 #发消息
  17.                 self.request.sendall(data.upper())
  18.             except Exception as e:
  19.                 print(e)
  20.                 break
  21.  
  22. if __name__ == \'__main__\':
  23.     s = socketserver.ThreadingTCPServer((\'127.0.0.1\',8000),Myserver) #多线程的TCP服务端 第一个参数是IP和端口 第二个参数相当于把通信循环加进去了
  24.     s.serve_forever()  #这两项相当于实现了链接循环 只要有链接进来 直接进入通信循环 执行myserver下的handle方法

    UDP版本：
  1. #UDP版本
    class Myserver(socketserver.BaseRequestHandler):  #来一个链接产生一个实例
        def handle(self):  #定义了一个通信循环的功能
            while True:
                data = self.request[0]
    print(data)
    self.request[1].sendto(self.request[0].upper(),self.client_address)
  1.  

socketserver中两大类：第一类：server类，处理链接 第二类：request类，处理通信

server类：

 

 request类：

 

继承关系：

  1. +------------+
    | BaseServer |
    +------------+
          |
          v
    +-----------+        +------------------+
    | TCPServer |------->| UnixStreamServer |
    +-----------+        +------------------+
          |
          v
    +-----------+        +--------------------+
    | UDPServer |------->| UnixDatagramServer |
    +-----------+        +--------------------+

 

 

 

 

利用hmac+加盐的方式来实现

客户端：

  1. #_*_coding:utf-8_*_
  2. __author__ = \'Linhaifeng\'
  3. from socket import *
  4. import hmac,os
  6. secret_key=b\'linhaifeng bang bang bang\'
  7. def conn_auth(conn):
  8.     \'\'\'
  9.     认证客户端链接
  10.     :param conn:
  11.     :return:
  12.     \'\'\'
  13.     print(\'开始验证新链接的合法性\')
  14.     msg=os.urandom(32)
  15.     conn.sendall(msg)
  16.     h=hmac.new(secret_key,msg)  #将盐和随机产生的32位数组合生成一个新值
  17.     digest=h.digest() #将新值转化为数字
  18.     respone=conn.recv(len(digest)) #接收与数字同等长度的值
  19.     return hmac.compare_digest(respone,digest) #将接收到的值和自己的值做比较，返回一个True或False
  20.  
  21. def data_handler(conn,bufsize=1024):
  22.     if not conn_auth(conn):
  23.         print(\'该链接不合法,关闭\')
  24.         conn.close()
  25.         return
  26.     print(\'链接合法,开始通信\')
  27.     while True:
  28.         data=conn.recv(bufsize)
  29.         if not data:break
  30.         conn.sendall(data.upper())
  32. def server_handler(ip_port,bufsize,backlog=5):
  33.     \'\'\'
  34.     只处理链接
  35.     :param ip_port:
  36.     :return:
  37.     \'\'\'
  38.     tcp_socket_server=socket(AF_INET,SOCK_STREAM)
  39.     tcp_socket_server.bind(ip_port)
  40.     tcp_socket_server.listen(backlog)
  41.     while True:
  42.         conn,addr=tcp_socket_server.accept()
  43.         print(\'新连接[%s:%s]\' %(addr[0],addr[1]))
  44.         data_handler(conn,bufsize)
  46. if __name__ == \'__main__\':
  47.     ip_port=(\'127.0.0.1\',9999)
  48.     bufsize=1024
  49.     server_handler(ip_port,bufsize)

 

客户端：

  1. #_*_coding:utf-8_*_
  2. __author__ = \'Linhaifeng\'
  3. from socket import *
  4. import hmac,os
  6. secret_key=b\'linhaifeng bang bang bang\'
  7. def conn_auth(conn):
  8.     \'\'\'
  9.     验证客户端到服务器的链接
  10.     :param conn:
  11.     :return:
  12.     \'\'\'
  13.     msg=conn.recv(32)
  14.     h=hmac.new(secret_key,msg)
  15.     digest=h.digest()
  16.     conn.sendall(digest)
  18. def client_handler(ip_port,bufsize=1024):
  19.     tcp_socket_client=socket(AF_INET,SOCK_STREAM)
  20.     tcp_socket_client.connect(ip_port)
  22.     conn_auth(tcp_socket_client)
  24.     while True:
  25.         data=input(\'>>: \').strip()
  26.         if not data:continue
  27.         if data == \'quit\':break
  29.         tcp_socket_client.sendall(data.encode(\'utf-8\'))
  30.         respone=tcp_socket_client.recv(bufsize)
  31.         print(respone.decode(\'utf-8\'))
  32.     tcp_socket_client.close()
  34. if __name__ == \'__main__\':
  35.     ip_port=(\'127.0.0.1\',9999)
  36.     bufsize=1024
  37.     client_handler(ip_port,bufsize)

客户端

 

版权声明：本文为caixiaowu原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/caixiaowu/p/12489436.html