这是一个创建于 2172 天前的主题，其中的信息可能已经有所发展或是发生改变。
公司现在的系统是一个推送的消息表，用户的消息记录表(用户个人中心要看到记录)。
每次添加广播(全体推送)的时候，在消息表添加一条记录，然后在用户的消息记录表添加上了所有用户的记录...
定时任务的间隔都是一分钟，一次拿取所有未推送的记录然后推送出去。然后这里就有一个 bug，前一分钟拿到的所有记录未推送完，也就是推送的状态未修改完，下次推送的定时任务有进行，就会造成重复推送了。
各位大佬你们的这个相关的是怎么设计的。
每次添加广播(全体推送)的时候，在消息表添加一条记录，然后在用户的消息记录表添加上了所有用户的记录...
定时任务的间隔都是一分钟，一次拿取所有未推送的记录然后推送出去。然后这里就有一个 bug，前一分钟拿到的所有记录未推送完，也就是推送的状态未修改完，下次推送的定时任务有进行，就会造成重复推送了。
各位大佬你们的这个相关的是怎么设计的。
 |
1
Kinnice 2018-12-16 12:32:52 +08:00 via Android
redis
|
 |
2
rockyou12 2018-12-16 12:38:30 +08:00
消息生产者吧未推送的消息放进队列里，用 redis、或者 kafka、rabbitmq 这些都行。发送者订阅队列然后发送，不要用定时任务循环查表表。
|
 |
4
lifespy 2018-12-16 16:56:18 +08:00
分组推送，不要一次全部推送
|
 |
5
lihongjie0209 2018-12-16 16:59:26 +08:00
这是一个并发定时任务的问题, 把定时任务设置为禁止并发执行就可以, 或者是有一个全局锁保证只有一个定时任务在运行
|
 |
6
opengps 2018-12-16 17:05:56 +08:00 via Android
消息队列，取过的数据在就读取不到了
|
 |
8
CallMeReznov 2018-12-16 17:10:55 +08:00
rabbitmq
|
 |
9
loveCoding 2018-12-16 17:23:59 +08:00
存个任务状态标识就行了,用户量不多,不要搞那么复杂.
MQ 作为消费者一直会有 listener 监听 topic 消息并消费,不需要干预 |
 |
10
wd 2018-12-16 17:49:08 +08:00 via iPhone
简单处理的话，每条消息加一个标记呗，表示未推送，正在推送，已经推送
|
|
11
wd 2018-12-16 17:50:19 +08:00 via iPhone
或者就是启动任务的时候，检查下钱一个任务是不是完了。
|
 |
12
wuYin 2018-12-16 17:56:50 +08:00 via Android
以前用 curl_multi 硬核实现过类似推送 [允悲]
|
 |
13
myhot21 2018-12-16 17:59:10 +08:00 via Android
这需求和消息队列完全一样。
|
 |
14
agdhole 2018-12-16 18:12:55 +08:00
量小的话简单的消息队列就行,php 也有很多这方面的轮子
|
 |
15
hcheng 2018-12-16 22:09:43 +08:00
我们用了 flock 这个命令，老哥可以去了解下
|
 |
16
alcarl 2018-12-16 22:34:24 +08:00 via Android
。。。。。。。。定时任务 select 扫出来，扔到推送之前加个推送中的状态和发起推送时间就可以了，再加一个定时任务处理发起推送时间超过 10 分钟状态仍然没变成已推送的，重新改发起推送时间，重新推，还可以加个推送次数，判断推几次就不推了。。。。。。别问我怎么知道的(T ＿ T)
|
 |
19
uoddsa OP |
 |
20
junbaor 2018-12-17 16:27:08 +08:00
如果是全体用户推的话那就不用这么浪费空间给每个用户存一行，我们是单独有一个全局消息表，用户拉自己消息的同时也会拉取全局消息，合并后返回给客户端。全局消息还有类似 tag 一样的东西和用户 tag 进行匹配。
|
Select Language