rocketmq发送顺序消息（四）

rocketmq怎么发送消息可参考我的上一篇博客：rocketmq发送第一条消息。此处我们讲解如何发送rocketmq顺序消息

producer

public class ProducerOrder {public static void main(String[] args) throws Exception {DefaultMQProducer producer = new DefaultMQProducer("testGrp");// 设置nameserver地址  nameserver具备路由功能（发现服务，有点注册中心的意思），让其分配合理的broker来进行消息发送producer.setNamesrvAddr("192.168.52.11:9876");try {producer.start();} catch (MQClientException e) {e.printStackTrace();}for (int i = 0; i < 20; i++) {Message message = new Message("monkeyOrderMsgTopic", ("这是顺序消息：" + i).getBytes());producer.send(message,// 自定义选择Queuenew MessageQueueSelector() {/**** @param list 当前topic里所有的queue* @param message 要发送的消息* @param o 对应到 send（） 里的 args参数* @return*/@Overridepublic MessageQueue select(List<MessageQueue> list, Message message, Object o) {// 根据传入的参数决定QueueMessageQueue messageQueue = list.get((Integer)o);return messageQueue;}}, 0, 3000);}System.out.println("发送完成");}
}

consumer

public class ConsumerOrder {public static void main(String[] args) throws Exception {DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("testConsumerOrder");consumer.setNamesrvAddr("192.168.52.11:9876");consumer.subscribe("monkeyOrderMsgTopic","*");consumer.registerMessageListener(new MessageListenerOrderly() {@Overridepublic ConsumeOrderlyStatus consumeMessage(List<MessageExt> list, ConsumeOrderlyContext consumeOrderlyContext) {for (MessageExt messageExt : list) {System.out.println(new String(messageExt.getBody()) + "current Thread:" + Thread.currentThread().getName());}return ConsumeOrderlyStatus.SUCCESS;}});consumer.start();System.out.println("consumer start .....");}}

测试结果：

总结：

你们应该如何保证消息的顺序?

同一topic
同一个QUEUE
发消息的时候一个线程去发送消息
消费的时候一个线程消费一个queue里的消息或者使用MessageListenerOrderly
多个queue 只能保证单个queue里的顺序

rocketmq发送顺序消息（四）相关推荐

RocketMq发送延迟消息
什么是延迟消息? 对于消息中间件来说,producer将消息发送到mq的服务器,但并不期望这条消息马上被消费,而是推迟到当前时间点之后的某个时间点后再投递到queue中让consumer进行消费,延迟 ...
RocketMQ发送延迟消息时报错，发送同步消息却正常
延时消息代码如下: Message<Mdds> message = MessageBuilder.withPayload(mdds).build(); // 延迟第3级发送(延迟10秒) ...
rocketMq发送事务消息
事务消费我们经常支付宝转账余额宝,这是日常生活的一件普通小事,但是我们思考支付宝扣除转账的钱之后,如果系统挂掉怎么办,这时余额宝账户并没有增加相应的金额,数据就会出现不一致状况了. 上述场景在各个类 ...
RocketMQ（九）RocketMQ顺序消息
目录一.什么是顺序消息? 二.顺序消息的原理三.全局顺序消息四.局部顺序消息五.顺序消息缺陷一.什么是顺序消息? 消息有序指的是,消费者端消费消息时,需按照消息的发送顺序来消费,即先发送的消 ...
RocketMQ - 6 生产者，顺序消息
Producer类型 Producer主要职能就是生产消息,发送消息.它可以对多个主题发送消息,甚至可以通过Tag定义些简单的过滤.更复杂的过滤可以使用filter组件来进行相应的业务操作 Rocke ...
RocketMQ 发送消息的基本案例
RocketMQ 消息发送的基本样例 "一发.一存.一消费" 是消息中间件的本质,本文简单的记录来RocketMQ消息的基本样例,包含消息的发送(同步消息/异步消息/单向消息).消 ...
聊一聊顺序消息（RocketMQ顺序消息的实现机制）
本文来自:https://www.cnblogs.com/hzmark/p/orderly_message.html 当我们说顺序时,我们在说什么? 日常思维中,顺序大部分情况会和时间关联起来,即时间 ...
消息中间件学习总结（10）——Kafka、RabbitMQ、RocketMQ消息中间件的消息发送性能对比
引言分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦.现在开源的消息中间件有很多,前段时间我们自家的产品 RocketMQ (MetaQ的内核) 也顺利开源,得到大家的关注. ...
RocketMQ——顺序消息
消息有序指的是可以按照消息的发送顺序来消费. RocketMQ可以严格的保证消息有序.但这个顺序,不是全局顺序,只是分区(queue)顺序.要全局顺序只能一个分区. 之所以出现你这个场景看起来不是顺序 ...

rocketmq发送顺序消息（四）

rocketmq发送顺序消息（四）相关推荐

最新文章

热门文章