通过 Websocket 与 NSQ 通信

Question

是否可以通过用户浏览器中运行的网络应用程序通过 websocket 连接与NSQ通信？任何内置的 NSQ 功能或第三方库建议都会有很大帮助。

Answer 1

最近有WSQ库解决了通过 websocket 连接与 NSQ 通信的任务。

它允许在 Websocket 和 NSQ 端分别定义消息编码/解码逻辑。此外，WSQ 支持注入认证和授权逻辑，控制用户订阅和发布主题的权限，以及基于消息内容的传入消息过滤。

创建 WSQ 服务器示例：

// Create the default config

wsqConfig := wsq.NewConfig()

// Configure Websocket CheckOrigin callback to bypass any checks.

// Don't do it in production!

wsqConfig.SetWSCheckOrigin(wsq.CheckOriginBypass)

// Create the server instance specifying message and user types to use.

server := wsq.NewServer[message, *wsq.AnonymousUser](

    // Address (optional) and port to listen on

    ":9980",

    // WSQ Config instance

    wsqConfig,

    // NSQ Config instance

    nsq.NewConfig(),

    // WSQ Transformer struct providing encoders/decoders for NSQ and Websocket sides respectivly

    &wsq.Transformer[message]{NSQEnDec: &nsqEnDec{}, WSEnDec: &wsEnDec{}},

    // Authentication controller

    &wsq.NoAuthentication,

)

server.Run()