MQ概述：MessageQueue(消息队列)，实在消息的传输过程中保存消息的容器，都用于分布式系统之间进行通信分布式系统通信的两种方式：直接远程调用和借助第三昂完成间接通信发送方称谓生产者，接收方称为消费者MQ优势和劣势优势：应用解耦：如把一个系统的不同功能拆分出来，中间连接mq，那么其中一个功能的系统挂掉也不会影响其它系统，达到解耦异步提速：如一个订单接受下单请求，正常需要去库存，支付，物流三个系统走一遍，但是可以通过直接交手mq然后直接返回，那三个系统用mq去排队进行操作，大大缩短等待时间，增加系统吞吐量削峰填谷劣势：系统可用性降低系统复杂性提高一致性问题RabbitMQ时基于AMQP(

目录一、数据同步1.1、什么是数据同步1.2、解决数据同步面临的问题1.3、解决办法1.3.1、同步调用1.3.2、异步通知（推荐）1.3.3、监听binlog1.3、基于RabbitMQ实现数据同步1.3.1、需求1.3.2、在“酒店搜索服务”中声明exchange、queue、routingKey，同时开启监听1.3.3、在“酒店管理服务”中发布消息1.3.4、启动微服务并测试一、数据同步1.1、什么是数据同步我们知道elasticsearch的数据是来源于数据库（比如mysql）. 当我们在写了代码将mysql中的数据导入es中，那么这次导入之后mysql的数据并不会一成不变，将来我们的

📢📢📢📣📣📣哈喽！大家好，我是【一心同学】，一位上进心十足的【Java领域博主】！😜😜😜✨【一心同学】的写作风格：喜欢用【通俗易懂】的文笔去讲解每一个知识点，而不喜欢用【高大上】的官方陈述。q✨【一心同学】博客的领域是【面向后端技术】的学习，未来会持续更新更多的【后端技术】以及【学习心得】。✨如果有对【后端技术】感兴趣的【小可爱】，欢迎关注【一心同学】💞💞💞❤️❤️❤️感谢各位大可爱小可爱！❤️❤️❤️ 目录一、MQ是什么？二、MQ的使用场景2.1异步处理🚀易错概念讲解🌴传统的做法🌵使用消息队列2.2应用解耦🌴传统做法🌵使用消息队列2.3流量削锋2.4日志处理2.5消息通讯三、使用MQ的好处四

概述RabbitMQ的消息确认有两种。一种是消息发送确认。这种是用来确认生产者将消息发送给交换器，交换器传递给队列的过程中，消息是否成功投递。发送确认分为两步，一是确认是否到达交换器，二是确认是否到达队列。第二种是消费接收确认。这种是确认消费者是否成功消费了队列中的消息。详细一、运行效果二、实现过程①、引入rabbitmq包org.springframework.bootspring-boot-starter-amqp②、修改application.properties配置spring.rabbitmq.host=127.0.0.1spring.rabbitmq.port=5672spring

一、消息中间件RabbitMQ---概述和概念【一】1、概述1、大多应用中，可通过消息服务中间件来提升系统异步通信、扩展解耦能力2、消息服务中两个重要概念：消息代理（messagebroker）和目的地（destination）当消息发送者发送消息以后，将由消息代理接管，消息代理保证消息传递到指定目的地。3、消息队列主要有两种形式的目的地队列（queue）：点对点消息通信（point-to-point）主题（topic）：发布（publish）/订阅（subscribe）消息通信4、点对点式：消息发送者发送消息，消息代理将其放入一个队列中，消息接收者从队列中获取消息内容，消息读取后被移出队列消

介绍RabbitMQ是实现AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。RabbitMQ主要是为了实现系统之间的双向解耦而实现的。当生产者大量产生数据时，消费者无法快速消费，那么需要一个中间层。保存这个数据。AMQP，即AdvancedMessageQueuingProtocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可

1.消息队列1.1.MQ的相关概念1.1.1.什么是MQMQ(messagequeue)，从字面意思上看，本质是个队列，FIFO先入先出，只不过队列中存放的内容是message而已，还是一种跨进程的通信机制，用于上下游传递消息。在互联网架构中，MQ是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。使用了MQ之后，消息发送上游只需要依赖MQ，不用依赖其他服务。1.1.2.为什么要用MQ1.流量消峰举个例子，如果订单系统最多能处理一万次订单，这个处理能力应付正常时段的下单时绰绰有余，正常时段我们下单一秒后就能返回结果。但是在高峰期，如果有两万次下单操作系统是处理不了的，只能限制订单超过一

目录基本概念 MQ的优势 1.应用解耦 2.异步提速 3.削峰填谷 MQ的劣势使用mq的条件 常见MQ产品 RabbitMQ简介RabbitMQ的六种工作模式  JMSRabbitMQ安装和配置。RabbitMQ控制台使用。RabbitMQ快速入门——生产者需求:RabbitMQ快速入门——消费者小结 基本概念 多个系统之间的通信方式有两种，一是直接远程调用，二是通过第三方，mq就是这个第三方MQ的优势 1.应用解耦一个好的系统肯定会要求高内聚低耦合。像下面这个，订单系统发个订单到库存时，如果库存系统损坏了可能会连带影响订单系统。有了mq之后，消息存放在mq里面，哪怕库存坏了几分钟，好了之后也

java.lang.OutOfMemoryError:Javaheapspace 解决方法这个问题的根源是jvm虚拟机的默认Heap大小是64M,可以通过设置其最大和最小值来实现.设置的方法主要是几个.1.可以在windows更改系统环境变量加上JAVA_OPTS=-Xms64m-Xmx512m2.如果是linux系统Linux在{tomcat_home}/bin/catalina.sh的前面，加setJAVA_OPTS='-Xms64-Xmx512'

WorkQueues1.轮询分发消息1.1抽取工具类1.2启动两个工作线程1.3启动一个发送线程1.4结果展示2.消息应答2.1概念2.2自动应答2.3消息应答的方法2.4Multiple的解释2.5消息自动重新入队2.6消息手动应答代码2.7手动应答效果演示3.RabbitMQ持久化3.1概念3.2队列如何实现持久化3.3消息实现持久化3.4不公平分发3.5预期值工作队列（又称任务队列）的主要思想是避免立即执行资源密集型任务，而不得不等待它完成。相反我们安排任务在之后执行。我们把任务封装为消息并将其发送到队列。在后台运行的工作进程将弹出任务并最终执行作业。当有多个工作线程时，这些工作线程将一