springboot2.0集成rabbitmq的示例代码

以下是详细讲解Spring Boot 2.0集成RabbitMQ的示例代码的完整攻略，包含两个示例说明。

示例1：发送和接收简单的消息

步骤1：添加依赖

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

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

步骤2：配置RabbitMQ连接

在您的Spring Boot项目中，您需要配置RabbitMQ连接。以下是一个简单的示例：

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

步骤3：发送消息

在您的Spring Boot项目中，您需要使用RabbitTemplate发送消息。以下是一个简单的示例：

@Autowired
private RabbitTemplate rabbitTemplate;

public void sendMessage(String message) {
    rabbitTemplate.convertAndSend("my_exchange", "my_routing_key", message);
}

步骤4：接收消息

在您的Spring Boot项目中，您需要使用@RabbitListener注解接收消息。以下是一个简单的示例：

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

示例2：发送和接收复杂的消息

步骤1：添加依赖

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

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
</dependency>

步骤2：配置RabbitMQ连接

在您的Spring Boot项目中，您需要配置RabbitMQ连接。以下是一个简单的示例：

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

步骤3：定义消息类

在您的Spring Boot项目中，您需要定义消息类。以下是一个简单的示例：

public class MyMessage {
    private String name;
    private int age;

    // getters and setters
}

步骤4：发送消息

在您的Spring Boot项目中，您需要使用RabbitTemplate发送消息。以下是一个简单的示例：

@Autowired
private RabbitTemplate rabbitTemplate;

public void sendMessage(MyMessage message) {
    rabbitTemplate.convertAndSend("my_exchange", "my_routing_key", message);
}

步骤5：接收消息

在您的Spring Boot项目中，您需要使用@RabbitListener注解接收消息。以下是一个简单的示例：

@RabbitListener(queues = "my_queue")
public void receiveMessage(MyMessage message) {
    System.out.println("Received message: " + message.getName() + ", " + message.getAge());
}

注意，您需要在您的Spring Boot项目中配置Jackson2JsonMessageConverter，以便正确地序列化和反序列化消息。以下是一个简单的示例：

@Bean
public MessageConverter messageConverter() {
    return new Jackson2JsonMessageConverter();
}

@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, MessageConverter messageConverter) {
    RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
    rabbitTemplate.setMessageConverter(messageConverter);
    return rabbitTemplate;
}

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory, MessageConverter messageConverter) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setMessageConverter(messageConverter);
    return factory;
}

总结

Spring Boot 2.0集成RabbitMQ非常简单。您只需要添加依赖，配置RabbitMQ连接，定义消息类，然后使用RabbitTemplate发送和接收消息即可。如果您需要发送和接收复杂的消息，您需要配置Jackson2JsonMessageConverter以便正确地序列化和反序列化消息。