mq的作用主要是用来解耦,削峰,异步, 增加MQ,系统的复杂性也会增加很多, 也会带来其他的问题,比如MQ挂了怎么办,怎么保持数据的幂等性 幂等性问题通俗点讲就是保证数据不被重复消费,同时数据也不能少, 也就是数据一致性问题。 下面是MQ丢失的3种情况 1,生产者发送消息至MQ的数据丢失 解决方法: ...
分类:
其他好文 时间:
2020-08-04 14:12:11
阅读次数:
86
Apache Kafka 架构和相关概念 Apache Kafka 是一款开源的分布式消息引擎系统 消息引擎的同类 ActiveMQ RabbitMQ WebSphere MQ Rocket MQ JMS仅仅是一组 API 协议 消息引擎的作用 削峰填谷 缓冲上下游瞬时突发流量,使其更平滑.特别是对 ...
分类:
Web程序 时间:
2020-07-28 00:19:27
阅读次数:
86
基于分布式异步框架celery 前文已知,celery可以执行异步任务、延时任务、定时任务。 broker:'redis://127.0.0.1:6379/2' # 消息队列(中间件) broker 可以使用Redis、RabbitMQ backend:'redis://127.0.0.1:6379 ...
分类:
其他好文 时间:
2020-07-27 23:58:21
阅读次数:
99
一.消息的可靠投递 在使用RabbitMq的时候,作为消息发送方希望杜绝任何消息丢失或者投递失败的场景。RabbitMQ为我们提供了两种方式用来控制消息的投递可靠性 rabbitMQ 整个消息投递过程为: producer -> rabbitMQ broker -> exchange -> queu ...
分类:
其他好文 时间:
2020-07-27 17:53:27
阅读次数:
116
事件总线 什么是事物 例如:事物 所有看到的一切都是事物,不能看到的也是事物 例如:团队微服务,成员微服务,聚合微服务,网关api,认证中心等等包括类,对象 所有的事件都是事物变化的结果 大家接触事件最早就是在js 或者是c#高级特性。大家对于事件不默认,但是对于事件不是很好理解 什么是事件 事件就 ...
分类:
其他好文 时间:
2020-07-26 01:25:30
阅读次数:
85
RabbitMq保证消息可靠性之确认模式 前提 完成 SpringBoot 整合 RabbitMq 中的Topic通配符模式 一、更改Producer工程的application.yml文件 spring: rabbitmq: host: localhost port: 5672 virtual-h ...
分类:
其他好文 时间:
2020-07-26 01:04:06
阅读次数:
114
RabbitMq保证消息可靠性之回退模式 前提 完成 SpringBoot 整合 RabbitMq 中的Topic通配符模式 一、更改Producer工程的application.yml文件 spring: rabbitmq: host: localhost port: 5672 virtual-h ...
分类:
其他好文 时间:
2020-07-26 01:03:17
阅读次数:
81
RabbitMq高级特性之消费端限流 一丶首先部署SpringBoot框架 完成 SpringBoot 整合 RabbitMq 中的Topic通配符模式 二丶在 resource资源文件夹里application.yml文件中 添加配置 spring: rabbitmq: listener: sim ...
分类:
其他好文 时间:
2020-07-26 01:02:48
阅读次数:
134
RabbitMq高级特性之TTL 存活时间/过期时间 每条消息设置过期时间 整个 Queue 队列设置过期时间 前提 完成 RabbitMq高级特性之消费端限流 一、每条消息设置过期时间 1.更改ProducerTest.java文件 import lombok.extern.slf4j.Slf4j ...
分类:
其他好文 时间:
2020-07-26 01:02:10
阅读次数:
137
RabbitMq高级特性之死信队列 又称 死信交换机 DLX 当消息成为 Dead message 后,会重新发送到另一个交换机,这个交换机就是 DLX 消息成为死信的情况公有三种: 队列消息长度达到限制 消费者拒接消费消息 basicNack/basicReject,并且不把消息重新放回原目标队列 ...
分类:
其他好文 时间:
2020-07-26 01:01:14
阅读次数:
126