一、Messagedispatcheasync（消息异步分发）在activemq4.0以后，你可以选择broker同步或异步的把消息分发给消费者。可以设置dispatchAsync属性，默认是true，通常情况下这是最佳的。修改：可以通过如下几种方式1：在ConnectionFactory层设置((ActiveMQConnectionFactory)connec..
分类：
其他好文 时间：
2017-05-12 13:15:12
阅读次数：
250
前言： MQTT是IBM开发的一个即时通讯协议。MQTT是面向M2M和物联网的连接协议，采用轻量级发布和订阅消息传输机制。 大家可以直接上GitHub下载MQQT服务的源码，源码地址：https://github.com/mqtt/mqtt.github.io/wiki/libraries 主要内容 ...
概述Kafka端到端审计是指生产者生产的消息存入至broker，以及消费者从broker中消费消息这个过程之间消息个数及延迟的审计，以此可以检测是否有数据丢失，是否有数据重复以及端到端的延迟等。
目...
分类：
其他好文 时间：
2017-05-10 23:12:00
阅读次数：
330
Topic：标签名，一个消息队列的名称 Producer：生产者，发布消息 Consumer：消费者，订阅发布消息，进行处理的存在 Broker：kafka集群，有一个、多个Topic Partition：分区，采用分区的设计有几个目的。一是可以处理更多的消息，不受单台服务器的限制。Topic拥有多 ...
分类：
其他好文 时间：
2017-05-09 13:43:37
阅读次数：
151
一、简介延迟和定时消息投递（DelayandScheduleMessageDelivery）有时候我们不希望消息马上被broker投递出去，而是想要消息60秒以后发给消费者，或者我们想让消息没隔一定时间投递一次，一共投递指定的次数。。。类似这种需求，ActiveMQ提供了一种broker端消息定时调度机制。注..
分类：
其他好文 时间：
2017-05-09 13:42:04
阅读次数：
248
broker.idbroker的唯一标识符，如果不配置则自动生成，建议配置且一定要保证集群中必须唯一，默认-1log.dir日志数据存放的目录，默认/tmp/kafka-logslog.dirs日志数据存放的目录，如果没有配置则使用log.dir，建议此项配置。zookeeper.connectZookeeper主机地址，如果zookeeper..
分类：
其他好文 时间：
2017-05-08 10:12:00
阅读次数：
215
本节内容 1.Kafka基础概念 1.1 出世背景 1.2 基本原理 1.2.1.前置知识 1.2.2.架构和原理 1.2.3.基本概念 1.2.4.kafka特点 2.Kafka初体验 2.1 环境准备 2.2 Kafka小试牛刀 2.2.1单个broker初体验 2.2.2 多个broker初体 ...
分类：
其他好文 时间：
2017-05-07 23:20:02
阅读次数：
275
在Kafka中，LogManager负责管理broker上全部的Log（每个topic-partition为一个Log）。通过阅读源码可知其详细完毕的功能例如以下： 1. 依照预设规则对消息队列进行清理。 2. 依照预设规则对消息队列进行持久化（flush操作）。 3. 连接ZooKeeper进行b ...
分类：
其他好文 时间：
2017-05-06 23:03:21
阅读次数：
342
RabbitMQ 是使用Erlang编写的一个开源的消息队列，本身支持很多的协议：AMQP，XMPP, SMTP, STOMP，也正是如此，使的它变的非常重量级，更适合于企业级的开发。同时实现了一个经纪人(Broker)构架，这意味着消息在发送给客户端时先在中心队列排队。对路由(Routing)，负 ...
分类：
其他好文 时间：
2017-05-06 12:00:15
阅读次数：
201
一、简介Master-Slave集群：由至少3个节点组成，一个Master节点，其他为Slave节点。只有Master节点对外提供服务，Slave节点处于等待状态。当主节点宕机后，从节点会推举出一个节点出来成为新的Master节点，继续提供服务。优点是可以解决多服务热备的高可用问题，缺点是无法解决..
分类：
其他好文 时间：
2017-05-05 23:21:54
阅读次数：
453
