短连接给用户推消息方案

fantasmic 2023-08-08

用户请求接口开启推送任务，服务端收到后回调用户地址推送消息（不用长连接）
用户请求接口停止推送任务，服务端收到后停止回调用户地址
用户有几十上百，是用定时器还是其他方法呢？
如果用定时器停止时如果和定时器不在同个进程只凭定时器ID能否删除定时器？

暂无

 406  2 0

efnic 2023-08-08

这种方式不适合用定时器；
安装webman的队列和异步HTTP客户端；把需要回调的任务投入队列，由队列去消费回调用户地址；
当用户停止推送任务时，停止向队列投递任务，停止回调用户地址；

chaz6chez 2023-08-08

推荐消费队列；redis、redis-stream、rabbitmq都可以；

fantasmic 2023-08-09

开启任务后用循环推送吗。如果停止任务怎么将循环停止
efnic 2023-08-09

是用队列https://www.workerman.net/plugin/12
消费者去消费队列（回调用户地址）
fantasmic 2023-08-09

看了下有个疑问，多个用户的消息只能在一个队列下消费吗？（指的是动态队列的消费）
fantasmic 2023-08-09

提示
消费进程可以同时消费多种不同的队列，新增队列不需要修改process.php中的配置，新增队列消费者时只需要在app/queue/redis下新增对应的Consumer类即可，并用类属性$queue指定要消费的队列名

文档的消费多种队列是事先写死的，我想要投递时A、B、C...队列，消费时消费对应的队列
chaz6chez 2023-08-09

https://www.workerman.net/plugin/69
https://www.workerman.net/plugin/67
可以看一下这两个队列
当然https://www.workerman.net/plugin/67的2.0还是beta，暂时还没做完整的测试用例
chaz6chez 2023-08-09

另外，你说的这个场景，和我的 https://www.workerman.net/plugin/102 这个插件中的HookServer场景是一样的，你可以clone下来参考一下，我是通过队列消费来进行处理的