由于消息的消费方式有两种，所以两种方式也有不同的API：　　1. consumerGroup：默认值为DEFAULT_CONSUMER，Consumer组名，多个Consumer如果属于一个应用，订阅同样的消息，且消费逻辑一致，则应该将它们归为同一组　　2. messageModel：消息模型，默认...

　　推，Broker主动向Consumer推消息，它Consumer的一种，应用通常向对象注册一个Listener接口，一旦接收到消息，Consumer对象立刻回调Linstener接口方法。Push方式里,consumer把轮询过程封装了,并注册MessageListener监听器,取到消息后,唤醒MessageLi...

　RocketMQ除了支持普通消息，顺序消息之外，还支持了事务消息。　　分布式事务就是指事务的参与者、支持事务的服务器、资源服务器以及事务管理器分别位于不同的分布式系统的不同节点之上。以上是百度百科的解释，简单的说，就是一次大的操作由不同的小操作组成，这些小的操作分布在不同的服务器上，且属于不同的应用，分布式事务需要保...

　　消费消息的顺序要求同发送消息的顺序一致，在RocketMQ中，主要指的是局部顺序，即一类消息为满足顺序性，必须Producer单线程顺序发送，并且发送给到同一队列，这样Consumer就可以按照Producer发送的顺序去消费消息。　　正常情况下可以保证完全的顺序消息，但是一旦发生通信异常，Broker重启，由于队...

在RocketMQ中提供了三种发送消息的模式：　　1.NormalProducer（普通）　　2.OrderProducer（顺序）　　3.TransactionProducer（事务）下面来介绍一下producer中的各个API的使用：　　1.producerGroup：Producer组名，默认值为DEFAULT_...

　　　　1.rocketmq-common:通用的常量枚举，基类方法或者数据结构，按描述的目标来分包，通俗易懂。报名有admin,consumer,filter,hook,message等。　　2.rocketmq-remoting:用Netty写的客户端和服务端，fastjson做的序列化，自定义二进制协议　　3.r...

　　pom.xml如下：<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.3.1</ver...

　　官网地址：https://github.com/apache/rocketmq-externals　　　　拉下来之后，使用idea打开rocketmq-console，在application.properties配置文件中修改rocketmq.config.namesrvAddr(前面集群环境下的nameserv...

前面已经学习了RockeMQ的四种集群方式，接下来就来搭建一个双Master(2m)的集群环境。序号　　　　ip　　　　　　用户名　　　　密码　　　　　　　　角色　　　　　　　　　　　　模式(1)　　　47.105.145.123　　root　　　　　　　　　　nameServer1,brokerServer1　　　　...

RocketMQ推荐了几种Broker集群方式，这里的Slave不可写，但可读，类似于Mysql主备方式　　这是一种风险比较大的集群方式，因为一旦Borker重启或宕机期间，将会导致这个服务不可用，因此是不建议线上环境去使用的。　　一个集群全部都是Master，没有Slave,它的优点和缺点如下：　　优点：配置简单，单...

　　　　　　是一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式特点。　　Producer、Consumer、队列都可以分布式。　　 Producer吐一些队列轮流収送消息，队列集合称为Topic，Consumer如果做广播消费，则一个consumer　　实例消费返个Topic对应的所有队列，如果做...

　　应用程序使用KafkaConsul'le「向Kafka订阅主题，并从订阅的主题上接收消息。Kafka的消息读取不同于从其他消息系统读取数据，它涉及了一些独特的概念和想法。　　单个的消费者就跟前面的消息系统的消费者一样，创建一个消费者对象，然后订阅一个主题并开始接受消息，然后做自己的业务逻辑，但是Kafka天生就是支...

　　不论将kafka作为什么样的用途，都少不了的向Broker发送数据或接受数据，Producer就是用于向Kafka发送数据。如下：　　　　pom.xml文件如下：<!--https://mvnrepository.com/artifact/org.apache.kafka/kafka--><dep...

　　Producer主动的通过push将消息发布到Broker上，Consumer通过Pull的的方式从Broker消息消息。　　通过Push的方式由于是一有消息就推到Broker,所以极大的保证了消息实时性，但是在某些情况下，可能由于Consumer网络，或是其他原因倒是消费速度低，此时就可能会导致Consumer堆...

　　zookeeper中的节点可以持久化/有序的两个维度分为四种类型：　　PERSIST：持久化无序（保存在磁盘中）　　PERSIST_SEQUENTIAL：持久化有序递增　　EPHEMERAL：非持久化的无序的，保存在内存中，当客户端关闭后消失。　　EPHEMERAL_SEQUENTIAL：非持久有序递增，保存在内存...