是否可以通過用戶瀏覽器中運行的網(wǎng)絡(luò)應(yīng)用程序通過 websocket 連接與NSQ通信？任何內(nèi)置的 NSQ 功能或第三方庫建議都會有很大幫助。
1 回答
GCT1015
TA貢獻1827條經(jīng)驗 獲得超4個贊
最近有WSQ庫解決了通過 websocket 連接與 NSQ 通信的任務(wù)。
它允許在 Websocket 和 NSQ 端分別定義消息編碼/解碼邏輯。此外，WSQ 支持注入認證和授權(quán)邏輯，控制用戶訂閱和發(fā)布主題的權(quán)限，以及基于消息內(nèi)容的傳入消息過濾。
創(chuàng)建 WSQ 服務(wù)器示例：
// 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()
- 1 回答
- 0 關(guān)注
- 117 瀏覽
添加回答
舉報
0/150
提交
取消