高可用究竟指的是什么？请参考： "关于高可用的系统" RocketMQ做了以下的事情来保证系统的高可用 多master部署，防止单点故障 消息冗余（主从结构），防止消息丢失 故障恢复（本篇暂不讨论） 那么问题来了： 怎么支持多broker的写？ 怎么实现消息冗余？ 下面分开说明这两个问题 多mast ...
分类：
其他好文 时间：
2018-05-05 15:27:28
阅读次数：
202
一.前言看完RocketMQ的源代码后，其namesrv和broker通信机制使用的就是Netty，故对Netty产生了兴趣。根据自己一般学习的规律，都是先把源代码下载，编译出来，然后断点已经打日志调试。所以这篇文章介绍mac下面怎么下载编译Netty源代码。二.下载源代码
分类：
Web程序 时间：
2018-05-03 16:30:27
阅读次数：
662
从图中可以看出RabbitMQ主要由Exchange和Queue两部分组成，然后通过RoutingKey关联起来，消息投递到Exchange然后通过Queue接收。RabbitMQ消息队列基本概念RabbitMQ Server： 也叫broker server，它是一种传输服务。他的角色就是维护一条 ...
分类：
其他好文 时间：
2018-05-03 15:25:58
阅读次数：
189
举例说明：假设有 3 个 broker 节点，分别是61616，61618, 61620，其中 61616 和 61618 组成主、从节点，而 61616（或61618）和 61620 构成集群。61616 和 61618 使用 jdbc 持久化，61620 使用 kahaDB。 这样混合配置：能更 ...
分类：
其他好文 时间：
2018-04-28 22:12:45
阅读次数：
177
使用 jdbc 方式配置主从模式，持久化消息存放在数据库中。 在同一时刻，只有一个 master broker，master 接受客户端的连接，slave 不接受连接。当 master 因为关机而下线后，其中一个 slave 会提升为 master，然后接受客户端连接。但原来 master 的非持久 ...
分类：
数据库 时间：
2018-04-27 02:42:03
阅读次数：
276
（一）zookeeper与activemq原理 使用ZooKeeper实现的Master Slave实现方式，是对ActiveMQ进行高可用的一种有效的解决方案，高可用的原理：使用ZooKeeper（集群）注册所有的ActiveMQ Broker。只有其中的一个Broker可以对外提供服务（也就是M ...
分类：
其他好文 时间：
2018-04-23 18:41:36
阅读次数：
177
一、ACK机制简介 ACK (Acknowledgement），即确认字符，在数据通信中，接收站发给发送站的一种传输类控制字符。表示发来的数据已确认接收无误。 JMS API中约定了Client端可以使用四种ACK_MODE,在javax.jms.Session接口中: AUTO_ACKNOWLED ...
分类：
其他好文 时间：
2018-04-23 11:12:41
阅读次数：
1526
kakfka架构图： 理解kafka需要理解三个问题。 1.producer,broker,consumer，ZK的工作模式。 broker，ZK是作为一个后台服务,而producer和consumer是作为一个SDK提供给开发者进行开发用。 2.producer和consumer的交互类型。 一般 ...
分类：
其他好文 时间：
2018-04-21 16:14:13
阅读次数：
140
基本概念 Kafka将消息以topic为单位进行归纳。 将向Kafka topic发布消息的程序称为producers. 将预订topics并消费消息的程序称为consumer. Kafka以集群的方式运行，可以由一个或多个服务组成，每个服务叫做一个broker. producers通过网络将消息发 ...
分类：
其他好文 时间：
2018-04-17 22:26:44
阅读次数：
151
RocketMQ集群搭建-4.2.0版本https://juejin.im/post/5a911ea16fb9a0633f0e36a1 直接在官网下载的二进制包，编译容易出现问题 启动broker，报错：rocketmq Cannot allocate memory 可根据机器内存大小，配置jvm参 ...
分类：
其他好文 时间：
2018-04-13 15:08:25
阅读次数：
161
