Spring Boot 零xml整合dubbo

傷城~ 2022-05-13 14:10 216阅读 0赞

# 项目结构 #

首先看下完整项目结构：  
![项目结构][TIM_E6_88_AA_E5_9B_BE20180830175607.png]

各模块功能介绍如下

1.  **parent** :父工程，依赖版本控制。
2.  **dubbo-sample-api** :公共文件所属模块，provider和consumer都依赖该模块。
3.  **dubbo-sample-provider** : dubbo的provider模块，api模块中接口的具体实现
4.  **dubbo-sample-consumer** ： 消费者模块，间接provider

# parent模块 #

parent父模块只有一个pom.xml文件,主要下面这些内容：

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>spring-boot-demo</artifactId>
            <groupId>qike.com</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>parent</artifactId>
    
        <properties>
            <dubbo-spring-boot>0.2.0</dubbo-spring-boot>
        </properties>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>io.spring.platform</groupId>
                    <artifactId>platform-bom</artifactId>
                    <version>Cairo-SR1</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <dependencies>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
    
            <dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>${dubbo-spring-boot}</version>
            </dependency>
        </dependencies>
    
    </project>

其中`dubbo-spring-boot-starter`是官方提供的spring boot整合dubbo框架，自动整合了dubbo的所有依赖包。

# api模块 #

api模块只有一个接口：

public interface HelloProvider { 
    
        public String hello(String message);
    }

api模块的主要起到的是契约的作用，控制着服务消费者和提供者双方的实现细节，如调用方法，出入参数。

# provider模块 #

## pom文件 ##

首先provider继承自parent依赖了api:

配置文件resource/application.properties，具体解释详见注释：

spring.application.name = dubbo-sample-provider
    server.port = 9090
    
    # dubbo扫描的包
    dubbo.scan.basePackages  = com.qike.dubbo.sample.provider
    
    # dubbo项目名称
    dubbo.application.name = dubbo-sample-provider
    
    # dubbo协议相关，如端口
    # ProtocolConfig Bean
    dubbo.protocol.id = dubbo
    dubbo.protocol.name = dubbo
    dubbo.protocol.port = 30880
    spring.dubbo.protocol.status = server
    
    # service版本
    provider.service.version = 1.0.0
    
    # 注册服务器信息，这里是zookeeper
    ## RegistryConfig Bean
    dubbo.registry.address = zookeeper://192.168.2.251:2181
    dubbo.registry.timeout = 3000

spring boot启动器:

@EnableDubboConfig
    @SpringBootApplication(scanBasePackages = "com.qike.dubbo.sample.provider")
    public class DubboProviderApplication {
    
        public static void main(String[] args) {
            new SpringApplicationBuilder(DubboProviderApplication.class)
                    .web(WebApplicationType.NONE)
                    .run(args);
        }
    
    }

@Service(version = "${provider.service.version}")
    public class RPCHelloProvderImpl implements HelloProvider {
    
        public String hello(String message) {
            return message + " from provider";
        }
    }

启动控制台显示如下日志：

![1.png][]

dubbo-damin控制台可以查看到该服务的地提供者信息了：

![2.png][]

# consumer模块 #

消费者是一个web模块，所以pom文件中处理需要依赖api外，还有`spring-boot-starter-web`:

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>dubbo-sample</artifactId>
            <groupId>qike.com</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>dubbo-sample-consumer</artifactId>
    
        <dependencies>
    
            <dependency>
                <groupId>qike.com</groupId>
                <artifactId>dubbo-sample-api</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
    
        </dependencies>
    
    </project>

application.properties配置：

spring.application.name = dubbo-sample-consumer
    server.port = 9091
    
    dubbo.application.name = dubbo-sample-consumer
    
    # 注册中心
    dubbo.registry.address = zookeeper://192.168.2.251:2181
    dubbo.registry.timeout = 3000
    
    # provider版本，与provider中的版本一致
    provider.service.version = 1.0.0

启动器:

@EnableDubboConfig
    @SpringBootApplication(scanBasePackages = "com.qike.dubbo.sample.consumer")
    public class DubboConsumerApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(DubboConsumerApplication.class,args);
        }
    
    }

controller:

@RequestMapping("/demo")
    @RestController
    public class HelloController {
    
    
        @Reference(version = "${provider.service.version}")
        HelloProvider helloProvider;
    
        @GetMapping("/hello")
        public Object hello(String message){
            return  helloProvider.hello(message);
        }
    
    }

启动：  
![3.png][]

控制台：  
![3.png][]

浏览器打开地址`http://localhost:9091/demo/hello?message=hello%20dubbo`：  
![5.png][]

[TIM_E6_88_AA_E5_9B_BE20180830175607.png]: http://obzgrz9dr.bkt.clouddn.com/TIM%E6%88%AA%E5%9B%BE20180830175607.png
[1.png]: http://obzgrz9dr.bkt.clouddn.com/1.png
[2.png]: http://obzgrz9dr.bkt.clouddn.com/2.png
[3.png]: http://obzgrz9dr.bkt.clouddn.com/3.png
[5.png]: http://obzgrz9dr.bkt.clouddn.com/5.png