自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

利用Springboot+Dubbo,構(gòu)建分布式微服務(wù),全程注解開發(fā)

開發(fā) 架構(gòu) 分布式
隨著互聯(lián)網(wǎng)的發(fā)展,網(wǎng)站應(yīng)用的規(guī)模不斷擴(kuò)大,常規(guī)的垂直應(yīng)用架構(gòu)已無法應(yīng)對(duì),分布式服務(wù)架構(gòu)以及流動(dòng)計(jì)算架構(gòu)勢在必行,亟需一個(gè)治理系統(tǒng)確保架構(gòu)有條不紊的演進(jìn)。

隨著互聯(lián)網(wǎng)的發(fā)展,網(wǎng)站應(yīng)用的規(guī)模不斷擴(kuò)大,常規(guī)的垂直應(yīng)用架構(gòu)已無法應(yīng)對(duì),分布式服務(wù)架構(gòu)以及流動(dòng)計(jì)算架構(gòu)勢在必行,亟需一個(gè)治理系統(tǒng)確保架構(gòu)有條不紊的演進(jìn)。

[[326586]]

一、先來一張圖

說起 Dubbo,相信大家都不會(huì)陌生!阿里巴巴公司開源的一個(gè)高性能優(yōu)秀的服務(wù)框架,可以使得應(yīng)用可通過高性能的 RPC 實(shí)現(xiàn)服務(wù)的輸出和輸入功能,同時(shí)可以和 Spring 框架無縫集成。

 

Dubbo 架構(gòu)圖

節(jié)點(diǎn)角色說明:

  • Provider:暴露服務(wù)的服務(wù)提供方
  • Consumer:調(diào)用遠(yuǎn)程服務(wù)的服務(wù)消費(fèi)方
  • Registry:服務(wù)注冊(cè)與發(fā)現(xiàn)的注冊(cè)中心
  • Monitor:統(tǒng)計(jì)服務(wù)的調(diào)用次數(shù)和調(diào)用時(shí)間的監(jiān)控中心
  • Container:服務(wù)運(yùn)行容器

二、實(shí)現(xiàn)思路

今天,我們以一個(gè)用戶選擇商品下訂單這個(gè)流程,將其拆分成3個(gè)業(yè)務(wù)服務(wù):用戶中心、商品中心、訂單中心,使用 Springboot + Dubbo 來實(shí)現(xiàn)一個(gè)小 Demo!

服務(wù)交互流程如下:

本文主要是介紹 Springboot 與 Dubbo 的框架整合以及開發(fā)實(shí)踐,而真實(shí)的業(yè)務(wù)服務(wù)拆分是一個(gè)非常復(fù)雜的過程,比我們介紹的這個(gè)要復(fù)雜的多,上文提到的三個(gè)服務(wù)只是為了項(xiàng)目演示,不必過于糾結(jié)為什么要這樣拆分!

好了,廢話也不多說了,下面我們開擼!

  • 1.在虛擬機(jī)創(chuàng)建 4 臺(tái) centos7,任意選擇一臺(tái)安裝 zookeeper
  • 2.構(gòu)建微服務(wù)項(xiàng)目并編寫代碼
  • 3.在 centos7 上部署微服務(wù)
  • 4.遠(yuǎn)程服務(wù)調(diào)用測試

三、zookeeper安裝

在使用 Dubbo 之前,我們需要一個(gè)注冊(cè)中心,目前 Dubbo 可以選擇的注冊(cè)中心有 zookeeper、Nacos 等,一般建議使用 zookeeper!

