SpringBoot整合RabbitMQ及原理

更新時間：2023年06月27日 11:32:32 作者：LoneWalker、

這篇文章主要介紹了SpringBoot整合RabbitMQ及其原理分析,本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下

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、生產(chǎn)者、消費者

創(chuàng)建兩個SpringBoot應用，模擬消息生產(chǎn)者與消費者【publisher、consumer】。

2-1生產(chǎn)者

編寫配置文件，用戶名和密碼等自行修改這里虛擬機的名稱是上一篇文章中新建的。

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 {
    @Bean
    public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMessageConverter(jackson2JsonMessageConverter());
        return rabbitTemplate;
    }
    @Bean
    public MessageConverter jackson2JsonMessageConverter() {
        return new Jackson2JsonMessageConverter();
    }
    @Bean
    public DirectExchange getExchange(){
        return new DirectExchange("directExchange",false,false);
    }
    @Bean
    public Queue getQueue(){
        return new Queue("publisher.addUser",true,false,false);
    }
    @Bean
    public 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來發(fā)送消息：

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

@RequiredArgsConstructor
@Service
public class PublisherServiceImpl implements PublisherService{
    private final RabbitTemplate rabbitTemplate;
    @Override
    public 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消費者

消費者的配置和生產(chǎn)者一樣，不贅述了，直接看代碼：

@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 注解一起使用，根據(jù)接受的參數(shù)類型進入具體的方法中。