rabbitmq在spring里面的实例使用

在Spring中使用RabbitMQ需要先引入相应的依赖，然后配置连接工厂、交换机、队列等信息，最后编写相应的发送和接收消息的代码。

具体步骤如下：

1. 引入依赖

在pom.xml文件中添加如下依赖：

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

2. 配置连接工厂

在配置文件中添加RabbitMQ的连接信息：

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

3. 配置交换机和队列

在Java代码中通过注入AmqpAdmin对象进行交换机和队列的声明，如下所示：

@Autowired
private AmqpAdmin amqpAdmin;

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

@Bean
public DirectExchange exchange() {
    return new DirectExchange("test.exchange");
}

@Bean
public Binding binding() {
    return BindingBuilder.bind(queue()).to(exchange()).with("test.key");
}

4. 编写发送消息的代码

使用RabbitTemplate对象发送消息，如下所示：

@Autowired
private RabbitTemplate rabbitTemplate;

public void send() {
    String message = "hello";
    rabbitTemplate.convertAndSend("test.exchange", "test.key", message);
}

5. 编写接收消息的代码

使用@RabbitListener注解监听队列并处理接收到的消息，如下所示：

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

以上就是在Spring中使用RabbitMQ的简单示例。