RabbitMQ消费者错误消息



我的RabbitMQ服务器运行良好。查看下面的端口和ip。

C:Usersparmarc>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。属性文件:

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。属性文件:

#######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

有谁能指出消费者设置有什么问题吗?我试着用谷歌搜索,但没有找到满意的答案,解决了我的问题。所以在这里问

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

制表符属性文件

mq-Config中有127.0.0.1后。属性文件:

服务器。host = 127.0.0.1#制表符在这里

因此无法连接。我猜rabbitMQ没有从属性文件中修剪东西。所以,即使你的值后面有一个空格,它的行为也会出乎意料。

我删除了制表符

服务器。host = 127.0.0.1

最新更新