一、简介 在将 Storm Topology 提交到服务器集群运行时，需要先将项目进行打包。本文主要对比分析各种打包方式，并将打包过程中需要注意的事项进行说明。主要打包方式有以下三种： 第一种：不加任何插件，直接使用 mvn package 打包； 第二种：使用 maven-assembly-plugin 插件进行打包； 第三种：使用 maven-shade-plugin ...

一、Storm 1.1 简介 Storm 是一个开源的分布式实时计算框架，可以以简单、可靠的方式进行大数据流的处理。通常用于实时分析，在线机器学习、持续计算、分布式 RPC、ETL 等场景。Storm 具有以下特点： 支持水平横向扩展； 具有高容错性，通过 ACK 机制每个消息都不丢失； 处理速度非常快，每个节点每秒能处理超过一百万个 tuples ； 易于设置和操作...

本文基于 Dubbo 2.6.1 版本，望知悉。 1. 概述 前置阅读文章： 《精尽 Dubbo 源码分析 —— 注册中心（一）之抽象 API》 《精尽 Dubbo 源码分析 —— 注册中心（二）之 Zookeeper》 我们先来看下 《Dubbo 用户指南 —— Redis 注册中心》 文档，内容如下： 基于 Redis 实现的注册中心。 使用 Redis 的 ...

本文基于 Dubbo 2.6.1 版本，望知悉。 1. 概述 前置阅读文章： 《精尽 Dubbo 源码分析 —— Zookeeper 客户端》 《精尽 Dubbo 源码分析 —— 注册中心（一）之抽象 API》 在《注册中心（一）之抽象 API》 中，我们分享的那是相当抽象。因此，在本文中，我们会分享 Dubbo 使用 Zookeeper 作为注册中心的代码，同时也会分享...

本文基于 Dubbo 2.6.1 版本，望知悉。 1. 概述 在 《精尽 Dubbo 源码分析 —— 项目结构一览》「3.5 dubbo-registry」 中，对 dubbo-registry注册中心这个大模块做了大体的介绍。那么从本文开始，分享注册中心的代码实现。 本文分享 dubbo-registry-api 模块，注册中心的抽象 API ，类结构如下图： 整体比较易懂，笔...

一、集群规划 这里搭建一个 3 节点的 Storm 集群：三台主机上均部署 Supervisor 和 LogViewer 服务。同时为了保证高可用，除了在 hadoop001 上部署主 Nimbus 服务外，还在 hadoop002 上部署备用的 Nimbus 服务。Nimbus 服务由 Zookeeper 集群进行协调管理，如果主 Nimbus 不可用，则备用 Nimbus 会成为新的主...

本文基于 Dubbo 2.6.1 版本，望知悉。 1. 概述 在 dubbo-remoting-zookeeper 模块，实现了 Dubbo 对 Zookeeper 客户端的封装。在该模块中，抽象了通用的 Zookeeper Client API 接口，实现了两种 Zookeeper Client 库的接入： 基于 Apache Curator 实现。 <dubbo:r...

本文来自cowbi的投稿~ Oracle 于 2014 发布了 Java8（jdk1.8），诸多原因使它成为目前市场上使用最多的 jdk 版本。虽然发布距今已将近 7 年，但很多程序员对其新特性还是不够了解，尤其是用惯了 Java8 之前版本的老程序员，比如我。 为了不脱离队伍太远，还是有必要对这些新特性做一些总结梳理。它较 jdk.7 有很多变化或者说是优化，比如 interface ...

本文基于 Dubbo 2.6.1 版本，望知悉。 1. 概述 在 《精尽 Dubbo 源码分析 —— 服务引用（一）之本地引用（Injvm）》 一文中，我们已经分享了本地引用服务。在本文中，我们来分享远程引用服务。在 Dubbo 中提供多种协议( Protocol ) 的实现，大体流程一致，本文以 Dubbo Protocol 为例子，这也是 Dubbo 的默认协议。 如果不熟悉该协议...

1. 安装环境要求 you need to install Storm’s dependencies on Nimbus and the worker machines. These are: Java 7+ (Apache Storm 1.x is tested through travis ci against both java 7 and java 8 JDKs) Py...