为什么要顺序消费保证消息的顺序消费是生产业务场景下经常面临的挑战,例如电商的下单逻辑,在用户下单之后,会发送创建订单和扣减库存的消息,我们需要保证扣减库存在创建订单之后执行。处理业务逻辑后,向MQ发送一......
2023-10-11 21:20 阅读 阅读全文文章浏览阅读10w+次,点赞10次,收藏78次。消息中间件的技术选型心得-RabbitMQ、ActiveMQ和ZeroMQ作者:chszs,转载需注明。博客主页:http://blog.csdn.net/chszsRabbitMQ、ActiveMQ和ZeroMQ都是极好的消息中间件,但是我们在项目中该选择哪个......
2024-01-23 13:30 阅读 阅读全文文章浏览阅读2.2k次,点赞4次,收藏4次。RabbitMQ简介在介绍RabbitMQ之前实现要介绍一下MQ,MQ是什么?MQ全称是Message Queue,可以理解为消息队列的意思,简单来说就是消息以管道的方式进行传递。RabbitMQ是一个实现了AMQP(Advanced Mess......
2024-01-24 06:49 阅读 阅读全文文章浏览阅读170次。RabbitMQ 其他知识点幂等性概念用户对于同一操作发起的一次请求或者多次请求的结果是一致的,不会因为多次点击而产生了副作用。举个最简单的例子,那就是支付,用户购买商品后支付,支付扣款成功,但......
2024-01-24 00:06 阅读 阅读全文文章浏览阅读378次。1. RabbitMQ1.1. 现实问题目前我们已经完成了商品和搜索系统的开发。我们思考一下,是否存在问题?商品的原始数据保存在数据库中,增删改查都在数据库中完成。搜索服务数据来源是索引库,如果数据库商......
2024-01-25 06:29 阅读 阅读全文文章浏览阅读288次。4、Linux Rabbitmq 安装4.0 安装说明4.0.2 安装步骤(1) 先安装erlang(2) 安装rabbitmq4.0.2 版本说明erlang 与 rabbitmq 版本必须相对应,否则会出现安装异常,具体版本搭配 如下地址:https://www.rabbitmq.com/which-erlang.html4.1 开......
2023-11-11 17:34 阅读 阅读全文文章浏览阅读1.4k次。import threadingimport pika# 处理消息def callback(ch, method, properties, body): print(" [x] Received %r" % body) # channel.basic_ack(delivery_tag=method.delivery_tag) # 取出之后即删除def consume(): credentials = pika.PlainCredentials('guest......
2024-01-24 13:19 阅读 阅读全文前言**为什么引入消息队列?**引入 MQ 给我们解决了一些问题,但同时又引入了一些复杂的问题,这些问题是大型项目中必须解决的重点,更重要的是,面试也经常问。实际上消息队列可以说是没法百分之百保证可靠性的!RabbitM......
2023-10-11 21:20 阅读 阅读全文文章浏览阅读3.7w次,点赞4次,收藏10次。前言在Redis秒杀功能设计与实现一篇中,我们使用redis实现了商品的秒杀抢购功能,在当前的设计中,只涉及到商品抢购,即用户锁定名额,并将成功抢购到的用户信息保存到redis中了但......
2024-01-21 13:06 阅读 阅读全文文章浏览阅读944次,点赞2次,收藏8次。为什么使用MQ?MQ的优点简答 异步处理 - 相比于传统的串行、并行方式,提高了系统吞吐量。 应用解耦 - 系统间通过消息通信,不用关心其他系统的处理。 流量削锋 - 可以通过消息队......
2024-01-23 18:37 阅读 阅读全文