Dubbo創建提供者、消費者項目（dubbo怎么使用）

需要先開啟zookeeper和dubbo

Dubbo環境搭建

 

spring版本

Dubbo服務提供消費者接口搭建

創建Maven項目=> gmail-interface 用於存放共同的服務接口（存放實體bean和接口interface）

創建Maven項目=> user-service-provider 服務提供者（提供接口實現類）（接口的實現類impl）

創建Maven項目=> order-service-consumer 服務消費者（使用到提供者的接口的實現類）（接口的實現類impl）

 

在接口項目中有自己的引用格式（pom.xml）（可以在其他maven項目中使用接口）（用於在消費者和提供者引用）

<groupId>com.atguigu.gmall</groupId>
<artifactId>gmall-interface</artifactId>
<version>0.0.1-SNAPSHOT</version>

 

 

在消費者和提供者 pom.xml 中引用dubbo，接口項目，zookeeper客戶端（也可使用其他的注冊中心，可在dubbo官網查詢）

    <!-- 引入接口項目的接口 -->
    <dependency>
        <groupId>com.atguigu.gmall</groupId>
        <artifactId>gmall-interface</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </dependency>
    <!-- 引入dubbo -->
    <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.6.2</version>
    </dependency>
    <!-- 注冊中心使用的是zookeeper，引入操作zookeeper的客戶端 -->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>2.12.0</version>
    </dependency>

 

在消費者（consumer.xml）和提供者（provider.xml）的resources下分別創建兩個xml（使用的是spring配置方式配置dubbo和zookeeper）（xml名字隨便取，之后使其ioc生效修改名字就行）

<?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.xsd
        http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!-- 1、指定當前服務/應用的名字（同樣的服務名字相同，不要和別的服務同名） -->
    <dubbo:application name="user-service-provider"></dubbo:application>
    
    <!-- 2、指定注冊中心的位置 -->
    <!-- <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry> -->
    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
    
    <!-- 3、指定通信規則（通信協議？通信端口） -->
    <dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>
    
    <!-- 4、暴露服務   ref：指向服務的真正的實現對象 -->
    <dubbo:service interface="com.atguigu.gmall.service.UserService" 
        ref="userServiceImpl01" timeout="1000" version="1.0.0">
        <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
    </dubbo:service>
    
    <!--統一設置服務提供方的規則  -->
    <dubbo:provider timeout="1000"></dubbo:provider>
    
    
    <!-- 服務的實現 -->
    <bean id="userServiceImpl01" class="com.atguigu.gmall.service.impl.UserServiceImpl"></bean>
    
    
    <dubbo:service interface="com.atguigu.gmall.service.UserService" 
        ref="userServiceImpl02" timeout="1000" version="2.0.0">
        <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
    </dubbo:service>
    <bean id="userServiceImpl02" class="com.atguigu.gmall.service.impl.UserServiceImpl2"></bean>
    
    <!-- 連接監控中心 -->
    <dubbo:monitor protocol="registry"></dubbo:monitor>
    
</beans>

<?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://dubbo.apache.org/schema/dubbo"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd
        http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <context:component-scan base-package="com.atguigu.gmall.service.impl"></context:component-scan>


    <dubbo:application name="order-service-consumer"></dubbo:application>
    
    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
    
    <!--  配置本地存根-->
    
    <!--聲明需要調用的遠程服務的接口；生成遠程服務代理  -->
    <!-- 
        1）、精確優先 (方法級優先，接口級次之，全局配置再次之)
        2）、消費者設置優先(如果級別一樣，則消費方優先，提供方次之)
    -->
    <!-- timeout="0" 默認是1000ms-->
    <!-- retries="":重試次數，不包含第一次調用，0代表不重試-->
    <!-- 冪等（設置重試次數）【查詢、刪除、修改】、非冪等（不能設置重試次數）【新增】 -->
    <dubbo:reference interface="com.atguigu.gmall.service.UserService" 
        id="userService" timeout="5000" retries="3" version="*">
        <!-- <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> -->
    </dubbo:reference>
        
    <!-- 配置當前消費者的統一規則：所有的服務都不檢查 -->
    <dubbo:consumer check="false" timeout="5000"></dubbo:consumer>

    <dubbo:monitor protocol="registry"></dubbo:monitor>
    <!-- <dubbo:monitor address="127.0.0.1:7070"></dubbo:monitor> -->
    
</beans>

 

 啟動檢查

 

超時（timeout，ms，設置提供者消費者使用超時時間，精確優先（方法先，接口后），消費者優先，）

重試（retries，設置重試次數不包括最開始調用，重試會調用其他的提供者）

 

 

 

 

 

 

 

 

多版本使用（version）

提供者

 

消費者

 

 

 

 

 本地存根（消費者先執行部分邏輯，再調用提供者服務）

需要先在接口應用處寫上接口

再在提供者位置上實現接口

public class UserServiceStub implements UserService {
    
    private final UserService userService;

    /**
     * 傳入的是userService遠程的代理對象
     * @param userService
     */
    public UserServiceStub(UserService userService) {
        super();
        this.userService = userService;
    }

