通过spring配置的时候需要启动ActiveMQ吗？

Question

当我尝试使用 spring jms 集成测试 activemq 时，出现连接被拒绝的错误。我需要启动 activemq 服务器还是什么？根据我的理解，当我设置 brokerconnction

时，spring 将拥有启动活动 mq 的所有方法

来源

@SpringBootApplication
@EnableJms
public class Application {
    @Bean
    public DefaultJmsListenerContainerFactory myJmsContainerFactory() {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory());
        return factory;
    }
    @Bean
    public JmsTemplate jmsTemplate(){
        JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setDefaultDestination(new ActiveMQQueue("jms.queue"));
        jmsTemplate.setConnectionFactory(connectionFactory());
        return jmsTemplate;
    }

    @Bean
    public ActiveMQConnectionFactory connectionFactory(){
        ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory("tcp://:61616");
        activeMQConnectionFactory.setBrokerURL("tcp://localhost:61616");
        return activeMQConnectionFactory;
    }
    public static void main(String[] args){
        // Clean out any ActiveMQ data from previous run
        FileSystemUtils.deleteRecursively(new File("activemq-data"));

        // Launch the application
        ConfigurableApplicationContext context = SpringApplication.run(Application.class, args);

        // Send a message
        MessageCreator messageCreator = new MessageCreator() {

            @Override
            public Message createMessage(Session session) throws JMSException {
                return session.createTextMessage("ping!");
            }
        };

        JmsTemplate jmsTemplate = context.getBean(JmsTemplate.class);
        System.out.println("Sending a new message");
        jmsTemplate.send("mailbox-destination", messageCreator);
    }
}

错误

Exception in thread "main" org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused
    at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:316)
    at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:169)
    at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:497)
    at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:580)
    at org.blanc.whiteboard.jms.Application.main(Application.java:67)
Caused by: javax.jms.JMSException: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused

Answer 1

如果您使用 vm://localhost URL，将在 vm 传输上启动内存代理；如果你使用 tcp://... url 你需要启动一个外部代理，或者添加一个代理 bean 到你的应用程序。

通过spring配置的时候需要启动ActiveMQ吗？

Do we need to start ActiveMQ when configuring through spring?

activemq

spring-jms

来源

错误