根据文档的说明
https://www.eggjs.org/zh-CN/core/cluster-and-ipc#agent-%E6%9C%BA%E5%88%B6
写一个agent.js
// agent.js
module.exports = agent => {
// 在这里写你的初始化逻辑
// 也可以通过 messenger 对象发送消息给 App Worker
// 但需要等待 App Worker 启动成功后才能发送,不然很可能丢失
agent.messenger.on('egg-ready', () => {
agent.messenger.sendToApp('xxx_action', '232r');
});
};
eggjs版本:2.17.0/3.15.0
无论是放在app还是extend目录,都是只加载不执行,请问啥原因?谢谢
1条答案
按热度按时间hyrbngr71#
应用场景是
server通过socketio连接了多个worker,worker会实时发送socketio消息到server,server再转发到client,但是这个消息没有按照顺序到client,所以思路是socketio到server后,先redis pub(worker pub不知道能不能按照顺序),然后在agent里面sub,然后统一发送到client,不知道这能不能解决不按顺序的问题,有没有大佬给个思路,谢谢