想问下各位大佬这个面试题

2021-04-10 07:49:01 +08:00
 fatcheung
就是我们发送消息可能会用到消息中间件,如果失败了,我们会记录到表里面,然后会用定时调度去扫。但是这个操作可能会有一定的延时,有没有更快的方法?🤔
2994 次点击
所在节点    Java
14 条回复
xuanbg
2021-04-10 08:07:20 +08:00
快是什么快?要消除的是定时任务的延时效果?这个没意义,现在发不出去的消息,马上重发大概率也是发不出去的。
fatcheung
2021-04-10 08:19:10 +08:00
@xuanbg 对啊,面试官问我有没有更加即时的方法,我答不上来,有点困惑,想问问各位老哥😂
noreplay
2021-04-10 08:51:49 +08:00
跟面试官说,记录完之后,发个通知给面试官,让面试官马上打电话通知调用方。🌚🌚
mseasons
2021-04-10 09:04:34 +08:00
将失败了的信息写进一个优先级队列,然后每次执行任务之前都检查队列,有就发送。

实际上把轮询写进了代码逻辑,就像程序响应系统中断一样
skymei
2021-04-10 09:09:28 +08:00
没有 ACK 机制吗,失败的没有 ACK 确认会自动进入延时队列,延时结束之后会自动进入原队列。
leafre
2021-04-10 09:38:08 +08:00
callback 持久化到 db 同时开个线程重试消息
ch2
2021-04-10 09:45:01 +08:00
把定时任务改成循环监听,就是看门狗机制
blackboom
2021-04-10 11:42:52 +08:00
Binlog listener
young1lin
2021-04-10 11:51:21 +08:00
用 Binglog 机制不行么,或者 MySQL 的插件 mysql-udf-http 。或者像 Kafka 一样,用带有回调的方法发送消息,阻塞直到发送成功,外加 ACK = -1
qianxiaobang
2021-04-10 13:42:32 +08:00
加个发送结果,发送过去如果没有响应,就起几个定时任务( 10s,30s,60s,5min )来重试;长期没有结果再走定时跑批
jacksparrow414
2021-04-10 13:49:50 +08:00
redis 的 list 结构? LPUSHRPOP 试一下
securityCoding
2021-04-10 14:03:32 +08:00
他想要的应该是 binlog
DoctorCat
2021-04-10 19:13:11 +08:00
写到 kafka/RabbitMQ/RocketMQ 理论上应该更快一些。
cubecube
2021-04-13 00:49:24 +08:00
应该是想让你说延时队列处理,然后 balabala 队列的一些问题

这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/769628

V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX