四川建设人员数据网站,营销型网站名词解释,适合个人网站,wordpress镜像是什么意思大家好#xff0c;我是了不起#xff0c;专为小白解决痛点的了不起。 一、非任意时间 1、修改 在服务器端#xff08;rocketmq-broker端#xff09;的属性配置文件中加入以下行#xff1a; messageDelayLevel1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h … 大家好我是了不起专为小白解决痛点的了不起。 一、非任意时间 1、修改 在服务器端rocketmq-broker端的属性配置文件中加入以下行 messageDelayLevel1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h 缺点需要重启rocketmq的服务端 二、任意时间 1、借鉴原生的逻辑 先建立多个时间范围的level依靠一个定时任务搬运到一天以内的时候建立时间轮的方式建立时分秒三个表来查着着几个区间的数据上一个级别的查到才会注册下一个级别的定时任务执行完成后取消注册时间轮有HashedWheelTimer需要考虑持久化问题 2、时间轮加rocketmq image 1.rocketMQ默认支持18个等级 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h 2.支持任意延时设计逻辑为拆分法用默认的rocketMQ去支持 任意时间都能够通过上面的时间组装出来 3.在1分中内需要发送的采用时间轮方式发送出去 4.延时会走 guava-topic不会走业务需要的topic只有当真正需要发送的时候才会走业务topic 5.考虑1分钟内由于强制重启等所带来的数据丢失问题. (TODO) 代码 https://github.com/civism/civism-rocket 优点 不需要依赖除rocketMQ以外的任何中间间可以算是0侵入 支持任意时间纬度的延时 实现简单浅显易懂安全与否取决于rocketMQ rocketMQ所有的优点 缺点 极端情况下会有一分钟的数据丢失(服务重启并且满足刚好进入时间轮) 增大了rocketMQ的自带的延时压力 rocketMQ所有的缺点 3、存储介质加时间轮 生产延迟消息延迟消息由两部分组成--该笔消息的订单号key业务数据value 存储消息当把延迟消息组装好之后把该消息key,value放入redis中并设置一定的超时时间同时存入时间轮数据结构中 取出消息当该消息在时间轮数据结构中到期时取出key然后根据这个key去redis中取value 通过RocketMQ的生产者线程把消息发送出去若发送成功则把redis中该key删除若是发送失败则记录日志人工补偿 每部分的作用是 HashedWheelTimer存储消息的keykey到期时自动弹出---起到一个定时器的作用 Redis将完整的延迟消息存储到内存中时还把数据持久化到硬盘当redis重启时基本不丢数据 RocketMQ发送延迟消息 这里有几个问题需要注意 当系统突然宕机服务器重启后时间轮HashedWheelTimer中的key都将消失并且很难恢复此时丢失的key对应在Redis中的value只能等待时间到期这种情况怎么办即数据丢失问题也可以不使用Redis存储完整的消息把完整的消息直接放入时间轮数据结构中或放入延迟队列DelayQueue中用这种方式也会存在数据丢失的问题即系统突然宕机服务器重启后未到期的数据都将丢失因为对数据没有进行持久化 当key从HashedWheelTimer中取出后根据该key在Redis中没取到数据这种情况该怎么办即数据不一致的问题 当消息到期后用RocketMQ发送时发送好几次都失败了这时候除了记录日志人工进行补偿之外还有什么好的解决方案--解决办法之一是把这些发送失败的消息存入数据库表中然后启动一个定时任务定时把发送失败的消息通过RocketMQ再次发送出去若发送成功将该消息从数据库中删除若这次还是发送失败则下次定时任务执行时再继续尝试发送。 这里的HashedWheelTimer可以用Delayqueue代替它两相比较而言HashedWheelTimer的时间复杂度比Delayqueue要好些。 参考借鉴 1、https://github.com/civism/civism-rocket 2、https://blog.csdn.net/zhaoming19870124/article/details/94152008 写在最后 欢迎大家添加我的微信识别下方二维码我会在朋友圈更新日常思考分享一下感悟和经历可以围观朋友圈一般不闲聊。 添加时备注消息“电子书”还会送大家一份优质电子书资料 由于添加的好友较多通过可能较慢还望海涵 扫描二维码加我的微信有好礼相送 本文由 mdnice 多平台发布
