`
manzhizhen
  • 浏览: 293407 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

Dubbo源代码实现二:服务调用的动态代理和负载均衡

阅读更多

疑惑一:为什么在Spring中我们能像注入普通本地服务JavaBean一样注入远程的Dubbo服务Bean

我们知道,Dubbo将服务调用封装成普通的SpringBean,于是我们可以像使用本地的Spring Bean一样,来调用远端的Dubbo服务,并有LoadBalanceFailover的功能。现在,我们从源码的角度来看看,Dubbo是如何做到这点的。

我们知道,要成为Dubbo服务的消费者,需要在Springxml文件中配置dubbo:reference节点,如下:

 

<dubbo:reference id="configRemoteService"

interface="com.manzhizhen.biz.ConfigRemoteService"

version="1.0.0" filter="DataVerifyDubboConsumerFilter,LogDubboConsumerFilter" />

 

在这里,我们已经发现了点特别,如果是普通的Spring Bean配置,会有个class属性,用来配置该Bean所属的类型,因为Spring最后需要创建一个该类型的对象,但Dubbo提供的自定义标签dubboreference却很奇怪,它提供的是interface,接口!怎么能从接口创建对象呢?别急,我们接着看。我们知道,在Spring容器中,由配置到Spring容器中的Bean,要经历配置->BeanDefinition->可用的Bean这几个阶段,Bean的所有创建信息,都放在了BeanDefinition对象中,因为Dubbo提供了自己的dubbo:reference标签,在上一篇文章(http://manzhizhen.iteye.com/admin/blogs/2276242)我们已经提到,Dubbo需要提供自己的BeanDefinition的解析类DubboBeanDefinitionParser,来自己将dubbo:reference元素转换成BeanDefinition对象:

registerBeanDefinitionParser("reference"new DubboBeanDefinitionParser(ReferenceBean.classfalse)); 

我们看看 DubboBeanDefinitionParser中是如何将dubbo:reference元素转换成BeanDefinition对象的,下面给出部分源码:

 

public class DubboBeanDefinitionParser implements BeanDefinitionParser {

    private final Class<?> beanClass;

    private final boolean required;

    public DubboBeanDefinitionParser(Class<?> beanClass, boolean required) {

        this.beanClass = beanClass;

        this.required = required;

    }

 

    public BeanDefinition parse(Element element, ParserContext parserContext) {

        return parse(element, parserContext, beanClass, required);

    }

   

    @SuppressWarnings("unchecked")

    private static BeanDefinition parse(Element element, ParserContext parserContext, Class<?> beanClass, boolean required) {

        RootBeanDefinition beanDefinition = new RootBeanDefinition();

        beanDefinition.setBeanClass(beanClass);

        beanDefinition.setLazyInit(false);

        String id = element.getAttribute("id");

   /** 下面略*/

 

我们直接看parse操作,beanDefinition.setBeanClass(beanClass);直接将传入的beanClass作为BeanDefinition要创建的Spring Bean的类型,于是乎,我们知道了,所有的Dubbo消费者Bean都是ReferenceBean类型的对象,interface属性中配置的接口只是让ReferenceBean对象知道Dubbo的服务提供方提供的方法签名而已。但问题立马来了,既然是ReferenceBean类型的对象,但我们确实使用的不应该是interface配置的类型的实例吗?,比如我们都是这样使用这个Bean的:

 

@Autowired

privateConfigRemoteService configRemoteService;

 

它似乎就是ConfigRemoteService类型,而不是ReferenceBean类型,于是我们想到了,Dubbo肯定在某个地方创建了一个实现了该interface(比如上面的com.manzhizhen.biz.ConfigRemoteService)类型的对象,一般来说,Dubbo的消费者模块中只有服务提供者模块暴露的API所以,需要能在Java体系中的动态创建对象,你一定立马想到了动态代理

ReferenceConfigReferenceBean的父类,它存储了一些配置信息,我们看看ReferenceConfig中几个比较重要的成员变量:

 

private static final ProxyFactory proxyFactory = ExtensionLoader.getExtensionLoader(ProxyFactory.class).getAdaptiveExtension();

// 接口类型

private String               interfaceName;

private Class<?>             interfaceClass;

// 接口代理类引用

private transient volatile T ref;

private transient volatile Invoker<?> invoker;

 

这里我们直接看到了代理工厂proxyFactory还有表示interface配置的类型的interfaceNameinterfaceClassref正是用来存储代理工厂proxyFactory创建出来的代理类!不信我们可以先看看ReferenceConfig中的几个方法:

 

public synchronized T get() {

    if (destroyed){

        throw new IllegalStateException("Already destroyed!");

    }

   if (ref == null) {

      init();

   }

   return ref;

}

 

private void init() {

if (initialized) {

         return;

}

/** 此处有省略*/

     if (ProtocolUtils.isGeneric(getGeneric())) {

         interfaceClass = GenericService.class;

     } else {

         try {

               interfaceClass = Class.forName(interfaceName, true, Thread.currentThread()

           .getContextClassLoader());

         } catch (ClassNotFoundException e) {

               throw new IllegalStateException(e.getMessage(), e);

         }

         checkInterfaceAndMethods(interfaceClass, methods);

     }

/** 此处有大量省略*/

    //attributes通过系统context进行存储.

    StaticContext.getSystemContext().putAll(attributes);

    ref = createProxy(map);

}

 

private T createProxy(Map<String, String> map) {

       /** 此处有大量省略*/

       Boolean c = check;

       if (c == null && consumer != null) {

           c = consumer.isCheck();

       }

       if (c == null) {

           c = true; // default true

       }

       if (c && ! invoker.isAvailable()) {

           throw new IllegalStateException("Failed to check the status of the service " + interfaceName + ". No provider available for the service " + (group == null ? "" : group + "/") + interfaceName + (version == null ? "" : ":" + version) + " from the url " + invoker.getUrl() + " to the consumer " + NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion());

       }

       if (logger.isInfoEnabled()) {

           logger.info("Refer dubbo service " + interfaceClass.getName() + " from url " + invoker.getUrl());

       }

       // 创建服务代理

       return (T) proxyFactory.getProxy(invoker);

   }

 

这里先简单介绍下Dubbo中的InvokerInvocation两个接口,Invoker定义了Dubbo服务调用者的基本操作行为,而Invocation描述调用过程中的方法信息,可理解成调用的上下文信息,我们直接看看这两个接口的定义:

 

public interface Invoker<T> extends Node {

    /**

     * get service interface.

     *

     * @return service interface.

     */

    Class<T> getInterface();

 

    /**

     * invoke.

     *

     * @param invocation

     * @return result

     * @throws RpcException

     */

    Result invoke(Invocation invocation) throws RpcException;

}

 

public interface Invocation {

       /** 为了缩短篇幅,常规的注释这里省略了*/

   String getMethodName();

 

   Class<?>[] getParameterTypes();

 

   Object[] getArguments();

 

   Map<String, String> getAttachments();

  

   String getAttachment(String key);

  

   String getAttachment(String key, String defaultValue);

 

   Invoker<?> getInvoker();

}

 

可以看到,这两个接口的定义有点类似于反射API中的相关定义,没错,调用就是调用,简单可扩展即可。我们知道可以在Dubbo中通过SPI的方式定义些拦截器(Filter),而拦截器中就可以使用Invoker#invoke来进行递归调用了。

 

可见ReferenceConfig#get方法直接将代理工厂创建的代理对象返回,而该方法最终会被ReferenceConfig的子类ReferenceBeangetObject方法调用:

 

public Object getObject() throws Exception {

    return get();

}

 

我们知道,在Spring容器中,会利用BeanDefinition对象信息来初始化创建之后的Bean对象,但如果你想插手“创建对象”这一步,有两种方法:1.使用工厂方法模式来指定某个工厂方法创建Bean2. Bean的类实现FactoryBean接口,没错,Dubbo中就是用第二种方法来插手Bean对象创建这一步,所以显然ReferenceBean实现了FactoryBean接口,而getObject()正是FactoryBean接口中定义的,这也就是为什么我们可以直接用interface属性中配置的类型来直接使用该Dubbo消费者对象的原因了。这样就解释了我们上面抛出的问题。

 

那么,Dubbo也像Spring容器中那样默认对接口实现使用JDK代理,而对非接口实现使用CGLib方式来代理吗?我们上面又看到,代理对象是以Invoker对象为基础创建的(return (T) proxyFactory.getProxy(invoker);),在Dubbo中,定义了一个代理工厂接口ProxyFactory

 

@SPI("javassist")

public interface ProxyFactory {

 

    @Adaptive({Constants.PROXY_KEY})

    <T> T getProxy(Invoker<T> invoker) throws RpcException;

 

    @Adaptive({Constants.PROXY_KEY})

    <T> Invoker<T> getInvoker(T proxy, Class<T> type, URL url) throws RpcException;

}

 

抽象类AbstractProxyFactory实现了它的getProxy方法:

 

public abstract class AbstractProxyFactory implements ProxyFactory {

    public <T> T getProxy(Invoker<T> invoker) throws RpcException {

        Class<?>[] interfaces = null;

        String config = invoker.getUrl().getParameter("interfaces");

        if (config != null && config.length() > 0) {

            String[] types = Constants.COMMA_SPLIT_PATTERN.split(config);

            if (types != null && types.length > 0) {

                interfaces = new Class<?>[types.length + 2];

                interfaces[0] = invoker.getInterface();

                interfaces[1] = EchoService.class;

                for (int i = 0; i < types.length; i ++) {

                    interfaces[i + 1] = ReflectUtils.forName(types[i]);

                }

            }

        }

        if (interfaces == null) {

            interfaces = new Class<?>[] {invoker.getInterface(), EchoService.class};

        }

        return getProxy(invoker, interfaces);

    }

   

    public abstract <T> T getProxy(Invoker<T> invoker, Class<?>[] types);

}

 

可以看出,AbstractProxyFactory#getProxy的通用实现,其实主要是将该代理需要实现的接口给确定好,该接口存储在invoker对象的urlinterfaces参数中,是一个字符串,用逗号分隔,我们不需要关心interfaces中存储的到底是哪些接口,只需要知道的是,invoker.getInterface()会加入到其中,而另一个重载的getProxy方法显然是丢给子类来实现了。AbstractProxyFactory有两个实现类:JdkProxyFactoryJavassistProxyFactory,顾名思义,一个是使用JDK的动态代理,一个是使用Javaassist来实现动态代理,我们直接看JdkProxyFactory的实现:

 

public class JdkProxyFactory extends AbstractProxyFactory {

    @SuppressWarnings("unchecked")

    public <T> T getProxy(Invoker<T> invoker, Class<?>[] interfaces) {

        return (T) Proxy.newProxyInstance(Thread.currentThread().getContextClassLoader(), interfaces, new InvokerInvocationHandler(invoker));

    }

 

    public <T> Invoker<T> getInvoker(T proxy, Class<T> type, URL url) {

        return new AbstractProxyInvoker<T>(proxy, type, url) {

            @Override

            protected Object doInvoke(T proxy, String methodName,

                                      Class<?>[] parameterTypes,

                                      Object[] arguments) throws Throwable {

                Method method = proxy.getClass().getMethod(methodName, parameterTypes);

                return method.invoke(proxy, arguments);

            }

        };

    }

}

 

JdkProxyFactorygetProxy方法中我们看到了熟悉的类:InvokerInvocationHandler,很显然它实现了JDK中的InvocationHandler接口:

 

public class InvokerInvocationHandler implements InvocationHandler {

    private final Invoker<?> invoker;

 

    public InvokerInvocationHandler(Invoker<?> handler){

        this.invoker = handler;

    }

 

    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {

        String methodName = method.getName();

        Class<?>[] parameterTypes = method.getParameterTypes();

        if (method.getDeclaringClass() == Object.class) {

            return method.invoke(invoker, args);

        }

        if ("toString".equals(methodName) && parameterTypes.length == 0) {

            return invoker.toString();

        }

        if ("hashCode".equals(methodName) && parameterTypes.length == 0) {

            return invoker.hashCode();

        }

        if ("equals".equals(methodName) && parameterTypes.length == 1) {

            return invoker.equals(args[0]);

        }

        return invoker.invoke(new RpcInvocation(method, args)).recreate();

    }

}

 

也像我们预期那样,invoke操作是由invoker对象来完成的,这里的recreateResult中的方法,只是对结果进行“再处理”,如果没异常就返回,有异常则再次抛出。

 

所以,看到这我们就明白了,在Dubbo中,没有使用CGLib进行代理,而是使用JDKJavassist来进行动态代理!我们知道,动态代理是无法用反射做的,只能靠动态生成字节码,这就需要使用字节码工具包,比如asmJavassist等,在Spring3.2.2之前版本的源码中,我们可以看到是有单独spring-asm的模块的,但在Spring3.2.2版本开始,就没有spring-asm模块了,不是不使用了,而是spring-asm已经整合到spring-core中了,可见asmSpring中的地位(CGLib使用的就是asm),至于Dubbo为什么不使用CGLib,当我们选择动态代理实现时,无非考虑的是如下因素:

  1. 使用的难易程度。
  2. 功能,比如JDK的代理只能通过接口实现,而CGLib则没这个限制。
  3. 生成的字节码的效率,包括创建的效率和运行的效率。
  4. 生成的字节码大小,为什么说这也比较重要?这和生成的Class和其实例的大小相关。

至于具体的原因,可以参考Dubbo作者的博客:http://javatar.iteye.com/blog/814426

 

那么,接下来的问题就是,什么时候会使用JDK的动态代理,而什么时候使用Javassist的动态代理呢?dubbo-rpc-api的模块中,有个com.alibaba.dubbo.rpc.ProxyFactory文件,里面定义了代理的几种方式:

 

stub=com.alibaba.dubbo.rpc.proxy.wrapper.StubProxyFactoryWrapper

jdk=com.alibaba.dubbo.rpc.proxy.jdk.JdkProxyFactory

javassist=com.alibaba.dubbo.rpc.proxy.javassist.JavassistProxyFactory

 

StubProxyFactoryWrapper是存根(stub)的代理工厂,主要用于暴露服务提供者的本地服务给远端消费者来调用。可以直接通过xml的配置来手动选择代理,比如:

<dubbo:provider proxy="jdk" /><dubbo:consumer proxy="jdk" />

如果不配置,由于ProxyFactory接口上有@SPI("javassist")注解,所以默认是使用Javassist来实现动态代理!

 

具体细节可以深入源码去了解,这里不多做介绍。

 

疑惑二:当有多个服务提供者存在时,Dubbo是怎么做负载均衡的?

我们想知道消费者选择提供者时,是怎样选择远端的服务者的?轮询还是权重?

我们先探讨负载均衡LoadBalance,在Dubbo的源码中,它是在dubbo-cluster模块中来实现的,我们看看dubbo-cluster模块中com.alibaba.dubbo.rpc.cluster.LoadBalance文件中的内容:

 

random=com.alibaba.dubbo.rpc.cluster.loadbalance.RandomLoadBalance

roundrobin=com.alibaba.dubbo.rpc.cluster.loadbalance.RoundRobinLoadBalance

leastactive=com.alibaba.dubbo.rpc.cluster.loadbalance.LeastActiveLoadBalance

consistenthash=com.alibaba.dubbo.rpc.cluster.loadbalance.ConsistentHashLoadBalance

 

这下我们一看就知道Dubbo中有四种LB的方式:随机、轮询、最少活跃和一致哈希。在这之前,我们先来看看负载均衡的接口LoadBalance

 

@SPI(RandomLoadBalance.NAME)

public interface LoadBalance {

   /**

    * select one invoker in list.

    *

    * @param invokers invokers.

    * @param url refer url

    * @param invocation invocation.

    * @return selected invoker.

    */

    @Adaptive("loadbalance")

   <T> Invoker<T> select(List<Invoker<T>> invokers, URL url, Invocation invocation) throws RpcException;

}

 

接口LoadBalance 的定义说明,LoadBalance 的实现只是在一个服务提供的调用者列表(invokers)中选出一个调用者即可,默认的负载方式是随机负载均衡(@SPI(RandomLoadBalance.NAME)),我们也可以指定使用哪种负载均衡:

<dubbo:reference interface="xxx" loadbalance="roundrobin"/>    <dubbo:service interface="xxx" loadbalance="roundrobin" />

 

肯定有人会问,普通的随机负载均衡和轮询的负载均衡方式效果不是一样的吗?确实,如果是普通的随机,理论上来说和轮询的方式效果一致,甚至有时候还不如轮询的好,因为这和采取的随机数的随机程度随机数生成开销两种因素有关,但如果在随机过程中加入权重这一属性的话,随机的优势不言而喻了,比如可以做到“预热”功能,给刚上的服务器在某段时间内分配比其他服务器更少的请求,让刚上的服务器能先“热热身”,这一点,普通轮询方式是很难做到的。没错,Dubbo默认的随机负载方式就加入了权重这一因数,权重精确到某个接口的某个方法,这也是我们所期望的,其默认“预热”时间是10分钟

 

Dubbo中有个抽象类AbstractLoadBalance,它实现了获取某个接口某个方法的权重值,预热部分的计算也包含在其中,这里代码就不贴出来了,之所以Dubbo这样做,是因为其他负载形式都用到权重因子。

 

我们这里简单描述下各种负载均衡的实现方式:

随机负载均衡(RandomLoadBalance:先统计所有服务器上该接口方法的权重总和,然后对这个总和随机nextInt一下,看生成的随机数落到哪个段内,就调哪个服务器上的该服务。

轮询负载均衡(RoundRobinLoadBalance):如果所有服务器的该接口方法的权重一样,则直接内部的序列计数器(sequences+1然后对服务器的数量进行取模来决定调用哪个服务器上的服务;如果服务器的该接口方法的权重不一样(就是说存在预热中的服务器),则找到其中最大的权重,然后将内部的权重计数器(weightSequences+1并对该最大权重数取模,然后再找出权重比该取模后的值大服务器列表,最后通过内部的序列计数器(sequences+1然后对服务器列表数量进行取模来决定调用哪个服务器上的服务。

最少活跃负载均衡(LeastActiveLoadBalance:每个接口和接口方法都对应一个RpcStatus对象,记录了他们的活跃数、失败数等等相关统计信息,此种负载均衡方式是在活跃数最低的服务器中对其权重的总和取模来看结果是在哪个权重段中,则选择该服务器来调用,活跃数就像并发量降级中的计数器一样,开始调用时活跃数+1,调用结束时活跃数-1,所以活跃值越大,表明该提供者服务器的该接口方法耗时越长,而消费能力强的提供者接口往往活跃值很低。最少活跃负载均衡保证了“慢”提供者能接收到更少的服务器调用。

一致哈希负载均衡(ConsistentHashLoadBalance):一致性哈希算法的负载均衡保证了同样的请求(参数)将会落到同一台服务器上,这在某些场景是非常有用的,Dubbo中默认采用了160个虚拟节点,因为Dubbo的请求URL中除了我们使用的参数,还有些额外的系统调用参数,比如timestamploadbalancepidapplication等,有人可定会问,Dubbo会对URL中哪些参数进行hashDubbo默认除了对我们接口所有参数进行hash外,还会加上这些额外参数,因为有timestamp,这是不是也意味着在Dubbo的重试调用时timestamp不变?

 

上述的四种负载均衡,除了一致性哈希,其他三种都依赖了接口方法的权重统计,借助权重的不同,随机负载均衡就能做到动态调整的效果,Dubbo中的轮询负载方式,也利用了权重,那么有人会问,Dubbo中的随机和轮询是不是差别不大?是的,笔者也这样认为,相似的效果,也有着相似的缺点,Dubbo中的随机和轮询负载都没有考虑到提供者服务器消费服务的能力,如果相差很大,“慢”提供者有可能被“快”提供给者给拖垮,其根本原因也是这两种负载均衡的加权因子考虑的不是服务耗时。最少活跃的负载均衡就很巧妙的解决了此问题,而且它不是直接通过统计服务调用的耗时,而是采用统计调用差(活跃数)。一致性哈希特别适用于有缓存的系统,这样缓存命中率会比较高。

 

 

一句话总结本文,虽然动态代理和负载均衡没有直接的关系,但因为看源码看到这里了,所以写篇文章“纪念”一下,带着问题看源码往往就是这种效果。可以看出,Dubbo的设计者,在很多细节上都下足了功夫,从动态代理的选型和负载的多种实现方式就可以看出来,好的软件框架,不仅需要有好的架构设计,技术细节实现起来也不能马虎。本来想写更多,但有人和我说过,技术博文不要太长… …

1
1
分享到:
评论
9 楼 manzhizhen 2018-05-14  
xiangqianzou_liu 写道
"所以显然ReferenceConfig实现了FactoryBean接口",这里有问题噢,ReferenceConfig 没有实现FactoryBean接口,而是ReferenceBean 直接实现的。


看得很仔细,我修改下!!
8 楼 xiangqianzou_liu 2018-05-14  
"所以显然ReferenceConfig实现了FactoryBean接口",这里有问题噢,ReferenceConfig 没有实现FactoryBean接口,而是ReferenceBean 直接实现的。
7 楼 manzhizhen 2017-07-06  
yingwuluohan 写道
楼主我想问个dubbo超时的问题哈。我的应用有很多个服务由于业务流程多,对DB操作时间又过长导致时常发生服务请求超时的情况,如果不考虑对DB和服务端做优化,那么当服务端接口超时的时候一般有什么好的处理方案吗?以便给消费的服务一个好的处理超时的结果(除了熔断和dubbo本身的mock )


其实我们应该努力提高的是Provider的可用性,而不是在Consumer端做多么健全的兜底方案,很多因素会造成调用超时,这时候我一般就在Consumer捕获超时异常然后返回默认值就行了,你说的对下游进行自动降级已经是比较高级的方案了,但需要特殊的中间件或工具来支持
6 楼 yingwuluohan 2017-07-04  
楼主我想问个dubbo超时的问题哈。我的应用有很多个服务由于业务流程多,对DB操作时间又过长导致时常发生服务请求超时的情况,如果不考虑对DB和服务端做优化,那么当服务端接口超时的时候一般有什么好的处理方案吗?以便给消费的服务一个好的处理超时的结果(除了熔断和dubbo本身的mock )
5 楼 manzhizhen 2017-06-25  
yingwuluohan 写道
sorry ,看到了……

相互学习,哈哈

4 楼 yingwuluohan 2017-06-22  
sorry ,看到了……
3 楼 yingwuluohan 2017-06-22  
楼主能麻烦下发个地址呗,我翻了半天没找到啊
2 楼 manzhizhen 2017-06-18  
有写的哇。。。
1 楼 yingwuluohan 2017-06-07  
良心博主啊,见解深刻,敢问博主的第三篇和第四篇的dubbo讲解是没有写吗?

相关推荐

    Dubbo源代码(2.8.4)

    总的来说,Dubbo 2.8.4的源代码是一个深度学习分布式服务治理框架的好材料,它揭示了服务治理的核心机制和实现细节,对于理解微服务架构和提升Java开发能力大有裨益。通过深入研究,开发者可以更好地利用Dubbo来构建...

    Dubbo源代码(2.5.4)

    【Dubbo源代码(2.5.4)】是一份重要的开源项目资源,它包含了Dubbo框架在2.5.4版本的完整源代码。Dubbo是中国阿里巴巴公司贡献的高性能、轻量级的服务治理框架,它专注于服务调用、监控和服务治理。这个版本的源...

    Dubbo源代码分析之远程调用过程(2.5.4开发版)

    该文档分析了 Dubbo 框架中 RPC 调用的整个流程,并基于源代码按照执行 时序进行说明,源码版本为2.5.4开发版。 涉及的关键点包括:Invocation、Invoker、Directory、路由、负载均衡、集群容错、过滤器以及监控模块...

    dubbo2.8.4源代码

    【描述】"git下载,调整pom文件,通过mvn install -Dmaven.test.skip=true打包" 这段描述揭示了获取和构建Dubbo源代码的过程。首先,使用Git工具从官方仓库克隆源代码,这涉及到Git的基本操作如`git clone`。其次,...

    dubbo调用示例

    Dubbo的负载均衡策略(如随机、轮询、最少活跃调用数等)会在多个服务实例间分配请求,确保系统的高可用性。 此外,Dubbo还提供了监控、熔断、降级等高级特性,帮助开发者更好地管理和维护分布式系统。通过学习和...

    Spring+mybatis+dubbo整合源代码及jar包

    Dubbo2.5.3版本在服务治理、监控、容错等方面有显著提升,支持基于接口的透明化调用,具备动态配置、服务注册与发现、负载均衡、熔断和降级等特性,是构建分布式系统的关键组件。 将这三个框架整合在一起,可以构建...

    阿里巴巴dubbo-2.5.4源代码

    Dubbo提供了多种负载均衡策略,如随机、轮询、权重等,源代码中这些策略的实现可以帮助我们理解如何在多台服务提供者间进行智能调度。 5. **监控与调用链跟踪** `Monitor`接口是监控服务的核心,用于收集服务调用...

    SSM+dubbo项目源代码

    SSM+dubbo项目源代码是基于Spring、SpringMVC、MyBatis以及Dubbo构建的微服务架构。这个项目展示了如何将这些技术有效地整合在一起,以实现高效、可扩展的分布式系统。 首先,Spring框架是Java领域最广泛使用的依赖...

    Dubbo分布式服务管理

    总结来说,Dubbo分布式服务管理是构建大规模分布式系统的基石,通过Maven项目管理和Dubbo的组件机制,可以有效地实现服务的发布、消费、监控,提升系统的可扩展性和稳定性。对于开发者而言,理解和掌握Dubbo的使用,...

    Dubbo源码(注释版)

    Dubbo是中国阿里巴巴公司开源的一款高性能、轻量级的Java服务框架,它主要专注于服务治理,包括服务注册、发现、调用、负载均衡、容错、监控等。此压缩包提供的" Dubbo源码(注释版)"是针对Dubbo 2.7.3版本的源代码...

    dubbo学习后自己的源代码

    本项目是基于Dubbo的学习实践,包含了作者自己编写的源代码,分为三个部分:`dubbo-demo-api`、`dubbo-demo-provider_api`和`dubbo-demo-consumer_api`,分别代表了服务接口定义、服务提供者和服务消费者。...

    dubbo-3.1.4源码包

    在【压缩包子文件的文件名称列表】"apache-dubbo-3.1.4-src"中,你可以找到dubbo的主要模块和源代码,包括: 1. `dubbo-common`:包含了dubbo的核心通用模块,如配置管理、日志处理、序列化等。 2. `dubbo-remoting...

    Dubbo服务框架 v2.7.22.zip

    3. **负载均衡**:Dubbo内置了多种负载均衡策略,如轮询、随机、权重等,可以根据实际情况选择合适的策略,确保服务调用的均衡性。 4. **集群容错**: Dubbo支持故障转移、失败重试、失效剔除等多种集群容错策略,...

    eclipse 中实现dubbo provider、customer源代码及zookeeper、dubbo-admin压缩包

    在本压缩包中,你将找到关于如何在Eclipse环境中实现Dubbo服务提供者(Provider)和服务消费者(Consumer)的源代码,以及如何利用Zookeeper作为注册中心和Dubbo管理员控制台(dubbo-admin)的相关资源。这个压缩包...

    dubbo实例代码

    而“src”目录则是源代码存放的地方,可能包含服务提供者和服务消费者的实现代码,以及相应的配置文件,如dubbo配置、Zookeeper连接配置等。通过这些代码,我们可以进一步了解如何在实际项目中集成和使用Dubbo和...

    alibaba-dubbo-dubbo-2.5.7-0-ge2d63ad.tar.gz

    通过研究这些源代码,开发者可以了解到Dubbo如何处理服务的注册与发现、如何实现RPC通信、如何进行服务路由和负载均衡等核心功能。此外,还可以学习到Dubbo如何与其他组件如Zookeeper、Spring等进行集成,以及如何...

    dubbo-2.5.4官网源码下载

    Dubbo由阿里巴巴开发并捐赠给Apache基金会,它提供了包括服务注册与发现、负载均衡、容错、监控等一系列微服务治理功能。在下载dubbo-2.5.4版本的源码后,我们可以深入学习和理解以下关键概念和技术: 1. **服务...

    dubbo源码解析2

    Dubbo是一个高性能、轻量级的开源Java RPC框架,它提供了服务自动注册与发现、透明化的远程方法调用、智能负载均衡等功能。Dubbo的设计理念是“为服务而生”,旨在简化微服务架构下的服务管理和调用。 #### 三、...

    dubbo多个版本-jar包

    Dubbo是中国阿里巴巴公司开源的一款高性能、轻量级的Java服务治理框架,它主要负责服务的注册、发现、调用以及负载均衡等任务。这个压缩包文件包含的是从dubbo-2.0.10到dubbo-2.5.2-sources的多个版本的jar包,这些...

    灰度系统(基于dubbo、spring扩展实现的接入层灰度、服务层灰度、mq灰度、外部调用灰度,支持多套灰度环境).zip

    在灰度发布场景下,dubbo可以通过配置不同的权重来控制不同版本服务的调用比例,从而实现服务层的灰度测试。比如,新旧版本的服务可以分配不同的权重,新服务逐渐增加权重,以渐进式地将流量切换到新版本。 2. **...

Global site tag (gtag.js) - Google Analytics