本文基于 Dubbo 2.6.1 版本，望知悉。 1. 概述 本文分享 dubbo:// 协议的远程调用的第三部分：异步调用。 对应 《Dubbo 用户指南 —— 事件通知》 文档。定义如下： 在调用之前、调用之后、出现异常时，会触发 oninvoke、onreturn、onthrow 三个事件，可以配置当事件发生时，通知哪个类的哪个方法。 看完定义，是不是有点疑惑，和本文的标题仿...

本文基于 Dubbo 2.6.1 版本，望知悉。 1. 概述 从本文开始，我们开始分享 dubbo:// 协议的远程调用，主要分成四个部分： 通信实现 同步调用 异步调用 参数回调 本文分享 通信实现 部分。 《精尽 Dubbo 源码解析 —— NIO 服务器》 系列，是本文的前置文章，所以胖友需要先读完这个系列。哈哈哈，当然，也可以凑合看看先。 本文涉及类图...

一、简介 Storm-Redis 提供了 Storm 与 Redis 的集成支持，你只需要引入对应的依赖即可使用： <dependency> <groupId>org.apache.storm</groupId> <artifactId>storm-redis</artifactId> <version>...

一、整合说明 Storm 官方对 Kafka 的整合分为两个版本，官方说明文档分别如下： Storm Kafka Integration 主要是针对 0.8.x 版本的 Kafka 提供整合支持； Storm Kafka Integration (0.10.x+) 包含 Kafka 新版本的...

本文基于 Dubbo 2.6.1 版本，望知悉。 1. 概述 从这篇文章开始，我们开始分享服务调用的实现。在前面，艿艿已经写了服务： 本地暴露、远程暴露 本地引用、远程引用 那么在服务调用，必然也是分： 本地调用 远程调用 本文分享本地调用，在 dubbo-rpc-injvm 模块实现。 相比远程调用，实现上会简单很多：因为调用的服务，就在本地进程内，且...

本文基于 Dubbo 2.6.1 版本，望知悉。 1. 概述 本文接 《精尽 Dubbo 源码分析 —— 动态代理（二）之 JDK》 一文，分享使用 Dubbo 本地存根( Stub )的特性。 当然，从标题我们就可以看出，实现的原理是基于动态代理的机制。 在 《Dubbo 用户指南 —— 本地存根》 中，已经非常详尽的分享了本地存根的概念和使用，本文就不重复介绍啦。 文档有一点点小小...

一、Storm集成HDFS 1.1 项目结构 本用例源码下载地址：storm-hdfs-integration 1.2 项目主要依赖 项目主要依赖如下，有两个地方需要注意： 这里由于我服务器上安装的是 CDH 版本的 Hadoop，在导入依赖时引入的也是 CDH 版本的依赖，需要使用 标签指定 CDH 的仓库地址； hadoop-common 、 hadoop-cli...

本文基于 Dubbo 2.6.1 版本，望知悉。 1. 概述 本文接 《精尽 Dubbo 源码分析 —— 动态代理（一）之 Javassist》 一文，分享使用 JDK 生成动态代理的代码实现。 如果 JDK Proxy 不熟悉的胖友，可以看下 《 Java JDK 动态代理（AOP）使用及实现原理分析》 学习下。 学无止境呀。 另外，如果使用 JDK 生成代理，配置方式如下： `...

本文基于 Dubbo 2.6.1 版本，望知悉。 1. 概述 本文分享 Dubbo 动态代理的实现。 在 《Dubbo 用户指南 —— schema 配置参考手册》 中，我们可以看到 和 标签中，可以通过 “proxy” 属性，可以配置动态代理的生成方式： 生成动态代理方式，可选：jdk / javassist 从说明中，我们可以看到，Dubbo 实现了两种方式生成代理： ...

一、简介 下图为 Strom 的运行流程图，在开发 Storm 流处理程序时，我们需要采用内置或自定义实现 spout(数据源) 和 bolt(处理单元)，并通过 TopologyBuilder 将它们之间进行关联，形成 Topology。 二、IComponent接口 IComponent 接口定义了 Topology 中所有组件 (spout/bolt) 的公共方法，自定义的 ...