xml

下图是从官网摘过来的RocketMQ架构图 RocketMQ架构分为四个部分：NameServer，Broker，Producer，Consumer。其中每一部分都可以水平扩展以避…

本文在Linux环境下安装RocketMQ RocketMQ 4.x以上版本安装需要JDK1.8 +， Maven 首先在官网下载RocketMQ的源码包，如果没有安装Maven，…

RocketMQ其实不怎么遵循JMS标准 NameServer用于收集其他角色的信息，里面存了许多列表，用于保存各角色的信息，Producer发送和Consumer消费信息都不直接…

建立maven项目，导入下面依赖 <!– https://mvnrepository.com/artifact/org.apache.rocketmq/rocketmq-c…

RocketMQ的Consumer有两种消费模式，通过 consumer.setMessageModel(MessageModel.BROADCASTING) 和consumer.…

Tag过滤 在Producer中使用Tag： Message msg = new Message(“TopicTest”,”TagA” ,(“Hello RocketMQ ” ).…

事务消息就是事务里参杂着发消息的动作 如果一个事务里牵扯到发消息的操作，那么一旦消息被消费了，想要回滚，这时就变的很难 所以在没有commit的时候，消息只会暂时发送存在broke…

发送消息时，我们除了可以向指定的Topic发送消息，还可以向指定的Queue发消息。有以下4种方法 DefaultMQProducer producer1 = new Defaul…

SLF4J（Simple Logging Facade for Java）是多种日志框架（JDK logging，log4j，logback…）的一种集成抽象或者说是它们的门面，a…

Zookeeper是一种用于分布式应用程序的分布式协调服务 Zookeeper提供了一些简单的原语操作（create，delete，exists，get data，set data…