Springboot与Dubbo整合三种方式详解

整合环境：

jdk：8.0

dubbo：2.6.2

springboot：2.1.5

项目结构：

1、搭建项目环境：

　　(1)创建父项目与三个子项目，创建项目时，都使用spring initializr，创建时，父项目中注意的一点：

　　

　　(2)创建三个子项目，在已有的父项目上右键，新建模块；

　　(3)创建完成后：将三个子项目在父项目pom.xml中配置：

　　

　　(4)修改所有子项目中的parent标签：（删掉之前parent中的springboot）修改为：

　　

　　(5)项目创建完成;

2、配置项目dubboservice，只包含接口：

　

3、第一种方式使用xml文件：

3.1、配置项目dubboserviceimpl(服务提供者)：

（1）引入dubbo相关依赖，以及zookeeper客户端依赖，由于需要与其他服务器通信，引入web依赖，pom.xml：

     
         
      
       4.0.0
          
              
       
        top.free
               
       
        springboot-dubbo
               
       
        0.0.1-SNAPSHOT
           
          
      
       top.free
          
      
       dubboserviceimpl
          
      
       0.0.1-SNAPSHOT
          
              
       
        1.8
           
          
              
               
                   
        
         top.free
                    
        
         dubboservice
                    
        
         0.0.1-SNAPSHOT
                
               
               
                   
        
         org.springframework.boot
                    
        
         spring-boot-starter-web
                
               
               
                   
        
         com.alibaba.boot
                    
        
         dubbo-spring-boot-starter
                    
        
         0.2.0
                
              
               
                   
        
         com.101tec
                    
        
         zkclient
                    
        
         0.10
                
               
                   
        
         org.springframework.boot
                    
        
         spring-boot-starter-test
                    
        
         test
                
           
      
     

 

  （2） xml文件配置 provider.xml：

（3）　配置实现类ServiceImpl：

      

package top.free.dubboserviceimpl;import org.springframework.stereotype.Component;import top.free.dubboservice.TestDubboService;@Componentpublic class ServiceImpl implements TestDubboService {    @Override    public String getData(String user) {        return "你好，我们通信了："+user;    }}

 

（4）主启动类上加上：@ImportResource(locations = "classpath:provider.xml")

 

package top.free;import com.alibaba.dubbo.config.spring.context.annotation.DubboComponentScan;import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.context.annotation.ImportResource;@SpringBootApplication@ImportResource(locations = "classpath:provider.xml")public class DubboserviceimplApplication {    public static void main(String[] args) {        SpringApplication.run(DubboserviceimplApplication.class, args);    }}

（5）在application.properties中加上项目启动的端口号： server.port=8080

3.2、配置dubboweb项目（消费者）

（1）引入dubbo相关依赖，以及zookeeper客户端依赖，由于需要与其他服务器通信，引入web依赖，pom.xml：

     
         
      
       4.0.0
          
              
       
        top.free
               
       
        springboot-dubbo
               
       
        0.0.1-SNAPSHOT
           
          
      
       top.free
          
      
       dubboweb
          
      
       0.0.1-SNAPSHOT
          
      
       dubboweb
          
      
       Demo project for Spring Boot
          
              
       
        1.8
           
          
              
                   
        
         top.free
                    
        
         dubboservice
                    
        
         0.0.1-SNAPSHOT
                
               
                   
        
         org.springframework.boot
                    
        
         spring-boot-starter-web
                
               
                   
        
         com.alibaba.boot
                    
        
         dubbo-spring-boot-starter
                    
        
         0.2.0
                
               
                   
        
         com.101tec
                    
        
         zkclient
                    
        
         0.10
                
               
                   
        
         org.springframework.boot
                    
        
         spring-boot-starter-test
                    
        
         test
                
           
      
     

 

 （2）配置controller：

 

