MQ

一、角色 publisher 生产者 发消息的人 我 consumer 消费者 消费消息的人 班主任 exchange 交换机 负责消息路由 queue 队列 存储消息 班长 virtualHost 虚拟主机 隔离不同租户的exchange、queue、消息的隔离 二、结构图 ......

1、消息队列应用场景 消息队列，指保存消息的一个容器，本质是个队列。 异步处理，主要目的是减少请求响应时间； 应用解耦，使用消息队列后，只要保证消息格式不变，消息的发送方和接收方并不需要彼此联系； 流量削峰，秒杀活动中，系统峰值流量往往集中于一小段时间，消息队列作为缓冲，可以削弱峰值流量； 日志处理 ......

1、下载 https://objects.githubusercontent.com/github-production-release-asset-2e65be/374927/3381b277-0ffa-4ddf-b353-dc78d1e9eda4?X-Amz-Algorithm=AWS4-HMA ......

### MQ常用命令集合 ```sh 1、分配MQ ./mqadmin allocateMQ -n localhost:9876 -t tst-topic -i ipList ipList 以逗号分隔 2、删除topic ./mqadmin deleteTopic -n localhost:9876 ......

# 根据用途分类 - 命令类 - 事件类 - 数据类 # 命令类 - 有指定的接收者 - 对于接收者，有明确他需要做什么事情 # 事件类 - 一般就是发生某个事件，另外加上业务单号的id+状态 - 可能会导致接收方调用自己方的api，导致数据多次交互，建议用数据类 # 数据类 - 一版是发生某件事， ......

## 主要通过消息合并实现，采用线程池异步发撒 ```java @Configuration public class BatchMqConfig { //测试批量 public static final String BATCH_QUEUE_NAME="batch.queue"; @Bean pu ......

# 集群扩容 ## 加入集群 1）启动一个新的MQ容器： 点击查看代码 ``` docker run -d --net mq-net \ -v ${PWD}/.erlang.cookie:/var/lib/rabbitmq/.erlang.cookie \ -e RABBITMQ_DEFAULT_U ......

