{"id":187989,"date":"2020-11-09T08:57:04","date_gmt":"2020-11-09T00:57:04","guid":{"rendered":"http:\/\/4563.org\/?p=187989"},"modified":"2020-11-09T08:57:04","modified_gmt":"2020-11-09T00:57:04","slug":"%e6%b1%82-python-%e5%a4%a7%e4%bd%ac%e8%a7%a3%e6%95%91","status":"publish","type":"post","link":"http:\/\/4563.org\/?p=187989","title":{"rendered":"\u6c42 Python \u5927\u4f6c\u89e3\u6551"},"content":{"rendered":"
\n
\n
\n

\u6c42 Python \u5927\u4f6c\u89e3\u6551 <\/h1>\n

<\/p>\n

\n
\u8cc7\u6df1\u5927\u4f6c : 1521815837 <\/span> <\/i> 0<\/span> <\/div>\n
<\/div>\n<\/p><\/div>\n<\/p><\/div>\n<\/p><\/div>\n
<\/p>\n

\u6700\u8fd1\u505a\u9879\u76ee\u5199\u4e86\u4e00\u4e2a\u5c0f websocket \u670d\u52a1\u5668\u4f46\u662f\u6709\u62a5\u9519\u6211\u81ea\u5df1\u6ca1\u6cd5\u641e\u5b9a\u6c42\u5927\u795e\u89e3\u6551<\/p>\n

\u62a5\u9519\u4fe1\u606f\uff1a \"\u6c42 \u4ee3\u7801\uff1a<\/p>\n

import socket import time import hashlib import base64 import struct import threading import chardet  connlist = [] s = socket.socket()          host = \"0.0.0.0\" port = 1999                 s.bind((host, port))        s.listen(500)   def getheads(data):     data = data.decode()     datasplit = data.split(\"rn\")     datasplit = datasplit[1:-2]     headslist = {}     for i in datasplit:         k,v = i.split(\":\",1)         headslist[k] = v.replace(' ','')     return headslist  def _get_data(info, setcode):     payload_len = info[1] & 127     fin = 1 if info[0] & 128 == 128 else 0     opcode = info[0] & 15     if payload_len == 126:         mask = info[4:8]         decoded = info[8:]     elif payload_len == 127:         mask = info[10:14]         decoded = info[14:]     else:         mask = info[2:6]         decoded = info[6:]     bytes_list = bytearray()     for i in range(len(decoded)):         chunk = decoded[i] ^ mask[i % 4]         bytes_list.append(chunk)     if opcode == 0x00:         opcode = setcode     if opcode == 0x01:         body = str(bytes_list, encoding='utf-8',errors='ignore')         return fin, opcode, body     else:         body = decoded         return fin, opcode, body              def recv(conn):     msg = ''     opcode = 0x00     while True:         raw_data = b''         while True:             section = conn.recv(1024)             raw_data += section             if len(section) < 1024:                 break         fin, _opcode, fragment = _get_data(raw_data,opcode)         opcode = _opcode if _opcode != 0x00 else opcode         msg += fragment         if fin == 1:              break     return msg      def send(conn,msg,fin=True):     data = struct.pack('B', 129) if fin else struct.pack('B', 0)     msg_len = len(msg)     if msg_len <= 125:         data += struct.pack('B', msg_len)     elif msg_len <= (2**16 - 1):         data += struct.pack('!BH', 126, msg_len)     elif msg_len <= (2**64 - 1):         data += struct.pack('!BQ', 127, msg_len)     else:         while True:             fragment = msg[:(2**64 - 1)]             msg -= fragment             if msg > (2**64 - 1):                 conn.send(fragment, False)             else:                 conn.send(fragment)     data += bytes(msg,encoding='utf-8',errors='ignore')     conn.send(data)   def shakehands(conn):     data = conn.recv(1024)     heads = getheads(data)     msg = heads[\"Sec-WebSocket-Key\"]     key = msg + '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'     ser_key = hashlib.sha1(key.encode('utf-8')).digest()     token = base64.b64encode(ser_key)     message = \"HTTP\/1.1 101 Switching ProtocolsrnUpgrade: websocketrnConnection: UpgradernSec-WebSocket-Accept: \"+bytes.decode(token)+\"rnWebSocket-Origin: \"+str(heads[\"Origin\"])+\"rnWebSocket-Location: ws:\/\/\"+str(heads[\"Host\"])+\"rnrn\"     conn.send(message.encode())     connlist.append(conn)  def websockethandle(conn,addr):     shakehands(conn)      ip,port = addr     print(ip+\" \u8fde\u5165\")     print(\"\u5f53\u524d\u7528\u6237\u6570:\"+str(len(connlist)))     while True:         try:              data= recv(conn)         except Exception as e:             print(e)             print(ip+\" \u65ad\u5f00\")             conn.close()             connlist.remove(conn)             print(\"\u5f53\u524d\u7528\u6237\u6570:\"+str(len(connlist)))             break         for i in connlist:             if i != conn:                 send(i,data)                      while True:     conn,addr = s.accept()     threading.Thread(target=websockethandle,args=(conn,addr,)).start() <\/code><\/pre>\n<\/p><\/div>\n
 \u5927\u4f6c\u6709\u8a71\u8aaa<\/b> (8<\/span>)        <\/div>\n
 <\/div>\n<\/p><\/div>\n<\/p><\/div>\n
    \n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : anjianshi <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u6392\u67e5\u4e00\u4e0b\u6240\u6709 + \u53f7\u7684\u5730\u65b9\uff1f\u662f\u4e0d\u662f\u5728\u628a\u5b57\u7b26\u4e32\u548c bytes \u8fdb\u884c\u62fc\u63a5\u3002
    \u5e76\u4e14\u770b\u9519\u8bef\u4fe1\u606f\uff0c\u662f\u5de6\u4fa7\u5b57\u7b26\u4e32\uff0c\u53f3\u4fa7 bytes \u3002\u4f8b\u5982
    a = ‘abc’
    b = b’def’
    a + b
    \u4f1a\u62a5\u8fd9\u4e2a                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : anjianshi <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u7c97\u770b\u4e86\u4e00\u4e0b\uff0c\u4f60\u770b\u662f\u4e0d\u662f\u8fd9\u6837\u7684\u95ee\u9898\uff1a
    1. def recv(conn) \u91cc\u8c03\u7528 _get_data(raw_data) \u65f6\u4f20\u5165\u7684 raw_data \u662f bytes
    2. def _get_data(info, setcode) \u91cc\u6536\u5230\u7684 info \u662f bytes\uff0c\u51fd\u6570\u91cc\u7684 decoded \u53d8\u91cf\u662f\u57fa\u4e8e info \u7684\uff0c\u6240\u4ee5\u4e5f\u662f bytes\uff0c
     \u7136\u540e\u51fd\u6570\u8fd4\u56de\u503c body \u5728\u6700\u4e0b\u9762\u7684\u4e00\u4e2a if \u5206\u652f\uff0c\u5c31\u7b49\u4e8e decoded \u53d8\u91cf\uff0c\u6240\u4ee5\u8fd4\u56de\u7684\u4e5f\u662f bytes
    3. def recv(conn) \u83b7\u53d6\u5230 _get_data() \u7684\u8fd4\u56de\u503c\u5e76\u5199\u5165 fragment \u53d8\u91cf\uff0c\u4f46\u6309\u4e0a\u9762\u7684\u6d41\u7a0b\uff0cfragment \u662f\u4e00\u4e2a bytes
    4. def recv(conn) \u6267\u884c\u4e86 msg += fragment\uff0cmsg \u662f str\uff0cfragment \u662f bytes\uff0c\u6700\u7ec8\u62a5\u9519                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : dd99iii <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 message = “HTTP\/1.1 101 Switching ProtocolsrnUpgrade: websocketrnConnection: UpgradernSec-WebSocket-Accept: “+bytes.decode(token)+”rnWebSocket-Origin: “+str(heads[“Origin”])+”rnWebSocket-Location: ws:\/\/”+str(heads[“Host”])+”rnrn”<\/p>\n
    \u6211\u731c\u8fd9\u4e2a\u662f bytes\uff1a
    bytes.decode(token)                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : dd99iii <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 @dd99iii \u731c\u9519\u4e86                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : CEBBCAT <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u660e\u767d\u4e86\u5417\uff1f#\u4e3a\u4ec0\u4e48\u800c\u6d3b\uff1f                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : ysc3839 <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u201c\u5ba2\u6237\u7aef\u65ad\u5f00\u8fde\u63a5\u201d\u662f\u5728\u54ea\u51fa\u73b0\u7684\uff1f\u4f60\u7684\u4ee3\u7801\u91cc\u6ca1\u6709\u5440\uff1f                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : qile1 <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 msg=b”\u8bd5\u8bd5                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
     \u8cc7\u6df1\u5927\u4f6c : dahuahua <\/span>  <\/div>\n
     <\/i>            <\/span> <\/div>\n<\/p><\/div>\n
                                                                 \u4e3a\u4ec0\u4e48\u4e0d\u6253\u5370\u65e5\u5fd7                                                            <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n","protected":false},"excerpt":{"rendered":"
    \u6c42 Python \u5927\u4f6c\u89e3\u6551 \u8cc7\u6df1\u5927…<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":[],"categories":[],"tags":[],"_links":{"self":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts\/187989"}],"collection":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=187989"}],"version-history":[{"count":0,"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts\/187989\/revisions"}],"wp:attachment":[{"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=187989"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=187989"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=187989"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}