SpringBoot多模块项目整合Dubbo

迷南。 2023-01-05 12:10 189阅读 0赞

## SpringBoot框架整合Dubbo有3种方式： ##

**Demo的项目结构：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpdWNoYW5nMTk5NTA3MDM_size_1_color_FFFFFF_t_70][]![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpdWNoYW5nMTk5NTA3MDM_size_1_color_FFFFFF_t_70 1][]

### **1.dubbo.xml + @ImportResource注解        ** ###

**（1）导入包：**

<dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo</artifactId>
                <version>2.7.1</version>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>2.7.1</version>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-recipes</artifactId>
                <version>2.7.1</version>
            </dependency>
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.4.8</version>
            </dependency>

**（2）dubbo.xml配置文件，这里的配置和spring的方式是一样的**

<?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://code.alibabatech.com/schema/dubbo
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
        <dubbo:application name="product_provider"></dubbo:application>
        <dubbo:registry protocol="zookeeper" address="192.168.247.129:2181"></dubbo:registry>
        <dubbo:protocol name="dubbo" port="20002"></dubbo:protocol>
    
        <bean id="productService" class="com.study.service.impl.ProductServiceImpl"></bean>
        <dubbo:service interface="com.study.service.ProductService" ref="productService" loadbalance="roundrobin"></dubbo:service>
    
        <dubbo:provider timeout="7000"></dubbo:provider>
    </beans>

**（3）Application启动类添加注解@ImportResource(locations = \{"classpath:dubbo.xml"\})导入配置文件**

@SpringBootApplication
    @ComponentScan(basePackages = "com.study")
    @ImportResource(locations = {"classpath:dubbo.xml"})
    public class UserApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(UserApplication.class, args);
        }
    
    }

### **2.application.yml + @EnableDubbo注解 + @Service注解(详解配置) + @Reference注解(详解配置) ** ###

**（1）导入包：**

<dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>0.2.0</version>
            </dependency>

**（2） application.yml配置文件：**

dubbo:
      application:
        name: product_proider
      registry:
        protocol: zookeeper
        address: 192.168.247.129:2181
      protocol:
        name: dubbo
        port: 20002
      provider:
        timeout: 7000

**（3）服务提供者代码@Service注解来暴露和注册服务，注意这里的@Service不是spring的注解，而是dubbo包自带的注解**

package com.study.service.impl;
    
    import com.alibaba.dubbo.config.annotation.Service;
    import com.study.service.ProductService;
    import com.study.service.UserService;
    import org.springframework.stereotype.Component;
    
    @Component
    @Service(interfaceClass = ProductService.class, loadbalance = "roundrobin")
    public class ProductServiceImpl implements ProductService {
    
        @Override
        public String getProductByUser() {
            return "获取商品信息";
        }
    }

**（4）服务消费者代码@Reference注解来引用服务：**

package com.study.service.impl;
    
    import com.alibaba.dubbo.config.annotation.Reference;
    import com.alibaba.dubbo.config.annotation.Service;
    import com.study.service.ProductService;
    import com.study.service.UserService;
    import org.springframework.stereotype.Component;
    
    
    @Component
    @Service
    public class UserServiceImpl implements UserService {
    
        @Reference(interfaceClass = ProductService.class, retries = 0, check = false)
        private ProductService productService;
    
        @Override
        public String getUser() {
            System.out.println("获取用户信息");
            System.out.println(this.productService.getProductByUser());
            return "getUser";
        }
    
    }

**（5）Application启动类添加注解@EnableDubbo开启服务**

@SpringBootApplication
    @ComponentScan(basePackages = "com.study")
    @EnableDubbo
    public class UserApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(UserApplication.class, args);
        }
    
    }

### **3.DubboConfig配置类文件+ @EnableDubbo注解 + @Service注解 + @Reference注解 ** ###

**（1）导入包：**

<dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>0.2.0</version>
            </dependency>

**（2）DubboConfig配置类文件：**

服务提供者的配置文件：

