zoukankan      html  css  js  c++  java
  • dubbo-常用配置

    一、启动时检查

    官网说明:

    Dubbo 缺省会在启动时检查依赖的服务是否可用,不可用时会抛出异常,阻止 Spring 初始化完成,以便上线时,能及早发现问题,默认 check="true"

    可以通过 check="false" 关闭检查,比如,测试时,有些服务不关心,或者出现了循环依赖,必须有一方先启动。

    另外,如果你的 Spring 容器是懒加载的,或者通过 API 编程延迟引用服务,请关闭 check,否则服务临时不可用时,会抛出异常,拿到 null 引用,如果 check="false",总是会返回引用,当服务恢复时,能自动连上。

    在消费者一方的 dubbo-consumer.xml 配置里:

    <!--生成远程服务代理,可以和本地bean一样使用demoService
         ***** 启动时检查:
         check="true",Dubbo 缺省会在启动时检查依赖的服务是否可用,不可用时会抛出异常,阻止 Spring 初始化完成,以便上线时,能及早发现问题,默认 check="true"
        -->
        <dubbo:reference id="userFacade" interface="com.lhy.service.user.UserFacade" check="true" />

    只启动消费者,不启动生产者

    会报如下的错:

    org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'userController': 
    Injection of autowired dependencies failed; nested exception is org.springframework.beans.factory.BeanCreationException:
    Could not autowire field: private com.lhy.service.user.UserFacade com.lhy.consumer.controller.UserController.userFacade;
    nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'userFacade':
    FactoryBean threw exception on object creation; nested exception is java.lang.IllegalStateException:
    Failed to check the status of the service com.lhy.service.user.UserFacade.
    No provider available for the service com.lhy.service.user.UserFacade
    from the url zookeeper://192.168.85.3:2181/com.alibaba.dubbo.registry.RegistryService?application=lhy-consumer&check=true&dubbo=2.5.4&interface=com.lhy.service.user.UserFacade&methods=getById,getUsers,addUser&pid=13664&revision=1.0&side=consumer&timestamp=1541645721420 to the consumer 192.168.0.105 use dubbo version 2.5.4

    设置  check="fase" 则可以正常启动消费者,在调用该服务的时候,则会报错

    二、集群容错

    当服务提供者部署到多个机器的时候,此时可以配置集群容错,一般配置为Failover (缺省配置) 或者Failfast 即可。可以配置到提供者上,也可以配置到消费者上

    <!-- 声明需要暴露的服务接口 ,写操作可设置retries="0"避免重复调用SOA服务
             集群容错:
             cluster="failover":失败自动切换,当出现失败,重试其它服务器 [1]。通常用于读操作,但重试会带来更长延迟。可通过 retries="2" 来设置重试次数(不含第一次)。
             cluster="failfast" :快速失败,只发起一次调用,失败立即报错。通常用于非幂等性的写操作,比如新增记录。
             cluster="failsafe" :失败安全,出现异常时,直接忽略。通常用于写入审计日志等操作。
             cluster="failback":失败自动恢复,后台记录失败请求,定时重发。通常用于消息通知操作。
             cluster="forking":广播调用所有提供者,逐个调用,任意一台报错则报错 。通常用于通知所有提供者更新缓存或日志等本地资源信息。
             一般配置为failover,重试0次/或者failfast
        -->
        <dubbo:service retries="0" interface="com.lhy.service.user.UserFacade" ref="userFacade" cluster="failover"/>

     三、负载均衡

    dubbo的负载均衡可以通过xml配置,也可以在dubbo-admin管控台动态配置。一般使用管控台配置,更加灵活。

    一般配置为随机模式

    管控台配置负载均衡,可以对每个服务的每个方法设置负载均衡策略。(但是管控台的策略 没有一致性hash)

    xml配置,可以配在提供者,也可以配置在消费者:

    <dubbo:service"interface="...""loadbalance="roundrobin""/>
    或者
    <dubbo:reference"interface="...""loadbalance="roundrobin""/>

     四、直连提供者

    在开发及测试环境下,经常需要绕过注册中心,只测试指定服务提供者,这时候可能需要点对点直连,点对点直连方式,将以服务接口为单位,忽略注册中心的提供者列表,A 接口配置点对点,不影响 B 接口从注册中心获取列表。

    通过 XML 配置(消费者)

    <dubbo:reference id="accountFacade" interface="com.lhy.service.user.AccountFacade" url="dubbo://localhost:20880" />

    五、只订阅

    官方解释:为方便开发测试,经常会在线下共用一个所有服务可用的注册中心,这时,如果一个正在开发中的服务提供者注册,可能会影响消费者不能正常运行。

    可以让服务提供者开发方,只订阅服务(开发的服务可能依赖其它服务),而不注册正在开发的服务,通过直连测试正在开发的服务。

    只订阅 provider.xml配置:

    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
    
        <!--提供方应用信息,用户计算依赖关系-->
        <dubbo:application name="lhy-service"/>
    
        <!--使用zookeeper注册中心暴露服务地址-->
        <!--只订阅,不注册: register="false"
        开发阶段,只订阅zk中已有的服务(开发中的服务可能用到),而不向zk注册服务,配合直连使用,此时消费者通过直连来调用
        -->
        <dubbo:registry address="zookeeper://192.168.85.3:2181?backup=192.168.85.4:2181,192.168.85.5:2181" register="false"/>
        <!--<dubbo:registry"protocol="zookeeper""address="10.20.153.10:2181,10.20.153.11:2181,10.20.153.12:2181""/>-->
    
        <!-- 用dubbo协议在20880端口暴露服务 -->
        <dubbo:protocol name="dubbo" port="20880" />
    
        <!-- 声明需要暴露的服务接口 ,写操作可设置retries="0"避免重复调用SOA服务
             集群容错:
             cluster="failover":失败自动切换,当出现失败,重试其它服务器 [1]。通常用于读操作,但重试会带来更长延迟。可通过 retries="2" 来设置重试次数(不含第一次)。
             cluster="failfast" :快速失败,只发起一次调用,失败立即报错。通常用于非幂等性的写操作,比如新增记录。
             cluster="failsafe" :失败安全,出现异常时,直接忽略。通常用于写入审计日志等操作。
             cluster="failback":失败自动恢复,后台记录失败请求,定时重发。通常用于消息通知操作。
             cluster="forking":广播调用所有提供者,逐个调用,任意一台报错则报错 。通常用于通知所有提供者更新缓存或日志等本地资源信息。
             一般配置为failover,重试0次/或者failfast
        -->
        <dubbo:service retries="0" interface="com.lhy.service.user.UserFacade" ref="userFacade" cluster="failover"/>
    
        <dubbo:service retries="0" interface="com.lhy.service.user.ProductFacade" ref="productFacade" cluster="failover"/>
    
        <dubbo:service retries="0" interface="com.lhy.service.user.AccountFacade" ref="accountFacade" cluster="failover"/>
    
    
    </beans>

    消费者一方,consumer.xml ,通过直连来访问:

     <dubbo:reference id="accountFacade" interface="com.lhy.service.user.AccountFacade" url="dubbo://localhost:20880" />

    说白了就是,开发测试阶段,不让服务提供方往注册中心注册,但是能从注册中心订阅已有的服务(如果正开发的服务依赖某个服务的话,可以调用)。如果配置了只订阅,那么本 provider中所有的服务,只能通过 直连来访问。

  • 相关阅读:
    5js
    4js
    3js
    2js
    1js
    7css
    6css
    5css
    Django高级项目实战-开发企业级问答网站,学Django就这了
    Java日志第27天 2020.8.1
  • 原文地址:https://www.cnblogs.com/lihaoyang/p/9928266.html
Copyright © 2011-2022 走看看