springboot整合rabbitmq的示例代码

以下是“Spring Boot整合RabbitMQ的示例代码”的完整攻略，包含两个示例说明。

简介

在本文中，我们将介绍如何使用Spring Boot框架来整合RabbitMQ。我们将使用spring-boot-starter-amqp依赖项来连接RabbitMQ，并编写一个简单的生产者和消费者示例。

步骤1：添加依赖项

首先，您需要在您的Spring Boot项目中添加以下依赖项：

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

步骤2：配置RabbitMQ连接

在application.properties文件中添加以下配置：

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

步骤3：编写生产者代码

以下是一个简单的Spring Boot RabbitMQ生产者示例：

package com.example.demo;

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class ProducerApplication implements CommandLineRunner {

    @Autowired
    private RabbitTemplate rabbitTemplate;

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

    @Bean
    public Queue queue() {
        return new Queue("hello");
    }

    @Override
    public void run(String... args) throws Exception {
        String message = "Hello World!";
        rabbitTemplate.convertAndSend("hello", message);
        System.out.println("Message sent: " + message);
    }
}

步骤4：编写消费者代码

以下是一个简单的Spring Boot RabbitMQ消费者示例：

package com.example.demo;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class ConsumerApplication {

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

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

示例说明

这两个示例演示了如何使用Spring Boot框架来整合RabbitMQ。生产者将消息发送到名为hello的队列中，而消费者从该队列中接收消息并将其打印到控制台上。在生产者示例中，我们使用了RabbitTemplate来发送消息，而在消费者示例中，我们使用了@RabbitListener注释来接收消息。