Apache camel、RabbitMQ如何发送消息/对象

Question

我希望有人能在这件事上提供一些帮助。

我正在使用camel rabbitmq，出于测试目的，我试图向队列发送一条消息，我试图在rabbitmq接口中显示该消息，然后也读回它。

谢谢你

====================第二部分

我现在得到的错误如下：

Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; reason: {#method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - cannot redeclare exchange 'rhSearchExchange' in vhost '/' with different type, durable, internal or autodelete value, class-id=40, method-id=10), null, ""}
    at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67)
    at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33)
    at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343)
    at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:216)
    at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118)
    ... 47 more

谢谢

Answer 1

所以我昨天才弄明白，我遇到了和你一样（或者至少类似）的问题。

RabbitMQ URI中的选项必须与创建exchange时使用的选项完全匹配。例如，在我的配置中，我有一个名为tasks的交换，它是一种直接类型，是持久的，并且没有配置为自动删除。注意，rabbitmq camel组件中的autodelete选项的默认值是true。此外，我还希望使用路由键camel获取消息。这意味着我的rabbitmq URI需要看起来像：

rabbitmq:localhost:5672/tasks?username=guest&password=guest&autoDelete=false&routingKey=camel

此外，我希望从一个名为task_queue的现有队列中读取，而不是让rabbitmq骆驼组件声明它自己的队列。因此，我还需要添加一个额外的查询参数，因此我的rabbitmq URI是

rabbitmq:localhost:5672/tasks?username=guest&password=guest&autoDelete=false&routingKey=camel&queue=task_queue

这种配置对我起作用了。下面，我从配置交换和队列并发送一条消息的代码中添加了一些Java代码片段，以及我的骆驼路由配置。

rabbitConnFactory = new ConnectionFactory();
rabbitConnFactory.setHost("localhost");
final Connection conn = rabbitConnFactory.newConnection();
final Channel channel = conn.createChannel();

// declare a direct, durable, non autodelete exchange named 'tasks'    
channel.exchangeDeclare("tasks", "direct", true); 
// declare a durable, non exclusive, non autodelete queue named 'task_queue'
channel.queueDeclare("task_queue", true, false, false, null); 
// bind 'task_queue' to the 'tasks' exchange with the routing key 'camel'
channel.queueBind("task_queue", "tasks", "camel"); 

channel.basicPublish("tasks", "camel", MessageProperties.PERSISTENT_TEXT_PLAIN, "hello, world!".getBytes());

@Override
public void configure() throws Exception {
    from("rabbitmq:localhost:5672/tasks?username=guest&password=guest&autoDelete=false&routingKey=camel&queue=task_queue")
        .to("mock:result");
}

希望这有帮助！