java - 从另一个进程连接到嵌入式 AMQ

Question

我有一个使用 ActiveMQ 代理的应用程序。为了进行一些集成测试，我创建了另一个将消息放入队列的工具。我想要实现的是避免使用物理 ActiveMQ，而是在启动应用程序的同时初始化 AMQ，然后连接我的工具，将消息加载到该队列中，最后关闭所有连接。当我像 vm://localhost 这样启动 AMQ 传输时，我可以使用相同的进程(单元测试)执行类似的操作，但当我想从另一个进程连接以将 sht 放入队列时，它不起作用。有人遇到过类似的问题吗？

Answer 1

虚拟机传输无法在启动它的 JVM 之外进行通信。结合peer使用 vm 进行传输允许嵌入式代理通过 discovery 发现远程代理网络(多播、jgroups 等)，但这似乎有点过头了，为了简单起见，建议使用 tcp。

//create embedded broker using tcp
BrokerService broker = new BrokerService();
broker.addConnector("tcp://localhost:61616");
broker.start();

//remote client use tcp to connect, but local JVM client can use vm
vm:broker:(tcp://localhost:61616)