SpringCloud系列之Nacos+Dubbo应用篇

前言

本文在前篇文章《SpringCloud系列之Nacos应用篇》基础上集成Dubbo,公司项目中新项目采用SpringCloud(后续会逐渐替换至spring cloud alibaba全家桶),老项目采用传统SSM+Dubbo,部分业务上新老项目都有所涉及,原先少许业务上是直接通过http请求来处理新老项目交互的,总觉得这样做不够优雅,也不利于维护,于是自己调研调研看。
在前篇《SpringCloud系列之集成Dubbo应用篇》文章中Dubbo是依托zookeeper作为服务注册发现组件,这次项目中以SpirngCloud,Nacos,Dubbo三者集成起来,减少了Eureka、SpringConfig、zookeeper组件的投入,配置、服务注册发现都依赖Nacos服务,减少维护工作,死磕Nacos即可。

项目版本

spring-boot-version:2.2.5.RELEASE
spring-cloud.version:Hoxton.SR3
nacos.version:1.3.2
dubbo.version:2.6.9/2.7.6

项目说明

新项目模块间采用Feign进行相互交互,老项目模块间采用Dubbo进行交互,新老项目间采用Dubbo交互。在集成Dubbo时也针对Dubbo 2.6.x及Dubbo 2.7.x版本进行分别说明。

当然也可以都用Dubbo进行交互。

涉及Nacos配置信息,请查阅上篇文章《SpringCloud系列之Nacos应用篇》,本文只涉及新增Dubbo相关的配置,完整项目源码请查看本文文末项目源码。

项目结构

项目分支付模块和用户模块,支付模块提供Dubbo服务供用户模块消费,用户模块提供Feign服务供支付模块调用。

集成Dubbo2.6.x

集成Dubbo2.6.x系列版本中费了不少时间,主要涉及nacos-client版本中不同版本有些类所属包发生了变更,导致集成时提示找不到类,自己尝试调整了下依赖的版本,最终要么这个版本有这个问题,另外一个版本又有另一个问题,都不能很好解决,心想不会就这么凉凉了吧
常见问题如下
java.lang.NoClassDefFoundError: com/alibaba/nacos/client/naming/utils/StringUtils
java.lang.NoClassDefFoundError: com/alibaba/nacos/api/naming/NamingMaintainService
后来在Nacos Github上看到了这条issues,发现基本是同样的问题,就按照以下版本测试了下,居然成功了,后来又在此依赖版本上对相应版本进行了升级。
//github.com/alibaba/nacos/issues/2022

最终依赖如下
pom.xml

        <!--nacos discovery-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>com.alibaba.nacos</groupId>
                    <artifactId>nacos-client</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!--nacos config-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>com.alibaba.nacos</groupId>
                    <artifactId>nacos-client</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!--dubbo-->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.1.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.9</version>
        </dependency>
        <!--dubbo nacos-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo-registry-nacos</artifactId>
            <version>2.6.7</version>
            <exclusions>
                <exclusion>
                    <groupId>com.alibaba.nacos</groupId>
                    <artifactId>nacos-client</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!--nacos-->
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>1.3.2</version>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-all</artifactId>
            <version>4.1.31.Final</version>
        </dependency>

支付模块

application.properties

Dubbo 2.6.x 系列需在Dubbo配置项中增加dubbo.application.name配置项,不然再启动时会提示缺少该配置项

dubbo.application.name=pay-service
# dubbo扫描包路径
dubbo.scan.base-packages=com.chinawu.cloud.pay.service
# dubbo协议
dubbo.protocol.name=dubbo
# 随机端口
dubbo.protocol.port=-1
# zookeeper地址
dubbo.registry.address=nacos://127.0.0.1:8848

DPayService.java

@Service为Dubbo注解,import com.alibaba.dubbo.config.annotation.Service;

@Service
public class DPayService implements DPayFacade {

    @Override
    public String goToPay(String userName) {
        System.out.println("dubbo.method:goToPay request "+userName);
        return "dubbo.method:goToPay result:" + userName + " pay success";
    }
}

PayServiceApplication.java

SpringBoot 启动类需增加 @EnableDubbo 注解标签,不然服务没法暴露,注册

@SpringBootApplication
@EnableDiscoveryClient
@EnableAutoConfiguration
@EnableFeignClients(basePackages = {"com.chinawu.cloud.user.*"})
@EnableDubbo
public class PayServiceApplication {

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

}

用户模块

application.properties