package top.free.controller;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;import top.free.dubboservice.TestDubboService;@RestControllerpublic class TestDubboWeb {    //serviceImpl会显示红色，这个是因为编译时找不到bean注入，不影响结果    @Autowired    private TestDubboService servcieImpl;    @RequestMapping("/test/{user}")    public String getData(@PathVariable("user")String user){        String data =servcieImpl.getData(user);        return data;    }}

 （3）配置消费者的consumer.xml文件：

（4）在主启动类上加：@ImportResource(locations = "classpath:consumer.xml")

package top.free;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.context.annotation.ImportResource;@SpringBootApplication@ImportResource(locations = "classpath:consumer.xml")public class DubbowebApplication {    public static void main(String[] args) {        SpringApplication.run(DubbowebApplication.class, args);    }}

 （5）在application.properties文件中加上启动的端口号：server.port=8081

 （6）、第一种xml方式配置完成；

（7）、首先在本地安装这三个项目：

 （8）、安装完成后就可以起动dubboserviceimpl与dubboweb两个项目,并测试：

 4、第二种使用配置类方式（API）：pom.xml文件不修改，application.properties文件不做修改（只配置了端口号）

　　4.1、服务提供者（项目dubboserviceimpl）：配置类DubboProviderConfig（注意与主程序类XXXApplication的位置）

　　

　　（1）、配置类代码：

package top.free.config;import com.alibaba.dubbo.config.ApplicationConfig;import com.alibaba.dubbo.config.ProtocolConfig;import com.alibaba.dubbo.config.RegistryConfig;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;@Configurationpublic class DubboProviderConfig {    /*相当于xml中服务提供者的别名：
     */    @Bean    public ApplicationConfig myApplicationConfig(){        ApplicationConfig ac = new ApplicationConfig();        ac.setName("provider3");        return ac;    }    /*相当于注册中心配置：
     */    @Bean    public RegistryConfig myregistryConfig(){        RegistryConfig rc = new RegistryConfig();        rc.setAddress("XXXXXXXX:2181");        rc.setProtocol("zookeeper");        return rc;    } /*相当于暴露服务的协议以及端口：
     */    @Bean    public ProtocolConfig myProtocolConfig(){        ProtocolConfig pc = new ProtocolConfig();        pc.setName("dubbo");        pc.setPort(20888);        return pc;    }    /*在实现类上加注解来代替：暴露的服务
     */}

（2）、实现类：注意这里使用的@Service注解是Dubbo的service注解，标志这个类时提供服务的类

（3）、主程序类上加入@EnableDubbo扫描所有包下使用dubbo提供的注解类（或者@EnableDubbo(scanBasePackages = "top.free.dubboserviceimpl")只扫描特定包下有没有使用dubbo提供的注解），注意：注释掉第一种方式加载的xml文件；

4.2、配置消费者（dubboweb项目）：配置类DubboConsumerConfig

（1）、配置类代码：

package top.free.config;import com.alibaba.dubbo.config.ApplicationConfig;import com.alibaba.dubbo.config.RegistryConfig;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;@Configurationpublic class DubboConsumerConfig {    /*相当于consumer.xml中的：
      */    @Bean    public ApplicationConfig myapplicationConfig(){        ApplicationConfig ac = new ApplicationConfig();        ac.setName("consumer3");        return ac;    }    /*相当于：
      */    @Bean    public RegistryConfig myregistryConfig(){        RegistryConfig rc = new RegistryConfig();        rc.setAddress("39.108.125.227:2181");        rc.setProtocol("zookeeper");        return rc;    }/*使用注解方式来代替：
      */}

（2）、在Controller的属性上加注解@Reference：注意，是dubbo提供的注解，用于标志需要引用的服务

（3）、在主启动类上加：@EnableDubbo扫描使用dubbo提供的注解，注释第一种方式加载的xml（我试过，消费者好像不加@EnableDubbo也可以，提供者必须加）；

（4）、启动dubboserviceimpl和dubboweb两个程序，并测试：

5、第三种方式：属性文件方式：

　　5.1、服务提供者（dubboserviceimpl项目）：

　　（1）把第二种方式中，配置类文件让它不要被加载：（注释掉这个注解，不需要这个类）

　　（2）实现类不变：如下图：使用@Service来标志提供的服务

　　

　　（3）主程序类不变，与第二种方式一致，如下：

　　

　　（4）在application.properties文件中加入如下：

#别名dubbo.application.name=prodiver2#注册中心zookeeper地址dubbo.registry.address=XXXXXXXX:2181dubbo.registry.protocol=zookeeper#暴露的服务端口与协议dubbo.protocol.name=dubbodubbo.protocol.port=20880server.port=8080

 

5.2、消费者（dubboweb项目）：

（1）把第二种方式中，配置类文件让它不要被加载：（注释掉这个注解，不需要这个类）

（2）、Controller服务调用与第二种方式一致，如下：使用@Reference来表明需要引用服务的属性

（3）主配置类不变（与第二种方式一致），如下：

（4）application.properties属性文件中：

#消费者别名dubbo.application.name=consumer#注册中心zookeeper地址与协议dubbo.registry.address=zookeeper://39.108.125.227:2181dubbo.registry.protocol=zookeeperserver.port=8081

 （5）启动测试：

6、至此三种方式整合完成；