消息队列 每当想到消息队列：我们都会想到RabbitMQ，ActiveMQ，RocketMQ，等等一些专业的消息中间件。但是如果我们做的事情比较简单，只有一个消息队列，要使用专业的消息中间件是非常麻烦的，因此我们可以使用Redis做消息队列。 如果对消息的可靠性没有较高的要求的话，那么就可以使用Re ...
分类：
其他好文 时间：
2020-04-19 16:19:09
阅读次数：
74
消息队列（Message Queue，简称MQ），从字面意思上看，本质是个队列，FIFO先入先出，只不过队列中存放的内容是message而已。 其主要用途：不同进程Process/线程Thread之间通信。 为什么会产生消息队列？有几个原因： 不同进程（process）之间传递消息时，两个进程之间耦 ...
分类：
其他好文 时间：
2020-04-17 20:05:56
阅读次数：
148
最近用SpringBoot集成RocketMQ实现消息实时推送，一直卡在本地启动RocketMQ失败。现在先记录一下，以后看时间解决。当然，如果有好心的朋友，可以提供解决方案(#^.^#)。 我用的是Apache包，SpringBoot有RocketMQ starter，这个后面再讲。 1 <dep ...
分类：
编程语言 时间：
2020-04-17 00:15:12
阅读次数：
291
概述 场景 服务解耦 削峰填谷 异步化缓冲：最终一致性/柔性事务 MQ应用思考点 生产端可靠性投递 消费端幂等：消息只能消费一次 高可用、低延迟、可靠性 消息堆积能力 可扩展性 业界主流MQ ActiveMQ：适合传统需求，并发性差 RabbitMQ：扩展性差 RocketMQ：扩展性强 Kafka ...
分类：
编程语言 时间：
2020-04-15 00:32:15
阅读次数：
107
前言 近期在研究各种消息队列方案，为了有一个直观的使用体验，我把Kafka，RocketMQ，RabbitMQ各自部署了一遍，并使用了最基本的生产与消费消息功能。在部署过程中也遇到一些问题，特此记录。本文只适用于没有使用过消息队列，还停留在安装部署阶段的新手用户，要了解一个软件，最好的开始方法是开始 ...
分类：
其他好文 时间：
2020-04-14 21:03:28
阅读次数：
69
之前参加 rocketmq 的 meetup，台上有人讲，kafka 不支持同步刷盘，当时没太在意，今天抽空看了下代码： kafka 提供了配置参数来支持同步刷盘，和 rocktmq 的做法不同（4.7 的 rmq 在 sync_disk 模式，统一在 GroupCommitService 中刷盘， ...
分类：
其他好文 时间：
2020-04-12 12:49:37
阅读次数：
211
1.问题出现 搭完mq单主单从集群之后，美滋滋想发一下message, 没想到碰到一个坑爹的问题： com.alibaba.rocketmq.client.exception.MQBrokerException: CODE: 14 DESC: service not available now, m ...
分类：
系统相关 时间：
2020-04-10 00:36:42
阅读次数：
616
一、发展历程 早期淘宝内部有两套消息中间件系统：Notify和Napoli。 先有的Notify(至今12历史)，后来因有序场景需求，且恰好当时Kafka开源(2011年)，所以参照Kafka的设计理念自研了RocketMQ。 目前Notify和RocketMQ二者的定位如下: RocketQ 主要 ...
分类：
其他好文 时间：
2020-04-07 22:20:50
阅读次数：
72
1:topic下面的queue 奇偶数会影响消费端的消费数量, 假设 4个队列,8个消息,每个节点各自消费两条,如果不对等的话,就没办法做一个负载均衡 队列的数量要大于consumer数量,不然多出来的consumer无法分配到queue,消息没办法消费,需要控制队列大于消费端 2:集群模式和广播模 ...
分类：
其他好文 时间：
2020-04-06 16:01:42
阅读次数：
135
使用netty的开源框架 Dubbo：阿里开源的高性能rpc通讯框架 RocketMQ：阿里出品的高性能消息队列 Spark：为大规模数据处理设计的一款计算引擎 Elasticsearch,Cassandra,Flink,Netty-SocketIO,Spring5,Play,Grpc... Net ...
分类：
Web程序 时间：
2020-04-06 00:28:27
阅读次数：
121
