SpringCloud系列之集成Dubbo应用篇

前言

项目版本

项目说明

集成Dubbo 2.6.x

新项目模块

老项目模块

集成Dubbo 2.7.x

参考资料

系列文章

SpringCloud系列开篇文章就说到了，公司新项目将入坑SpringCloud全家桶，但原先线上老项目是采用Spring+Dubbo技术栈的，新项目中的部分业务还是和老项目有点关联的，重写这一部分业务逻辑也是需要点时间，本来想通过http请求进行业务交互的，总感觉不够优雅，原先也了解过SpringCloud Alibaba，趁着这个机会捣腾捣腾。

spring-boot-version：2.2.5.RELEASE

spring-cloud.version：Hoxton.SR3

dubbo版本会分成2.6.x系列和2.7.x系列二个版本进行说明

dubbo2.6.x

<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.2.1.RELEASE</version>

<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.5</version>

dubbo2.7.x

<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.6</version>

<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo</artifactId>
<version>2.7.6</version>

本章节主要记录集成Dubbo，所以SpringCloud组件中只用到了Eureka服务，为了便于说明Duboo服务调用简单搞了个图说明下

因仅仅是简单演示，我这边偷下懒，通过访问老项目中/web/user/addCart接口调用新项目中DCartServiceImpl的addCart方法，其中addCart方法中又会调用老项目中UserServiceImpl的getByUserId方法，从而演示SpringCloud项目和Dubbo项目之间互相调用

项目结构图如下

cart-facade 购物车对外接口定义模块

pom.xml

<?xml version="1.0" encoding="UTF-8"?>

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>com.chinawu.cloud</groupId>
<artifactId>cart-facade</artifactId>
<version>1.0.0-SNAPSHOT</version>

DCartService.java

public interface DCartService {

/**
 * <p >
 * 功能：加入购物车
 * </p>
 * @param userId 用户id
 * @param goodsId 物品id
 * @author wuyubin
 * @date  2020年04月22日
 * @return
 */
String addCart(Long userId,Long goodsId);

}

cart-service 购物车接口实现模块

<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.2.1.RELEASE</version>

<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.5</version>

<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>2.12.0</version>

<groupId>com.chinawu.old</groupId>
<artifactId>user-facade</artifactId>
<version>1.0.0-SNAPSHOT</version>

application.properties

服务端口

server.port=9007

服务应用名称

spring.application.name=cart-service

eureka服务端地址

eureka.client.serviceUrl.defaultZone=

http://localhost:9003/eureka/

dubbo扫描包路径

dubbo.scan.base-packages=com.chinawu.cloud.cart.service

dubbo协议

dubbo.protocol.name=dubbo

随机端口

dubbo.protocol.port=-1

zookeeper地址

dubbo.registry.address=zookeeper://127.0.0.1:2181

DCartServiceImpl.java

注意事项：

@Service为com.alibaba.dubbo.config.annotation包下的注解标签而不是Spring中的

@Reference 申明引用Dubbo服务

@Service

