ActiveMQ源码-BrokerService和PersistenceAdapter

activemq-broker 模块 test/java 目录下有个 IDERunner 类: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 public class IDERunner { private static final boolean TRANSPORT_TRACE = false; public static void main(String[]args) throws Exception { BrokerService brokerService = new BrokerService(); // brokerService.addConnector( // "tcp://0.0.0.0:61616?trace=" + TRANSPORT_TRACE + // "&transport.wireFormat.maxFrameSize=104857600"); brokerService.setPersistent(false); brokerService.setUseJmx(false); brokerService.setAdvisorySupport(false); brokerService.start(); brokerService.waitUntilStopped(); } } 注释掉 brokerService 调用 addConnector 方法的三行代码,然后 debug 运行该类的 main 方法。 ...

2024-08-27 · 9 min · 4479 words · chensoul

ActiveMQ源码本地调试运行

源码构建 1、从 https://github.com/apache/activemq 下载源码 1 git clone https://github.com/apache/activemq 2、切换至 activemq-5.18.x 分支 1 2 cd activemq git checkout activemq-5.18.x 3、构建源码 1 mvn package -DskipTests 构建成功之后,在 assembly/target 目录可以看到打包好的压缩文件。 在 Idea 中运行代码 activemq-console 在 Idea 中运行代码 activemq-console,启动 activemq: 1、在 idea 中打开项目 ...

2024-08-09 · 2 min · 732 words · chensoul

ActiveMQ安装和使用

ActiveMQ 是一个实现了 JMS 协议的开源消息中间件,目前它有两种版本:ActiveMQ “Classic” 和 ActiveMQ Artemis。 Artemis 版本作为Classic版本的替代品而诞生,相较的提升点有: 高性能与低延迟:Artemis通过改进的设计实现了更高的吞吐量和更低的消息处理延迟。 ...

2024-07-05 · 9 min · 4290 words · chensoul