参考 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
一：使用ZooKeeper实现的MasterSlave实现方式，是对ActiveMQ进行高可用的一种有效的解决方案，高可用的原 理：使用ZooKeeper（集群）注册所有的ActiveMQ Broker。只有其中的一个Broker可以对外提供服务（也就是Master节点），其 他的Broker处于待 ...
分类：
其他好文 时间：
2018-03-27 14:43:41
阅读次数：
190
一：介绍 1.说明原理 A:生产者将信道设置成confirm模式，一旦信道进到confirm模式，所有该信道上发布的消息都会被指派一个唯一的ID（从1开始）。 一旦消息被投递到所有匹配的队列后，broker就会发送一个确认给生产者，并包括了唯一的ID，这样就使得生产者知道消息已经到达目的队列。 B: ...
分类：
其他好文 时间：
2018-03-22 23:52:22
阅读次数：
508
Kafka自0.9.0.0版本引入了配额管理(quota management)，旨在broker端对clients发送请求进行限流(throttling)。目前Kafka支持两大类配额管理： 网络带宽（network bandwidth）配额管理：定义带宽阈值来限制请求发送速率，阈值单位是字节/秒 ...
分类：
其他好文 时间：
2018-03-20 18:07:02
阅读次数：
2014
sql server设置：ALTER DATABASE <DatabaseName> SET ENABLE_BROKER;语句让相应的数据库启用监听服务，以便支持SqlDependency特性 using System;using System.Data;using System.Data.SqlC ...
分类：
数据库 时间：
2018-03-16 18:39:24
阅读次数：
1175
