Springboot+Dubbo整合-蒲公英云

简介

当前dubbo是官方宣布更新后最新版本，由于官方并未给出使用spring-boot-starter-dubbo，因此这里使用的是老雷写的开源spring-boot-starter-dubbo
并且已经是支持最新版本的dubbo-2.5.7

spring-boot-starter-dubbo的git地址
https://gitee.com/reger/spring-boot-starter-dubbo/blob/master/pom.xml

项目准备

Dubbo 从 2.5.8 版本开始，分别提供了三个方式配置，提供了更完善的支持
xml：上一篇入门篇的方式
property:本篇方式：官方再开源后已经提供了dubbo-spring-boot-starter
Annotation：注解方式

官方文档：http://dubbo.apache.org/zh-cn/blog/dubbo-annotation.html

2.5.8之后版本springboot整合：服务互调

spring boot 2.0.3版本以注意
错误提示：java.lang.ClassNotFoundException: org.springframework.boot.bind.RelaxedDataBinder
boot.bind下找不到RelaxedDataBinder这个方法
查看API发现,这个org.springframework.boot.bind 包已经删掉了,导致RelaxedPropertyResolver这个方法已经不可用
解决方案：
boot版本改为1.5.x版本对应dubbo-spring-boot-starter0.1.0
boot版本改为2.1.x版本对应dubbo-spring-boot-starter0.2.0

官方给定的对应版本号

dubbo-spring	Java	Spring Boot	Dubbo
0.2.1	1.8+	2.1.x	2.6.5 +
0.1.1	1.7+	1.5.x	2.6.5 +

dubbo-api:公共接口和实体bean，主要是两个服务的接口
dubbo-a:服务a
dubbo-b:服务b

服务调用

package com.bamboo.bserver.controller;
import com.alibaba.dubbo.config.annotation.Reference;
import com.bamboo.aserver.city.service.CityService;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
/**
 * demo url
 * http://localhost:9001
 *
 * @author bamboo
 * @time 2019-6-27
 */
@RestController
public class BambooController {
    private Log logger = LogFactory.getLog(BambooController.class);
    // 调用服务service 注解
    @Reference
    private CityService cityService;
    /**
     * default url
     */
    @GetMapping("/")
    public String find(Model model, String name) {
        return "bamboo  server";
    }
    // 调用服务a的city服务
    @GetMapping("/city")
    public String getCity(Model model, String name) {
        return cityService.getC("bamboo");
    }
}

b服务user的实现，主要这里的service不是spring的注解而是com.alibaba.dubbo.config.annotation.Service;

package com.bamboo.bserver.impl;
import com.alibaba.dubbo.config.annotation.Service;
import com.bamboo.bserver.user.service.UserService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
 * @program: dubbo-api
 * @description: 服务实现
 * @author: Bamboo zjcjava@163.com
 * @create: 2019-06-27 16:18
 **/
//注意，这里的service注解用的不是spring的注解，而是com.alibaba.dubbo.config.annotation.Service;
@Service
public class UserServiceImpl implements UserService{
    private static final Logger logger = LoggerFactory.getLogger(UserServiceImpl.class);
    @Override
    public String getUser(String name) {
        logger.debug("User service running :{}",name);
        return "user:"+name;
    }
}

dubbo-a,dubbo-b的pom基本相似指数artifactId不同而已

<?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">
    <modelVersion>4.0.0</modelVersion>
    <groupId>springboot</groupId>
    <artifactId>dubbo-b</artifactId>
    <version>0.0.1</version>
    <!-- Spring Boot   -->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.3.RELEASE</version>
    </parent>
    <properties>
        <dubbo-spring-boot>1.0.0</dubbo-spring-boot>
    </properties>
    <dependencies>
        <!-- Spring Boot Web   -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- https://mvnrepository.com/artifact/com.alibaba.boot/dubbo-spring-boot-project -->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>
        <dependency>
            <groupId>springboot</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>0.0.1</version>
        </dependency>
        <!-- Junit -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
    </dependencies>
</project>

b服务的配置application.properties

## server port
server.port=9002
#消费者名称
dubbo.application.name=dubbo-consumer
#需要使用到提供者服务的包路径
dubbo.scan.base-packages= com.bamboo.bserver
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.protocol.port=2081
dubbo.consumer.check=false

dubbo.consumer.check=false 在服务启动时不检查依赖服务的检查，会报空

具体代码已经提交到我的GitHub上
https://github.com/BambooZhang/dubbo-study

2.5.7版本springboot整合方式

