什么是MQ？ 【1】MQ：MessageQueue，消息队列。队列，是一种FIFO先进先出的数据结构。消息由生产者发送到MQ进行排队，然后按原来的顺序交由消息的消费者进行处理。QQ和微信就是典型的MQ。为什么要用MQ（MQ的优点）？ MQ的作用主要有以下三个方面： 【1】异步 例子：快递员发快递，直接到客户家效率会很低。引入菜鸟驿站后，快递员只需要把快递放到菜鸟驿站，就可以继续发其他快递去了。客户再按自己的时间安排去菜鸟驿站取快递。 作用：异步能提高系统的响应速度、吞吐量。 【2】解耦 例子：《ThinkinginJAVA》很经典，但是都是英文，我们看不懂，所以需要编
作者：顾欣Triple是Dubbo3提出的基于HTTP2的开放协议，旨在解决Dubbo2私有协议带来的互通性问题。Triple基于HTTP/2定制自己的流控，支持通过特定的异常通知客户端业务层服务端负载高情况，保护了服务端被大流量击垮，提高系统高可用能力。一、流控反压现状客户端和服务器端在接收数据的时候有一个缓冲区来临时存储数据，但是缓冲区的大小是有限制的，所以有可能会出现缓冲区溢出的情况，HTTP通过流控保护数据溢出丢失风险。1、HTTP/1流控在HTTP/1.1中，流量的控制依赖的是底层TCP协议，在客户端和服务器端建立连接的时候，会使用系统默认的设置来建立缓冲区。在数据进行通信的时候，会
作者：顾欣Triple是Dubbo3提出的基于HTTP2的开放协议，旨在解决Dubbo2私有协议带来的互通性问题。Triple基于HTTP/2定制自己的流控，支持通过特定的异常通知客户端业务层服务端负载高情况，保护了服务端被大流量击垮，提高系统高可用能力。一、流控反压现状客户端和服务器端在接收数据的时候有一个缓冲区来临时存储数据，但是缓冲区的大小是有限制的，所以有可能会出现缓冲区溢出的情况，HTTP通过流控保护数据溢出丢失风险。1、HTTP/1流控在HTTP/1.1中，流量的控制依赖的是底层TCP协议，在客户端和服务器端建立连接的时候，会使用系统默认的设置来建立缓冲区。在数据进行通信的时候，会
MQ概述MQ全称MessageQueue（消息队列），是在消息的传输过程中保存消息的容器。多用于分布式系统之间进行通信。分布式系统之间进行通信：远程调用：各系统间直接通过远程调用的方式；借助第三方完成系统通信：上面A系统用来发送消息的为：生产者B系统用来接收消息的为：消费者MQ为：中间键小结⚫MQ，消息队列，存储消息的中间件⚫分布式系统通信两种方式：直接远程调用和借助第三方完成间接通信⚫发送方称为生产者，接收方称为消费者MQ的优势和劣势优势：⚫应用解耦⚫异步提速⚫削峰填谷劣势：⚫系统可用性降低⚫系统复杂度提高⚫一致性问题优势：1.应用解耦：我们先看一幅图：客户通过订单系统下单；上面的订单系统与
MQ概述MQ全称MessageQueue（消息队列），是在消息的传输过程中保存消息的容器。多用于分布式系统之间进行通信。分布式系统之间进行通信：远程调用：各系统间直接通过远程调用的方式；借助第三方完成系统通信：上面A系统用来发送消息的为：生产者B系统用来接收消息的为：消费者MQ为：中间键小结⚫MQ，消息队列，存储消息的中间件⚫分布式系统通信两种方式：直接远程调用和借助第三方完成间接通信⚫发送方称为生产者，接收方称为消费者MQ的优势和劣势优势：⚫应用解耦⚫异步提速⚫削峰填谷劣势：⚫系统可用性降低⚫系统复杂度提高⚫一致性问题优势：1.应用解耦：我们先看一幅图：客户通过订单系统下单；上面的订单系统与
智能安全辅助驾驶系统STM32——MQ3酒精传感器的应用（HAL库）准备：MQ3酒精传感器一个、STM32开发板（本实验采用F103RCT6，其他型号可参考本文同理设置）一、MQ3酒精传感器的介绍MQ3酒精传感器主要用于酒精检测，其原理是使用的气敏材料是在清洁空气中电导率较低的二氧化锡(SnO2)。当传感器所处环境中存在酒精蒸汽时，传感器的电导率随空气中酒精气体浓度的增加而增大。使用简单的电路即可将电导率的变化转换为与该气体浓度相对应的输出信号。MQ-3气体传感器对酒精的灵敏度高，可以抵抗汽油、烟雾、水蒸气的干扰。这种传感器可检测多种浓度酒精气氛，是一款适合多种应用的低成本传感器。该模块主要特
智能安全辅助驾驶系统STM32——MQ3酒精传感器的应用（HAL库）准备：MQ3酒精传感器一个、STM32开发板（本实验采用F103RCT6，其他型号可参考本文同理设置）一、MQ3酒精传感器的介绍MQ3酒精传感器主要用于酒精检测，其原理是使用的气敏材料是在清洁空气中电导率较低的二氧化锡(SnO2)。当传感器所处环境中存在酒精蒸汽时，传感器的电导率随空气中酒精气体浓度的增加而增大。使用简单的电路即可将电导率的变化转换为与该气体浓度相对应的输出信号。MQ-3气体传感器对酒精的灵敏度高，可以抵抗汽油、烟雾、水蒸气的干扰。这种传感器可检测多种浓度酒精气氛，是一款适合多种应用的低成本传感器。该模块主要特
数据的丢失问题可能出现在生产者、MQ服务器、消费者中，以RabbitMQ和Kafka为例来分析一下。RabbitMQ生产者弄丢了数据生产者将数据发送到RabbitMQ的时候，可能数据就在半路给搞丢了，因为网络问题等都有可能。可以用RabbitMQ提供的事务功能，生产者发送数据之前开启RabbitMQ事务channel.txSelect() ，然后发送消息，如果消息没有成功被RabbitMQ接收到，生产者会收到异常报错，此时就可以回滚事务channel.txRollback() ，然后重试发送消息。如果收到了消息，那么可以提交事务channel.txCommit() 。try{//通过工厂创建连
数据的丢失问题可能出现在生产者、MQ服务器、消费者中，以RabbitMQ和Kafka为例来分析一下。RabbitMQ生产者弄丢了数据生产者将数据发送到RabbitMQ的时候，可能数据就在半路给搞丢了，因为网络问题等都有可能。可以用RabbitMQ提供的事务功能，生产者发送数据之前开启RabbitMQ事务channel.txSelect() ，然后发送消息，如果消息没有成功被RabbitMQ接收到，生产者会收到异常报错，此时就可以回滚事务channel.txRollback() ，然后重试发送消息。如果收到了消息，那么可以提交事务channel.txCommit() 。try{//通过工厂创建连
概述：1、当数据量过大时，将数据存放到es中，增加查询的效率，降低和数据库的交互。【一次性导入】2、使用mq同步es数据，避免DB中数据和Es中的不一致。【消息队列持续同步db中的数据】3、注意springboot和es的版本问题，不然项目一定起不来【elk6.几不支持springboot2.3点几的版本】我用的是：springboot-2.2.10.RELEASE；es-6.4版本关键导包!--集成es-->dependency>groupId>org.springframework.boot/groupId>artifactId>spring-boot-starter-data-elast