    @Override
    public List<UserAddress> getUserAddressList(String userId) {
        // TODO Auto-generated method stub
        System.out.println("UserServiceStub.....");
        if(!StringUtils.isEmpty(userId)) {
            return userService.getUserAddressList(userId);
        }
        return null;
    }
}

提供者配置（stub）：

 

 

 

 

 

 springboot版本

SpringBoot與dubbo整合的三種方式：

1）、導入dubbo-starter，在主運行方法上使用@EnableDubbo在application.properties配置屬性，使用@Service【暴露服務】使用@Reference【引用服務】

2）、保留dubbo xml配置文件（spring中的xml配置）;

導入dubbo-starter，使用@ImportResource導入dubbo的配置文件（@ImportResource(locations="classpath:provider.xml")）即可

3）、使用注解API的方式：

將每一個組件手動創建到容器中,讓dubbo來掃描其他的組件

 

第一種方式（使用@Service【暴露服務】使用@Reference【引用服務】）

導入依賴（接口依賴，dubbo-spring-boot-starter依賴）（包含了dubbo，zookeeper）

        <dependency>
            <groupId>com.atguigu.gmall</groupId>
            <artifactId>gmall-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>

 

 

在application.properties中配置dubbo

dubbo.application.name=user-service-provider
dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper

dubbo.protocol.name=dubbo
dubbo.protocol.port=20881

dubbo.monitor.protocol=registry
dubbo.scan.base-packages=com.atguigu.gmall

 

提供者：

在springboot的主運行方法下開啟dubbo的注解功能（@EnableDubbo）

將提供者的   spring包下的注解@service換為@Component

並使用dubbo包下的注解@service（將接口暴露到dubbo中，能給其他應用提供接口）

 

 

 這樣就不需要大量的在springboot中配置了

 

 

消費者

開啟springboot主運行方法中的dubbo注解（@EnableDubbo）

在dubbo中遠程引用其他應用的接口

將@Autowired改為@Reference

 

 

application.xml（因為監控中心使用的是8080端口，所以應用我們使用8081端口）

server.port=8081

dubbo.application.name=boot-order-service-consumer
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.monitor.protocol=registry

 

負載均衡（根據什么規則分配任務給各個服務器，提供者，消費者都可以定義）

dubbo高可用機制（zk宕機，dubbo直連，負載均衡，服務降級，集群容錯整合hystrix）

詳情參考

隨機權重（dubbo默認）

@Reference(loadbalance="random")

輪詢權重

@Reference(loadbalance="random")

最小活躍（最小調用任務時長）

@Reference(loadbalance="leastactive")

 

第二種方式（和spring配置一樣）

導入dubbo-starter

導入依賴（接口依賴，dubbo-spring-boot-starter依賴）（包含了dubbo，zookeeper）

        <dependency>
            <groupId>com.atguigu.gmall</groupId>
            <artifactId>gmall-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>

 

保留provider.xml 和 consumer.xml

 

在消費者（consumer.xml）和提供者（provider.xml）的resources下分別創建兩個xml（使用的是spring配置方式配置dubbo和zookeeper）（xml名字隨便取，之后使其ioc生效修改名字就行）

 

 

 在springboot主運行方法上使用

@ImportResource(locations="classpath:provider.xml")

 

 

第三種方式（使用config將配置加入容器）

 在springboot主運行方法上使用掃描配置

@EnableDubbo(scanBasePackages="com.atguigu.gmall")

 

 

使用config配置dubbo

 

@Configuration
public class MyDubboConfig {
    
    @Bean
    public ApplicationConfig applicationConfig() {
        ApplicationConfig applicationConfig = new ApplicationConfig();
        applicationConfig.setName("boot-user-service-provider");
        return applicationConfig;
    }
    
    //<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
    @Bean
    public RegistryConfig registryConfig() {
        RegistryConfig registryConfig = new RegistryConfig();
        registryConfig.setProtocol("zookeeper");
        registryConfig.setAddress("127.0.0.1:2181");
        return registryConfig;
    }
    
    //<dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>
    @Bean
    public ProtocolConfig protocolConfig() {
        ProtocolConfig protocolConfig = new ProtocolConfig();
        protocolConfig.setName("dubbo");
        protocolConfig.setPort(20882);
        return protocolConfig;
    }
    
    /**
     *<dubbo:service interface="com.atguigu.gmall.service.UserService" 
        ref="userServiceImpl01" timeout="1000" version="1.0.0">
        <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
    </dubbo:service>
     */
    @Bean
    public ServiceConfig<UserService> userServiceConfig(UserService userService){
        ServiceConfig<UserService> serviceConfig = new ServiceConfig<>();
        serviceConfig.setInterface(UserService.class);
        serviceConfig.setRef(userService);
        serviceConfig.setVersion("1.0.0");
        
        //配置每一個method的信息
        MethodConfig methodConfig = new MethodConfig();
        methodConfig.setName("getUserAddressList");
        methodConfig.setTimeout(1000);
        
        //將method的設置關聯到service配置中
        List<MethodConfig> methods = new ArrayList<>();
        methods.add(methodConfig);
        serviceConfig.setMethods(methods);
        
        //ProviderConfig
        //MonitorConfig
        
        return serviceConfig;
    }

}