如何实现指标中间件Socketio通知,应该跟踪发射和监听事件?
我在一个用例来跟踪所有socket.io通知交易,这是由服务器触发,类似的API请求/ RES计数器来验证订阅验证..
我们使用一个明确的中间件,它跟踪所有用户和征收订阅规则accordingly.Now试图实现类似的一种中间件的套接字IO通知也做了REST API的请求..
技术堆栈:的NodeJS,环路,快速,插座IO。
任何建议,请..
回答如下:你可以使用socket.use()
从文档:
寄存器中间件,这是获取为每个传入分组执行,并且接收该分组,并任选地执行延迟到下一个注册的中间件的功能作为参数的函数。
通过中间件回调错误作为特殊的错误数据包到客户端发送。
io.on('connection', (socket) => { socket.use((packet, next) => { if (packet.doge === true) return next(); next(new Error('Not a doge error')); }); });
如何实现指标中间件Socketio通知,应该跟踪发射和监听事件?
我在一个用例来跟踪所有socket.io通知交易,这是由服务器触发,类似的API请求/ RES计数器来验证订阅验证..
我们使用一个明确的中间件,它跟踪所有用户和征收订阅规则accordingly.Now试图实现类似的一种中间件的套接字IO通知也做了REST API的请求..
技术堆栈:的NodeJS,环路,快速,插座IO。
任何建议,请..
回答如下:你可以使用socket.use()
从文档:
寄存器中间件,这是获取为每个传入分组执行,并且接收该分组,并任选地执行延迟到下一个注册的中间件的功能作为参数的函数。
通过中间件回调错误作为特殊的错误数据包到客户端发送。
io.on('connection', (socket) => { socket.use((packet, next) => { if (packet.doge === true) return next(); next(new Error('Not a doge error')); }); });