首先就是比如rabbitmq、rocketmq、kafka，都有可能会出现消费重复消费的问题，正常。因为这问题通常不是mq自己保证的，是给你保证的。然后我们挑一个kafka来举个例子，说说怎么重复消费吧。 kafka实际上有个offset的概念，就是每个消息写进去，都有一个offset，代表他的序号 ...
分类：
其他好文 时间：
2019-07-03 09:16:07
阅读次数：
106
kafka,activemq rabbitmq.rocketmq的优点和缺点: 特性 ActiveMQ RabbitMQ RocketMQ Kafka 单机吞吐量 万级，吞吐量比RocketMQ和Kafka要低了一个数量级 万级，吞吐量比RocketMQ和Kafka要低了一个数量级 10万级，Roc ...
分类：
其他好文 时间：
2019-07-03 00:46:05
阅读次数：
88
RocketMQ重试机制 消息重试分为两种： Producer发送消息的重试 和 Consumer消息消费的重试 。 一、Producer端重试 Producer端重试是指: Producer往MQ上发消息没有发送成功，比如网络原因导致生产者发送消息到MQ失败。 看一下代码： 针对网上说的超时异常会 ...
分类：
其他好文 时间：
2019-07-02 00:17:20
阅读次数：
80
一、Windows环境搭建RocketMQ 1. 下载RocketMQ Binary压缩包，并解压缩，我的安装目录为E:\programs\rocketmq\rocketmq-all-4.5.1 2. 配置环境变量：ROCKETMQ_HOME，其值为RocektMQ的安装目录 3. 启动NameSe ...
分类：
其他好文 时间：
2019-07-01 00:38:44
阅读次数：
128
SpringBoot整合RocketMQ 上篇博客讲解了服务器集群部署RocketMQ 博客地址： "RocketMQ(2) Docker部署RocketMQ集群" 这篇在上篇搭建好的基础上,将SpringBoot整合RocketMQ实现生产消费。 : "https://github.com/yud ...
分类：
编程语言 时间：
2019-06-30 15:51:20
阅读次数：
119
集群部署规划整个集群分三层，分别是应用接入层、Nameserver集群和Broker集群，下面分别对这三部分说明：接入层接入层其实就是应用连接MQ集群的地址，目前生产环境我们是直接连接了nameserver的IP地址，如果nameserver扩容或者换服务器了，大家需要修改apollo并且重启服务更新新的nameserver地址，虽然这个事情的几率比较低，但是如果发生了还是比较麻烦，所有我们新的接
分类：
其他好文 时间：
2019-06-30 11:16:13
阅读次数：
137
业务场景之类的请看另一篇生产者的实现； 集合到Spring里是： MessageListener里是用来实现消费这个消息后的具体业务逻辑的； ...
分类：
其他好文 时间：
2019-06-28 11:46:09
阅读次数：
855
公司使用了最新的rocketmq框架，然后2天日志跑了快2个g。。。。 无奈网上只有4.2的教程。。。只好自己研究 环境rocketmq4.4 springboot 看源码找到配置日志等级和路径的地方（4.4和4.2是有区别的！） 可以看出是读取系统参数，所以，只要在启动的时候设置即可（在sping ...
分类：
其他好文 时间：
2019-06-27 11:00:14
阅读次数：
209
RocketMQ(1) 架构原理 RocketMQ是阿里开源的分布式消息中间件，跟其它中间件相比，RocketMQ的特点是 纯JAVA实现 ； 集群和HA实现相对简单 ； 在发生宕机和其它故障时消息丢失率更低 。 一、RocketMQ专业术语 先讲专业术语的含义，后面会画流程图来更好的去理解它们。 ...
分类：
其他好文 时间：
2019-06-27 00:44:29
阅读次数：
92
面试题 1.为什么使用消息队列？ 2.消息队列有什么优点和缺点？ 3.Kafka、ActiveMQ、RabbitMQ、RocketMQ 都有什么区别，以及适合哪些场景？ 面试官心理分析 其实面试官主要是想看看： 第一，你知不知道你们系统里为什么要用消息队列这个东西？不少候选人，说自己项目里用了 Re ...
分类：
其他好文 时间：
2019-06-26 18:01:38
阅读次数：
136
