原生mq消费spring-boot-mq

原生MQ（消息队列）消费是指直接在Spring Boot应用中集成MQ服务，通过Spring Boot提供的支持来处理来自消息队列的消息。这通常涉及到以下几个步骤：

1. **添加依赖**：首先，在Spring Boot项目的pom.xml文件中添加MQ客户端库的依赖，如RabbitMQ、Apache Kafka或Redis等。

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId> <!-- 如果使用RabbitMQ -->
    <!-- 或者其他MQ的相关starter，如 spring-boot-starter-kafka -->
</dependency>

2. **配置连接信息**：在application.yml或application.properties中配置MQ的连接地址、用户名、密码等基本信息。

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

3. **创建消费者组件**：创建一个实现了`MessageListener`或对应MQ API的Java类，这个类将负责接收并处理消息。

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;

@RabbitListener(queues = "myQueue")
public void consumeMessage(Message message) {
    String content = new String(message.getBody(), StandardCharsets.UTF_8);
    // 处理接收到的消息
}

4. **启动监听器**：在Spring Boot的启动类上使用`@EnableAutoConfiguration`启用自动配置，或手动配置`MessageConverter`和`ConcurrentTaskScheduler`。

@SpringBootApplication
@EnableAutoConfiguration
public class App {
    public static void main(String[] args) {
        SpringApplication.run(App.class, args);
    }
}