Java代码创建仲裁队列  点击查看代码 ``` @Bean public Queue quorumQueue() ......

仲裁队列：仲裁队列是3.8版本以后才有的新功能，用来替代镜像队列，具备下列特征： - 与镜像队列一样，都是主从模式，支持主从数据同步 - 使用非常简单，没有复杂的配置 - 主从同步基于Raft协议，强一致 从RabbitMQ 3.8版本开始，引入了新的仲裁队列，他具备与镜像队里类似的功能，但使用更加 ......

RabbitMQ是基于Erlang语言编写，而Erlang又是一个面向并发的语言，天然支持集群模式。RabbitMQ的集群有两种模式： •**普通集群**：是一种分布式集群，将队列分散到集群的各个节点，从而提高整个集群的并发能力。 •**镜像集群**：是一种主从集群，普通集群的基础上，添加了主从备份 ......

案例 优点 缺点 同步 调用 Feign 时效性较强，可以立即得到结果 1、耦合度高 2、性能和吞吐能力下降 3、有额外的资源消耗 4、有级联失败问题 异步 调用 Rabbit MQ 1、吞吐量提示：无需等待订阅者处理完成，响应更快速 2、故障隔离：服务没有直接调用，不存在级联失败问题 3、调用间没 ......

将applicationContext 里面获取到的bean添加到allrunner里面,进行 私有化部署数据源初始化 消费是优于一些bean，这个意思是消息消费注册的时候可能有一些bean还没有，所以等一会，消费者是先于一些bean的 Spring加载RocketMq消费者实例后会立即开始消费，不 ......

Cannot resolve configuration property 'rabbitmq.username'rabbitmq: username: admin password: admin virtual-host: test_data listener: simple: # 表示消费者消费 ......

经典队列镜像 — 兔子MQ (rabbitmq.com) why？ message 信息同步 =》 queue 一段时间不可用（可用性 降低） Configuring Synchronisation Let's start with the most important aspect of queu ......

https://www.rabbitmq.com/ha.html#mirroring-arguments why？ node 不可用， maybe message 会丢失 What is Queue Mirroring Important: mirroring of classic queues w ......

转载于：https://blog.csdn.net/weixin_40461281/article/details/122837923 RuoYi-Cloud-Plus 微服务通用权限管理系统 重写 RuoYi-Cloud 全方位升级(不兼容原框架) 系统演示: 传送门 分布式集群版本(功能一致) ......

Kafka和MQ（消息队列）是两个不同的消息传递系统，它们的区别主要表现在以下几个方面： 1. 数据处理方式：Kafka是一种流式数据处理平台，用于在高吞吐量条件下发送、存储和处理消息流。MQ则更侧重于异步消息传递，即将消息发送到队列中，由消费者按照一定规则进行消费。 2. 消息持久化：Kafka基 ......

[MQ系列1：消息中间件执行原理](https://www.cnblogs.com/wzh2010/p/15888498.html "MQ系列1：消息中间件执行原理") [MQ系列2：消息中间件的技术选型](https://www.cnblogs.com/wzh2010/p/15311174.htm ......

# 1.解析注解方式的mq消费者 # 2.注解的定义 ```java @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.METHOD) public @interface JmqListener { String id() default ......

[MQ系列1：消息中间件执行原理](https://www.cnblogs.com/wzh2010/p/15888498.html "MQ系列1：消息中间件执行原理") [MQ系列2：消息中间件的技术选型](https://www.cnblogs.com/wzh2010/p/15311174.htm ......

纯记录，本文转载自(75条消息) yum安装rabbitmq_哪吒闹海883的博客-CSDN博客 1. yum install epel-release -y 2. yum install rabbitmq-server -y 执行完1.2步其实rabbitmq已经安装成功了 3.启动rabbitm ......

## IBMMQ 下载安装 目前版本是 >= IBMMQ 9.0。目前先以 windows 平台来开发。下载地址： https://public.dhe.ibm.com/ibmdl/export/pub/software/websphere/messaging/mqadv/ 选择 mqadv_dev ......

使用rocket mq实现分布式事务 发送半消息 -> 执行本地事务 -> 回查本地事务执行状态 -> 第二个服务消费事务消息 1.参照下面链接去安装rocketmq https://blog.csdn.net/weixin_43464076/article/details/127766159 ro ......

mq介绍 1. 介绍一下ActiveMQ /ApolloMQ 老牌的消息队列，使用Java语言编写。 优点：老牌的消息队列，使用Java语言编写。对JMS（Java Message Service）支持最好，采用多线程并发，资源消耗比较大。如果你的主语言是Java，可以重点考虑。 缺点：由于历史悠久 ......

1.流量消峰 举个例子，如果订单系统最多能处理一万次订单， 这个处理能力应付正常时段的 下单时绰绰有余，正 常时段我们下单-秒后就能返回结果。但是在高峰期，如果有两万次下单操作系统是处理不了的，只能限 制订单超过一万后不允许用户下单。使用消息队列做缓冲，我们可以取消这个限制，把-秒内下的订单分 散成 ......

一、优缺点 ActiveMQ 官网地址:http://activemq.apache.org/ - 官网介绍 Apache ActiveMQ是最流行的开源、多协议、基于Java的消息代理。它支持行业标准协议，因此用户可以从多种语言和平台的客户端选择中获益。从JavaScript、C、C++、Pyth ......

一、MQ（消息队列）： 1、本质： MQ(message queue)，本质是个队列，FIFO先入先出原则。在互联网架构中，MQ是一种常见的上下游“逻辑解耦+物理解耦”的消息通信服务。 2、优缺点： （1）、优点： 1）、异步： 不同的业务可以同时从消息队列中获取消息进行消费，实现异步处理。 2）、 ......

rabbit mq下载地址：https://www.rabbitmq.com/install-windows.html erlang下载地址：https://www.erlang.org/downloads（下载太慢可以使用迅雷）。 erlang 与 rabbitmq对照关系地址：https://w ......

一、消息积压的原因 1、producer生产消息突然增多 比如大促期间，抢购，秒杀业务。 2、consumer消费性能突然下降 比如消费失败时重试，程序死锁，io阻塞。 3、消费系统本身出现瓶颈 这种情况很少，对于绝大多数使用消息队列的业务来说，消息队列本身的处理能力要远大于业务系统的处理能力。主流 ......

某些业务完成测试自动化需要模拟『发送MQ』功能，本文介绍一下怎么在比较方便地在Jmeter中发送『MQ』消息。 安装Jmeter插件 在Github上有人分享了关于『Jmeter发送MQ』的插件，地址在：https://github.com/aliesbelik/jmeter-amqp-plugin ......