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

<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.5</version>
</dependency>

dubbo2.7.x

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

項目說明

本章節主要記錄集成Dubbo，所以SpringCloud組件中只用到了Eureka服務，為了便於說明Duboo服務調用簡單搞了個圖說明下

因僅僅是簡單演示，我這邊偷下懶，通過訪問老項目中/web/user/addCart接口調用新項目中DCartServiceImpl的addCart方法，其中addCart方法中又會調用老項目中UserServiceImpl的getByUserId方法，從而演示SpringCloud項目和Dubbo項目之間互相調用

集成Dubbo 2.6.x

新項目模塊

項目結構圖如下

cart-facade 購物車對外接口定義模塊
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">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.chinawu.cloud</groupId>
    <artifactId>cart-facade</artifactId>
    <version>1.0.0-SNAPSHOT</version>
</project>

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 購物車接口實現模塊
pom.xml

<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.5</version>
</dependency>
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>2.12.0</version>
</dependency>
<!--老項目用戶模塊對外接口-->
<dependency>
    <groupId>com.chinawu.old</groupId>
    <artifactId>user-facade</artifactId>
    <version>1.0.0-SNAPSHOT</version>
</dependency>

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 用戶模塊業務模塊
項目結構如下

pom.xml

<dependencies>
    <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>
</dependencies>

user-dubbo.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	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>

</beans>

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

如果項目中使用的Dubbo為2.7.x系列的，調整相關jar包依賴即可。

新項目模塊

新項目中將原先dubbo-spring-boot-starter和dubbo進行如下替換

<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.7.6</version>
</dependency>
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo</artifactId>
    <version>2.7.6</version>
</dependency>
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>4.0.1</version>
</dependency>
<dependency>
    <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>
</dependency>
<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.4.7</version>
</dependency>

如果調整后項目啟動報錯，則需根據相應報錯內容進行解決，主要是依賴包的版本問題，筆者在調整工程中就遇到如下問題
問題：org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented
原因：
因為項目中有依賴curator-recipes包，而curator-recipes 4.0.1包中依賴zookeeper版本是3.5.x的，排除curator-recipes包中的zookeeper，依賴自己的zookeeper版本即可

老項目模塊

老項目模塊升級比較方便，直接將原先dubbo調整如下即可

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

最后通過訪問，獲取到正常數據就OK啦
http://localhost:8080/xxx_web_war_exploded/web/user/addCart?userId=1&goodsId=1

參考資料

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

系列文章

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

SpringCloud系列之服務注冊發現（Eureka）應用篇

SpringCloud系列之網關（Gateway）應用篇

項目源碼