dubbo-srpingboot-provider 服务端
dubbo-srpingboot-consumer 消费端
dubbo-admin-2.5.7.war 监控管理后台
源码地址：
https://github.com/BambooZhang/dubbo-study/tree/master/dubbo-springboot

##相同部分

pom

服务端和消费端的pom都一样都使用了springboot

两个项目的maven依赖都一摸一样这里只拷贝主要部分，详细请参考git中的源码

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.9.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <dependencies>
        <!--spring boot-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
        <!--spring-boot-starter-dubbo-->
        <dependency>
            <groupId>com.gitee.reger</groupId>
            <artifactId>spring-boot-starter-dubbo</artifactId>
            <version>1.0.9</version>
        </dependency>
    </dependencies>

service

都使用同一个service文件ProviderService .java

package com.bamboo;
public interface  ProviderService {
    public String sayHello(String name);
}

##服务端
服务端实现接口

package com.bamboo.provider;
import com.alibaba.dubbo.config.annotation.Service;
import com.bamboo.ProviderService;
@Service
public class ProviderServiceImpl implements ProviderService {  
    public String sayHello(String name) {         
        return "Hello:"+name+"你好，你好~~";  
    }  
}

application.yml

server:
    port: 8081
spring:
  dubbo:
    application:
      name: service-provider
    base-package: com.bamboo.provider  # dubbo服务发布者实现类注解@service所在的包
    registry:
      address: 192.168.0.91                   # zookeeper注册中心的地址
      port: 2181                           # zookeeper注册中心的端口
    protocol:
      name: dubbo
      serialization: hessian2
    provider:
      retries: 0                           # 服务调用重试次数，服务发布者不给重试，让服务调用者自己重试

启动类

package com;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import java.util.concurrent.TimeUnit;
/**
 * Created by xialeme on 2017/12/11.
 */
@SpringBootApplication
public class ProviderApplication implements CommandLineRunner {
    public static void main(String[] args) throws InterruptedException {
        SpringApplication.run(ProviderApplication.class, args);
        TimeUnit.MINUTES.sleep(10); //提供者main线程暂停10分钟等待被调用
        System.err.println("服务提供者------>>服务关闭");
    }
    @Override
    public void run(String... args) throws Exception {
        System.err.println("服务提供者------>>启动完毕");
    }
}

消费端

这里使用了两个注解
Component：在项目启动的时候执行调用
RestController：使用REST风格可以在页面访问接口实现调用
Consumer

package com.bamboo.consumer;
import com.bamboo.ProviderService;
import com.reger.dubbo.annotation.Inject;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
/**
 * Created by bamboo on 2017/12/11.
 */
@RestController
@Component//启动时调用
public class Consumer implements CommandLineRunner {
    // 使用兼容注入，可以使用dubbo原生注解@Reference注入
    @Inject
    public ProviderService service;
    // 使用兼容注入
    @Inject
    public ProviderService bidService;
    @Override
    public void run(String... args){
        String name="system start";
        System.out.println(service.sayHello(name));;
        System.out.println("调用完成");
    }
    @RequestMapping(value = "/", method = RequestMethod.GET)
    @ResponseBody
    public String  run(String name){
        name= name==null?"system start":name;
        return service.sayHello(name);
    }
}

消费端启动类

package com;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
 * Created by bamboo on 2017/12/11.
 * contextClass
 */
@SpringBootApplication
public class ConsumerApplication implements CommandLineRunner {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
    @Override
    public void run(String... args) throws Exception {
        System.err.println("服务调用者------>>启动完毕");
    }
}

启动执行

依此启动服务端和消费端
可以在消费端控制台看到

服务调用者------>>启动完毕
Hello:system start你好，你好~~
调用完成

说明服务启动的时候已经执行了

然后在浏览器打开消费端的接口
http://localhost:8082/?name=bamboo
可以看到窗口返回的数据，说明调用成功

Hello:bamboo你好，你好~~

当然如果你启动了dubbo-admin,也可以在控制台看到如下情况，这里就不截图了

应用名:  
     角色:     降级:     操作
    service-consumer    消费者    未降级    屏蔽 |  容错
    service-provider    提供者

配置扩展

由于目前官方并未给出他们的springboot-dubbo-start因此老雷给出的版本其实也是根据现有官方提供的相关xml配置写出的spring胶水代码部分实现的。因此配置和xml官方的是一样的只是以yml的风格实现了配置而已，具体配置请参考官方给出的配置为准。
dubbo官网
http://dubbo.io/
老雷的代码地址
https://gitee.com/reger/spring-boot-starter-dubbo

Dubbo第一章：Dubbo-admin编译和Dubbo简单入门
http://blog.csdn.net/zjcjava/article/details/78766095