首先在安裝 Zookeeper 之前,需要安裝并配置好 JDK,本機(jī)采用的是Oracle Java8 SE。

  • 安裝JDK(已經(jīng)安裝可以忽略)
  1. yum -y install java-1.8.0-openjdk 
  • 查看java安裝情況
  1. java -version 

  • JDK安裝完成之后,下載安裝Zookeeper
  1. #創(chuàng)建一個(gè)zookeeper文件夾 
  2. cd /usr 
  3. mkdir zookeeper 
  4.  
  5. #下載zookeeper-3.4.14版本 
  6. wget http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz 
  7.  
  8. #解壓 
  9. tar -zxvf zookeeper-3.4.14.tar.gz 
  • 創(chuàng)建數(shù)據(jù)、日志目錄
  1. #創(chuàng)建數(shù)據(jù)和日志存放目錄 
  2. cd /usr/zookeeper/ 
  3. mkdir data 
  4. mkdir log 
  5.  
  6. #把conf下的zoo_sample.cfg備份一份,然后重命名為zoo.cfg 
  7. cd conf/ 
  8. cp zoo_sample.cfg zoo.cfg 
  • 配置zookeeper
  1. #編輯zoo.cfg文件 
  2. vim zoo.cfg 

  • 啟動(dòng)Zookeeper
  1. #進(jìn)入Zookeeper的bin目錄 
  2. cd zookeeper/zookeeper-3.4.14/bin 
  3.  
  4. #啟動(dòng)Zookeeper 
  5. ./zkServer.sh start 
  6.  
  7. #查詢Zookeeper狀態(tài) 
  8. ./zkServer.sh status 
  9.  
  10. #關(guān)閉Zookeeper狀態(tài) 
  11. ./zkServer.sh stop 

出現(xiàn)如下信息,表示啟動(dòng)成功!

四、項(xiàng)目介紹

  • springboot版本:2.1.1.RELEASE
  • zookeeper版本:3.4.14
  • dubbo版本:2.7.3
  • mybtais-plus版本:3.0.6
  • 數(shù)據(jù)庫:mysql-8
  • 構(gòu)建工具:maven
  • 服務(wù)模塊:用戶中心、商品中心、訂單中心

五、代碼實(shí)踐

5.1、初始化數(shù)據(jù)庫

首先在 mysql 客戶端,創(chuàng)建3個(gè)數(shù)據(jù)庫,分別是:dianshang-user、dianshang-platform、dianshang-business。

  • 在 dianshang-user 數(shù)據(jù)庫中,創(chuàng)建用戶表 tb_user,并初始化數(shù)據(jù)

  • 在 dianshang-platform 數(shù)據(jù)庫中,創(chuàng)建商品表 tb_product,并初始化數(shù)據(jù)

  • 在 dianshang-platform 數(shù)據(jù)庫中,創(chuàng)建訂單表 tb_order、訂單詳情表 tb_order_detail

5.2、創(chuàng)建工程

數(shù)據(jù)庫表設(shè)計(jì)完成之后,在 IDEA 下創(chuàng)建一個(gè)名稱為dianshang的Springboot工程。

最終的目錄如下圖:

目錄結(jié)構(gòu)說明:

  • dianshang-common:主要存放一些公共工具庫,所有的服務(wù)都可以依賴使用
  • dianshang-business:訂單中心,其中api模塊主要是提供dubbo服務(wù)暴露接口,provider模塊是一個(gè)springboot項(xiàng)目,提供服務(wù)處理操作
  • dianshang-user:用戶中心,其中api模塊和provider模塊,設(shè)計(jì)與之類似
  • dianshang-platform:商品中心,其中api模塊和provider模塊,設(shè)計(jì)與之類似

在父類pom文件中加入dubbo和zookeeper客戶端,所有依賴的項(xiàng)目都可以使用。

  1. <!-- lombok --> 
  2. <dependency> 
  3.     <groupId>org.projectlombok</groupId> 
  4.     <artifactId>lombok</artifactId> 
  5.     <version>1.18.4</version> 
  6.     <scope>provided</scope> 
  7. </dependency> 
  8.  
  9. <!-- Dubbo Spring Boot Starter --> 
  10. <dependency> 
  11.     <groupId>org.apache.dubbo</groupId> 
  12.     <artifactId>dubbo-spring-boot-starter</artifactId> 
  13.     <version>2.7.3</version> 
  14. </dependency> 
  15. <!-- 因?yàn)槭褂玫氖?nbsp;zookeeper 作為注冊(cè)中心,所以要添加 zookeeper 依賴 --> 
  16. <dependency> 
  17.     <groupId>org.apache.zookeeper</groupId> 
  18.     <artifactId>zookeeper</artifactId> 
  19.     <version>3.4.13</version> 
  20.     <exclusions> 
  21.         <exclusion> 
  22.             <groupId>org.slf4j</groupId> 
  23.             <artifactId>slf4j-api</artifactId> 
  24.         </exclusion> 
  25.         <exclusion> 
  26.             <groupId>org.slf4j</groupId> 
  27.             <artifactId>slf4j-log4j12</artifactId> 
  28.         </exclusion> 
  29.         <exclusion> 
  30.             <groupId>log4j</groupId> 
  31.             <artifactId>log4j</artifactId> 
  32.         </exclusion> 
  33.     </exclusions> 
  34. </dependency> 
  35. <!--使用curator 作為zookeeper客戶端--> 
  36. <dependency> 
  37.     <groupId>org.apache.curator</groupId> 
  38.     <artifactId>curator-framework</artifactId> 
  39.     <version>4.2.0</version> 
  40. </dependency> 
  41. <dependency> 
  42.     <groupId>org.apache.curator</groupId> 
  43.     <artifactId>curator-recipes</artifactId> 
  44.     <version>4.2.0</version> 
  45. </dependency> 

