RabbitMQ embedded broker不是从Spring Boot应用程序启动的

Question

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

 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[dispatcherServlet]的servlet.Service（）引发异常[请求处理失败；嵌套异常为org.SpringFramework.Messaging.MessagingException：java.net.ConnectException：connect；嵌套异常为org.SpringFramework.Amqp.AmqpConnectException：java.net.ConnectException：connect]并带有根本原因[请求处理失败；嵌套异常为org.SpringFramework.Messaging.MessagingException：connect

java.net.ConnectException：连接被拒绝：连接在java.net.DualStackPlainsockeTimpl.WaitForConnect（本机方法）~[NA:1.8.0_25]在java.net.DualStackPlainsockeTimpl.java:85)~[NA:1.8.0_25]在java.net.AbstractPlainsockeTimpl.doConnect(AbstractPlainsockeTimpl.345)~[NA:1.8.0_25]在

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

Answer 1

没有所谓的“嵌入式RabbitMQ经纪人”。

您必须分别安装和启动它。它不是用Java写的，而是Erlang。

是什么让你相信Boot嵌入了一个经纪人？