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