从事实时计算多年，熟悉jstorm/spark/flink/kafka/rocketMq, 热衷于开源，希望在这里和前辈们一起学习与分享，得到长足的进步！邮箱：hustfxj@gmail.com 我的githup地址是：https://github.com/hustfxj。欢迎和大家一起交流探讨问题。
发布时间：2014-08-15 13:38:08
Metrics是一个给JAVA服务的各项指标提供度量工具的包，在JAVA代码中嵌入Metrics代码，可以方便的对业务代码的各个指标进行监控，同时，Metrics能够很好的跟Ganlia、Graphite结合，方便的提供图形化接口。基本使用方式直接将core包（目前稳定版本3.0.1）导入pom文件即可，配置如下： com.codahale.........【阅读全文】
发布时间：2014-08-07 10:08:05
本文从外部消息在worker进程内部的转化，传递及处理过程入手，一步步分析在worker-data中的数据项存在的原因和意义。试图从代码实现的角度来回答，如果是从头开始实现worker的话，该如何来定义消息接口，如何实现各自接口上的消息处理。Topology到Worker的映射关系Topology由Spout,Bolt组成，其逻辑关系大体如下.........【阅读全文】
发布时间：2014-07-18 10:20:37
绿色部分是我们最常用、比较简单的部分。红色部分是与事务相关的，在以后的文章会具体讲解。BaseComponent 是Storm提供的“偷懒”的类。为什么这么说呢，它及其子类，都或多或少实现了其接口定义的部分方法。这样我们在用的时候，可以直接继承该类，而不是自己每次都写所有的方法。但值得一提的是，BaseXXX这.........【阅读全文】
发布时间：2014-07-09 14:57:13
本文首先介绍了Storm的基本概念和数据流模型，然后结合一个典型应用场景来说明Storm支持Topology之间数据流订阅的必要性，最后对比了Storm与另一个流处理系统在数据流模型上的区别之处。Storm基本概念Storm是一个开源的实时计算系统，它提供了一系列的基本元素用于进行计算：Topology、Stream、Spout、Bolt等等。.........【阅读全文】
发布时间：2014-06-14 21:00:41
最近一直在抽时间研究设计模式，之前对设计模式也有一定的了解，但是都没有平心静气的去研究过，只是了解了一些皮毛，最近打算再深入研究一下，重新打开了设计模式的数据，对之前的疑问一个个的刨根问底，今天看了简单工厂模式和策略模式看的人有点小晕，两个的大概思路没有怎么变，都是通过多态去减少代码的耦合度，怎么看.........【阅读全文】
发布时间：2014-04-13 13:29:29
私有数据使用1.为什么需要线程私有数据：原因一：有时候需要维护基于每个线程的数据，用线程ID作为索引。因为线程ID不能保证是小而连续的整数，所以不能简单的分配一个线程数据数组，用线程ID作为数组的索引。即使线程ID确实是小而连续的整数，可能还希望有一些额外的保护，以防止某个线程的数据和其它线程的数据相混.........【阅读全文】
