模拟消息队列

Question

我的应用程序使用了大量的消息队列连接，这使得我很难在本地运行我的环境。目前，我只是简单地连接到DEV或测试环境，当这些环境中存在问题时，可能会出现问题。

我有什么方法可以为本地开发构建一个假消息队列服务？我想拥有以下一些功能：

• 处理来自多个进程的并发读写
• 可靠的消息消耗(通过可见性超时)
• 保证最多一次交货

这个是可能的吗？

我考虑过的事情包括：-构建一个模拟JMS服务并将其部署到某个地方(或者在VM中运行它)--实现一个模拟服务，它根据传入的消息返回不同的响应

还要别的吗？

Answer 1

您可以使用类似于在您的ActiveMQ中嵌入的单元测试代理来测试应用程序各个部分的行为。

创建嵌入式代理非常简单，您可以根据测试内容调整不同测试的配置。

@Before
public void startBroker() throws Exception {
    brokerService = new BrokerService();
    brokerService.setPersistent(false);
    brokerService.setUseJmx(false);
    brokerService.addConnector("tcp://localhost:0");
    brokerService.start();
    brokerService.waitUntilStarted();

    brokerURI = brokerService.getTransportConnectorByScheme("tcp").getPublishableConnectString();
}