【发布时间】:2014-11-27 02:25:57
【问题描述】:
我在 AWS 中有一个 rabbitmq 集群设置。两台机器都是 ha-all,镜像队列,它们位于 ELB 后面。队列名称 hips.preprod.queue 有一个 springamqp 消费者。 springamqp 版本是 3.3.4。
消费者直接连接到 ELB 而不是主机。当消费者连接到兔子集群时,会创建一个连接。但是一段时间后,我在同一 IP 但在不同的套接字上看到更多的兔子连接。奇怪的是,连接选项卡下的一些客户端显示版本是 3.2.4,而其他客户端是 3.3.4。我还检查了消费者的类路径,但找不到任何 3.2.4 amqp jar。我完全不知道如何拥有不同版本的相同客户端。有没有人经历过类似的事情。
以下是“连接”选项卡中的数据
Network Overview
Name Protocol Client Node From client To client Timeout Channels Virtual host User name State
10.161.2.178:27238 AMQP 0-9-1 RabbitMQ / Java3.3.4 rabbit@infopush-rabbit2 17B/s(37kB total) 8B/s(24kB total) 1s 1 /INFOPUSH
running
10.161.2.178:27312 AMQP 0-9-1 RabbitMQ / Java3.2.4 rabbit@infopush-rabbit2 1B/s(2.4kB total) 1B/s(1.2kB total) 25s 1 /INFOPUSH
running
10.161.2.178:27711 AMQP 0-9-1 RabbitMQ / Java3.3.4 rabbit@infopush-rabbit2 17B/s(20kB total) 9B/s(10kB total) 1s 1 /INFOPUSH
running
10.161.2.178:28833 AMQP 0-9-1 RabbitMQ / Java3.2.4 rabbit@infopush-rabbit1 1B/s(2.8kB total) 0B/s(1.4kB total) 25s 1 /INFOPUSH
running
10.161.2.178:29093 AMQP 0-9-1 RabbitMQ / Java3.2.4 rabbit@infopush-rabbit1 0B/s(2.5kB total) 0B/s(1.2kB total) 25s 1 /INFOPUSH
running
10.161.2.178:29692 AMQP 0-9-1 RabbitMQ / Java3.3.4 rabbit@infopush-rabbit1 16B/s(15kB total) 9B/s(7.9kB total) 1s 3 /INFOPUSH
running
10.161.2.92:10032 AMQP 0-9-1 RabbitMQ / Java3.2.4 rabbit@infopush-rabbit2 1B/s(1.7kB total) 0B/s(857B total) 25s 1 /INFOPUSH
running
10.161.2.92:56573 AMQP 0-9-1 RabbitMQ / Java3.3.4 rabbit@infopush-rabbit1 17B/s(40kB total) 8B/s(21kB total) 1s 4 /INFOPUSH
running
10.161.2.92:56703 AMQP 0-9-1 RabbitMQ / Java3.2.4 rabbit@infopush-rabbit1 1B/s(1.7kB total) 0B/s(1.1kB total) 25s 1 /INFOPUSH
running
10.161.2.92:9352 AMQP 0-9-1 RabbitMQ / Java3.3.4 rabbit@infopush-rabbit2 17B/s(46kB total) 9B/s(29kB total) 1s 5 /INFOPUSH
running
10.161.2.92:9506 AMQP 0-9-1 RabbitMQ / Java3.2.4 rabbit@infopush-rabbit2 1B/s(2.5kB total) 0B/s(1.2kB total) 25s 1 /INFOPUSH
running
谢谢 -帕舒
【问题讨论】:
-
这很奇怪。我会尽量确保所有使用 rabbit 的应用程序的库都是最新的
标签: amazon-web-services rabbitmq java-8 amazon-elb spring-amqp