public class DCartServiceImpl implements DCartService {

Logger LOGGER = LoggerFactory.getLogger(DCartServiceImpl.class);
@Reference
DUserService dUserService;
/**
 * <p >
 * 功能：加入购物车
 * </p>
 * @param userId 用户id
 * @param goodsId 物品id
 * @author wuyubin
 * @date  2020年04月22日
 * @return
 */
public String addCart(Long userId,Long goodsId) {
    DUserDTO userDTO = dUserService.getByUserId(userId);
    LOGGER.info("i am springcloud project dubbo method:addCart,userId:{},goodsId:{}",userId,goodsId);
    return userDTO.toString()+" addCart goodsId:"+goodsId+" success";
}

CartServiceApplication.java

@SpringBootApplication

@EnableDiscoveryClient

//@EnableAutoConfiguration

public class CartServiceApplication {

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

xxx-user模块依托于xxx-web模块运行访问，项目结构图如下

user-facade 用户模块对外接口定义类

项目结构如下

public interface DUserService {

/**
 * <p >
 * 功能：根据用户id查询用户信息
 * </p>
 * @param
 * @author wuyubin
 * @date  2020年04月23日
 * @return
 */
DUserDTO getByUserId(Long userId);

user-service 用户模块业务模块

<dependency>
    <groupId>com.chinawu.old</groupId>
    <artifactId>user-facade</artifactId>
    <version>1.0.0-SNAPSHOT</version>
</dependency>
<!--新项目Dubbo接口定义类-->
<dependency>
    <groupId>com.chinawu.cloud</groupId>
    <artifactId>cart-facade</artifactId>
    <version>1.0.0-SNAPSHOT</version>
</dependency>

user-dubbo.xml

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd        http://code.alibabatech.com/schema/dubbo        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

<!--对外暴露提供服务接口-->
<dubbo:service  interface="com.chinawu.old.user.facade.interfaces.DUserService" ref="userServiceImpl" />
<!--引用其他模块服务接口-->
<dubbo:reference interface="com.chinawu.cloud.cart.interfaces.DCartService" id="userServiceDCartService"></dubbo:reference>

UserServiceImpl.java

此处@Service为org.springframework.stereotype.Service

@Service("userServiceImpl")

public class UserServiceImpl implements UserService,DUserService {

Logger LOGGER = LoggerFactory.getLogger(UserServiceImpl.class);
@Autowired
DCartService userServiceDCartService;
/**
 * <p >
 * 功能：根据用户id获取会员名称
 * </p>
 * @param
 * @author wuyubin
 * @date  2020年04月23日
 * @return
 */
public String getNameById(Long userId) {
    return "admin";
}
/**
 * <p >
 * 功能：根据用户id查询用户信息
 * </p>
 * @param
 * @author wuyubin
 * @date  2020年04月23日
 * @return
 */
public DUserDTO getByUserId(Long userId) {
    DUserDTO dto = null;
    String userName = getNameById(userId);
    if (null != userName && !"".equals(userName)) {
        dto = new DUserDTO();
        dto.setUserId(userId);
        dto.setUserName(userName);
        dto.setCreateTime(new Date());
    }
    LOGGER.info("i am old project dubbo method:getByUserId,userId:{}",userId);
    return dto;
}
/**
 * <p >
 * 功能：添加购物车（仅仅演示SpringCloud和Dubbo集成）
 * </p>
 * @param
 * @author wuyubin
 * @date  2020年04月23日
 * @return
 */
public String addCart(Long userId,Long goodsId) {
    return userServiceDCartService.addCart(userId,goodsId);
}

user-web 用户模块web请求

WebUserController.java

@RestController

@RequestMapping("/web/user")

public class WebUserController {

@Autowired
UserService userServiceImpl;
@RequestMapping(value = "/detail")
public String getDetail(Long userId){
    return userServiceImpl.getNameById(userId);
}
@RequestMapping(value = "/addCart")
public String addCart(Long userId,Long goodsId){
    return userServiceImpl.addCart(userId,goodsId);
}

最后通过访问

http://localhost:8080/xxx_web_war_exploded/web/user/addCart?userId=1&goodsId=1

如果项目中使用的Dubbo为2.7.x系列的，调整相关jar包依赖即可。

新项目中将原先dubbo-spring-boot-starter和dubbo进行如下替换

<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.6</version>

<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo</artifactId>
<version>2.7.6</version>

<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>4.0.1</version>

<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>4.0.1</version>
<exclusions>
    <exclusion>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
    </exclusion>
</exclusions>

<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.7</version>

如果调整后项目启动报错，则需根据相应报错内容进行解决，主要是依赖包的版本问题，笔者在调整工程中就遇到如下问题

问题：org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented

原因：

因为项目中有依赖curator-recipes包，而curator-recipes 4.0.1包中依赖zookeeper版本是3.5.x的，排除curator-recipes包中的zookeeper，依赖自己的zookeeper版本即可

老项目模块升级比较方便，直接将原先dubbo调整如下即可

<groupId>org.apache.dubbo</groupId>

dubbo

<version>2.7.6</version>

最后通过访问，获取到正常数据就OK啦

https://github.com/apache/dubbo-spring-boot-project

SpringCloud系列之配置中心（Config）使用说明

SpringCloud系列之服务注册发现（Eureka）应用篇

SpringCloud系列之网关（Gateway）应用篇

项目源码

原文地址

https://www.cnblogs.com/chinaWu/p/12818661.html

SpringCloud系列之集成Dubbo应用篇服务端口服务应用名称eureka服务端地址dubbo扫描包路径dubbo协议随机端口zookeeper地址

服务端口

服务应用名称

eureka服务端地址

dubbo扫描包路径

dubbo协议

随机端口

zookeeper地址

继续阅读

nginx location中斜线的位置的重要性

Apache2.4.x 配置文件详解Apache配置需要了解如下：开始讲解：

配置apache支持PHP（win7）

27 Best Free Eclipse Plug-ins for Java Developer to be ProductiveCode Quality PluginsText Editor PluginsDependency ManagementVersion Control Integration PluginsFramework Development Continuous Integration Related PluginsOther Utility Plugins

Java String.format方法的简单使用

neo4j之cypher使用文档

GitHub连夜封杀！这份阿里 10W 字内部 Java 字面试手册到底有多强？

spark/scala关于【资源文件】加载方法概述外部文件加载方案测试资源文件打包入jar包中小结

mybatis_入门程序Mybatis入门

AOP编程_Android优雅权限框架(1)概念基础，2021金三银四前言正文大纲正文

Effective Java 8:通用程序设计

OOM三种类型

工厂模式-三种类型

【递归】高效率求2的n次幂

win10本地scala和spark安装安装scala安装spark

scala (3) Function 和 Method