0

我无法在 rabbitmq 代理的“CustomerQ”队列中发送消息。我已经通过 spring boot 将 rabbitmq 代理配置为嵌入式服务器。

 package com.testlab.chapter2;

  import org.springframework.amqp.core.Queue;
  import org.springframework.amqp.rabbit.core.RabbitMessagingTemplate;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.context.annotation.Bean;
  import org.springframework.context.annotation.Lazy;
  import org.springframework.stereotype.Component;



  @Component 
  @Lazy
 class Sender {

  RabbitMessagingTemplate template;

  @Autowired
  Sender(RabbitMessagingTemplate template){
    this.template = template;
  }

  @Bean
  Queue queue() {
    return new Queue("CustomerQ", false);
   }

   public void send(String message){
    System.out.println(template.getRabbitTemplate().getConnectionFactory());

    template.convertAndSend("CustomerQ", message);
    }
  }

 **application.properties file configuration:**

  spring.rabbitmq.host=localhost
  spring.rabbitmq.port=5672
  spring.rabbitmq.username=guest
  spring.rabbitmq.password=guest

当代码尝试将任何消息连接/放入队列时出现以下 错误错误：

Servlet.service() 用于路径 [] 上下文中的 servlet [dispatcherServlet] 引发异常 [请求处理失败；嵌套异常是 org.springframework.messaging.MessagingException: java.net.ConnectException: Connection denied: connect; 嵌套异常是 org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection denied: connect] 根本原因

java.net.ConnectException：连接被拒绝：在 java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85) 处的 java.net.DualStackPlainSocketImpl.waitForConnect(Native Method) ~[na:1.8.0_25] 处连接 ~[na:1.8 .0_25] 在 java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345) ~[na:1.8.0_25] 在 java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[na:1.8.0_25] 在java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) ~[na:1.8.0_25] 在 java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172) ~[na:1.8.0_25] 在 java.net。 SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[na:1.8.0_25] at java.net.Socket.connect(Socket.java:589) ~[na:1.8.0_25]

我会感谢你在这方面的帮助。

4

1 回答 1

4

没有“嵌入式 RabbitMQ 代理”之类的东西。

您必须单独安装和启动它。它不是用 Java 编写的，它是 Erlang。

是什么让您相信 Boot 嵌入了代理？

于 2017-01-21T19:29:37.783 回答