基本概念 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
参考 Kafka bootstrap-servers vs zookeeper in kafka-console-consumer 具体分析以后补充 ...
分类：
其他好文 时间：
2018-04-12 22:32:35
阅读次数：
1112
匠心零度 转载请注明原创出处，谢谢！ RocketMQ网络部署图 NameServer：在系统中是做命名服务，更新和发现 broker服务。 Broker Master：broker 消息主机服务器。 Broker Slave： broker 消息从机服务器。 Producer： 消息生产者。 Co ...
分类：
其他好文 时间：
2018-04-06 13:51:26
阅读次数：
257
首先解释一下mqtt协议的session的概念，因为只有有了session才会存在消息质量保证一说如果清理会话（CleanSession）标志被设置为0，服务端必须基于当前会话（使用客户端标识符识别）的状态恢复与客户端的通信。如果没有与这个客户端标识符关联的会话，服务端必须创建一个新的会话。在连接断开之后，当连接断开后，客户端和服务端必须保存会话信息[MQTT-3.1.2-4]。当清理会话标志为0
分类：
其他好文 时间：
2018-04-05 11:39:52
阅读次数：
772
一、Kafka回顾 1、AMQP协议 消息队列中消息交互规范，多数分布式消息中间件基于该协议进行消息传输 2、Broker 对于kafka，将生产者发送的消息，动态的添加到磁盘，一个Broker等同于一个kafka应用实例，用于存放消息队列 3、主题：分区：消息 一个分区（Patition）等同于一 ...
分类：
其他好文 时间：
2018-04-03 14:34:55
阅读次数：
161
1 、存储方式 物理上把 topic 分成一个或多个 patition（对应 server.properties 中的 num.partitions=3 配置），每个 patition 物理上对应一个文件夹（该文件夹存储该 patition 的所有消息和索引文件），如下： 图.4 2 、存储策略 无 ...
分类：
其他好文 时间：
2018-04-02 15:58:36
阅读次数：
178
Oracle数据库容灾解决方案：Oracle DataGuard部署实录
分类：
数据库 时间：
2018-04-01 00:04:06
阅读次数：
217
一：使用ZooKeeper实现的MasterSlave实现方式，是对ActiveMQ进行高可用的一种有效的解决方案，高可用的原 理：使用ZooKeeper（集群）注册所有的ActiveMQ Broker。只有其中的一个Broker可以对外提供服务（也就是Master节点），其 他的Broker处于待 ...
分类：
其他好文 时间：
2018-03-27 14:43:41
阅读次数：
190
