言曌博客

续接上文 本文我们介绍 RabbitMQ监听 svn hooks 提交的消息 关于 hooks 提交消息的，具体可以看这篇文章：SVN hook post-commit 设置自动更新仓库代码和发送请求......

最近有个功能需要通过 curl 去调用http接口创建RabbitMQ消息，所以我们需要知道接口的URL和参数格式 文档地址：https://pulse.mozilla.org/api/index.h......

目前主流mq基本都接触过了，如rabbitmq、rocketmq、kafka等。 最近维护一个老系统，里面用的是 activemq，需要部署一套新的环境。 关于安装 activemq 记录下......

消息堆积太多怎么办？消息过期失效怎么办？MQ队列满了怎么办？ 当生产者疯狂生产消息，消费者消费速度又比较慢的时候，甚至消费者挂了，导致MQ堆积太多消息，甚至堆积时间久了消息被丢弃了，该怎么办？下面简单......

一、场景介绍 1、消息严格有序场景 比如客户开车出事故了需要保险公司来处理，至少要有以下几个步骤: 报案、查勘定损、立案、收单理算支付、结案等环节，这些环节是严格有序的。保险公司每完成一个环节，需要给......

什么情况下会消息丢失？如何保证消息的可靠性？   这里以 RocketMQ 来说明，从三个角度来看 先献上一张图，网上找的，侵删 一. 生产者 描述：生产者因为网络原因发送时丢失， 解决办......

如何保证消息不被重复消费？或者说，如何保证消息消费的幂等性？ 一、有哪些可能导致重复消费 首先，我们无法避免消息被重复消费。那什么情况下会出现重复消费呢? 这里说几种可能会重复消费的情况。 &nbsp......

如果面试官问我们如何保证消息队列的高可用？我们可以说其中一个自己熟悉的MQ去跟他讲。 所谓MQ高可用无非是MQ挂了，怎么保证数据不丢失，系统正常运行。一般都是通过搭建集群模式来做，数据会有副本。 &n......

一、为什么使用消息队列？ 从三个层面通过公司具体业务场景来回答 1. 异步 比如说，我之前在公司做的一个系统叫“跟踪提醒平台”，是一个公共的平台，可以给客户或者业务人员推送消息......

1、为什么要用MQ? 解耦 多个项目之间通过消息队列对同一消息进行处理，避免调用接口失败导致整个过程失败。目的是跟调用接口是一样的，只不过 MQ 可以异步、失败尝试、消息堆积等。 异步 生产者......

,目前国内的公司里消息中间件(即MQ)这块用的最多 Kafka 和 RocketMQ了。 本文介绍一下 RocketMQ 与 SpringBoot 整合，该示例比网上那些简单例子会更加清晰明了，同时也......

上文介绍了 RocketMQ 和可视化控制台的安装和启动，本文介绍通过 RocketMQ 官方的 api实现一个简单的生产者和消费者例子，因为是直接使用官方API，所以不需要 springboot 项......

消息中间件是当前互联网公司必用的一个东西，通常用于 异步、削峰和解耦。目前公司里常见的MQ主要是 RabbitMQ、RocketMQ 和 Kafka，目前所在的项目组主要是 Kafka，之前的一个公司......

通常为了测试两个服务之间消息生产和消费可以创建两个 SpringBoot 项目，这里为了简单，就用一个项目了，一个在正常的项目中，作为消费者(订阅者)，等待接受消息；另一个通过 测试类生产消息，发送消......

在 DockerHub 中搜索 RabbitMQ，点此直达。 我们安装带有management的，即有控制台界面的。 在终端输入命令(已经安装了 docker) docker run......