Kafka架构 如上图所示，一个典型的kafka集群中包含若干producer（可以是web前端产生的page view，或者是服务器日志，系统CPU、memory等），若干broker（Kafka支持水平扩展，一般broker数量越多，集群吞吐率越高），若干consumer group，以及一个Z ...
分类：
其他好文 时间：
2017-05-23 12:17:23
阅读次数：
422
原文地址：http://blog.csdn.net/lifetragedy/article/details/51869032 ActiveMQ的集群 内嵌代理所引发的问题： 消息过载 管理混乱 如何解决这些问题——集群的两种方式： Master slave Broker clusters Activ ...
分类：
其他好文 时间：
2017-05-22 17:45:36
阅读次数：
189
整体结构 Producer producer依据用户指定的算法，将消息发送到指定的partition Part kafka以topic来进行消息管理，每一个topic包括多个part（ition），每一个part相应一个逻辑log，有多个segment组成。每一个segment中存储多条消息（见下图 ...
分类：
其他好文 时间：
2017-05-21 14:47:40
阅读次数：
264
Connector：ActiveMQ提供的，用来实现连接通讯的功能。包括：client-tobroker、broker-to-broker。 ActiveMQ允许客户端使用多种协议来连接 配置Transport Connector的文件在activeMQ安装目录的conf/activemq.xml中 ...
分类：
其他好文 时间：
2017-05-20 21:52:20
阅读次数：
251
一、简介activeMQ是apache开源的一个消息中间件.之前的RPC基本上都是高耦合的,而消息中间件的采用,实现了松耦合.它基于JMS规范,支持多种传输协议,最重要的是它实现了异步的调用.二、主要概念provider(broker)provider是消息中间件服务的提供者,在activeMQ也称为broker.在两种实..
分类：
其他好文 时间：
2017-05-19 22:11:52
阅读次数：
222
据说杰克船长被黑客盗片了，看来信息安全依然任重而道远，本文以此为引子，来介绍下spring boot对于系统集成方面的支持。 Spring Security提供一套安全框架，通过IOC和AOP来实现安全功能，其涉及两个重要的概念，认证&授权。在Spring中，其应用只需要在一个配置类上注解@Enab ...
分类：
编程语言 时间：
2017-05-17 21:31:53
阅读次数：
1033
import java.util.HashMap; import java.util.List;import java.util.Map;import java.util.Properties; import org.junit.Test; import kafka.consumer.Consume ...
分类：
编程语言 时间：
2017-05-16 14:42:28
阅读次数：
189
北京时间2017年5月12日20时左右，全球爆发大规模勒索软件感染事件，我国大量行业企业内网大规模感染，教育网受损严重，攻击造成了教学系统瘫痪，甚至包括校园一卡通系统。 据BBC报道，今天全球很多地方爆发一种软件勒索病毒，只有缴纳高额赎金（有的要比特币）才能解密资料和数据，英国多家医院中招，病人资料 ...
分类：
其他好文 时间：
2017-05-14 12:19:59
阅读次数：
413
RabbitMQ is the most widely deployed open source message broker With more than 35,000 production deployments of RabbitMQ world-wide at small startups ...
分类：
其他好文 时间：
2017-05-13 23:27:57
阅读次数：
319
一、Prefetch机制ActiveMQ通过Prefetch机制来提高性能，方式是在客户端的内存里可能会缓存一定数量的消息。缓存消息的数量由prefetchlimit来控制。当某个consumer的prefetchbuffer已经达到上限，那么broker不会再向consumer分发消息，直到consumer向broker发送消息的确认，确认..
分类：
其他好文 时间：
2017-05-12 14:27:52
阅读次数：
2068
