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：非持久有序递增，保存在内存...

　　通过某个节点的写操作结果对后面通过其他节点的读操作可见。　　如果更新数据后，并发访问的情况下可立即感知该更新，称为强一致性　　如果允许之后部分或全部感知不到该更新，称为弱一致性。　　若在之后的一段时间（通常该时间不是固定的）后，一定可以感知到该更新，称为最终一致性。　　即是任何一个没有发生故障的节点必须在有限的时间...

　　　　一个Kafka集群中包含若干个Broker(消息实例)，Kafka支持Broker横向扩展，Broker越多，吞吐量越大，同时也包含了若干个Producer(可以是web前端产生的PageView，或者是服务器日志，系统CPU、Memory等）和若干个Consumer(消费者)以及一个zookeeper集群，K...

　　Kafkaisadistributed,partitioned,replicatedcommitlogservice。它提供了类似于JMS的特性，但是在设计实现上完全不同，此外它并不是JMS规范的实现。kafka对消息保存时根据Topic进行归类，发送消息者成为Producer,消息接受者为Consumer,此外k...

持久化：将交换机或队列数据保存到磁盘，服务器宕机或重启之后依然存在。非持久化：将交换机或队列的数据保存到内存中，服务器宕机或重启之后数据将不存在。在RabbitMQ中也提供了持久化和非持久化方式。实现方式为将durable设置为false即可。在配置文件中配置交换机或队列时配置durable="false"即可，配置方...

在SpringAMQP项目中Spring也提供了对RabbitMQ的支持，这里在之前学习SpringBoot的时候也整合过，但是今天这里使用的Spring的xml配置来整个rabbit.SpringAMQP项目地址：https://spring.io/projects/spring-amqp；下面来看看使用方式。pom...

　　 　　上图表示一个消费者消费消息之后，不讲消息直接存储到队列，而是使用两个消费者各自声明一个队列，将各自的对应的队列与交换机绑定。这样每个消费者都读取的是自身所对应的队列的所有消息，大达到了一个生产者生产消息，所有消费者都能消费的目的。　　将交换机类型设置为fanout即可实现Publish/Subscr...