1

我第一次尝试 RabbitMQ 并决定使用 Spring AMQP 包装器。我打算先测试写入性能并将发送者设置到队列中：

弹簧设置：

<rabbit:connection-factory id="connectionFactory" host="localhost" 
                           username="guest" password="guest" />

<rabbit:admin connection-factory="connectionFactory" />

<rabbit:template id="myTemplate" connection-factory="connectionFactory"
                 exchange="myQueue"/>

发件人主要：

    ApplicationContext context = new ClassPathXmlApplicationContext(
                                             "th/rabbit-sender-context.xml");
    AmqpTemplate aTemplate = (AmqpTemplate) context.getBean("myTemplate");

    int total = 1000;
    for (int i = 0; i < total; i++) {
        System.out.println(i);
        aTemplate.convertAndSend("my.routingkey.1", "#"+i+" on "+new Date());
    }

但是，在发送 15 条消息后，客户端失败并出现以下异常：

Caused by: com.rabbitmq.client.AlreadyClosedException: clean connection shutdown; reason: Attempt to use closed channel
at com.rabbitmq.client.impl.AMQChannel.ensureIsOpen(AMQChannel.java:190)
at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:291)
at com.rabbitmq.client.impl.ChannelN.basicPublish(ChannelN.java:636)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:365)
at com.sun.proxy.$Proxy4.basicPublish(Unknown Source)
at org.springframework.amqp.rabbit.core.RabbitTemplate.doSend(RabbitTemplate.java:675)
at org.springframework.amqp.rabbit.core.RabbitTemplate$1.doInRabbit(RabbitTemplate.java:351)
at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:627)
... 9 more

怎么来的？

4

2 回答 2

1

正如 Diogo 所提到的，通道上的任何无效操作（例如，尝试从不存在的队列中消费）都会导致通道被关闭。一旦通道关闭，它就无法再使用 - 这就是您看到 AlreadyClosedException 的原因。

如果意外的 Channel 或 Connection 关闭是一个问题，您可以使用Lyra等客户端自动为您恢复它们。

于 2014-03-31T05:23:16.237 回答
1

看看你的兔子配置。

您的 amqp 模板“myTemplate”设置为交换“myQueue”.. 可以吗？是否有任何名为“myQueue”的交易所，或者这是您的队列名称？如果没有，请创建一个交换器，然后将该路由键设置为您想要的队列。

如果您设置了无效的 Exchange，则不会为您的模板打开/获取任何通道，从而导致 AlreadyClosedException。

于 2014-03-24T02:25:39.770 回答