python.problems上的websocket服务器

Question

我面临的任务是为websocket提供支持，为Python实现一个简单的服务器句柄。当然我知道关于tornadoIO，但问题在于实现它。 连接和握手（交换私钥）的步骤，我做了，但后来我有问题。 1）来自客户端（浏览器）的消息确实出现，但它们被编码。我找到了关于它的信息，但无法弄清楚如何解码它们。文档说消息隐藏在掩码下面（据我所知它是一个XOR），但是打开这个掩码的钥匙没有被客户端（浏览器）拒绝，或者我没有看到它。 2）发送服务器的消息，客户端（浏览器）被忽略。根据文档

conn.send(bytes(0x00)) 
conn.send(u'test'.encode('utf-8')) 
conn.send(bytes(0xFF)) 

上传的源代码here 发送和我这里

# -*- coding: utf-8 -*- 
from __future__ import unicode_literals 
import socket,sys,hashlib,time 
from base64 import b64encode 
from threading import Thread 
#=================================== 
bindto=['127.3.1.4',80] 
thr_kill=False 

def getsett(text,ss,si,es): 
#this function i'm use for cut strings by known patterns 
    global getsett_i1,getsett_i2 
    if text==None: return None 
    if ss==None: return None 
    if es==None: return None 
    text1=text.lower() 
    ss=ss.lower() 
    es=es.lower() 
    if ss!='': getsett_i1=text1.find(ss,si) 
    else: getsett_i1=si 
    if getsett_i1==-1: return None 
    if es!='': getsett_i2=text1.find(es,getsett_i1+len(ss)) 
    else: getsett_i2=len(text1) 
    if getsett_i2==-1: return None 
    return text[getsett_i1+len(ss):getsett_i2] 

def thr_waitclient(): 
    global bindto,thr_kill 
    serv=socket.socket(socket.AF_INET,socket.SOCK_STREAM) 
    serv.bind((bindto[0],bindto[1])) 
    while thr_kill==False: 
     serv.listen(1) 
     conn,adr=serv.accept() 
     data=conn.recv(4096) 
     print data 
#checking connection type 
     if getsett(data,'connection: ',0,"\r\n").lower()=='upgrade' and getsett(data,'upgrade: ',0,"\r\n").lower()=='websocket': 
#handshake 
     wbs=getsett(data,'Sec-WebSocket-Key: ',0,"\r\n") 
     conn.send("HTTP/1.1 101 Web Socket Protocol Handshake\r\nUpgrade: WebSocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: "+b64encode(hashlib.sha1(wbs+'258EAFA5-E914-47DA-95CA-C5AB0DC85B11').digest())+"\r\nSec-WebSocket-Origin: *\r\nAccess-Control-Allow-Origin: *\r\nOrigin: *\r\nAccess-Control-Allow-Credentials:true\r\nAccess-Control-Allow-Headers:content-type\r\n\r\n") 
#wait for clien's messahe,then send response 
     while True: 
      print conn.recv(4096) #first problem:message is coded 
      conn.send(bytes(0x00)) 
      conn.send(u'test'.encode('utf-8')) 
      conn.send(bytes(0xFF)) 
      #second problem: client ignore message 
      time.sleep(0.5) 
     else: 
     conn.close() 
    serv.close() 

Thread(None,thr_waitclient).start() 
while thr_kill!=True: 
    time.sleep(0.3) 
sys.exit(0) 

Answer 1

发布源有WebSocket协议的两个不同的主要变化。您的示例代码是两种混合，不适用于任何一种协议。

Chrome，Firefox和IE10的最新版本使用较新的HyBi/IETF协议。较旧版本的Chrome和当前版本的Safari（桌面和移动版）使用较旧的Hixie协议。

Hixie协议使用'\ x00'来指示帧的开始，'\ xff'用来指示帧的结束。 Hixie协议没有将浏览器屏蔽到服务器数据。 Hixie协议有两个主要版本：75和76.版本76有一个额外的数据片段，在标题之后但在正常帧之前交换。

较新的HyBi/IETF协议使用一个2-10字节的头部，其中包含有效载荷长度并且没有单独的结束标记。在较新的协议中，浏览器到服务器的有效载荷数据使用4字节的运行XOR掩码进行屏蔽。头部之后的前4个字节是浏览器到服务器案例中的掩码。服务器到浏览器的数据没有被屏蔽。 HyBi协议的握手标题和过程也不同。

许多WebSocket服务器都支持WebSocket协议的Hixie和HyBi/IETF版本（您可以从浏览器发送的头文件中确定它使用的是什么版本）。

下面是各种协议版本规格：

• Hixie 75
• Hixie 76
• HyBi/IETF 6455