简单的 Java AMQP 服务器

Question

是否有任何用 Java 编写的简单 AMQP 服务器/代理实现？

我需要用它进行本地集成测试。我想从ant/maven启动，不需要任何集群、持久化、性能等功能。只是一个类似 RabbitMQ 的模拟实例，无需安装（就像 maven pom 中的依赖项）和配置。

Answer 1

我想说，编写测试整个应用程序的集成测试/端到端测试/自动用户验收测试是完全合法的，包括在 MQ 中完成的所有操作。您应该明智地选择引发此类事件的测试用例，因为它会大大减慢测试的反馈循环。

有 org.apache.qpid，您可以将其简单地包含在您的应用程序作为 mvn/gradle (mvncentral) 依赖项（gradle 示例)：

testCompile 'org.apache.qpid:qpid-broker:6.0.1'

然后添加一个包含 ExternalResource 的 Rule，该规则在测试之前启动代理，有点类似于这个相当简单的设置：

@Rule
private static final ExternalResource embeddedAMQPBroker = new ExternalResource() {
    Broker broker;

    @Override
    protected void before() throws Throwable {
        BrokerOptions brokerOptions = new BrokerOptions();
        brokerOptions.setConfigProperty("qpid.amqp_port", "55672");
        broker = new Broker();
        broker.startup(brokerOptions);
    }

    @Override
    protected void after() {
        broker.shutdown();
    }
};

未经测试，因为对我来说这不起作用，因为我的所有应用程序都包含 Jetty 9 并且 QPID（仍然）需要 Jetty<9。

Answer 2

您正在寻找的是 AMQP 模拟对象。我真的不知道，并且怀疑您是否会找到现成的。
如果您使用 JUnit 作为测试，那么您正在执行 UNIT 测试。单元测试与集成测试不同，不包括实际读取/写入队列。
也许在这里您可以重组您的测试甚至代码以包含除队列读/写之外的所有内容？
另一种选择是，如果您已将 AMQP 包装到其他类中以实现可移植性，那么只需模拟该对象即可。

Answer 3

在 2016 年发布我的答案后，最近一个新选项引起了我的注意：

RabbitMQ Mock (https://github.com/fridujo/rabbitmq-mock）项目达到了确切的目的，并且重量轻得多。它仍然是一个非常年轻的项目（2018 年 5 月才开始），但我自己能够使用它进行集成测试。

为了验证模拟是否像“真实的东西”一样工作，我首先针对 RabbitMQ 实例运行我的代码，然后切换到模拟。