溫馨提示:小編在搭建環(huán)境的時(shí)候,發(fā)現(xiàn)一個(gè)坑,工程中依賴的zookeeper版本與服務(wù)器的版本,需要盡量一致,例如,本例中zookeeper服務(wù)器的版本是3.4.14,那么在依賴zookeeper文件庫的時(shí)候,也盡量保持一致,如果依賴3.5.x版本的zookeeper,項(xiàng)目在啟動(dòng)的時(shí)候會(huì)各種妖魔鬼怪的報(bào)錯(cuò)!

5.3、創(chuàng)建用戶中心項(xiàng)目

在 IDEA 中,創(chuàng)建dianshang-user子模塊,并依賴dianshang-common模塊

  1. <dependencies> 
  2.     <dependency> 
  3.         <groupId>org.project.demo</groupId> 
  4.         <artifactId>dianshang-common</artifactId> 
  5.         <version>1.0.0</version> 
  6.     </dependency> 
  7. </dependencies> 

同時(shí),創(chuàng)建dianshang-user-provider和dianshang-user-api模塊。

  • dianshang-user-api:主要對(duì)其他服務(wù)提供接口暴露
  • dianshang-user-provider:類似一個(gè)web工程,主要負(fù)責(zé)基礎(chǔ)業(yè)務(wù)的crud,同時(shí)依賴dianshang-user-api模塊

5.3.1、配置dubbo服務(wù)

在dianshang-user-provider的application.yml文件中配置dubbo服務(wù),如下:

  1. #用戶中心服務(wù)端口 
  2. server: 
  3.   port: 8080 
  4. #數(shù)據(jù)源配置 
  5. spring: 
  6.   datasource: 
  7.     druid: 
  8.       driver-class-name: com.mysql.cj.jdbc.Driver 
  9.       url: "jdbc:mysql://localhost:3306/dianshang-user" 
  10.       username: root 
  11.       password: 111111 
  12. #dubbo配置 
  13. dubbo: 
  14.   scan: 
  15.     # 包名根據(jù)自己的實(shí)際情況寫 
  16.     base-packages: org.project.dianshang.user 
  17.   protocol: 
  18.     port: 20880 
  19.     name: dubbo 
  20.   registry: 
  21.     #zookeeper注冊(cè)中心地址 
  22.     address: zookeeper://192.168.0.107:2181 

5.3.2、編寫服務(wù)暴露接口以及實(shí)現(xiàn)類

