SVN可视化平台(5) -- RabbitMQ监听消息,创建文件 续接上文 本文我们介绍 RabbitMQ监听 svn hooks 提交的消息 关于 hooks 提交消息的,具体可以看这篇文章:SVN hook post-commit 设置自动更新仓库代码和发送请求...... 言曌 12月20日 1067 6 阅读全文
RabbitMQ使用HTTP API发送消息 最近有个功能需要通过 curl 去调用http接口创建RabbitMQ消息,所以我们需要知道接口的URL和参数格式 文档地址:https://pulse.mozilla.org/api/index.h...... 言曌 11月17日 3898 6 阅读全文
activemq for windows安装,修改端口号 目前主流mq基本都接触过了,如rabbitmq、rocketmq、kafka等。 最近维护一个老系统,里面用的是 activemq,需要部署一套新的环境。 关于安装 activemq 记录下...... 言曌 09月23日 1529 6 阅读全文
【消息队列】6-消息堆积太多怎么办?消息过期失效怎么办?队列满了怎么办? 消息堆积太多怎么办?消息过期失效怎么办?MQ队列满了怎么办? 当生产者疯狂生产消息,消费者消费速度又比较慢的时候,甚至消费者挂了,导致MQ堆积太多消息,甚至堆积时间久了消息被丢弃了,该怎么办?下面简单...... 言曌 11月20日 3503 6 阅读全文
【消息队列】5-如何保证消息的顺序性? 一、场景介绍 1、消息严格有序场景 比如客户开车出事故了需要保险公司来处理,至少要有以下几个步骤: 报案、查勘定损、立案、收单理算支付、结案等环节,这些环节是严格有序的。保险公司每完成一个环节,需要给...... 言曌 11月20日 3038 6 阅读全文
【消息队列】4-什么情况下消息会丢失?如何保证消息的可靠性传输? 什么情况下会消息丢失?如何保证消息的可靠性? 这里以 RocketMQ 来说明,从三个角度来看 先献上一张图,网上找的,侵删 一. 生产者 描述:生产者因为网络原因发送时丢失, 解决办...... 言曌 11月19日 2886 6 阅读全文
【消息队列】3-有哪些可能导致重复消费?如何保证消息消费的幂等性? 如何保证消息不被重复消费?或者说,如何保证消息消费的幂等性? 一、有哪些可能导致重复消费 首先,我们无法避免消息被重复消费。那什么情况下会出现重复消费呢? 这里说几种可能会重复消费的情况。  ...... 言曌 11月18日 2673 6 阅读全文
【消息队列】2-如何保证消息队列的高可用? 如果面试官问我们如何保证消息队列的高可用?我们可以说其中一个自己熟悉的MQ去跟他讲。 所谓MQ高可用无非是MQ挂了,怎么保证数据不丢失,系统正常运行。一般都是通过搭建集群模式来做,数据会有副本。 &n...... 言曌 11月16日 2017 5 阅读全文
【消息队列】1-为什么使用消息队列?消息队列有什么优点和缺点?Kafka、ActiveMQ、RabbitMQ、RocketMQ 都有什么优点和缺点? 一、为什么使用消息队列? 从三个层面通过公司具体业务场景来回答 1. 异步 比如说,我之前在公司做的一个系统叫“跟踪提醒平台”,是一个公共的平台,可以给客户或者业务人员推送消息...... 言曌 11月16日 1902 6 阅读全文
RocketMQ浅谈与总结 1、为什么要用MQ? 解耦 多个项目之间通过消息队列对同一消息进行处理,避免调用接口失败导致整个过程失败。目的是跟调用接口是一样的,只不过 MQ 可以异步、失败尝试、消息堆积等。 异步 生产者...... 言曌 09月21日 2158 6 阅读全文
SpringBoot2.0 整合 RocketMQ 生产者和消费者示例 ,目前国内的公司里消息中间件(即MQ)这块用的最多 Kafka 和 RocketMQ了。 本文介绍一下 RocketMQ 与 SpringBoot 整合,该示例比网上那些简单例子会更加清晰明了,同时也...... 言曌 09月17日 10623 6 阅读全文
RocketMQ api 生产者和消费者例子 上文介绍了 RocketMQ 和可视化控制台的安装和启动,本文介绍通过 RocketMQ 官方的 api实现一个简单的生产者和消费者例子,因为是直接使用官方API,所以不需要 springboot 项...... 言曌 08月04日 8826 6 阅读全文
Mac或Linux安装RocketMQ和可视化控制台 消息中间件是当前互联网公司必用的一个东西,通常用于 异步、削峰和解耦。目前公司里常见的MQ主要是 RabbitMQ、RocketMQ 和 Kafka,目前所在的项目组主要是 Kafka,之前的一个公司...... 言曌 08月01日 9345 6 阅读全文
SpringBoot整合RabbitMQ,简单实现消息发送和订阅 通常为了测试两个服务之间消息生产和消费可以创建两个 SpringBoot 项目,这里为了简单,就用一个项目了,一个在正常的项目中,作为消费者(订阅者),等待接受消息;另一个通过 测试类生产消息,发送消...... 言曌 07月05日 6818 6 阅读全文
Docker下安装RabbitMQ 在 DockerHub 中搜索 RabbitMQ,点此直达。 我们安装带有management的,即有控制台界面的。 在终端输入命令(已经安装了 docker) docker run...... 言曌 06月30日 3470 6 阅读全文