python.problems上的websocket服务器
我面临的任务是为websocket提供支持,为Python实现一个简单的服务器句柄。当然我知道关于tornadoIO,但问题在于实现它。 连接和握手(交换私钥)的步骤,我做了,但后来我有问题。 1)来自客户端(浏览器)的消息确实出现,但它们被编码。我找到了关于它的信息,但无法弄清楚如何解码它们。文档说消息隐藏在掩码下面(据我所知它是一个XOR),但是打开这个掩码的钥匙没有被客户端(浏览器)拒绝,或者我没有看到它。 2)发送服务器的消息,客户端(浏览器)被忽略。根据文档python.problems上的websocket服务器
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)
发布源有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版本(您可以从浏览器发送的头文件中确定它使用的是什么版本)。
下面是各种协议版本规格:
你看现有的实现,如高速公路,ws4py,txws? – jfs 2012-03-10 00:02:56