有谁会开发微信模板消息推送队列的吗？

队列

木板

推送

微信

41 条回复 • 2018-03-03 15:59:58 +08:00

1

SourceMan

2018-03-02 09:32:28 +08:00

1

https://github.com/chrisboulton/php-resque

2

wccc

2018-03-02 09:44:36 +08:00

...有啥难的简单点一个线程从 redis 列表取数据再推送就好了

3

liyaojian

2018-03-02 10:01:31 +08:00

送分题，典型的队列应用场景

4

chinafeng

2018-03-02 10:45:55 +08:00

为什么会使用 for 循环...

5

dangyuluo

2018-03-02 10:46:45 +08:00

beanstalkd，rabbitMQ，太多了

6

zonyitoo

2018-03-02 10:47:04 +08:00

居然想到的是用 for 循环…………………………醉

7

TANKING

OP

2018-03-02 12:02:10 +08:00 via iPhone

谁有一些例子可以看看？

8

jswh

2018-03-02 12:10:59 +08:00

这种都用不到那么重的队列,几千个用户......。你的 php 超时是因为在 fpm 里超时吧。你把用户取到之后写到一个文本文件里面，然后在 cli 下跑就好了。如果量不多，手动跑跑也行，或者就写个 cron 定时检查有没有需要跑推送的文件，记得开始推送了对这个文件打个锁标记避免重复推送就好了。

9

odirus

2018-03-02 12:34:00 +08:00

1

那啥啥啥，小项目，完全可以就地取材，MySQL 也可以很好地实现消息队列的。。。反正我们小项目都用 MySQL 做消息队列了，多一个组件，多一份危险；大项目再上 MQ，保证 MQ 的高可用性需要花很多精力的。

假设数据表 tab_task 大致这样的：
seq_id, is_active, create_time, update_time

其中 is_active = 0 标示待消费的，is_active = 1 表示正在被处理，is_active = 2 标示已经处理好的。

--------------------------------------------------
正常消费线程，获取一个待处理任务（在一个事务中执行）：

UPDATE tab_task SET `is_active` = 1 AND `seq_id` = LAST_INSERT_ID(`seq_id`)
WHERE AND `is_active` = 0
ORDER BY `seq_id` ASC LIMIT 1;

SELECT * FROM tab_task
WHERE ROW_COUNT() > 0 AND `seq_id` = LAST_INSERT_ID();

----------------------------------------------------

定期检查超时的任务，然后发送报警，获取一个超时的任务（假设超时时间为 5 分钟）：

SELECT * FROM tab_task
WHERE is_active = 1 AND NOW() > DATE_ADD(`update_time`, INTERVAL 5 MINUTE)

--------------------------------------------------

10

odirus

2018-03-02 12:35:18 +08:00

只要面向接口编程，以后把 MySQL 队列替换成 MQ 队列就很方便

11

Enochyun

2018-03-02 12:42:08 +08:00

用 php 脚本跑啊

12

opengps

2018-03-02 13:30:26 +08:00

for 循环不是不可以，但是得用独立的线程，控制避免 cpu 连续争用

13

shuye00123

2018-03-02 13:42:02 +08:00

为什么要用队列啊，放线程池去运行就好了

14

qce7

2018-03-02 13:42:48 +08:00

cli 执行就行了

15

TANKING

OP

2018-03-02 13:49:25 +08:00 via iPhone

@qce7 cli 执行就不会超时的吗？

16

zjsxwc

2018-03-02 13:50:14 +08:00

cli 执行怎么会超时

17

loveCoding

2018-03-02 13:51:08 +08:00

直接放 redis 吧 ,效率高,不占内存

18

alinwu05

2018-03-02 13:51:38 +08:00

这样推送会被微信取消消息模板功能的！！

19

jjww

2018-03-02 14:03:27 +08:00

@odirus #9
小项目用 Redis 的 Pub/Sub 或者 List 做消息队列更合适.
对比你的 MySQL 解决方案, 看起来是引入了第三方组件, 其实降低了开发复杂度, 并且稳定性以及效率上提高了不少.

消息的生产者和消费者是不同的进程, 在功能上是解耦的.另外建议对消息用 msgpack 处理一下, 生产者 pack 消费者 unpack.

项目大的话建议用 RabbitMQ 等更成熟的解决方案.

20

TANKING

OP

2018-03-02 14:15:34 +08:00 via iPhone

经测试，用 cli 是可以，不会超时，但是我要做成一个网页版系统，只能用消息队列了。

21

TANKING

OP

2018-03-02 14:17:17 +08:00 via iPhone

@loveCoding 不太会用这个，看了看文档有点麻烦。

22

odirus

2018-03-02 14:31:25 +08:00

@jjww

谢谢指教，不过我有不同意见：

经过挖坑、填坑，我其实并不推荐 redis 来实现队列之类的，不确定性太多：
1. 如果我要查询历史消费记录，还是需要存储到其他稳定可靠的介质里面
2. 引入 redis 之后需要考虑维护其稳定性

如果真的是要扩展，我愿意上成熟的方案：例如阿里云的消息队列（当然如果有专门的基础组件研发团队，这又另说）