Spring Cloud和Dubbo整合開發筆記(1)

一、需求背景：

1. 公司內部老項目微服務技術棧使用Dubbo, 新項目技術棧使用主流的Spring Cloud相關組件開發，新舊項目涉及交互調用，無法直接通信數據傳遞。
2. 老項目基於Dubbo,重構代碼升級使用Spring Cloud,改造升級要求成本最低，不影響現有系統運行。

二、Dubbo和Spring Cloud 的比較

　　首先Dubbo是一個分布式服務框架，以及SOA治理方案。它的功能主要包括：高性能NIO通訊及多協議集成，服務動態尋址與路由，軟負載均衡與容錯，依賴分析與降級等,它是著名的阿里服務治理的核心框架。Spring Cloud更加關心為開發人員提供開箱即用的一系列常見的分布式工具（例如配置管理，服務發現，斷路器，智能路由，微代理，控制總線），它是基於輕量級框架Spring家族，維護版本速度相對較快。

想深入了解的朋友，可以參考這篇文章專門分析了兩者的區別：聽聽八年阿里架構師怎樣講述Dubbo和Spring Cloud微服務架構  

改造思路：Spring Cloud和Dubbo用於協調服務組件需要進行統一，使得Dubbo服務和Spring Cloud 服務能夠相互感知。其次統一微服務之間的通信協議，Spring Cloud使用Http協議，Dubbo支持Dubbo,Hessian,rmi,http,webservice,thrift,redis,rest,memcached協議;數據傳輸載體或者說格式在網絡中也是統一的，和調用的服務架構無關。改造前需要明確的是兩種架構Spring Cloud和Dubbo在項目中的主次，不然容易造成開發人員使用API困惑，代碼接口混亂，其次不要急於期望短期將架構統一，改造完整，特別是Spring Cloud帶來了項目開發更多的環節，更多的組件（意味着有更多的坑）。

改造方案：

• 傳統方案：保留完整的Dubbo老系統，Dubbo服務不需要向SpringCloud組件注冊服務，通過Ribbon/Fegin調用Dubbo服務暴露的Restful Api.缺點也明顯，需要人工維護Dubbo服務和Spring Cloud服務的關系，當Dubbo服務較多時，不同的環境配置太多。
• 傳統方案：借助SideCar支持多語言的特性，連接Dubbo和Spring Cloud底層使用Sidecar交互，同時Dubbo也可以將信息傳播到Eureka上面。缺點明顯，需要每個Dubbo服務節點額外配置Sidecar服務節點，同時增加了鏈路的長度。

我的方案：Spring Cloud和Dubbo的服務中心選擇阿里的Nacos，它是一個動態服務發現、配置管理和服務管理平台，為什么不選擇使用Zookeeper，因為zookeeper是個CP系統，強一致性。如果其中master掛掉，此時zookeeper集群會進行重新選舉，不能提供服務列表信息的服務，其次zookeeper通過tcp不能准確判斷服務此時是否可用，數據庫掛了，數據庫連接池滿了等也能提供TCP信息。通信協議我選擇Http協議，Dubbo2.6之后支持http協議，數據格式使用Json,前端無需根據服務區分數據格式解析。

Nacos支持部署的模式有單機，集群，多集群模式，Nacos 0.8之后支持數據庫持久化，可以方便看見服務信息的前后變化。單機模式很簡單啟動，下載最新版Nacos:https://github.com/alibaba/nacos/releases ,解壓直接運行bin/startup.sh或者startup.cmd即可。

Nacos不僅提供服務發現和服務健康監測，它也提供控制台可視化頁面進行動態配置服務，動態 DNS 服務，服務及其元數據管理等功能，Nacos0.8版本支持簡單登錄功能，默認用戶名/密碼為 nacos/nacos。：

相比Eureka提供的單一的看板頁面，提供的管理功能可以說沒得比，具體使用手冊參考官方：https://nacos.io/zh-cn/docs/console-guide.html，這里不再贅述。

首先開發基於Spring Cloud+Nacos架構的微服務,nacos-discovery-provider為服務提供者，nacos-discovery-consumer為服務消費方, 

nacos-discovery-provider的pom.xml加入相關依賴:

<dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            <version>0.2.1.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.0.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
            <version>2.0.6.RELEASE</version>
        </dependency>
    </dependencies>

 

 

application.properties的配置為：

server.port=18082
spring.application.name=service-provider
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848   
management.endpoints.web.exposure.include=*

 

其中spring.cloud.nacos.discovery.server-addr為配置的Nacos地址，management.endpoints.web.exposure.include=*表示對外暴露所有項目信息。

啟動類的代碼：

