右耳菌

在之前的两个测试案例中，都没有交换机，生产者直接发送消息到队列。而一旦引入交换机，消息发送的模式会有很大变化： 可以看到，在订阅模型中，多了一个exchange角色，而且过程...

右耳菌

Work queues，任务模型。简单来说就是让多个消费者绑定到一个队列，共同消费队列中的消息。 当消息处理比较耗时的时候，可能生产消息的速度会远远大于消息的消费速度。长此以...

右耳菌

将来我们开发业务功能的时候，肯定不会在控制台收发消息，而是应该基于编程的方式。由于RabbitMQ采用了AMQP协议，因此它具备跨语言的特性。任何语言只要遵循AMQP协议收发...

右耳菌

1.用户管理 点击Admin选项卡，首先会看到RabbitMQ控制台的用户管理界面： 这里的用户都是RabbitMQ的管理或运维人员。目前只有安装RabbitMQ时添加的it...

右耳菌

1.交换机 我们打开Exchanges选项卡，可以看到已经存在很多交换机： 我们点击任意交换机，即可进入交换机详情页面。仍然会利用控制台中的publish message 发...

右耳菌

RabbitMQ是基于Erlang语言开发的开源消息通信中间件，官网地址： https://www.rabbitmq.com/[https://www.rabbitmq.co...

右耳菌

消息Broker，目前常见的实现方案就是消息队列（MessageQueue），简称为MQ.目比较常见的MQ实现： ActiveMQ RabbitMQ RocketMQ Kaf...

右耳菌

异步调用方式其实就是基于消息通知的方式，一般包含三个角色： 消息发送者：投递消息的人，就是原来的调用方 消息Broker：管理、暂存、转发消息，你可以把它理解成微信服务器 消...

右耳菌

之前说过，我们现在基于OpenFeign的调用都属于是同步调用，那么这种方式存在哪些问题呢？举个例子，我们以一个余额支付功能为例来分析，首先看下整个流程： 目前我们采用的是基...

右耳菌

微服务一旦拆分，必然涉及到服务之间的相互调用，这里我们服务之间调用采用的是基于OpenFeign的调用。这种调用中，调用者发起请求后需要等待服务提供者执行业务返回结果后，才能...

右耳菌

如果觉得有收获，欢迎点赞和评论，更多知识，请点击关注查看我的主页信息哦~

右耳菌

AT模式同样是分阶段提交的事务模型，不过缺弥补了XA模型中资源锁定周期过长的缺陷。 1.Seata的AT模型 基本流程图: 阶段一RM的工作： 注册分支事务 记录undo-l...

右耳菌

Seata支持四种不同的分布式事务解决方案： XA TCC AT SAGA 这里我们以XA模式和AT模式来给大家讲解其实现原理。 本文主要讲解XA XA 规范 是 X/Ope...

右耳菌

还是以我在某站上看过的黑马商城的项目作为例子 参与分布式事务的每一个微服务都需要集成Seata，我们以trade-service为例。 1.引入依赖 为了方便各个微服务集成s...

右耳菌

1.准备数据库表 Seata支持多种存储模式，但考虑到持久化的需要，我们一般选择基于数据库存储。执行课前资料提供的《seata-tc.sql》，导入数据库表： 2. 准备配置...

右耳菌

解决分布式事务的方案有很多，但实现起来都比较复杂，因此我们一般会使用开源的框架来解决分布式事务问题。在众多的开源分布式事务框架中，功能最完善、使用最多的就是阿里巴巴在2019...

右耳菌

下单业务，前端请求首先进入订单服务，创建订单并写入数据库。然后订单服务调用购物车服务和库存服务: 购物车服务负责清理购物车信息 库存服务负责扣减商品库存 由于订单、购物车、商...

右耳菌

查询商品的RT较高（模拟的500ms），从而导致查询购物车的RT也变的很长。这样不仅拖慢了购物车服务，消耗了购物车服务的更多资源，而且用户体验也很差。对于商品服务这种不太健康...

右耳菌

建议方式二 案例 这里我们演示方式二的失败降级处理。 1. 自定义类，实现FallbackFactory，编写对某个FeignClient的fallback逻辑 2. 在hm...

右耳菌

当商品服务出现阻塞或故障时，调用商品服务的购物车服务可能因此而被拖慢，甚至资源耗尽。所以必须限制购物车服务中查询商品这个业务的可用线程数，实现线程隔离。 限流可以降低服务器压...