怎么关闭 SpringBoot 项目中的 ActiveMq

要关闭 SpringBoot 项目中的 ActiveMQ，可以在项目的配置文件中设置关闭参数。具体操作步骤如下：

1. 打开项目的配置文件（一般为 application.properties 或 application.yml）。
2. 在配置文件中添加以下参数：

spring.activemq.broker-url=failover:(tcp://localhost:61616)?timeout=3000&startupMaxReconnectAttempts=1
spring.activemq.in-memory=false
spring.activemq.pool.enabled=false
spring.activemq.packages.trust-all=true
spring.activemq.packages.trusted=com.xxx.xxx

其中，第一个参数指定了 ActiveMQ 的连接地址，第二个参数表示是否使用内存模式，第三个参数表示是否启用连接池，第四个参数表示是否信任所有包，第五个参数表示信任的包名。
3. 将第二个参数设置为 true，表示使用内存模式，即不启用 ActiveMQ。
4. 重启项目，ActiveMQ 将不再工作。

相关问题

springboot项目使用activemq

可以使用以下步骤在Spring Boot项目中集成ActiveMQ：

1. 在pom.xml中添加ActiveMQ依赖：

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

2. 在application.properties文件中添加ActiveMQ配置：

spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin

3. 创建一个消息生产者：

import javax.jms.ConnectionFactory;
import javax.jms.Queue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;

@Component
public class MessageProducer {
    
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;
    
    @Autowired
    private Queue queue;
    
    public void send(String message) {
        this.jmsMessagingTemplate.convertAndSend(queue, message);
    }
}

4. 创建一个消息消费者：

import javax.jms.Queue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class MessageConsumer {
    
    @Autowired
    private Queue queue;
    
    @JmsListener(destination = "${spring.activemq.queue-name}")
    public void receive(String message) {
        System.out.println("Received message: " + message);
    }
}

5. 在应用程序中使用消息生产者发送消息：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

@Component
public class MyApp implements CommandLineRunner {
    
    @Autowired
    private MessageProducer messageProducer;
    
    @Override
    public void run(String... args) throws Exception {
        messageProducer.send("Hello, World!");
    }
}

这样就可以在你的Spring Boot应用程序中使用ActiveMQ了。

springboot中 activemq 配置

### Spring Boot 中 ActiveMQ 的配置

为了在 Spring Boot 项目中集成并配置 ActiveMQ，可以遵循以下方法：

#### 添加依赖项
首先，在 `pom.xml` 文件中加入 ActiveMQ 和 JMS API 所需的依赖。这允许应用程序通过 Java Message Service (JMS) 接口与消息代理通信。

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-all</artifactId>
    <version>${activemq.version}</version>
</dependency>

<!-- 如果使用的是嵌入式的 ActiveMQ -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

当添加这些依赖之后，Spring Boot 自动配置机制将会检测到它们的存在，并尝试相应地设置必要的 bean[^2]。

#### 配置文件调整
接着修改项目的 `application.properties` 或者 `application.yml` 来指定连接参数和其他选项给 ActiveMQ 实例。

对于 properties 格式:

spring.jms.pub-sub-domain=false
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin

YAML 版本则如下所示:

spring:
  jms:
    pub-sub-domain: false
  activemq:
    broker-url: tcp://localhost:61616
    user: admin
    password: admin

上述配置指定了一个 TCP 协议下的本地主机上的默认端口号作为 Broker URL；同时也设定了访问凭证为 "admin"[^3]。

#### 编写发送接收逻辑
最后一步是在代码里实现消息生产者和消费者的功能。这里给出简单的例子来展示怎样创建这样的组件。

定义一个用于发送消息的服务类：

@Service
public class ProducerService {

    private final JmsTemplate jmsTemplate;

    public ProducerService(JmsTemplate jmsTemplate){
        this.jmsTemplate = jmsTemplate;
    }

    public void sendMessage(String destination, String message){
        System.out.println("Sending message='{}' to destination={}");
        jmsTemplate.convertAndSend(destination,message);
    }
}

以及相应的监听器用来处理接收到的消息：

@Component
@RequiredArgsConstructor(onConstructor_=@Autowired)
public class ConsumerListener implements SessionAwareMessageListener<TextMessage> {
    
    @Override
    public void onMessage(TextMessage message, Session session)throws JMSException{
        try {
            TextMessage textMsg = (TextMessage)message;
            System.out.println("Received message with content '" +textMsg.getText()+"'");
        } catch (JMSException e) {
            throw new RuntimeException(e);
        }
    }
}

以上就是关于如何在一个基于 Spring Boot 构建的应用程序内完成 ActiveMQ 基础设施搭建的过程概述[^1]。