当业务量上升后，由于mysql对全文检索或模糊查询支持的能力不强，在系统中查询的地方，往往会出现慢sql等，拖累系统其他模块，造成性能低下。 随着ES使用普及率的升高，ES是mysql的一个有效补充。我们可以将数据发送到搜索引擎（如ES）上，由搜索引擎来提供专业的服务。 接下来，就结合工作中实
前言： 在OLTP系统领域，我们在很多业务场景下都会面临事务一致性方面的需求，例如最经典的Bob给Smith转账的案例。传统的企业开发，系统往往是以单体应用形式存在的，也没有横跨多个数据库。我们通常只需借助开发平台中特有数据访问技术和框架（例如Spring、JDBC、http://ADO.NET），结合关系型数
一、消息队列 消息队列的基本需求 消息保序：消息的产生与消费有先后顺序，消息队列需保证消费的有序性。重复消息处理：生产者可能会发送重复消息，需保证消费的幂等性。消息可靠性保证：消息不能丢失，消费失败后，需保证有机制可以重新消费。 消息队列可靠性的保证 生产者丢数据消费者丢
1. 什么是中间件 什么是中间件 我国企业从20世纪80年代开始就逐渐进行信息化建设，由于方法和体系的不成熟，以及企业业务的市场需求的不断变化，一个企业可能同时运行着多个不同的业务系统，这些系统可能基于不同的操作系统、不同的数据库、异构的网络环境。现在的问题是，如何把这
点对点的消息传递中，目的地被称为队列（Queue） 点对点消息传递的特点如下： （1）每个消息只能有一个消费者，类似 1 对 1 的关系，好比个人快递自己领取自己的 （2）消息的生产者和消费者之间 没有时间上的相关性。无论消费者在生产者发送消息的时候是否处于运行状态，消费者都可以提取消息。好
消息队列是什么，或者说什么是消息队列、你用过哪些消息队列，几乎是在求职面试中经常问到的问题，我自己也经常问面试者这个问题，简单说消息队列是一个能先进先出且存储消息的容器。 基本组成部分 基本的消息队列主要有生产者（Producer）、代理（Broker）、消费者（Consumer）组成。 生产者
总结 1.异步处理： 用户注册后，发送“注册邮件”和“注册短信”。用户注册完成后，提交任务到 MQ，发送模块并行获取 MQ 中的任务。 2.系统解耦：比如用注册完成，再加一个发送微信通知。只需要新增发送微信消息模块，从 MQ 中读取任务，发送消息即可。无需改动注册模块的代码，这样注册模块与发
这是去年10月发过的一篇文章，写完之后小问题挺多的，公众号又只能改24个字，于是还是重新改一版。 这是一道很常见的面试题，但是大多数人并不知道怎么回答，这种问题其实可以有很多形式的提问方式，你一定见过而且感觉无从下手： 面对业务急剧增长你怎么处理？ 业务量增长10倍、100倍怎么处理？
MQ 一开始是用来解决通信问题的MQ的异步通信 可以削峰 抵御大量流量异步、解耦、削峰 一、RabbitMQ事务消息1.可以通知服务器开启事务模式2.发送消息 其实消息是先存储在一个临时队列3.提交事务 消息真正的提交到指定队列4.回滚事务 消费者使用事务 autoAck=false
目录前言MQ的适用场景MQ的选择MQ的术语和概念MQ的搭建导航 前言 MQ（Message Queue）消息队列 MQ的适用场景 异步处理 把一些耗时但不阻塞主流程的业务让MQ去做业务处理，提升用户体验 流量削峰填谷 秒杀场景，利用MQ控制流量，一旦超出阈值就丢弃请求或弹出错误页，防止应用被洪峰打死
RocketMQ版本4.6.0，记录自己看源码的过程 Consumer 在消费者启动过程中，会启动MQClientInstance，而MQClientInstance中会启动多个定时任务，其中就包括定时上报消费进度： private void startScheduledTask() { // 省略其它定时任务。。。 // 定时持久化消费进度，默
一、 RabbitMQ交换器 1. Direct案例 DirectExchange 路由策略是将消息队列绑定到 DirectExchange 上，当 一条消息到达DirectExchange 时会被转发到与该条消息 routing key 相同的 Queue 上，例如消息队列名为“hello-queue ”，则 routingkey 为“hello-queue ”的消息会被该消息
目录 1、优化1----复杂流程加MQ 2、什么叫做同步发送消息到RocketMQ？ 3、什么叫做异步发送消息到RocketMQ？ 4、什么叫做发送单向消息到RocketMQ？ 5、优化2---大数据大SQL 5.1、大SQL执行 5.2、如何将完整的订单数据发送到RocketMQ里去？ 总结： 1、优化1----复杂流程加MQ 订单系统仅
Broker Mq的架构描述： Name Server： Name Server可以做为一个集群部署，集群中的各 Name Server 是独立的，节点间无任何同步信息； Name Server 用于管理 Broker 实时配置信息和 Topic queue 的路由配置； Broker与Name Server集群中的所有服务器保持长连接， 并且Broker 每隔30秒向 Name Ser
docker 安装rabbitMQ 1、进入docker hub镜像仓库地址：https://hub.docker.com/ 2、搜索rabbitMq，进入官方的镜像，可以看到以下几种类型的镜像；我们选择带有“mangement”的版本（包含web管理页面）； 3、拉取镜像 docker pull rabbitmq:3.7.7-management 使用：docker images 查看所有镜像
这是一道很常见的面试题，但是大多数人并不知道怎么回答，这种问题其实可以有很多形式的提问方式，你一定见过而且感觉无从下手： 面对业务急剧增长你怎么处理？ 业务量增长10倍、100倍怎么处理？ 你们系统怎么支撑高并发的？ 怎么设计一个高并发系统？ 高并发系统都有什么特点？ ... ... 诸如此类，问
一、背景简介 在系统开发初期，很容易出现这样一种情况：不同业务线上开发人员，因为技术栈和版本时间的影响，在选型的时候会优先使用自己熟悉的，例如MQ中间件常用的：Kafka、Rocket、Rabbit等，这样很容易忽略各个项目之间的组件差异问题； 在系统开发中后期，业务相对稳定之后，通常都会对资源占用
前面我们讲了分布式事务的2PC、3PC , TCC 的原理。这些事务其实都在尽力的模拟数据库的事务，我们可以简单的认为他们是一个同步行的事务。特别是 2PC,3PC 他们完全利用数据库的事务能力，在一阶段开始事务后不进提交会严重影响应用程序的并发性能。TCC 一阶段虽然不会阻塞数据库，但是
消息队列（mq）是什么？ - 知乎 作者：Lowry 链接：https://www.zhihu.com/question/54152397/answer/1802083263 来源：知乎 著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。 我想直击 MQ 的本质，带你来一场更深层次的思考力训练：不仅仅搞清楚 What，同时理解 Why 和 H
目录 1、消息队列 2、Posix消息队列 2.1、消息队列属性 2.2、mq_open()函数 2.3、mq_close()函数 2.4、mq_unlink()函数 2.5、mq_getattr()函数 2.6、mq_setattr()函数 2.7、mq_send()函数 2.8、mq_receive()函数 2.9、my_notify()函数 2.9.1、my_notify()函数的若干规则 2.10、
1 jms:两个应用（消息服务应用接口！），分布系统通信，仅仅是接口，类似webservice调用，很多的实现厂商， 2 消息服务：两个应用之间通信，比如注册用户和发送短信， 3 之前while(true){}进行状态的监听，每隔一段时间，现在是mq通知，后者更好！！！ 4 被动的消息接受，也可以主动！ 5 消息生产者 1 只是一个接口
一、消息队列 什么是消息队列 消息（Message）是指在应用间传送的数据。消息可以非常简单，比如只包含文本字符串，也可以更复杂，可能包含嵌入对象。 消息队列（Message Queue）是一种应用间的通信方式，消息发送后可以立即返回，由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到
双写：新旧数据库在线迁移、数据库在线扩缩容等场景下，可以一边写旧库，一边写到MQ，新库将历史数据消化完后，消费MQ中的数据，在访问低峰，MQ中没有数据或很少数据后，切换到新库，MQ中堆积的数据被消费完后就可以下掉了。写MQ的数据可以靠Canal监听旧库得到。 双写缓冲：MySQL的Innodb中有
一、RabbitMQ出现消息丢失的情况及其解决办法 如图所示，RabbitMQ丢失消息的情况可以发送在任何一个节点。 1.1 生产者没有成功把消息发送到MQ a、丢失的原因：因为网络传输的不稳定性，当生产者在向MQ发送消息的过程中，MQ没有成功接收到消息，但是生产者却以为MQ成功接收到了消息，
下载rocketmq，选择binary 解压后，配置环境变量ROCKETMQ_HOME，变量值是MQ解压路径\MQ文件夹名 cmd命令跳转至MQ解压路径\MQ文件夹名\bin 路径下，执行start mqnamesrv.cmd 新弹出的窗口显示错误: 找不到或无法加载主类 org.apache.rocketmq.namesrv.NamesrvStartup 原因是没有设置好RO
