storm分组策略

内置分组策略

storm 内置了 8 种流分组的方式,通过实现 CustomStreamGrouping 接口可以实现自定义的流分组。InputDeclarer 接口定义了不同的流分组方式,每当TopologyBuilder#setBolt 方法被调用就返回该对象,用于声明一个bolt的输入流以及这些流应当如何分组。该接口定义的所有分组方法如下:

linux网络工具中的瑞士军刀-netcat

概述

NetCat,在网络工具中有“瑞士军刀”美誉,其有Windows和Linux的版本。因为它短小精悍(1.84版本也不过25k,旧版本或缩减版甚至更小)、功能实用,被设计为一个简单、可靠的网络工具,可通过TCP或UDP协议传输读写数据。同时,它还是一个网络应用Debug分析器,因为它可以根据需要创建各种不同类型的网络连接。

storm简介

storm是什么?

  • 免费、开源、分布式、高容错的实时计算系统;
  • 支持每秒每个节点百万tuple的实时处理;
  • supervisor 无状态(状态都保存在ZK或者磁盘上)和快速失败(每当遇到任何意外情况进程自动毁灭)的,因此supervisor的失败不会影响当前正在运行的任务,只要及时将他们重新启动即可;