dubbo.application.name=user-service
# dubbo扫描包路径
dubbo.scan.base-packages=com.chinawu.cloud.user.service
# dubbo协议
dubbo.protocol.name=dubbo
# 随机端口
dubbo.protocol.port=-1
# zookeeper地址
dubbo.registry.address=nacos://127.0.0.1:8848

UserController.java

@RestController
@RequestMapping("/user")
@RefreshScope
public class UserController {

    @Value("${spring.datasource.url}")
    private String datasourceUrl;

    // Dubbo服务消费
    @Reference(check = false)
    DPayFacade dPayFacade;


    /**
     * <p >
     * 功能:获取数据源连接配置信息
     * </p>
     * @param
     * @author wuyubin
     * @date  2020年9月3日
     * @return
     */
    @RequestMapping("/getDatasourceUrl")
    public String getDatasourceUrl() {
        return datasourceUrl;
    }

    /**
     * <p >
     * 功能:测试Dubbo服务调用
     * </p>
     * @param
     * @author wuyubin
     * @date  2020年9月3日
     * @return
     */
    @RequestMapping("/goToPay")
    public String goToPay() {
        return dPayFacade.goToPay("wuyubin");
    }
}

集成Dubbo2.7.x

集成Dubbo2.7.x系列版本,相比就简单不少,直接引入如下依赖
pom.xml

		<!--nacos discovery-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>com.alibaba.nacos</groupId>
                    <artifactId>nacos-client</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!--nacos config-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>com.alibaba.nacos</groupId>
                    <artifactId>nacos-client</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!--dubbo-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.8</version>
        </dependency>
        <!--dubbo nacos-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo-registry-nacos</artifactId>
            <version>2.7.6</version>
            <exclusions>
                <exclusion>
                    <groupId>com.alibaba.nacos</groupId>
                    <artifactId>nacos-client</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!--nacos-->
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>1.3.2</version>
        </dependency>

支付模块

application.properties

# dubbo扫描包路径
dubbo.scan.base-packages=com.chinawu.cloud.pay.service
# dubbo协议
dubbo.protocol.name=dubbo
# 随机端口
dubbo.protocol.port=-1
# zookeeper地址
dubbo.registry.address=nacos://127.0.0.1:8848

DPayService.java

@Service 为Dubbo注解,import org.apache.dubbo.config.annotation.Service;

@Service
public class DPayService implements DPayFacade {

    @Override
    public String goToPay(String userName) {
        System.out.println("dubbo.method:goToPay request "+userName);
        return "dubbo.method:goToPay result:" + userName + " pay success";
    }
}

用户模块

application.properties

# dubbo扫描包路径
dubbo.scan.base-packages=com.chinawu.cloud.user.service
# dubbo协议
dubbo.protocol.name=dubbo
# 随机端口
dubbo.protocol.port=-1
# zookeeper地址
dubbo.registry.address=nacos://127.0.0.1:8848

UserController.java

@RestController
@RequestMapping("/user")
@RefreshScope
public class UserController {

    @Value("${spring.datasource.url}")
    private String datasourceUrl;
    // Dubbo服务消费
    @Reference(check = false)
    DPayFacade dPayFacade;

    /**
     * <p >
     * 功能:获取数据源连接配置信息
     * </p>
     * @param
     * @author wuyubin
     * @date  2020年9月3日
     * @return
     */
    @RequestMapping("/getDatasourceUrl")
    public String getDatasourceUrl() {
        return datasourceUrl;
    }

    /**
     * <p >
     * 功能:测试Dubbo服务调用
     * </p>
     * @param
     * @author wuyubin
     * @date  2020年9月3日
     * @return
     */
    @RequestMapping("/goToPay")
    public String goToPay() {
        return dPayFacade.goToPay("wuyubin");
    }
}

测试验证

支付模块和用户模块都启动后,我们进入Nacos后台进行查看,发现服务都已注册上,如下图

请求下用户模块预留的接口(内部通过Dubbo请求支付模块),如下图
//localhost:9012/user/goToPay

请求下支付模块预留的接口(内部通过Feign请求用户模块),如下图
//localhost:9011/pay/get

至此Nacos和Dubbo已整合至SpringCloud。

参考资料

//github.com/alibaba/spring-cloud-alibaba
//nacos.io/zh-cn/docs/use-nacos-with-dubbo.html

系列文章

SpringCloud系列之配置中心(Config)使用说明

SpringCloud系列之服务注册发现(Eureka)应用篇

SpringCloud系列之网关(Gateway)应用篇

SpringCloud系列之集成Dubbo应用篇

SpringCloud系列之集成分布式事务Seata应用篇

SpringCloud系列之Nacos应用篇

项目源码

在这里插入图片描述