SpringBoot中Java消息队列集成

在Spring Boot中集成Java消息队列，通常使用RabbitMQ或Kafka作为消息中间件。下面分别介绍这两种消息队列的集成步骤。

1. RabbitMQ集成

首先，需要在pom.xml文件中添加RabbitMQ的依赖：

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

接下来，配置RabbitMQ连接信息。在application.properties或application.yml文件中添加以下配置：

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

然后，创建一个消息生产者。创建一个Java类，使用RabbitTemplate发送消息：

@Service
public class MessageProducer {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendMessage(String exchange, String routingKey, Object message) {
        rabbitTemplate.convertAndSend(exchange, routingKey, message);
    }
}

接下来，创建一个消息消费者。创建一个Java类，使用@RabbitListener注解监听指定的队列：

@Service
public class MessageConsumer {

    @RabbitListener(queues = "myQueue")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

最后，在主类上添加@EnableRabbit注解，以启用RabbitMQ支持：

@SpringBootApplication
@EnableRabbit
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

2. Kafka集成

首先，需要在pom.xml文件中添加Kafka的依赖：

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

接下来，配置Kafka连接信息。在application.properties或application.yml文件中添加以下配置：

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=myGroup
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

然后，创建一个消息生产者。创建一个Java类，使用KafkaTemplate发送消息：

@Service
public class KafkaMessageProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendMessage(String topic, String message) {
        kafkaTemplate.send(topic, message);
    }
}

接下来，创建一个消息消费者。创建一个Java类，使用@KafkaListener注解监听指定的主题：

@Service
public class KafkaMessageConsumer {

    @KafkaListener(topics = "myTopic")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

最后，在主类上添加@EnableKafka注解，以启用Kafka支持：

@SpringBootApplication
@EnableKafka
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

以上就是在Spring Boot中集成RabbitMQ和Kafka的方法。根据项目需求选择合适的消息队列中间件，并按照上述步骤进行集成。