RocketMQ_笔记

2020-08-13duchaochen阅读(693)评论(0)赞(0)

一、搭建RocketMQ集群 　　我搭建的是2-master no slave模式，所以在${rocketmq}/conf/2m-noslave/下的 brokder-*.properties 中添加filter...

2020-08-13duchaochen阅读(673)评论(0)赞(0)

理论部分在https://www.jianshu.com/p/453c6e7ff81c中的 “三、事务消息”。下面从代码层面看一下rockemq的事务消息 一、事务消费端。 　　从代码中看到跟其他模式的消费端没有什么两样。 package ...

2020-08-13duchaochen阅读(652)评论(0)赞(0)

　　看了https://www.jianshu.com/p/453c6e7ff81c这篇博客，得出顺序消费的结论。“要实现严格的顺序消息，简单且可行的办法就是：保证生产者 - MQServer - 消费者是一对一的关系”。 我们下面通过几个...

2020-08-13duchaochen阅读(700)评论(0)赞(0)

介绍： 　　RocketMQ的消息重试及时分为两种，一种是Producer端重试，一种是Consume端重试。 　　1、Producer端重试 ： 　　　　1.1消息发没发成功，默认情况下是3次重试。 　　2、Consumer端重试： 　　...

2020-08-13duchaochen阅读(853)评论(0)赞(0)

Rocketmq 消费者默认是集群的方式消费的，消费者还可以用广播的模式进行消费。广播模式消费就是所有订阅同一个主题的消费者都会收到消息。代码实现上其实很简单，就是在消费端添加 consumer.setMessageModel(Messag...

2020-08-13duchaochen阅读(930)评论(0)赞(0)

基本概念： 　　Producer：消息生产者，负责生产消息，一般由业务系统负责生产消息。 　　Consumer：消息消费者，负责消费消息，一般是后台系统负责异步消费。 　　Push Consumer：Consumer的一种，应用通常向Con...

2020-08-13duchaochen阅读(708)评论(0)赞(0)

1. https://github.com/didapinchegit/rocket-console 在github上下载rocketmq-consoler的源码， 用mvn clean package -DskipTests 打成war包...

2020-08-13duchaochen阅读(650)评论(0)赞(0)

1.环境准备: 准备四台主机(我这里用CentOSx64) 主机 角色 broker 192.168.192.130 Master1 BrokerServerA 192.168.192.131 Master2 BrokerServerB 1...

2020-08-13duchaochen阅读(662)评论(0)赞(0)

介绍: 　　多Master模式，一个集群无Slave，全是Master,例如2个Master或者3个Master。 　　优点：配置简单，单个Master宕机或重启维护对应用无影响，在磁盘配置为RAID10时，即使机器宕机不可恢复情况下，由于...

2020-08-13duchaochen阅读(668)评论(0)赞(0)

Consumer Acknowledgements and Publisher Confirms 消费者到RabbitMQ的投递处理确认在AMQP 0-9-1中被称之为“acknowledgements”；而RabbitMQ给生产者的确认是...