王文伟

在集群调用失败时，Dubbo 提供了多种容错方案，缺省为 failover 重试。 [](https://user-images.githubusercontent.com/7789698/38236939-50ec9e00-3758-11e8-88d5-7b470bac0352.png) 各节点关系： - 这里的 `Invoker` 是 `Provider` 的一个可调用 `Service` 的抽象，`Invoker` 封装了 `Provider` 地址及 `Service` 接口信息 - `Directory` 代表多个 `Invoker`，可以把它看成 `List` ，但与 `List` 不同的是，它的值可能是动态变化的，比如注册中心推送变更 - `Cluster` 将...

## LoadBalance层 ### 配置 #### 服务端服务级别 ``` ``` #### 客户端服务级别 ``` ``` #### 服务端方法级别 ``` ``` #### 客户端方法级别 ``` ``` 在集群负载均衡时，Dubbo 提供了多种均衡策略，缺省为 `random` 随机调用。 ``` @SPI(RandomLoadBalance.NAME) public interface LoadBalance {...

分析完了服务提供者，紧接着分析消费者。 从ReferenceBean入手 ## Config层 ### ReferenceBean ```java public void afterPropertiesSet() throws Exception { //init consumerConfig //... //init applicationConfig //init moduleConfig //init registryConfigs //init monitorConfig Boolean b = isInit(); if (b...

serialize层 dubbo的序列化方式包括：hessian2、fastjson、fst、jdk、kryo 只要通过配置`` 或`` 就可以实现 ```java @SPI("hessian2") public interface Serialization { /** * get content type id * * @return content type id */ byte getContentTypeId(); /** * get content...

本篇将着重分析dubbo的remoting模块 ## exchange 信息交换层 ### Exchangers（门面） ```java public class Exchangers { static { // check duplicate jar package Version.checkDuplicate(Exchangers.class); } private Exchangers() { } public static ExchangeServer bind(String url, Replier...

## 什么是Dubbo? Dubbo是阿里巴巴公司开源的一个高性能优秀的服务框架，使得应用可通过高性能的RPC实现服务的输出和输入功能，以及SOA服务治理方案，和spring框架无缝集成。 dubbo作为一个非常好的rpc项目，广泛在国内使用。 官网：http://dubbo.incubator.apache.org/ github地址：https://github.com/apache/incubator-dubbo 我们先看下项目结构：  模块说明： - **dubbo-common 公共逻辑模块**：包括 Util 类和通用模型。 - **dubbo-remoting 远程通讯模块**：相当于 Dubbo 协议的实现，如果 RPC 用 RMI协议则不需要使用此包。 - **dubbo-rpc 远程调用模块**：抽象各种协议，以及动态代理，只包含一对一的调用，不关心集群的管理。 - **dubbo-cluster 集群模块**：将多个服务提供方伪装为一个提供方，包括：负载均衡, 容错，路由等，集群的地址列表可以是静态配置的，也可以是由注册中心下发。 -...

# 脚本分析 mqbroker.sh ``` #!/bin/sh if [ -z "$ROCKETMQ_HOME" ] ; then ## resolve links - $0 may be a link to maven's home PRG="$0" # need this for relative...

## rocketMQ通信模块  NettyRemotingClient ``` @Override public void start() { //业务线程池 this.defaultEventExecutorGroup = new DefaultEventExecutorGroup( nettyClientConfig.getClientWorkerThreads(), new ThreadFactory() { private AtomicInteger threadIndex = new AtomicInteger(0); @Override public Thread newThread(Runnable r)...

不同版本jdk实现都不太一样。 关于1.6 http://ifeve.com/java-concurrent-hashmap-1/ http://ifeve.com/java-concurrent-hashmap-2/ http://www.importnew.com/16147.html 为什么ConcurrentHashMap是弱一致的？ （注意这是jdk1.6，1.7、1.8都不是弱一致了） http://ifeve.com/concurrenthashmap-weakly-consistent/ 关于1.7 http://www.blogjava.net/DLevin/archive/2013/10/18/405030.html 关于1.7和1.8区别 http://www.importnew.com/23610.html 接下来我们来分析1.8源码 先看下类的层次结构  ```java public class ConcurrentHashMap extends AbstractMap implements ConcurrentMap, Serializable { //最大容量不得超过1 e; return ((o instanceof...

我们看到最早的解析，是解析xml ``` ``` # StandardServer  ## StandardServer(LifecycleBase)的init ``` @Override public final synchronized void init() throws LifecycleException { if (!state.equals(LifecycleState.NEW)) { invalidTransition(Lifecycle.BEFORE_INIT_EVENT); } setStateInternal(LifecycleState.INITIALIZING, null, false); try { initInternal(); }...