RabbitMQ 消费者错误消息

Question

我的 RabbitMQ 服务器运行非常完美。检查下面的端口和 ip。

C:\Users\parmarc>netstat -ano | find "5672"
  TCP    0.0.0.0:5672           0.0.0.0:0              LISTENING       2704
  TCP    0.0.0.0:15672          0.0.0.0:0              LISTENING       2704
  TCP    0.0.0.0:55672          0.0.0.0:0              LISTENING       2704
  TCP    127.0.0.1:5672         127.0.0.1:61775        ESTABLISHED     2704
  TCP    127.0.0.1:15672        127.0.0.1:57671        ESTABLISHED     2704
  TCP    127.0.0.1:57671        127.0.0.1:15672        ESTABLISHED     8408
  TCP    127.0.0.1:61775        127.0.0.1:5672         ESTABLISHED     10312
  TCP    [::]:5672              [::]:0                 LISTENING       2704

我不断收到有关消费者的以下错误。我能够将东西推送到 RabbitMQ 中，但由于这个错误而无法使用。

WARN : org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - 
       Consumer raised exception, processing can restart if the connection factory supports it. 
       Exception summary: org.springframework.amqp.AmqpIOException: java.net.UnknownHostException: 127.0.0.1
INFO : org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - 
       Restarting Consumer: tag=[null], channel=null, acknowledgeMode=AUTO 
       local queue size=0

下面是我的mq-Config.properties文件：

server.host=127.0.0.1   
server.port=5672
search.service.vmhost=/
search.service.username=guest
search.service.password=guest


search.service.indexwriter.queue.name=search.service.indexwriter.queue.test
search.service.indexwriter.exchange.name=search.service.indexwriter.exchange.test
search.service.indexwriter.routing.key=search.service.indexwriter.routing.test
numberof.concurrentconsumer=10
max.failure.retry.attempts=3

下面是我的 mq-Config-consumer.properties 文件：

#######Consumer Properties######
retailer.syncservice.consumer.server.host=127.0.0.1
retailer.syncservice.consumer.server.port=5672
retailer.syncservice.consumer.service.vmhost=/
retailer.syncservice.consumer.service.username=guest
retailer.syncservice.consumer.service.password=guest
retailer.syncservice.consumer.queue.name=retailer.syncservice.queue.fanoutqueue.test
retailer.syncservice.consumer.exchange.name=retailer.consumer.direct.exchange.test
retailer.syncservice.consumer.routing.key=retailer.consumer.routingkey.test
numberof.concurrentconsumer=10

任何人都可以提出消费者设置有什么问题吗？我尝试用谷歌搜索但没有找到解决我问题的满意答案。所以在这里问一下。

Answer 1

在同事的帮助下解决了。这真是一个愚蠢的错误。

Tab Character after value in properties file

在mq-Config.properties文件中127.0.0.1之后有一个：

server.host = 127.0.0.1#tab character was here

因此无法连接。我猜 rabbitMQ 不会从属性文件中删除内容。因此，即使在您的值之后有一个 space，它也会出现意外行为。

我删除了制表符。

server.host = 127.0.0.1

之后就成功了。

RabbitMQ 消费者错误消息

RabbitMQ Consumer error message

java

rabbitmq

consumer