需求是这样的,在onWorkerStart中,定时检测并异步执行耗时任务,当有客户端连接ws时,可以实时获取该进程任务的执行日志。 目前我采用的方案是文件和redis这样的中间件。我在想,既然timer和websocket同属于一个进程,那么能否不用中间件,直接在onWorkerStart里发送send给客户端呢?
单进程模型是可以的: onConnect回调设法保存所有客户端连接,onWorkerStart回调定时执行异步任务并将异步结果反馈即send给客户端。
谢谢,已经解决,onWorkerStart回调中直接用connections对象
单进程模型是可以的:
onConnect回调设法保存所有客户端连接,onWorkerStart回调定时执行异步任务并将异步结果反馈即send给客户端。
谢谢,已经解决,onWorkerStart回调中直接用connections对象