在嵌入式Qpid Broker中创建Exchange与队列的问题排查

从你的描述来看，核心问题是Spring Rabbit的XML配置没有在嵌入式Qpid Broker中成功创建队列/交换机，导致报错Queue: 'push.customer.arkona.controller.search' not found。这主要是因为Qpid Broker的初始化逻辑和Spring Rabbit的声明机制需要正确配合，下面是具体的解决方案：

一、直接在Qpid Broker初始化配置中定义队列与交换机（最可靠方式） #

Qpid Broker支持通过虚拟主机的初始配置文件直接创建队列、交换机和绑定，这种方式是Broker层面的创建，启动后就会存在，不需要依赖Spring的声明逻辑。

1. 创建虚拟主机配置文件：在src/main/resources下新建virtualhost-config.json，把你需要的队列、交换机和绑定都定义进去，示例如下：

{
  "name": "default",
  "queues": [
    {
      "name": "push.customer.arkona.controller.search",
      "durable": true,
      "autoDelete": false
    },
    {
      "name": "pull.appt.arkona.scheduler.adapter",
      "durable": true,
      "autoDelete": false
    },
    {
      "name": "pull.appt.arkona.adapter.processor",
      "durable": true,
      "autoDelete": false
    }
    // 把你需要的其他队列依次添加进来
  ],
  "exchanges": [
    {
      "name": "your-direct-exchange", // 替换成你的交换机名称
      "type": "direct",
      "durable": true,
      "autoDelete": false
    }
    // 可以添加其他类型的交换机，比如topic、fanout等
  ],
  "bindings": [
    {
      "exchange": "your-direct-exchange",
      "queue": "push.customer.arkona.controller.search",
      "bindingKey": "push.customer.key" // 替换成你的绑定键
    }
    // 其他队列与交换机的绑定关系
  ]
}

2. 修改qpid-config.json指向这个配置：
   找到virtualhostnodes中的virtualHostInitialConfiguration配置，修改为：

"virtualHostInitialConfiguration" : "${qpid.home_dir}${file.separator}src${file.separator}main${file.separator}resources${file.separator}virtualhost-config.json"

二、调整Spring配置，确保自动声明生效 #

如果你希望通过Spring Rabbit的配置来声明队列和交换机，需要确保以下几点：

1. 添加RabbitAdmin Bean：
   RabbitAdmin是Spring负责向Broker声明队列、交换机和绑定的核心组件，你的rabbit-context.xml中缺少这个配置，需要添加：

<!-- 关联你的connectionFactory -->
<rabbit:admin connection-factory="rabbitConnectionFactory" />

2. 补全交换机的配置：
   你的rabbit-context.xml中<rabbit:direct标签没有写完，以direct交换机为例，补全配置并添加绑定：

<rabbit:direct-exchange name="your-direct-exchange">
    <rabbit:bindings>
        <rabbit:binding queue="push.customer.arkona.controller.search" key="push.customer.key" />
        <!-- 其他队列的绑定 -->
    </rabbit:bindings>
</rabbit:direct-exchange>

3. 修复ConnectionFactory的用户名密码：
   你的QpidConfig中connectionFactory()用了admin/admin，但password.properties里只有guest:guest，这会导致连接失败，声明逻辑无法执行。修改为：

private ConnectionFactory connectionFactory() {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setUsername("guest");
    factory.setPassword("guest");
    factory.setHost("127.0.0.1");
    factory.setPort(5672);
    return factory;
}

4. 确保Qpid Broker完全启动后再执行Spring声明：
   嵌入式Broker需要一点时间启动，你可以在Broker Bean中添加等待逻辑，确保Broker就绪后Spring才初始化AMQP组件：

@SuppressWarnings("rawtypes")
@Bean Broker broker() throws Exception {
    org.apache.qpid.server.Broker broker = new org.apache.qpid.server.Broker();
    broker.startup(brokerOptions());
    // 等待Broker启动完成，超时时间60秒
    broker.waitUntilStarted(60_000);
    return (Broker) broker;
}

三、验证步骤 #

1. 启动应用前，检查qpid-config.json和virtualhost-config.json的路径是否正确。
2. 启动后，查看Qpid Broker的日志，确认队列和交换机是否成功创建。
3. 测试消息发送与接收，确认不再出现队列找不到的错误。

内容的提问来源于stack exchange，提问作者vipulk10