mq剩余的没消费消息怎么继续消费

匿名- 2023-08-06 01:02:58

消费端如何保证消息队列MQ的有序消费

style="text-indent:2em;">今天给各位分享mq剩余的没消费消息怎么继续消费的知识,其中也会对前端mq重复消费解决办法进行解释,如果能碰巧解决你现在面临的问题,别忘了关注本站,现在开始吧!

本文目录

  1. mq队列怎么防止消息重复
  2. mq剩余的没消费消息怎么继续消费
  3. mq点对点和订阅发布的区别
  4. mq250更换变速箱油方法

mq队列怎么防止消息重复

MQ队列可以通过以下几种方式来防止消息重复:

1.消息去重:在消息发送前,对消息内容进行摘要计算,并将其作为消息的唯一标识。当消息到达队列后,队列会对消息的唯一标识进行比较,如果相同则认为消息重复,将其丢弃或将其存储到一个历史记录中。

2.幂等性设计:在消息的处理逻辑中,考虑到其可能被重复消费,因此采用幂等性设计,即对同一条消息的重复消费不会造成影响。例如,更新操作可以使用数据库的“乐观锁”机制,保证同一记录在多次更新时具有相同的版本号。

3.消息过期:在发送消息时,可以为每条消息设置一个过期时间,在到达过期时间后,消息队列会自动将其丢弃,避免了消息因为长时间未被消费而重复消费的情况。

4.去重缓存:在消息的生命周期中,将已经消费的消息标记为已处理,并将其缓存在一个去重缓存中。对于新收到的消息,先在去重缓存中进行查找,如果已经存在则认为是重复消息,直接丢弃。这种方式可以通过Redis等缓存工具来实现。

mq剩余的没消费消息怎么继续消费

当MQ中还有未消费的消息时,可以通过重新启动消费者程序来继续消费这些消息。在重新启动消费者程序时,程序会重新连接MQ并从上一次消费的位置继续消费未消费的消息。

如果需要重新消费所有消息,可以将消费者程序的消费位置重置为最初的位置,然后重新启动程序。

另外,也可以通过设置消费者程序的消费模式为“手动确认模式”,在消费完一条消息后手动确认消息已被消费,这样即使程序中途出现异常,也可以保证已经消费的消息不会被重复消费。

mq点对点和订阅发布的区别

1.点对点

消息生产者消息发送到queue中,然后消费者从queue中取。注意:消息被消费以后,队列中不再有存储,所以消费者不能消费已经被消费的消息了。也就是不能重复消费。

2.发布/订阅

生产者将消息发送到topic中,同事多个消费者消费这个消息。和点对点不同,发布到topic的消息会被所有订阅在消费。

2.二者分析与区别

2.1点对点模式

?

生产者发送一条消息到queue,只有一个消费者能收到。

2.2发布订阅模式

?

发布者发送到topic的消息,只有订阅了topic的订阅者才会收到消息。

小结

queue实现了负载均衡,一个消息只能被一个消费者接受,当没有消费者可用时,这个消息会被保存直到有一个可用的消费者,一个queue可以有很多消费者,他们之间实现了负载均衡,

所以Queue实现了一个可靠的负载均衡。

topic实现了发布和订阅,当你发布一个消息,所有订阅这个topic的服务都能得到这个消息,所以从1到N个订阅者都能得到一个消息的拷贝,

只有在消息代理收到消息时有一个有效订阅时的订阅者才能得到这个消息的拷贝。

疑问

发布订阅模式下,能否实现订阅者负载均衡消费呢?当发布者消息量很大时,显然单个订阅者的处理能力是不足的。实际上现实场景中是多个订阅者节点组成一个订阅组负载均衡消费topic消息即分组订阅,

这样订阅者很容易实现消费能力线性扩展。

?

3流行消息队列模型比较

传统企业型消息队列ActiveMQ遵循了JMS规范,实现了点对点和发布订阅模型,但其他流行的消息队列RabbitMQ、Kafka并没有遵循老态龙钟的JMS规范,是通过什么方式实现消费负载均衡、多订阅呢?

3.1RabbitMQ

RabbitMQ实现了AQMP协议,AQMP协议定义了消息路由规则和方式。生产端通过路由规则发送消息到不同queue,消费端根据queue名称消费消息。此外RabbitMQ是向消费端推送消息,订阅关系和消费状态保存在服务端。

?

生产端发送一条消息通过路由投递到Queue,只有一个消费者能消费到。

?

当RabbitMQ需要支持多订阅时,发布者发送的消息通过路由同时写到多个Queue,不同订阅组消费此消息。

RabbitMQ既支持内存队列也支持持久化队列,消费端为推模型,消费状态和订阅关系由服务端负责维护,消息消费完后立即删除,不保留历史消息。所以支持多订阅时,消息会多个拷贝。

3.2Kafka

?

Kafka只支持消息持久化,消费端为拉模型,消费状态和订阅关系由客户端端负责维护,消息消费完后不会立即删除,会保留历史消息。因此支持多订阅时,消息只会存储一份就可以了。

mq250更换变速箱油方法

一、放掉旧自动变速箱油。

放油前先行驶车辆,使自动变速箱油到正常工作温度(70℃-80℃),以便降低油的黏度(确保油内杂质和沉淀物随油一起排出),然后停车熄火,置于停车文件(P)位置,并拉紧手煞车,将车顶起。

二、拆下自动变速器油底壳上的放油螺塞

将油底壳内的油液放净,视情况拆下油底壳,彻底清洗油底壳和滤网(纸芯须更换),并清洗冷却器,然后再将油底壳和放油螺塞装好。

三、用压缩空气从加油口将液力变矩器里的油尽量吹出

四、加油时,注入规范的自动变油至规定的油面高度(因加入的是新油,温度较低,油面高度应在油尺刻度线的下限附近)。

五、将油全部放掉,重复一、二、三步骤;

六、然后起动引擎,在引擎怠速运转情况下,移动所有档位后回到停车文件(P)位置,此时如油面低,应继续加油至规定油面高度。

七、最后,达到正常工作温度,再次检查热车状态时的油面高度是否在油尺刻度线的上限附近,并调整油面高度。

八、如果加油时不慎使油面高于规定的高度,这时不应勉强使用,而应该再松开放油螺塞进行放油。

随着时间增加自动变速器油液内的化学成分也会变化,比如氧化变质,一些轻质成分也会挥发,还有蜡质成分也会析出。所以一般我们建议车主1年3万公里为一个周期更换自动变速器油。

如果你还想了解更多这方面的信息,记得收藏关注本站。

RocketMQ原理 消息消费流程
  • 声明:本文内容来自互联网不代表本站观点,转载请注明出处:bk.66688815.com/11/86771.html
上一篇:上网课时楼上有人在跳绳怎么办(好几次了,快疯了)怎么劝说(楼上在跳绳可以报警吗)
下一篇:QQ和TIM电脑客户端无法打开,一直弹出Q盾,怎么办(电脑打开qq弹出q盾打不开qq)
相关文章
返回顶部小火箭