时间戳

首页 > 解决方案 > 将 ZeroMQ 从浏览器连接到服务器

javascript - 将 ZeroMQ 从浏览器连接到服务器

问题描述

我试图让 ZeroMQ 在我的网络应用程序中工作。在前端，我使用的是应该在浏览器中工作的 JSZMQ 库（我知道大多数库都没有）。在 Python 后端，我使用的是 zmq。问题是我尝试的所有协议都会引发错误。如果我尝试 TCP，正如预期的那样，浏览器会抛出一个错误，说“不支持的传输”。

根据这个 SO question JSZMQ 应该在协议为“ws://”时工作。当我尝试这个时，服务器在运行它时立即抛出“不支持协议”错误。这是我的代码：

客户：

import * as zmq from 'jszmq'

const socket = new zmq.Pull()
socket.connect('ws://127.0.0.1:3000')
socket.on('message', msg => console.log(msg))

服务器：

import zmq

context = zmq.Context()
sock = context.socket(zmq.PUSH)
sock.bind('ws://127.0.0.1:3000') # This is what throws the error
sock.send('hello')

如果重要的话，我正在为服务器进行多处理，将 zmq 对象作为全局对象，因为它不可序列化并且不能作为参数传递给函数。

为什么这不起作用？

标签： javascriptpythonmultiprocessingzeromq

解决方案

你在这里有点困惑：

ws:// means http:// or default port 80
wss:// means https:// or default port 443

ws://<server>:<port> means http over that port.

在后台发生的是浏览器通过 http(s) 协议连接到服务器，并在可能的情况下升级到 websocket 的连接。

浏览器不允许原始套接字连接，但允许Websocket连接。

看看https://github.com/zeromq/jszmq#compatibility-with-zeromq：

与 ZeroMQ 的兼容性

最近在 zeromq 中添加了 WebSocket 传输，它仅在从源代码编译时可用。

zeromq 的其他端口，如 NetMQ (C#) 和 JeroMQ (Java) 尚不支持 WebSocket 传输。

您必须查看FastAPI Python 框架。

您正在寻找的模式是：

[SOCKET CLIENT] --> [FASTAPI SERVER] <--> [ZEROMQ]

本文档展示了如何在单个文件客户端 websocket 和 FastAPI 服务器中进行设置： https ://fastapi.tiangolo.com/advanced/websockets/

您的工作将在 websocket.receive_text 和 websocket.send_text 之间完成。

@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
    await websocket.accept()
    while True:
        data = await websocket.receive_text()
        # --> ZeroMQ Code Here <--
        await websocket.send_text(f"Message text was: {data}")

这个框架非常棒，您可以利用本机后台任务获得更多优势： https ://fastapi.tiangolo.com/tutorial/background-tasks/

因此，您可以接受来自客户端的消息，并在某个 ZeroMQ 工作人员完成后发回。

还有很多有用的特性，比如异步数据库、即时 OpenAPI 文档等等。

推荐阅读