package org.springframework.cloud.alibaba.cloud.examples;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@SpringBootApplication
@EnableDiscoveryClient
public class ProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }

    @RestController
    class EchoController {
        @RequestMapping(value = "/echo/{string}", method = RequestMethod.GET)
        public String echo(@PathVariable String string) {
            return "hello Nacos Discovery " + string;
        }

        @RequestMapping(value = "/divide", method = RequestMethod.GET)
        public String divide(@RequestParam Integer a, @RequestParam Integer b) {
            return String.valueOf(a / b);
        }
    }
}

 

使用SpringCloud的原生注解@EnableDiscoveryClient 開啟服務注冊發現功能。

接下來創建服務消費方nacos-discovery-consumer進行服務消費：

pom.xml:

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.0.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            <version>0.2.1.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
            <version>2.0.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
            <version>2.0.2.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
            <version>2.0.2.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-alibaba-sentinel</artifactId>
            <version>0.2.1.RELEASE</version>
        </dependency>
    </dependencies>

 

其中sentinel和傳統的Spring Cloud組件Hystrix類似，提供熔斷降級，系統負載保護等功能。application.properties的配置為：

spring.application.name=service-consumer
server.port=18083
management.endpoints.web.exposure.include=*
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

feign.sentinel.enabled=true

spring.cloud.sentinel.transport.dashboard=localhost:8080
spring.cloud.sentinel.eager=true

spring.cloud.sentinel.datasource.ds1.file.file=classpath: flowrule.json
spring.cloud.sentinel.datasource.ds1.file.data-type=json
spring.cloud.sentinel.datasource.ds1.file.rule-type=flow

 

其中flowrule.json配置了限流降級的規則：

[
  {
    "resource": "GET:http://service-provider/echo/{str}",
    "controlBehavior": 0,
    "count": 1,
    "grade": 1,
    "limitApp": "default",
    "strategy": 0
  }
]

 

消費啟動類ConsumerApplication.java:

package org.springframework.cloud.alibaba.cloud.examples;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.alibaba.cloud.examples.ConsumerApplication.EchoService;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.client.RestTemplate;

/**
 * @author liujie037
 */
@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class ConsumerApplication {

    @LoadBalanced
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }

    @FeignClient(name = "service-provider", fallback = EchoServiceFallback.class, configuration = FeignConfiguration.class)
    public interface EchoService {
        @RequestMapping(value = "/echo/{str}", method = RequestMethod.GET)
        String echo(@PathVariable("str") String str);

        @RequestMapping(value = "/divide", method = RequestMethod.GET)
        String divide(@RequestParam("a") Integer a, @RequestParam("b") Integer b);

        @RequestMapping(value = "/notFound", method = RequestMethod.GET)
        String notFound();
    }

}

class FeignConfiguration {
    @Bean
    public EchoServiceFallback echoServiceFallback() {
        return new EchoServiceFallback();
    }
}

class EchoServiceFallback implements EchoService {
    @Override
    public String echo(@PathVariable("str") String str) {
        return "echo fallback";
    }

    @Override
    public String divide(@RequestParam Integer a, @RequestParam Integer b) {
        return "divide fallback";
    }

    @Override
    public String notFound() {
        return "notFound fallback";
    }
}

 

通過 Spring Cloud 原生注解 @EnableDiscoveryClient 開啟服務注冊發現功能。給 RestTemplate 實例添加 @LoadBalanced 注解，開啟 @LoadBalanced 與 Ribbon 的集成：

消費的接口TestController.java：

package org.springframework.cloud.alibaba.cloud.examples;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.alibaba.cloud.examples.ConsumerApplication.EchoService;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

/**
 * @author liujie037
 */
@RestController
public class TestController {

    @Autowired
    private RestTemplate restTemplate;
    @Autowired
    private EchoService echoService;

    @Autowired
    private DiscoveryClient discoveryClient;

    @RequestMapping(value = "/echo-rest/{str}", method = RequestMethod.GET)
    public String rest(@PathVariable String str) {
        return restTemplate.getForObject("http://service-provider/echo/" + str,
                String.class);
    }

    @RequestMapping(value = "/notFound-feign", method = RequestMethod.GET)
    public String notFound() {
        return echoService.notFound();
    }

    @RequestMapping(value = "/divide-feign", method = RequestMethod.GET)
    public String divide(@RequestParam Integer a, @RequestParam Integer b) {
        return echoService.divide(a, b);
    }

    @RequestMapping(value = "/echo-feign/{str}", method = RequestMethod.GET)
    public String feign(@PathVariable String str) {
        return echoService.echo(str);
    }

    @RequestMapping(value = "/services/{service}", method = RequestMethod.GET)
    public Object client(@PathVariable String service) {
        return discoveryClient.getInstances(service);
    }

    @RequestMapping(value = "/services", method = RequestMethod.GET)
    public Object services() {
        return discoveryClient.getServices();
    }
}

 

訪問Nacos控制台：

 

測試服務消費正常使用postman:

 下一篇中我將繼續展示Dubbo服務創建和Spring Cloud 互相調用。