Worker间的通信:经常需要通过网络跨节点进行,Storm使用ZeroMQ或Netty(0.9以后默认使用)作为进程间通信的消息框架。 Worker进程内部通信:不同worker的thread通信使用LMAX Disruptor来完成。 不同topologey之间的通信:Storm不负责,需要自己 ...
分类:
其他好文 时间:
2017-05-25 01:14:31
阅读次数:
208
概念 Workers (JVMs): 在一个物理节点上可以运行一个或多个独立的JVM 进程。一个Topology可以包含一个或多个worker(并行的跑在不同的物理机上), 所以worker process就是执行一个topology的子集, 并且worker只能对应于一个topology Exec ...
分类:
其他好文 时间:
2017-05-24 17:01:47
阅读次数:
249
我原本是后台开发者,有过一段.net开发经历,因此比较喜欢vs的编程界面。转到前端之后我一直在找一款IDE来取代我在使用的webstorm(webstorm,sublime,atom都很好,想换个IDE ) notepad++是我一直以来很喜欢的一个编辑器,但是因为功能有限,很多时候满足不了我快速开 ...
分类:
其他好文 时间:
2017-05-24 16:12:19
阅读次数:
289
http://www.csdn.net/article/2015-03-09/2824135 Apache Storm 在Storm中,先要设计一个用于实时计算的图状结构,我们称之为拓扑(topology)。这个拓扑将会被提交给集群,由集群中的主控节点(master node)分发代码,将任务分配给 ...
分类:
其他好文 时间:
2017-05-24 12:46:29
阅读次数:
208
听说谷爹要把Kotlin作为了Android开发的一级语言,吓得我赶紧写个“Hello Kotlin!”压压惊! ...
分类:
其他好文 时间:
2017-05-23 23:38:42
阅读次数:
229
目的: 通过Spout发射kafka的数据,到bolt统计每一个单词的个数,将这些记录更新到mongodb中。 Spout的nextTuple方法会一直处于一个while循环这中,每一条数据发送给bolt后,bolt都会调用一次execute方法。 spout用于发射数据,bolt用于对数据进行处理 ...
分类:
数据库 时间:
2017-05-23 15:46:52
阅读次数:
242
0x01简介Zookeeper是一个很好的集群管理工具,被大量用于分布式计算。如Hadoop以及Storm系统中。ApacheZooKeeper是一个为分布式应用所设计开源协调服务,其设计目是为了减轻分布式应用程序所承担的协调任务。可以为用户提供同步、配置管理、分组和命名服务。0x02环境说明在三台..
分类:
其他好文 时间:
2017-05-22 15:13:14
阅读次数:
202
5、安装zookeeper本博客全部内容是原创。假设转载请注明来源http://blog.csdn.net/myhaspl/myhaspl@aaayun:~/jzmq-master$cd ..myhaspl@aaayun:~$wget http://apache.fayea.com/zookeepe ...
分类:
其他好文 时间:
2017-05-22 13:20:37
阅读次数:
193
博客公告: (1)本博客全部博客文章搬迁至《博客虫》http://blogchong.com/ (2)文章相应的源代码下载链接參考博客虫站点首页的“代码GIT”。 (3)很多其它的相关文章更新,以及代码等。请关注博客虫站点,站点中有技术Q群,以及代码共享链接。 (4)该博客内容还会继续更新,只是会慢 ...
分类:
其他好文 时间:
2017-05-21 16:04:21
阅读次数:
257
程序员写的代码最终是人在看,所以代码规范很重要,原则是:简明,易读,无二义性。 不光是程序书写的格式问题,还牵涉到程序设计、模块之间的关系、设计模式等方方面面。 代码复审的正确定义看代码是否在代码规范的框架内正确的解决了问题 代码复审的目的在于: 1.找出代码的错误,比如: 1)编码错误,比如一些碰 ...
分类:
其他好文 时间:
2017-05-21 14:51:23
阅读次数:
154