Rabbitmq入门与应用(三)-RabbitMQ开发流程-Toy模板网

这篇具有很好参考价值的文章主要介绍了Rabbitmq入门与应用(三)-RabbitMQ开发流程。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

RabbitMQ开发流程

引入依赖

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

配置MQ

最简配置

spring:
  rabbitmq:
    host: mq的安装机器ip
    port: 5672
    username: admin
    password: 123

创建队列

在配置类中创建队列对象。

@Configuration
public class SimpleQueueConfig {

    @Bean
    public Queue queue(){
        
    }
}

生产者

private RabbitTemplate rabbitTemplate; //rabbitmq操作对象
convertAndSend : 发送方法

Rabbitmq入门与应用(三)-RabbitMQ开发流程,rabbitmq,rabbitmq,分布式,java

if (m > 0) {
        Long maotai = stringRedisTemplate.opsForValue()
                .decrement("maotai");//原子性redis操作

        log.debug("抢购茅台一瓶，还剩:{}瓶", maotai);
         s1 =System.currentTimeMillis();
        //操作数据库修改数据
       rabbitTemplate.convertAndSend("hello_queue",1);
        s2 =System.currentTimeMillis();
       log.debug("耗时:{}ms",(s2-s1));

        return HttpResp.success("去库存成功:"+(s2-s1));
    } else {
        return HttpResp.failed("0");
    }

消费者

@RabbitListener(queues = “要监听的队列名称”)
@RabbitHandler //要使用RabbitMQ处理的方法

Rabbitmq入门与应用(三)-RabbitMQ开发流程,rabbitmq,rabbitmq,分布式,java 文章来源地址https://www.toymoban.com/news/detail-831365.html

@RabbitListener(queues = "hello_queue")
@Override
public void updateByBookIdMq(Long bookId) throws InterruptedException {
    LambdaQueryWrapper<Store>
            queryWrapper = new LambdaQueryWrapper<>();
    queryWrapper.eq(Store::getBook, bookId);
    Store store = storeDao.selectOne(queryWrapper);
    if (store.getNum() > 0) {
        int left = store.getNum() - 1;
        Thread.sleep(50);
        store.setNum(left);
        storeDao.updateById(store);
        log.debug("数据库修改数据完成,库存量:{}", left);
    }
}