在dianshang-user-api模塊中,創(chuàng)建一個(gè)UserApi接口,以及返回參數(shù)對(duì)象UserVo!

  1. public interface UserApi { 
  2.  
  3.     /** 
  4.      * 查詢用戶信息 
  5.      * @param userId 
  6.      * @return 
  7.      */ 
  8.     UserVo findUserById(String userId); 

其中UserVo,需要實(shí)現(xiàn)序列化,如下:

  1. @Data 
  2. @EqualsAndHashCode(callSuper = false
  3. @Accessors(chain = true
  4. public class UserVo implements Serializable { 
  5.  
  6.     private static final long serialVersionUID = 1L; 
  7.  
  8.     /** 
  9.      * 用戶ID 
  10.      */ 
  11.     private String userId; 
  12.  
  13.     /** 
  14.      * 用戶中文名 
  15.      */ 
  16.     private String userName; 

在dianshang-user-provider模塊中,編寫UserApi接口實(shí)現(xiàn)類,如下:

  1. @Service(interfaceClass =UserApi.class) 
  2. @Component 
  3. public class UserProvider implements UserApi { 
  4.  
  5.     @Autowired 
  6.     private UserService userService; 
  7.  
  8.     @Override 
  9.     public UserVo findUserById(String userId) { 
  10.         QueryWrapper<User> queryWrapper = new QueryWrapper<User>(); 
  11.         queryWrapper.eq("user_id",userId); 
  12.         User source = userService.getOne(queryWrapper); 
  13.         if(source != null){ 
  14.             UserVo vo = new UserVo(); 
  15.             BeanUtils.copyProperties(source,vo); 
  16.             return vo; 
  17.         } 
  18.         return null
  19.     } 

其中的注解@Service指的是org.apache.dubbo.config.annotation.Service下的注解,而不是Spring下的注解哦!

接著,我們繼續(xù)創(chuàng)建商品中心項(xiàng)目!

5.4、創(chuàng)建商品中心項(xiàng)目

與用戶中心項(xiàng)目類似,在 IDEA 中,創(chuàng)建dianshang-platform子模塊,并依賴dianshang-common模塊

  1. <dependencies> 
  2.     <dependency> 
  3.         <groupId>org.project.demo</groupId> 
  4.         <artifactId>dianshang-common</artifactId> 
  5.         <version>1.0.0</version> 
  6.     </dependency> 
  7. </dependencies> 

同時(shí),創(chuàng)建dianshang-platform-provider和dianshang-platform-api模塊。

  • dianshang-platform-api:主要對(duì)其他服務(wù)提供接口暴露
  • dianshang-platform-provider:類似一個(gè)web工程,主要負(fù)責(zé)基礎(chǔ)業(yè)務(wù)的crud,同時(shí)依賴dianshang-platform-api模塊

5.4.1、配置dubbo服務(wù)

在dianshang-platform-provider的application.yml文件中配置dubbo服務(wù),如下:

  1. #用戶中心服務(wù)端口 
  2. server: 
  3.   port: 8081 
  4. #數(shù)據(jù)源配置 
  5. spring: 
  6.   datasource: 
  7.     druid: 
  8.       driver-class-name: com.mysql.cj.jdbc.Driver 
  9.       url: "jdbc:mysql://localhost:3306/dianshang-platform" 
  10.       username: root 
  11.       password: 111111 
  12. #dubbo配置 
  13. dubbo: 
  14.   scan: 
  15.     # 包名根據(jù)自己的實(shí)際情況寫 
  16.     base-packages: org.project.dianshang.platform 
  17.   protocol: 
  18.     port: 20881 
  19.     name: dubbo 
  20.   registry: 
  21.     #zookeeper注冊(cè)中心地址 
  22.     address: zookeeper://192.168.0.107:2181 

5.4.2、編寫服務(wù)暴露接口以及實(shí)現(xiàn)類

在dianshang-platform-api模塊中,創(chuàng)建一個(gè)ProductApi接口,以及返回參數(shù)對(duì)象ProductVo!

  1. public interface ProductApi { 
  2.  
  3.     /** 
  4.      * 通過商品ID,查詢商品信息 
  5.      * @param productId 
  6.      * @return 
  7.      */ 
  8.     ProductVo queryProductInfoById(String productId); 

其中ProductVo,需要實(shí)現(xiàn)序列化,如下:

  1. @Data 
  2. @EqualsAndHashCode(callSuper = false
  3. @Accessors(chain = true
  4. public class ProductVo implements Serializable { 
  5.  
  6.     private static final long serialVersionUID = 1L; 
  7.  
  8.     /**商品ID*/ 
  9.     private String productId; 
  10.  
  11.     /**商品名稱*/ 
  12.     private String productName; 
  13.  
  14.     /**商品價(jià)格*/ 
  15.     private BigDecimal productPrice; 

在dianshang-platform-provider模塊中,編寫ProductApi接口實(shí)現(xiàn)類,如下:

  1. @Service(interfaceClass = ProductApi.class) 
  2. @Component 
  3. public class ProductProvider implements ProductApi { 
  4.  
  5.     @Autowired 
  6.     private ProductService productService; 
  7.  
  8.     @Override 
  9.     public ProductVo queryProductInfoById(String productId) { 
  10.         //通過商品ID查詢信息 
  11.         Product source = productService.getById(productId); 
  12.         if(source != null){ 
  13.             ProductVo vo = new ProductVo(); 
  14.             BeanUtils.copyProperties(source,vo); 
  15.             return vo; 
  16.         } 
  17.         return null
  18.     } 

接著,我們繼續(xù)創(chuàng)建訂單中心項(xiàng)目!

5.5、創(chuàng)建訂單中心項(xiàng)目

與商品中心項(xiàng)目類似,在 IDEA 中,創(chuàng)建dianshang-business子模塊,并依賴dianshang-common模塊

  1. <dependencies> 
  2.     <dependency> 
  3.         <groupId>org.project.demo</groupId> 
  4.         <artifactId>dianshang-common</artifactId> 
  5.         <version>1.0.0</version> 
  6.     </dependency> 
  7. </dependencies> 

同時(shí),創(chuàng)建dianshang-business-provider和dianshang-business-api模塊。

  • dianshang-business-api:主要對(duì)其他服務(wù)提供接口暴露
  • dianshang-business-provider:類似一個(gè)web工程,主要負(fù)責(zé)基礎(chǔ)業(yè)務(wù)的crud,同時(shí)依賴dianshang-business-api模塊

5.5.1、配置dubbo服務(wù)

在dianshang-business-provider的application.yml文件中配置dubbo服務(wù),如下:

  1. #用戶中心服務(wù)端口 
  2. server: 
  3.   port: 8082 
  4. #數(shù)據(jù)源配置 
  5. spring: 
  6.   datasource: 
  7.     druid: 
  8.       driver-class-name: com.mysql.cj.jdbc.Driver 
  9.       url: "jdbc:mysql://localhost:3306/dianshang-business" 
  10.       username: root 
  11.       password: 111111 
  12. #dubbo配置 
  13. dubbo: 
  14.   scan: 
  15.     # 包名根據(jù)自己的實(shí)際情況寫 
  16.     base-packages: org.project.dianshang.business 
  17.   protocol: 
  18.     port: 20882 
  19.     name: dubbo 
  20.   registry: 
  21.     #zookeeper注冊(cè)中心地址 
  22.     address: zookeeper://192.168.0.107:2181 

5.5.2、編寫服務(wù)暴露接口以及實(shí)現(xiàn)類

在dianshang-business-api模塊中,創(chuàng)建一個(gè)OrderApi接口,以及返回參數(shù)對(duì)象OrderVo!

  1. public interface OrderApi { 
  2.  
  3.     /** 
  4.      * 通過用戶ID,查詢用戶訂單信息 
  5.      * @param userId 
  6.      * @return 
  7.      */ 
  8.     List<OrderVo> queryOrderByUserId(String userId); 

其中OrderVo,需要實(shí)現(xiàn)序列化,如下:

  1. @Data 
  2. @EqualsAndHashCode(callSuper = false
  3. @Accessors(chain = true
  4. public class OrderVo implements Serializable { 
  5.  
  6.     private static final long serialVersionUID = 1L; 
  7.  
  8.     /**訂單ID*/ 
  9.     private String orderId; 
  10.  
  11.     /**訂單編號(hào)*/ 
  12.     private String orderNo; 
  13.  
  14.     /**訂單金額*/ 
  15.     private BigDecimal orderPrice; 
  16.  
  17.     /**下單時(shí)間*/ 
  18.     private Date orderTime; 

在dianshang-business-provider模塊中,編寫OrderApi接口實(shí)現(xiàn)類,如下:

  1. @Service(interfaceClass = OrderApi.class) 
  2. @Component 
  3. public class OrderProvider implements OrderApi { 
  4.  
  5.     @Autowired 
  6.     private OrderService orderService; 
  7.  
  8.     @Override 
  9.     public List<OrderVo> queryOrderByUserId(String userId) { 
  10.         QueryWrapper<Order> queryWrapper = new QueryWrapper<Order>(); 
  11.         queryWrapper.eq("user_id",userId); 
  12.         List<Order> sourceList = orderService.list(queryWrapper); 
  13.         if(!CollectionUtils.isEmpty(sourceList)){ 
  14.             List<OrderVo> voList = new ArrayList<>(); 
  15.             for (Order order : sourceList) { 
  16.                 OrderVo vo = new OrderVo(); 
  17.                 BeanUtils.copyProperties(order, vo); 
  18.                 voList.add(vo); 
  19.             } 
  20.             return voList; 
  21.         } 
  22.         return null
  23.     } 

至此,3個(gè)項(xiàng)目的服務(wù)暴露接口已經(jīng)開發(fā)完成!接下來我們來編寫怎么進(jìn)行遠(yuǎn)程調(diào)用!

5.6、遠(yuǎn)程調(diào)用

5.6.1、編寫創(chuàng)建訂單服務(wù)

在dianshang-business-provider模塊中,編寫創(chuàng)建訂單接口之前,先依賴dianshang-business-api和dianshang-user-api,如下:

  1. <!--商品服務(wù)接口暴露 api--> 
  2. <dependency> 
  3.     <groupId>org.project.demo</groupId> 
  4.     <artifactId>dianshang-platform-api</artifactId> 
  5.     <version>1.0.0</version> 
  6. </dependency> 
  7. <!--用戶服務(wù)接口暴露 api--> 
  8. <dependency> 
  9.     <groupId>org.project.demo</groupId> 
  10.     <artifactId>dianshang-user-api</artifactId> 
  11.     <version>1.0.0</version> 
  12. </dependency> 

在dianshang-business-provider模塊中,編寫創(chuàng)建訂單服務(wù),如下:

  1. @RestController 
  2. @RequestMapping("/order"
  3. public class OrderController { 
  4.  
  5.     @Autowired 
  6.     private OrderService orderService; 
  7.  
  8.     @Autowired 
  9.     private OrderDetailService orderDetailService; 
  10.  
  11.     @Reference(check =false
  12.     private ProductApi productApi; 
  13.  
  14.     @Reference(check =false
  15.     private UserApi userApi; 
  16.  
  17.     /** 
  18.      * 新增 
  19.      */ 
  20.     @JwtIgnore 
  21.     @RequestMapping(value = "/add"
  22.     public boolean add(String productId,String userId){ 
  23.         LocalAssert.isStringEmpty(productId,"產(chǎn)品Id不能為空"); 
  24.         LocalAssert.isStringEmpty(userId,"用戶Id不能為空"); 
  25.         ProductVo productVo = productApi.queryProductInfoById(productId); 
  26.         LocalAssert.isObjectEmpty(productVo,"未查詢到產(chǎn)品信息"); 
  27.         UserVo userVo = userApi.findUserById(userId); 
  28.         LocalAssert.isObjectEmpty(userVo,"未查詢到用戶信息"); 
  29.         Order order = new Order(); 
  30.         order.setOrderId(IdGenerator.uuid()); 
  31.         order.setOrderNo(System.currentTimeMillis() + ""); 
  32.         order.setOrderPrice(productVo.getProductPrice()); 
  33.         order.setUserId(userId); 
  34.         order.setOrderTime(new Date()); 
  35.         orderService.save(order); 
  36.  
  37.         OrderDetail orderDetail = new OrderDetail(); 
  38.         orderDetail.setOrderDetailId(IdGenerator.uuid()); 
  39.         orderDetail.setOrderId(order.getOrderId()); 
  40.         orderDetail.setProductId(productId); 
  41.         orderDetail.setSort(1); 
  42.         orderDetailService.save(orderDetail); 
  43.         return true
  44.     } 

其中的@Reference注解,是屬于org.apache.dubbo.config.annotation.Reference下的注解,表示遠(yuǎn)程依賴服務(wù)。

參數(shù)check =false表示啟動(dòng)服務(wù)時(shí),不做遠(yuǎn)程服務(wù)狀態(tài)檢查,這樣設(shè)置的目的就是為了防止當(dāng)前服務(wù)啟動(dòng)不了,例如用戶中心項(xiàng)目沒有啟動(dòng)成功,但是訂單中心又依賴了用戶中心,如果check=true,此時(shí)訂單中心啟動(dòng)會(huì)報(bào)錯(cuò)!

5.6.2、編寫用戶查詢自己的訂單信息

同樣的,在dianshang-user-provider模塊中,編寫用戶查詢自己的訂單信息接口之前,先依賴dianshang-business-api和dianshang-user-api,如下:

  1. <dependency> 
  2.     <groupId>org.project.demo</groupId> 
  3.     <artifactId>dianshang-business-api</artifactId> 
  4.     <version>1.0.0</version> 
  5. </dependency> 
  6. <dependency> 
  7.     <groupId>org.project.demo</groupId> 
  8.     <artifactId>dianshang-user-api</artifactId> 
  9.     <version>1.0.0</version> 
  10. </dependency> 

在dianshang-user-provider模塊中,編寫用戶查詢自己的訂單信息接口,如下:

  1. @RestController 
  2. @RequestMapping("/user"
  3. public class UserController { 
  4.  
  5.     @Reference(check =false
  6.     private OrderApi orderApi; 
  7.  
  8.  
  9.     /** 
  10.      * 通過用戶ID,查詢訂單信息 
  11.      * @param userId 
  12.      * @return 
  13.      */ 
  14.     @RequestMapping("/list"
  15.     public List<OrderVo> queryOrderByUserId(String userId){ 
  16.         return orderApi.queryOrderByUserId(userId); 
  17.     } 

至此,遠(yuǎn)程服務(wù)調(diào)用,編寫完成!

六、服務(wù)測試

在將項(xiàng)目部署在服務(wù)器之前,咱們先本地測試一下,看服務(wù)是否都可以跑通?

  • 啟動(dòng)用戶中心dianshang-user-provider

  • 繼續(xù)啟動(dòng)商品中心dianshang-platform-provider

接著啟動(dòng)訂單中心dianshang-business-provider

最后,我們來測試一下服務(wù)接口是否為我們預(yù)期的結(jié)果?

打開瀏覽器,輸入http://127.0.0.1:8082/order/add?productId=1&userId=1測試創(chuàng)建訂單接口,頁面運(yùn)行結(jié)果顯示正常!

我們?cè)賮砜纯磾?shù)據(jù)庫,訂單是否生成?

ok!很清晰的看到,數(shù)據(jù)已經(jīng)進(jìn)去了,沒啥問題!

我們?cè)賮頊y試一下在用戶中心訂單查詢接口,輸入http://127.0.0.1:8080/user/list?userId=1,頁面運(yùn)行結(jié)果如下!

到此,本地服務(wù)測試基本通過!

七、服務(wù)器部署

在上文中,我們介紹了服務(wù)的構(gòu)建、開發(fā)和測試,那如何在服務(wù)器端部署呢?

首先,修改各個(gè)項(xiàng)目的application.yml文件,將其中的數(shù)據(jù)源地址、dubbo注冊(cè)中心地址修改為線上能聯(lián)通的地址,然后在dianshang目錄下使用maven工具對(duì)整個(gè)工程執(zhí)行如下命令進(jìn)行打包!

  1. mvn clean install 

也可以在 IDEA 環(huán)境下,通過maven配置clean install命令執(zhí)行打包。

將各個(gè)項(xiàng)目target目錄下的dianshang-user-provider.jar、dianshang-platform-provider.jar、dianshang-business-provider.jar拷貝出來。

分別上傳到對(duì)應(yīng)的服務(wù)器目錄,本服務(wù)器采用的是 CentOS7,總共4臺(tái)服務(wù)器,其中一臺(tái)部署zookeeper,另外三臺(tái)部署三個(gè)微服務(wù)項(xiàng)目。

登錄服務(wù)器,輸入如下命令,確保JDK已經(jīng)安裝完成!

  1. java -version 

關(guān)閉所有服務(wù)器的防火墻,放行端口訪問!

  1. #關(guān)閉防火墻 
  2. systemctl stop firewalld.service 
  3.  
  4. #禁止開機(jī)啟動(dòng) 
  5. systemctl disable firewalld.service 
  • 啟動(dòng)用戶中心服務(wù),日志信息輸出到service.log(虛擬機(jī)ip:192.168.0.108)
  1. nohup java -jar  dianshang-user-provider.jar > service.log 2>&1 & 
  • 啟動(dòng)商品中心服務(wù),日志信息輸出到service.log(虛擬機(jī)ip:192.168.0.107)
  1. nohup java -jar  dianshang-platform-provider.jar > service.log 2>&1 & 
  • 啟動(dòng)訂單中心服務(wù),日志信息輸出到service.log(虛擬機(jī)ip:192.168.0.109)
  1. nohup java -jar  dianshang-business-provider.jar > service.log 2>&1 & 

打開瀏覽器,輸入http://192.168.0.109:8082/order/add?productId=1&userId=1測試創(chuàng)建訂單接口,頁面運(yùn)行結(jié)果顯示正常!

我們?cè)賮頊y試一下在用戶中心訂單查詢接口,輸入輸入http://192.168.0.108:8080/user/list?userId=1,頁面運(yùn)行結(jié)果如下!

很清晰的看到,輸出了2條信息,第二條訂單是在測試環(huán)境服務(wù)器生成的,第一條是本地開發(fā)環(huán)境生成的。

到此,服務(wù)器部署基本已經(jīng)完成!

如果是生產(chǎn)環(huán)境,可能就需要多臺(tái)zookeeper來保證高可用,至少2臺(tái)服務(wù)器來部署業(yè)務(wù)服務(wù),通過負(fù)載均衡來路由!

八、總結(jié)

整片文章比較長,主要是圍繞 springboot + dubbo 的整合,通過注解開發(fā)實(shí)現(xiàn)遠(yuǎn)程服務(wù)調(diào)用像傳統(tǒng)的 springmvc 開發(fā)一樣輕松,當(dāng)然還可以通過xml配置方式實(shí)現(xiàn)dubbo服務(wù)的調(diào)用,這個(gè)會(huì)在后期去介紹。

同時(shí)也介紹了服務(wù)器的部署,從中可以看出,開發(fā)雖然簡單,但是由于分布式部署,如何保證服務(wù)高可用成了開發(fā)人員頭等工作任務(wù),所以,分布式微服務(wù)開發(fā)雖然開發(fā)簡單,但是如何確保部署的服務(wù)高可用?運(yùn)維方面會(huì)帶來不少的挑戰(zhàn)!

九、參考

1、apache - dubbo - 官方文檔

 

責(zé)任編輯:武曉燕 來源: Java極客技術(shù)
相關(guān)推薦

2019-07-18 12:41:52

數(shù)字化服務(wù)網(wǎng)格微服務(wù)

2020-05-18 14:00:01

Dubbo分布式架構(gòu)

2023-09-25 08:00:00

架構(gòu)微服務(wù)

2023-11-01 08:00:00

負(fù)載均衡架構(gòu)開發(fā)

2018-03-02 16:11:29

Spring Clou分布式服務(wù)跟蹤

2025-04-11 02:30:00

2018-04-09 13:56:13

微服務(wù)架構(gòu)分布式

2018-03-13 16:42:26

分布式服務(wù)跟蹤

2018-04-02 15:01:31

微服務(wù)架構(gòu)分布式服務(wù)

2018-04-16 14:56:56

微服務(wù)架構(gòu)分布式服務(wù)

2018-04-18 16:07:49

Spring Clou微服務(wù)分布式

2017-07-28 16:41:53

Spring Clou微服務(wù)架構(gòu)

2020-02-25 23:39:11

架構(gòu)運(yùn)維技術(shù)

2018-05-23 15:58:27

Spring Clou微服務(wù)架構(gòu)

2018-07-19 14:58:14

Spring Clou微服務(wù)架構(gòu)

2023-08-25 16:26:49

微服務(wù)架構(gòu)

2017-03-02 13:19:43

dubbo分布式框架

2015-07-21 16:23:22

Node.js構(gòu)建分布式

2022-09-19 07:03:12

SPI開源開發(fā)者

2019-08-07 10:44:28

MySQLGoogle
點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號(hào)