2016-11-11 2 views
0

私のRabbitMQサーバは完全に動作しています。ポートとIPについては以下を確認してください。RabbitMQコンシューマエラーメッセージ

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ファイルです:

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

誰もがお勧めできます:以下

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ファイルです消費者の設定に何が問題なのですか?私はそれを検索しようとしましたが、私の問題を解決する満足のいく答えは見つかりませんでした。だからここでそれを尋ねる。

答えて

0

私は同僚の助けを借りて解決しました。それは本当にばかげたミスでした。

server.host:プロパティの値が127.0.0.1後でmq-Config.propertiesファイルがありました

提出後

タブ文字 = 127.0.0.1#タブ文字はこちら

そのため、接続できませんでした。私はrabbitMQがプロパティファイルから物事をトリミングしていないと思います。たとえあなたの価値の後にスペースがあっても、それは予期しない動作をします。

タブ文字が削除されました。

server.host = 127.0.0.1

それが働いた後。