Skip to content

xwbGithub/springBoot-dubbo

BranchesTags

Repository files navigation

#dubbo-project dubbo 项目开发.

spring普通方式集成dubbo:
order-service-consumer(服务消费者):
user-service-provider(服务提供者)

集成SpringBoot开发dubbo框架
boot-order-service-consumer(服务消费者)
boot-user-service-provider(服务提供者)

版本之间的对应关系 Dependencies
对应网址

Dependencies

versions Java Spring Boot Dubbo
0.2.0 1.8+ 2.0.x 2.6.2 +
0.1.1 1.7+ 1.5.x 2.6.2 +

dubbo和zookeeper的版本匹配关系

 <!-- dubbo依赖 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
             <version>2.6.5</version>
        </dependency>
        <!-- 引入注册中心 -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>
        <!--  因为导入的dubbo是2.6.5,所以此处需要导入对应版本的zk -->
        <!--dubbo-2.6.2之前使用以下zk -->
        <!--
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.11</version>
        </dependency>
        -->

属性的覆盖策略

官网描述如下
共3个文件.

dubbo.properties、application.yml、-D(虚拟机参数设定)

> ==>优先级为-D >dubbo.xml>dubbo.properties(测试请看dubbo.properties描述)

启动时检查

官网介绍
通过 spring 配置文件 关闭某个服务的启动时检查 (没有提供者时报错)：

<dubbo:reference interface="com.foo.BarService" check="false" />

关闭所有服务的启动时检查 (没有提供者时报错)：

<dubbo:consumer check="false" />

关闭注册中心启动时检查 (注册订阅失败时报错)：

<dubbo:registry check="false" />

通过 dubbo.properties

dubbo.reference.com.foo.BarService.check=false
dubbo.reference.check=false
dubbo.consumer.check=false
dubbo.registry.check=false

通过 -D 参数

java -Ddubbo.reference.com.foo.BarService.check=false
java -Ddubbo.reference.check=false
java -Ddubbo.consumer.check=false 
java -Ddubbo.registry.check=false

配置覆盖关系

以 timeout 为例，显示了配置的查找顺序，其它 retries, loadbalance, actives 等类似：

方法级优先，接口级次之，全局配置再次之。
如果级别一样，则消费方优先，提供方次之。
其中，服务提供方配置，通过 URL 经由注册中心传递给消费方。



综上所述：

精确优先：方法>接口>全局
消费者设置优先：如果级别一样,方法消费方>提供方

其官网介绍如下

重试次数

retries="2"
失败自动切换，当出现失败，重试其它服务器 [1]。通常用于读操作，但重试会带来更长延迟。可通过 retries="2" 来设置重试次数(不含第一次)。
重试次数配置如下：

 <dubbo:service retries="2" />

或者

 <dubbo:reference retries="2" />

或者

 <dubbo:reference>
     <dubbo:method name="findFoo" retries="2" />
 </dubbo:reference>

多版本

当一个接口实现，出现不兼容升级时，可以用版本号过渡，版本号不同的服务相互间不引用。

可以按照以下的步骤进行版本迁移：

  • 在低压力时间段，先升级一半提供者为新版本
  • 再将所有消费者升级为新版本
  • 然后将剩下的一半提供者升级为新版本

老版本服务 提供者 配置：

@com.alibaba.dubbo.config.annotation.Service(version = "1.0.0") //暴露服务
@Component
public class UserServiceImpl1 implements UserService {
}

新版本提供者 配置：

@com.alibaba.dubbo.config.annotation.Service(version = "2.0.0") //暴露服务
@Component
public class UserServiceImpl2 implements UserService {
   }

服务消费者选择版本调用

