原文链接    译者：魏勇

一个运行中的拓扑是由什么构成的：工作进程（worker processes），执行器（executors）和任务（tasks）

在一个 Storm 集群中，Storm 主要通过以下三个部件来运行拓扑：

1. 工作进程（worker processes）
2. 执行器（executors）
3. 任务（tasks）

阅读全文

原文链接    译者：魏勇

本文通过问答的形式解释了 Storm 的容错性原理。

工作进程（worker）死亡时会发生什么？

工作进程死亡的时候，supervisor 会重新启动这个进程。如果在启动过程中仍然一直失败，并且无法向 Nimbus 发送心跳，Nimbus 就会将这个 worker 重新分配到其他机器上去。

阅读全文

原文链接    译者：魏勇

Storm 最佳实践

关于配置 Storm + Trident 的建议

• worker 的数量最好是服务器数量的倍数；topology 的总并发度(parallelism)最好是 worker 数量的倍数；Kafka 的分区数(partitions)最好是 Spout（特指 KafkaSpout）并发度的倍数
• 在每个机器（supervisor）上每个拓扑应用只配置一个 worker
• 在拓扑最开始运行的时候设置使用较少的大聚合器，并且最好是每个 worker 进程分配一个
• 使用独立的调度器（scheduler）来分配任务（关于Scheduler 的知识请参考 xumingming 的博客 —— 译者注）
• 在每个 worker 上只配置使用一个 acker —— 这是 0.9.x 版本的默认特性，不过在早期版本中有所不同
• 在配置文件中开启 GC 日志记录；如果一切正常，日志中记录的 major GC 应该会非常少
• 将 trident 的 batch interval 配置为你的集群的端到端时延的 50% 左右
• 开始时设置一个很小的 TOPOLOGY_MAX_SPOUT_PENDING（对于 trident 可以设置为 1，对于一般的 topology 可以设置为 executor 的数量），然后逐渐增大，直到数据流不再发生变化。这时你可能会发现结果大约等于 “2 × 吞吐率(每秒收到的消息数) × 端到端时延” （最小的额定容量的2倍）。

阅读全文

原文链接    译者：魏勇

本文介绍了 Storm 命令行客户端中的所有命令操作。如果想要了解怎样设置你的 Strom 客户端和远程集群的交互，请按照配置开发环境一文中的步骤操作。

阅读全文

原文链接    译者：魏勇

Storm 能够保证每一个由 Spout 发送的消息都能够得到完整地处理。本文详细解释了 Storm 如何实现这种保障机制，以及作为用户如何使用好 Storm 的可靠性机制。

阅读全文

原文链接    译者：魏勇

Storm 有大量配置项用于调整 nimbus、supervisors 和拓扑的行为。有些配置项是系统级的配置项，在拓扑中不能修改，另外一些配置项则是可以在拓扑中修改的。

每一个配置项都在 Storm 代码库的 defaults.yaml 中有一个默认值。可以通过在 Nimbus 和 Supervisors 的环境变量中定义一个 storm.yaml 来覆盖默认值。最后，在使用 StormSubmitter 提交拓扑时也可以定义基于具体拓扑的配置项。但是，基于拓扑的配置项仅仅能够覆盖那些以 “TOPOLOGY” 作为前缀的配置项。

阅读全文

原文链接    译者：魏勇

Storm 系统中包含以下几个基本概念：

1. 拓扑（Topologies）
2. 流（Streams）
3. 数据源（Spouts）
4. 数据流处理组件（Bolts）
5. 数据流分组（Stream groupings）
6. 可靠性（Reliability）
7. 任务（Tasks）
8. 工作进程（Workers）

译者注：由于 Storm 的几个基础概念无论是直译还是意译均不够清晰，而且还会让习惯了 Storm 编程模型的读者感到困惑，因此后文在提及这些概念时大多还会以英文原文出现，希望大家能够谅解。

阅读全文

原文地址  首发博客地址   译者：aCoder2013    校对：方腾飞

这个问题对于我来说是一个很常见的问题，这也是由初级程序员成长到中级程序员的时候经常会遇到的问题。程序员不知道或不信任正在使用的约定，并且小心的检查着null。还有当程序员写代码的时候，总是会依赖于通过返回空(NULL)来表明某些意义，因此需要调用者去检查Null。换种方式来说，有两种空指针的检查场景：

阅读全文

原文链接 作者：Jakob Jenkov  译者：魏嘉鹏

在Java中，用System.currentTimeMillis()来测量时间最方便。
你要做的是在某些操作之前获取到时间，然后在这些操作之后你想要测量时间，算出时间差。下面是一个例子：
[code lang=”java”]
long startTime = System.currentTimeMillis();
callOperationToTime();
long endTime = System.currentTimeMillis();
long totalTime = endTime – startTime;
[/code]
阅读全文

Writer      ：李强强

从上一篇 图解 Java IO : 一、File源码 并没有把所有File的东西讲完。这次讲讲FilenameFilter，关于过滤器文件《Think In Java》中写道：

更具体地说，这是一个策略模式的例子，因为list()实现了基本功能，而按着形式提供了这个策略，完善list()提供服务所需的算法。

java.io.FilenameFilter是文件名过滤器接口，即过滤出符合规则的文件名组。

阅读全文

原文链接 作者：Jakob Jenkov  译者：魏嘉鹏

静态方法System.currentTimeMillis() 返回从1970年1月1日到现在的总毫秒数。返回类型为long。下面是一个例子：
[code lang=”java”]
long timeNow = System.currentTimeMillis();
[/code]
阅读全文

原文链接 作者：Jakob Jenkov  译者：魏嘉鹏

目录

• Java 8 Date Time API
• Java 7 Date Time API

当你初次尝试弄明白怎么去使用Java的date time 的API的时候，那是相当令人困惑的。Therefore I have put together this little trail on Java’s date and time classes。希望这会让你对Java’的date类和time类有个总体的认识。我也希望这能消除一些Sun所制造的关于Java中许多date和time类的困惑。
实际上，在Java8中，随着一整套新的类的引入，旧有的date time API已经发生了改变（清除）。这个教程将会一起解释Java8和Java7的date time API.

阅读全文

作者：方腾飞  本文是样章  购买本书=》  当当 京东 天猫 互动

第1章并发编程的挑战

并发编程的目的是为了让程序运行的更快，但是并不是启动更多的线程，就能让程序最大限度的并发执行。在进行并发编程时，如果希望通过多线程执行任务让程序运行的更快，会面临非常多的挑战，比如上下文切换的问题，死锁的问题，以及受限于硬件和软件的资源限制问题，本章会介绍几种并发编程的挑战，以及解决方案。

阅读全文

Writer      ：李强强

记得Java源码是从集合类开始看的，写了一系列集合相关的文章，受到不错的评价。感谢各位读者。我依旧会读到老写到老，并生动形象的写出来心得体会。这次依旧是图解Java IO。

Java IO – File的要点，应该是

1、跨平台问题的解决

2、文件的安全

3、文件的检索方法

阅读全文

作者：李强强

相继 图解Http协议 和 图解Cookie 之后，中间迷茫期哈，没写了！可是又要告诉你自己明明喜欢写为啥不写了！那就写吧，学到老学到老~ 然后写到老！本系列皆以图为主，力求简单易懂，娓娓道来。

阅读全文