有关网站建设的视频重庆建设网站的公司简介

有关网站建设的视频,重庆建设网站的公司简介,网站图片切换js代码,网站建设合同属于技术合同吗与Kafka类似#xff0c;RocketMQ也支持基于队列#xff08;分区#xff09;的顺序消费机制。具体表现为#xff1a;同一队列内的消息保证有序#xff0c;而不同队列间的消息则是无序的。实现顺序消息发送时#xff0c;生产者需在send方法中传入MessageQueueSelector。该接…与Kafka类似RocketMQ也支持基于队列分区的顺序消费机制。具体表现为同一队列内的消息保证有序而不同队列间的消息则是无序的。实现顺序消息发送时生产者需在send方法中传入MessageQueueSelector。该接口的select方法用于确定消息投递的目标队列常见实现方式是采用取模路由策略SendResult sendResult producer.send(msg, new MessageQueueSelector() { Override public MessageQueue select(ListMessageQueue mqs, Message msg, Object arg) { Integer id (Integer) arg; int index id % mqs.size(); return mqs.get(index); } }, orderId);注意必须使用同步发送方式确保顺序性。消费者端通过MessageListenerOrderly模式实现顺序消费consumer.registerMessageListener(new MessageListenerOrderly() { Override public ConsumeOrderlyStatus consumeMessage(ListMessageExt msgs, ConsumeOrderlyContext context) { System.out.printf(Receive order msg: new String(msgs.get(0).getBody())); return ConsumeOrderlyStatus.SUCCESS; } });顺序消费通过三级加锁机制保障Broker级锁确保消息只投递给特定消费者MessageQueue锁保证单线程处理队列消息ProcessQueue锁防止重平衡时的重复消费扩展说明 第三把锁主要应对消费者集群重平衡场景。当队列需要重新分配时该锁确保正在处理的消息能完成消费并提交位点避免新消费者重复消费。若不加此锁可能导致位点未提交的消息被重复处理。需注意顺序消费会降低系统吞吐量且存在消息阻塞传递效应应谨慎使用。