调用指定版本

 @Service
 public class UserServiceImpl implements OrderService {
     @Reference(version="1.0.0") 
     private UserService userService;

或者任意匹配

    @Service
    public class UserServiceImpl implements OrderService {
        @Reference(version="*")
        private UserService userService;

注意:本人在测试调用多版本的过程中使用以下配置(消费者端的配置)启动服务报错,没有试出来

dubbo:
  application:
    name: order-service-consumer #服务名称
  consumer:
    version: *  #匹配任意的版本进行调用

springBoot与Dubbo的三种连接方式

第1种方式

1、导入dubbo-starter
2、在application.properties中配置dubbo的属性
2.1、使用@Service 暴露服务 是dubbo的jar包注解
2.2、使用@Reference 引用服务 是dubbo的jar包注解
3、在主启动类添加@EnableDubbo注解

作用：开启基于dubbo的注解功能(2中实现方式)

3.1、直接在主启动类上添加注解

     @SpringBootApplication
     @EnableDubbo //开启基于dubbo的注解功能
     public class BootOrderServiceConsumerApplication {
         public static void main(String[] args) {
             SpringApplication.run(BootOrderServiceConsumerApplication.class, args);
         }
     }

3.2、在application.properties中使用包扫描

   dubbo.scan.base-packages=com.atguigu.gmail.service.impl #包扫描(和主类的@EnableDubbo的作用相同)

第2种方式(基于xml的ImportResource导入方式)

1、保留dubbo.xml配置文件的方式(里面配置dubbo的基本信息)
2、导入dubbo-starter
3、在主启动类引入配置文件@ImportResource

提供者

    @SpringBootApplication
    @ImportResource(locations = "classpath:provider.xml")
    public class BootUserServiceProviderApplication {
        public static void main(String[] args) {
            SpringApplication.run(BootUserServiceProviderApplication.class, args);
        }
    }

消费者

    @SpringBootApplication
    @ImportResource(locations = "classpath:consumer.xml")
    public class BootOrderServiceConsumerApplication {
        public static void main(String[] args) {
            SpringApplication.run(BootOrderServiceConsumerApplication.class, args);
        }
    }

第3种方式(基于注解api的方式)

将每一个组件放入到DubboConfig中

@Configuration
public class MyDubboConfig {
    /**
     * 相当于此bean替代了dubbo.application.* 标签
     *
     * @return applicationConfig
     */
    @Bean
    public ApplicationConfig applicationConfig() {
        ApplicationConfig applicationConfig = new ApplicationConfig();
        applicationConfig.setName("user-service-provider");//设置应用名
        return applicationConfig;
    }

    /**
     * 设置注册中心配置
     *
     * @return
     */
    @Bean
    public RegistryConfig registryConfig() {
        RegistryConfig registryConfig = new RegistryConfig();
        registryConfig.setAddress("127.0.0.1");
        registryConfig.setPort(2181);
        registryConfig.setProtocol("zookeeper");
        registryConfig.setCheck(false);
        return registryConfig;
    }
    /**
     * 服务提供接口
     * @param userService 入参的userService<br>
     *                    是从ioc中拿去 @Component public class UserServiceImpl implements UserService {...}
     * @return
     */
    @Bean
    public ServiceConfig<UserService> userServiceServiceConfig(UserServiceImpl userService) {
        ServiceConfig<UserService> serviceConfig = new ServiceConfig<>();
        serviceConfig.setInterface(UserService.class);
        serviceConfig.setRef(userService);
        serviceConfig.setVersion("1.0.0");
        serviceConfig.setTimeout(3000);
        serviceConfig.setRetries(3);

        //配置每一个method的属性
        MethodConfig methodConfig = new MethodConfig();
        methodConfig.setName("getUserAddressList");
        methodConfig.setTimeout(3000);
        methodConfig.setRetries(2);

        //将method的设置关联到service的配置中
        List<MethodConfig> methods = new ArrayList();
        methods.add(methodConfig);
        serviceConfig.setMethods(methods);

        return serviceConfig;
    }
    //每一个dubbo:xxx都对应一个xxxxConfig的配置
}

然后在主启动类上添加注解@DubboComponentScan

@SpringBootApplication
@DubboComponentScan(basePackages = "com.atguigu.gmail")
public class BootUserServiceProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(BootUserServiceProviderApplication.class, args);
    }
}

#高可用

duobbo直连

现象：zookeeper注册中心宕机，还可以消费dubbo暴露的服务

@Service
public class UserServiceImpl implements OrderService {
    @Reference(url = "127.0.0.1:20881")
    private UserService userService;
    //...
    }

loadBalance

负载均衡 客户端,服务端,都可配置此属性

@Service
public class UserServiceImpl implements OrderService {
    @Reference(loadbalance = "roundrobin")//负载均衡机制
    private UserService userService;
}

服务容错

服务端配置

添加依赖

 <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            <version>1.4.4.RELEASE</version>
        </dependency>

添加注解@EnableHystrix

@SpringBootApplication
@EnableDubbo /*开启基于注解的dubbo功能*/
@EnableHystrix //开启容错
public class BootUserServiceProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(BootUserServiceProviderApplication.class, args);
    }
}

在可能会出现的方法上面添加注解@HystrixCommand

@com.alibaba.dubbo.config.annotation.Service //暴露服务
@Component
public class UserServiceImpl implements UserService {
    @HystrixCommand
    @Override
    public List<UserAddress> getUserAddressList(String userId) {
        //......
        return null;
    }
}

客户端配置 主类添加注解

@SpringBootApplication
@EnableDubbo //开启基于dubbo的注解功能
@EnableHystrix
public class BootOrderServiceConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(BootOrderServiceConsumerApplication.class, args);
    }
}

方法上面添加容错机制

@Service
public class UserServiceImpl implements OrderService {
    @Reference(loadbalance = "roundrobin")//负载均衡机制
    private UserService userService;
    @Override
    @HystrixCommand
    public List<UserAddress> initOrder(String userId) {
        System.out.println("用户id" + userId);
        return userService.getUserAddressList(userId);
    }
    //容错方法
    public List<UserAddress> exceptionMethod() {
        List<UserAddress> arrayList = new ArrayList<>();
        UserAddress userAddress = new UserAddress();
        userAddress.setId(10);
        userAddress.setPhoneNum("123456");
        userAddress.setUserAddress("上海市");
        arrayList.add(userAddress);
        userAddress.setConsignee("测试");
        userAddress.setIsDefault("Y");
        return arrayList;
    }
}

dubbo原理



RPC调用原理如图：

  • 1 服务消费方（client）调用以本地调用方式调用服务；
  • 2 client stub接收到调用后负责将方法、参数等组装成能够进行网络传输的消息体；
  • 3 client stub找到服务地址，并将消息发送到服务端；
  • 4 server stub收到消息后进行解码；
  • 5 server stub根据解码结果调用本地的服务；
  • 6 本地服务执行并将结果返回给server stub；
  • 7 server stub将返回结果打包成消息并发送至消费方；
  • 8 client stub接收到消息，并进行解码；
  • 9 服务消费方得到最终结果。

1、dubbo原理-框架设计

官网地址



2、dubbo原理-启动解析、加载配置信息

3、dubbo原理-服务暴露

4、dubbo原理-服务引用

5、dubbo原理-服务调用

About

No description, website, or topics provided.

Resources

Readme
Activity

Stars

1 star

Watchers

0 watching

Forks

0 forks
Report repository

Releases

No releases published

Packages

No packages published

Languages