package com.study.service.config;
    
    import com.alibaba.dubbo.config.*;
    import com.study.service.ProductService;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    
    @Configuration
    public class DubboConfig {
    
        @Bean
        public ApplicationConfig applicationConfig() {
            ApplicationConfig applicationConfig = new ApplicationConfig();
            applicationConfig.setName("product_provider");
            applicationConfig.setQosEnable(false);
            return applicationConfig;
        }
    
        @Bean
        public RegistryConfig registryConfig() {
            RegistryConfig registryConfig = new RegistryConfig();
            registryConfig.setProtocol("zookeeper");
            registryConfig.setAddress("192.168.247.129:2181");
            return registryConfig;
        }
    
        @Bean
        public ProtocolConfig protocolConfig() {
            ProtocolConfig protocolConfig = new ProtocolConfig();
            protocolConfig.setName("dubbo");
            protocolConfig.setPort(20002);
            return protocolConfig;
        }
    
        @Bean
        public ProviderConfig providerConfig() {
            ProviderConfig providerConfig = new ProviderConfig();
            providerConfig.setTimeout(7000);
            return providerConfig;
        }
    
        @Bean
        public ServiceConfig<ProductService> serviceConfig(ProductService productService) {
            ServiceConfig<ProductService> serviceConfig = new ServiceConfig();
            serviceConfig.setRef(productService);
            serviceConfig.setInterface(ProductService.class);
            serviceConfig.setLoadbalance("roundrobin");
            return serviceConfig;
        }
    
    }

服务消费者的配置文件：

package com.study.service.config;
    
    import com.alibaba.dubbo.config.*;
    import com.study.service.ProductService;
    import com.study.service.UserService;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    
    @Configuration
    public class DubboConfig {
    
        @Bean
        public ApplicationConfig applicationConfig() {
            ApplicationConfig applicationConfig = new ApplicationConfig();
            applicationConfig.setName("user_provider");
            return applicationConfig;
        }
    
        @Bean
        public RegistryConfig registryConfig() {
            RegistryConfig registryConfig = new RegistryConfig();
            registryConfig.setProtocol("zookeeper");
            registryConfig.setAddress("192.168.247.129:2181");
            return registryConfig;
        }
    
        @Bean
        public ProtocolConfig protocolConfig() {
            ProtocolConfig protocolConfig = new ProtocolConfig();
            protocolConfig.setName("dubbo");
            protocolConfig.setPort(20001);
            return protocolConfig;
        }
    
        @Bean
        public ProviderConfig providerConfig() {
            ProviderConfig providerConfig = new ProviderConfig();
            providerConfig.setTimeout(7000);
            return providerConfig;
        }
    
        @Bean
        public ServiceConfig<UserService> serviceConfig(UserService userService /*spring impl注入进来*/) {
            ServiceConfig<UserService> serviceConfig = new ServiceConfig();
            serviceConfig.setRef(userService);
            serviceConfig.setInterface(UserService.class);
            serviceConfig.setLoadbalance("roundrobin");
            return serviceConfig;
        }
    
    
        @Bean
        public ReferenceConfig<ProductService> serviceConfig() {
            ReferenceConfig referenceConfig = new ReferenceConfig();
            referenceConfig.setInterface(ProductService.class);
            referenceConfig.setId("productService");
            referenceConfig.setRetries(0);
            referenceConfig.setCheck(false);
            return referenceConfig;
        }
    
    }

**（3）服务提供者代码@Service注解来暴露和注册服务，注意这里的@Service不是spring的注解，而是dubbo包自带的注解**

package com.study.service.impl;
    
    import com.alibaba.dubbo.config.annotation.Service;
    import com.study.service.ProductService;
    import com.study.service.UserService;
    import org.springframework.stereotype.Component;
    
    @Component
    @Service
    public class ProductServiceImpl implements ProductService {
    
        @Override
        public String getProductByUser() {
            return "获取商品信息";
        }
    }

**（4）服务消费者代码@Reference注解来引用服务：**

package com.study.service.impl;
    
    import com.alibaba.dubbo.config.annotation.Reference;
    import com.alibaba.dubbo.config.annotation.Service;
    import com.study.service.ProductService;
    import com.study.service.UserService;
    import org.springframework.stereotype.Component;
    
    
    @Component
    @Service
    public class UserServiceImpl implements UserService {
    
        @Reference
        private ProductService productService;
    
        @Override
        public String getUser() {
            System.out.println("获取用户信息");
            System.out.println(this.productService.getProductByUser());
            return "getUser";
        }
    
    }

**（5）Application启动类添加注解@EnableDubbo开启服务**

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpdWNoYW5nMTk5NTA3MDM_size_1_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/2021011210195922.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpdWNoYW5nMTk5NTA3MDM=,size_1,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpdWNoYW5nMTk5NTA3MDM_size_1_color_FFFFFF_t_70 1]: /images/20221119/93a4d9e75a1747749498fd4f05df7409.png