支持二进制的龙卷风网络套接字第 2 部分

Question

我正在尝试通过websockets传递二进制数据，更具体地说，通过websockets传递压缩字符串。在我当前的设置中，我使用龙卷风作为服务器，带有传输二进制数据的 websocket 客户端。二进制数据是通过用zlib压缩数据形成的。客户端和服务器都非常简单，如下所示。

服务器：

import tornado.websocket
import tornado.httpserver
import tornado.ioloop
import tornado.web
class WebSocketServer(tornado.websocket.WebSocketHandler):
    def open(self):
        print 'OPEN'
    def on_message(self, message):
        print 'len = {}'.format(len(message))
        print 'GOT MESSAGE: {}'.format(message.decode('zlib'))
    def on_close(self):
        print 'CLOSE'
app = tornado.web.Application([
        (r'/', WebSocketServer)
    ])
http_server = tornado.httpserver.HTTPServer(app)
http_server.listen(9500)
tornado.ioloop.IOLoop.instance().start()

客户：

import websocket
host = 'localhost'
port_ws = 9500
ws = websocket.create_connection('ws://{}:{}/'.format(host, port_ws))
message = 'this is my message'.encode('zlib')
print 'Length of message is {}'.format(len(message))
ws.send(message)

客户端不会抛出任何错误，它会打印出消息：Length of message is 24 。该消息根据 zlib 标准编码为str。另一端的服务器不会显示它收到了任何消息，它只是了解客户端已连接，然后断开连接。有谁知道问题出在哪里？我不确定问题是否出在龙卷风或 websockets 库中。有什么建议吗？

---

编辑：为了回应下面的评论(@plg(，我修改了上面的脚本以显示：

1. 非编码消息可以从客户端发送到龙卷风服务器
2. 龙卷风可以用编码消息回复

服务器：

import tornado.websocket
import tornado.httpserver
import tornado.ioloop
import tornado.web
class WebSocketServer(tornado.websocket.WebSocketHandler):
    def open(self):
        print 'OPEN'
    def on_message(self, message):
        print 'len = {}'.format(len(message))
        print 'GOT MESSAGE: {}'.format(message)
        self.write_message(message.encode('zlib'))
    def on_close(self):
        print 'CLOSE'
app = tornado.web.Application([
        (r'/', WebSocketServer)
    ])
http_server = tornado.httpserver.HTTPServer(app)
http_server.listen(9500)
tornado.ioloop.IOLoop.instance().start()

客户：

import websocket
host = 'localhost'
port_ws = 9500
ws = websocket.create_connection('ws://{}:{}/'.format(host, port_ws))
#message = 'this is my message'.encode('zlib')
message = 'this is my message'
print 'Length of message is {}'.format(len(message))
ws.send(message)
assert ws.recv().decode('zlib') == message

系统工作正常。断言不会引发错误。解码的消息与发送消息匹配。所以我想任何一个都有问题：

1. 从客户端发送编码消息
2. 龙卷风接收编码消息

老实说，我确实相信第一种选择比龙卷风更有可能。在我看来，我相信如果传入的消息没有按照 websocket 标准正确解码，龙卷风会提醒我。还有什么建议吗？

---

编辑：关于谁有过错的更多发展。我没有使用自己的服务器来中继我的连接，而是将连接中继到ws://echo.websocket.org/。我的测试应用程序如下所示：

import websocket
host = 'localhost'
port_ws = 9500
ws = websocket.create_connection('ws://echo.websocket.org/')
message = 'this is my message'
ws.send(message.encode('zlib'))
got = ws.recv().decode('zlib')
print 'GOT: {}'.format(got)
assert got == message

这实际上通过了测试，数据接收得很好。所以我想龙卷风接收数据有问题吗？

Answer 1

在查看了websocket库的源代码后，我发现默认情况下它将数据包格式化为文本。通过更改行：

ws.send('message')
# to:
ws.send('message', opcode=websocket.ABNF.OPCODE_BINARY)
# or better yet:
ws.send_binary('message')

数据包将被正常发送。我猜龙卷风只是忽略了假二进制数据包，因为它们被标记为文本并包含二进制。

Answer 2

由于这个提交龙卷风支持websocket压缩扩展。