用户请求接口开启推送任务,服务端收到后回调用户地址推送消息(不用长连接) 用户请求接口停止推送任务,服务端收到后停止回调用户地址 用户有几十上百,是用定时器还是其他方法呢? 如果用定时器停止时如果和定时器不在同个进程只凭定时器ID能否删除定时器?
暂无
这种方式不适合用定时器; 安装webman的队列和异步HTTP客户端;把需要回调的任务投入队列,由队列去消费 回调用户地址; 当用户停止推送任务时,停止向队列投递任务,停止回调用户地址;
推荐消费队列;redis、redis-stream、rabbitmq都可以;
开启任务后用循环推送吗。如果停止任务怎么将循环停止
是用队列https://www.workerman.net/plugin/12 消费者去消费队列(回调用户地址)
看了下有个疑问,多个用户的消息只能在一个队列下消费吗?(指的是动态队列的消费)
提示 消费进程可以同时消费多种不同的队列,新增队列不需要修改process.php中的配置,新增队列消费者时只需要在app/queue/redis下新增对应的Consumer类即可,并用类属性$queue指定要消费的队列名
文档的消费多种队列是事先写死的,我想要投递时A、B、C...队列,消费时消费对应的队列
https://www.workerman.net/plugin/69 https://www.workerman.net/plugin/67 可以看一下这两个队列 当然https://www.workerman.net/plugin/67的2.0还是beta,暂时还没做完整的测试用例
另外,你说的这个场景,和我的 https://www.workerman.net/plugin/102 这个插件中的HookServer场景是一样的,你可以clone下来参考一下,我是通过队列消费来进行处理的
这种方式不适合用定时器;
安装webman的队列和异步HTTP客户端;把需要回调的任务投入队列,由队列去消费 回调用户地址;
当用户停止推送任务时,停止向队列投递任务,停止回调用户地址;
推荐消费队列;redis、redis-stream、rabbitmq都可以;
开启任务后用循环推送吗。如果停止任务怎么将循环停止
是用队列https://www.workerman.net/plugin/12
消费者去消费队列(回调用户地址)
看了下有个疑问,多个用户的消息只能在一个队列下消费吗?(指的是动态队列的消费)
提示
消费进程可以同时消费多种不同的队列,新增队列不需要修改process.php中的配置,新增队列消费者时只需要在app/queue/redis下新增对应的Consumer类即可,并用类属性$queue指定要消费的队列名
文档的消费多种队列是事先写死的,我想要投递时A、B、C...队列,消费时消费对应的队列
https://www.workerman.net/plugin/69
https://www.workerman.net/plugin/67
可以看一下这两个队列
当然https://www.workerman.net/plugin/67的2.0还是beta,暂时还没做完整的测试用例
另外,你说的这个场景,和我的 https://www.workerman.net/plugin/102 这个插件中的HookServer场景是一样的,你可以clone下来参考一下,我是通过队列消费来进行处理的