1、相关依赖

这里无需指定版本号，让其跟着SpringBoot版本走。本示例使用SpringBoot版本号为2.7.10。

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency><dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>

2、生产者、消费者

创建两个SpringBoot应用，模拟消息生产者与消费者【publisher、consumer】。

2-1生产者

编写配置文件，用户名和密码等自行修改这里虚拟机的名称是上一篇文章中新建的。

server.port=8082
#rabbitmq服务器ip
spring.rabbitmq.host=localhost
#rabbitmq的端口
spring.rabbitmq.port=5672
#用户名
spring.rabbitmq.username=用户名
#密码
spring.rabbitmq.password=密码
#配置虚拟机
spring.rabbitmq.virtual-host=demo

声明交换机、队列并绑定：

@Configuration
public class RabbitMqConfig {@Beanpublic RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory) {RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);rabbitTemplate.setMessageConverter(jackson2JsonMessageConverter());return rabbitTemplate;}@Beanpublic MessageConverter jackson2JsonMessageConverter() {return new Jackson2JsonMessageConverter();}@Beanpublic DirectExchange getExchange(){return new DirectExchange("directExchange",false,false);}@Beanpublic Queue getQueue(){return new Queue("publisher.addUser",true,false,false);}@Beanpublic Binding getBinding(DirectExchange exchange,Queue queue){return BindingBuilder.bind(queue).to(exchange).with("publisher.addUser");}
}

新建User实体类

@Data
public class User {private Long id;private String name;private String desc;
}

在方法中使用RabbitTemplate来发送消息：

public interface PublisherService {/*** 添加用户* @param user 用户信息*/void addUser(User user);}

@RequiredArgsConstructor
@Service
public class PublisherServiceImpl implements PublisherService{private final RabbitTemplate rabbitTemplate;@Overridepublic void addUser(User user) {rabbitTemplate.convertAndSend("directExchange","publisher.addUser",user);}
}

以上需要注意的就是交换机的名称、队列名、routingKey。示例中使用的是直连交换机，routingKey需要和队列名保持一致。不懂的可以查看上一篇文章。

controller:

@RequiredArgsConstructor
@RestController
@RequestMapping("/user")
public class UserController {private final PublisherService publisherService;@PostMapping("/add")public void add(){User user = new User();user.setId(1000L);user.setName("黄忠");user.setDesc("老兵不死，只是逐渐凋零");publisherService.addUser(user);}}

2-2消费者

消费者的配置和生产者一样，不赘述了，直接看代码：

@Service
@Slf4j
public class ConsumerService {@RabbitListener(queues ="publisher.addUser")public void addUser(String userStr){User user = JSONObject.parseObject(userStr,User.class);log.info(user.toString());}
}

@RabbitListener 注解是指定某方法作为消息消费的方法，指定队列名称。@RabbitListener 如果标注在类上，需配合 @RabbitHandler 注解一起使用，根据接受的参数类型进入具体的方法中。