2017-07-28 15 views
0

私の春の起動アプリケーションは接続タイムアウトエラーをスローし、接続できません。私が見る他の興味深い問題は、春のアプリケーションプロパティで定義された接続タイムアウトプロパティを決して拾わないことです。ここで SpringBootウサギの接続タイムアウトの問題

org.springframework.amqp.AmqpTimeoutException: java.util.concurrent.TimeoutException 
    at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:74) ~[spring-rabbit-1.6.7.RELEASE.jar:na] 
    at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:309) ~[spring-rabbit-1.6.7.RELEASE.jar:na] 
    at org.springframework.amqp.rabbit.connection.CachingConnectionFactory.createConnection(CachingConnectionFactory.java:577) ~[spring-rabbit-1.6.7.RELEASE.jar:na] 
    at org.springframework.amqp.rabbit.core.RabbitTemplate.doExecute(RabbitTemplate.java:1431) ~[spring-rabbit-1.6.7.RELEASE.jar:na] 
    at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:1412) ~[spring-rabbit-1.6.7.RELEASE.jar:na] 
    at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:1388) ~[spring-rabbit-1.6.7.RELEASE.jar:na] 
    at org.springframework.amqp.rabbit.core.RabbitAdmin.getQueueProperties(RabbitAdmin.java:336) ~[spring-rabbit-1.6.7.RELEASE.jar:na] 
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.redeclareElementsIfNecessary(SimpleMessageListenerContainer.java:1123) [spring-rabbit-1.6.7.RELEASE.jar:na] 
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$800(SimpleMessageListenerContainer.java:98) [spring-rabbit-1.6.7.RELEASE.jar:na] 
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1329) [spring-rabbit-1.6.7.RELEASE.jar:na] 
    at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91] 
Caused by: java.util.concurrent.TimeoutException: null 
    at com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:76) ~[amqp-client-3.6.5.jar:na] 
    at com.rabbitmq.utility.BlockingCell.uninterruptibleGet(BlockingCell.java:110) ~[amqp-client-3.6.5.jar:na] 
    at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36) ~[amqp-client-3.6.5.jar:na] 
    at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:366) ~[amqp-client-3.6.5.jar:na] 
    at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:292) ~[amqp-client-3.6.5.jar:na] 
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:824) ~[amqp-client-3.6.5.jar:na] 
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:736) ~[amqp-client-3.6.5.jar:na] 
    at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:293) ~[spring-rabbit-1.6.7.RELEASE.jar:na] 
    ... 9 common frames omitted 

は私のJavaの設定、

@Configuration 
@EnableRabbit 
public class RabbitConfig { 

    private final String exchange; 
    private final String queueName; 


    public RabbitConfig(
      @Value("${exchange.name}") String exchange, 
      @Value("${queue.name}") String queue) { 

     this.exchange= exchange; 
     this.queueName=queue; 
} 

@Bean 
Queue queue() { 
    return new Queue(queueName, true); 
} 

@Bean 
DirectExchange exchange() { 
    return new DirectExchange(queueName); 
} 

@Bean 
Binding binding(Queue queue, DirectExchange exchange) { 
    return BindingBuilder.bind(queue).to(exchange).with(queueName); 
} 

@Bean 
SimpleMessageListenerContainer container(RabbitAdmin admin,CachingConnectionFactory connectionFactory) { 
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(); 
    connectionFactory.setCloseTimeout(10000); 
    container.setQueueNames(queueName); 
    container.setConnectionFactory(connectionFactory); 
    //container.setMessageListener(listenerAdapter); 
    return container; 
} 

// @Bean 
// MessageListenerAdapter listenerAdapter(Receiver receiver) { 
//  return new MessageListenerAdapter(receiver, "receiveMessage"); 
// } 

    @Bean 
    public RabbitAdmin admin(ConnectionFactory connectionFactory) { 
     return new RabbitAdmin(connectionFactory); 
    } 


} 

ですそして、私の春のアプリケーションプロパティは

spring.rabbitmq.host = 127.0.0.1 
spring.rabbitmq.port = 15672 
spring.rabbitmq.username = guest 
spring.rabbitmq.password = guest 

exchange.name=myExchange 
queue.name=myQueue 

spring.rabbitmq.cache.connection.mode=CONNECTION 
spring.rabbitmq.cache.channel.size=50 
spring.rabbitmq.cache.channel.checkout-timeout= 10000 

うさぎがアップして、ポート15672上で127.0.0.1上で実行されている、ように見えるが、アプリは決して接続できません。

+2

を調整します**必ず**のRabbitMQは15672で開い** AMQP **ポートを持っていますか?デフォルトでは、15672はWeb UI(管理コンソール)を表示し、AMQPポートは5672です。単に 'spring.rabbitmq.port'を' 5672'に変更するだけです。 –

+0

ああ、私は自分自身を殺していた。 – Imran

答えて

3

デフォルトでは、AMQPポートは5672です。ポート15672には、Web UI(管理コンソール)が表示されます。デフォルトの設定を使用している場合は、

spring.rabbitmq.port = 5672 

RabbitMQ networking configuration reference