MQ
MQ消息可靠性等
RabbitMQ如何保证消息可靠性？ 首先RabbirMQ是一个开源的支持多协议的性能优秀的消息中间件，他的消息可靠性，消息延迟以及可用性比较高，但是单机消息吞吐量比较一般。 消息的可靠性是指，消息准确无误的到达消费者手中，不能出现消息的丢失等问题，消息丢失又分为：①生产者发送消息为到达交换机，②消 ......
MQ 使用场景
解耦 系统间接口调用进行解耦。例如:A系统需要给B、C、D三个系统进行数据推送，那么需要在代码中维护推送接口，并且要考虑到所推送系统宕机的情况，此时对于数据该如何处理，同时如果需要新增推送的系统，那么A系统中需要新增推送接口，或者某一个系统不需要接收数据，A系统还需要进行代码维护。当加入MQ消息 ......
阿里三面：MQ 消息丢失、重复、积压问题，如何解决？
作者：美得让人心动 来源：https://blog.csdn.net/gu131007416553/article/details/120934738 面试官在面试候选人时，如果发现候选人的简历中写了在项目中使用了 MQ 技术（如 Kafka、RabbitMQ、RocketMQ），基本都会抛出一个问 ......
MQ系列14：MQ如何做到消息延时处理
[MQ系列1：消息中间件执行原理](https://www.cnblogs.com/wzh2010/p/15888498.html "MQ系列1：消息中间件执行原理") [MQ系列2：消息中间件的技术选型](https://www.cnblogs.com/wzh2010/p/15311174.htm ......
MQ消息中间件之RabbitMQ
1.MQ知识扩充 1.1 什么是MQ消息中间件 MQ全称 Message Queue（消息队列），是在消息的传输过程中保存消息的容器。它是应用程序和应用程序之间的通信方法 1.2 为什么使用MQ 【注：在项目中，可将一些无需即时返回且耗时的操作提取出来，进行异步处理，而这种异步处理的方式大大的节省了 ......
mq常用命令
添加可视化rabbitmq-plugins enable rabbitmq_management然后访问http://ip:15762 查看mq信息rabbitmqctl status 添加用户rabbitmqctl add_user user 123456 赋予user权限rabbitmqctl ......
打印mq异常消息记录
mq的异常日志，发现在线上有大量的异常信息，但是钉钉告警里面却没有搜到，自己已经重写了logback的TurboFilter方法，仍然无法打印。最后发现原来是自己给过滤了。代码如下： package com.gwm.marketing.filter.log; import ch.qos.logbac ......
中间件学习 - Rabbit MQ 概念及特殊MQ实现
# Rabbit MQ [官方文档](https://www.rabbitmq.com/) ## 介绍 Rabbit MQ是一个消息队列组件，使用Erlang开发，消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题 ## 安装使用 1. 安装Erlang （Rabbi ......
MQ消息积压处理方案
什么是MQ消息积压？ MQ消息积压是指消息队列中的消息无法及时处理和消费，导致队列中消息累积过多的情况。 消息积压后果： ①：消息不能及时消费，导致任务不能及时处理 ②：下游消费者处理大量的消息任务，导致系统性能下降、延迟增加以及资源消耗过高 MQ消息积压解决方法： 1、消费端： ①：增加消费者数量 ......
【转】MQ的选型
常用MQ的对比  > 其实对于这些消息队列的产品，每一种都在某一领域占有一席，在实际选型时，需要结合自身需 ......
【RocketMQ】MQ消息发送总结
RocketMQ是通过`DefaultMQProducer`进行消息发送的，它实现了`MQProducer`接口，`MQProducer`接口中定义了消息发送的方法，方法主要分为三大类： 1. `send`同步进行消息发送，向Broker发送消息之后等待响应结果； 2. `send`异步进行消息发送 ......
Feign和消息队列（MQ）的区别
Feign和消息队列（MQ）是两个不同的概念，它们分别用于不同的目的。下面我将分别介绍它们的作用和特点。 Feign是一个在微服务架构中用于实现服务间通信的轻量级、声明式的HTTP客户端。它由Netflix开源，并且与Spring Cloud集成得非常紧密。Feign可以让开发人员以类似于编写本地方 ......
不想引入mq？试试debezium
奥卡姆剃刀原理，“如无必要，勿增实体"。 在一些小型项目当中，没有引入消息中间件，也不想引入，但有一些业务逻辑想要解耦异步，那怎么办呢？ 我们的web项目，单独内网部署，由于大数据背景，公司消息中间件统一使用的kafka，在一些小项目上kafka就显得很笨重。 引入rocketmq或rabittmq ......
MQ 的种类
RabbitMQ ActiveMQ RocketMQ Kafka 公司/社区 Rabbit Apache 阿里巴巴 Apache 开发语言 Erlang Java Java Scala&Java 协议支持 AMQP、XMPP SMTP、STOMP OpenWire、STOMP REST、XMPP、A ......
Apache Rocket MQ 组件 （泛型应用）
一、实现 import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import org.apache.commons.lang3.StringUtils; import org.apache.rocketmq.clie ......
MQ消息队列篇：三大MQ产品的必备面试种子题
MQ（Message Queue）作为一种用于实现异步通信的技术，具有重要的作用和应用场景。在面试过程中，MQ相关的问题经常被问到，因此了解MQ的用途和设计原则是必不可少的。本文总结了MQ的常见面试题，包括MQ的作用、产品选型、消息不丢失的保证、消息消费的幂等性、消息顺序的保证、消息的高效读写、分布... ......
RabbitMQ - MQ幂等、去重的解决方案
1.场景描述消息中间件是分布式系统常用的组件，无论是异步化、解耦、削峰等都有广泛的应用价值。我们通常会认为，消息中间件是一个可靠的组件——这里所谓的可靠是指，只要我把消息成功投递到了消息中间件，消息就不会丢失，即消息肯定会至少保证消息能被消费者成功消费一次，这是消息中间件最基本的特性之一，也就是我们 ......
面试-mq
## NameServer 每个 Broker 在启动的时候会到 NameServer 注册，Producer 在发送消息前会根据 Topic 到 NameServer 获取到 Broker 的路由信息，Consumer 也会定时获取 Topic 的路由信息 ## Broker Broker负责消息 ......
ESP32连接MQ Sensor实现气味反应
> ## ESP32连接MQ Sensor实现气味反应 > > >  > > > | [ESP32+MQTT+MySQL实 ......
【Rocket MQ】【MsgId】MsgId 谁生成的？什么时候生成的？怎么生成的？
1 前言 这节我们来看看 Rocket MQ的一个小东西，就是我们平时发消息，消息里边有个 messageId，它是全局唯一的，就好奇是谁生成的？什么时候生成的？怎么生成的？我们跟进源码看下。 我这里看的是云消息队列里的开发包哈。 2 源码分析 2.1 消息发送过程 Rocket MQ作为消息中间件 ......
mq json转换器 JSON泛型反序列化, 多层嵌套，使用 TypeReference
需求 解析JSON, 并将其转换为对应的数据结构。例如：转换为 Map<String, Object> ......
如何保证mq消息的可靠性
拿rabbitmq举例吧 它有两种方案，一个是开启事务，但这种会降低性能； 还有种异步confirm机制，在生产者这边，mq消息成功消费后会有一个异步回调，所以通常会用这个模式。 光做这个常规情况下够了，如果考虑宕机，还有其他极端情况，要开启持久化，和使用数据库记录消息流水。 另外mq自动的ack只 ......