Dubbo與SpringBoot整合流程(從實例入手，附代碼下載)

来源:https://www.cnblogs.com/badaoliumangqizhi/archive/2019/12/31/12122336.html
-Advertisement-
Play Games

場景 Dubbo環境搭建-管理控制台dubbo-admin實現服務監控： https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/103624846 Dubbo搭建HelloWorld-搭建服務提供者與服務消費者並完成遠程調用(附代碼下載) ...


場景

Dubbo環境搭建-管理控制台dubbo-admin實現服務監控：

https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/103624846

Dubbo搭建HelloWorld-搭建服務提供者與服務消費者並完成遠程調用(附代碼下載)：

https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/103675259

在上面搭建好Dubbo的HelloWorld後，將其與Springboot項目進行整合。

註：

博客：
https://blog.csdn.net/badao_liumang_qizhi
關註公眾號
霸道的程式猿
獲取編程相關電子書、教程推送與免費下載。

實現

還是採用上面用戶服務提供者和訂單服務消費者的模式。

將公共的介面和實體類抽離出來，放在gmall-interface中。

新建服務提供者

打開Eclipse-新建一個Spring Starter Project

 

 

點擊Next，輸入相關包名與應用名

 

 

點擊next,這裡新建的是服務提供者，只需要簡單的SpringBoot項目，不用選擇Web依賴，直接點擊Next,

註意這裡的SpringBoot的版本為2.2.2，在後面選擇Dubbo-starter依賴時有版本對應關係。

 

 

建完之後的目錄為

 

 

然後打開pom.xml，添加上面公共介面的依賴以及dubbo-starter的依賴。

引入公共介面依賴，具體實現參照上面博客

  <dependency>
   <groupId>com.badao.gmall</groupId>
   <artifactId>gmall-interface</artifactId>
   <version>0.0.1-SNAPSHOT</version>
  </dependency>

 

引入dubbo-starter以及相關依賴

按照其官方指示：https://github.com/apache/dubbo-spring-boot-project

添加相應的dubbo的依賴和dubbo-starter的依賴

 

 

完整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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>2.2.2.RELEASE</version>
  <relativePath/> <!-- lookup parent from repository -->
 </parent>
 <groupId>com.badao</groupId>
 <artifactId>boot-user-service-provider</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <name>boot-user-service-provider</name>
 <description>Demo project for Spring Boot</description>

 <properties>
  <java.version>1.8</java.version>
 </properties>

 <dependencies>
  <dependency>
   <groupId>com.badao.gmall</groupId>
   <artifactId>gmall-interface</artifactId>
   <version>0.0.1-SNAPSHOT</version>
  </dependency>
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter</artifactId>
  </dependency>
  <!-- 引入dubbo -->
  <dependency>
   <groupId>com.alibaba</groupId>
   <artifactId>dubbo</artifactId>
   <version>2.6.2</version>
  </dependency>
  <!-- 註冊中心使用的是zookeeper，引入操作zookeeper的客戶端端 -->
  <dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-framework</artifactId>
   <version>2.12.0</version>
  </dependency>
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-test</artifactId>
   <scope>test</scope>
   <exclusions>
    <exclusion>
     <groupId>org.junit.vintage</groupId>
     <artifactId>junit-vintage-engine</artifactId>
    </exclusion>
   </exclusions>
  </dependency>
  <!-- Dubbo Spring Boot Starter -->
     <dependency>
         <groupId>com.alibaba.boot</groupId>
         <artifactId>dubbo-spring-boot-starter</artifactId>
         <version>0.2.1.RELEASE</version>
     </dependency>
 </dependencies>

 <build>
  <plugins>
   <plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
   </plugin>
  </plugins>
 </build>

</project>

 

參考上面博客搭建服務提供者時配置信息是在provider.xml中進行配置，在這裡要將其配置在application.properties中。

 

dubbo.application.name=user-service-provider
dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper
#
dubbo.protocol.name=dubbo
dubbo.protocol.port=20881
#
dubbo.monitor.protocol=registry
dubbo.scan.base-packages=com.badao.gmall

 

具體配置信息作用見上面博客。或者參照其官方指示

 

 

然後將上面博客搭建好的serviceImpl複製到springBoot項目中

package com.badao.gmall.service.impl;

import java.util.Arrays;
import java.util.List;

import org.springframework.stereotype.Component;

import com.alibaba.dubbo.config.annotation.Service;
import com.badao.gmall.bean.UserAddress;
import com.badao.gmall.service.UserService;

@Service  //暴露服務
@Component
public class UserServiceImpl implements UserService {

 public List<UserAddress> getUserAddressList(String userId) {
  
  // TODO Auto-generated method stub
  UserAddress address1 = new UserAddress(1, "霸道流氓氣質", "1", "李老師", "123456789", "Y");
  UserAddress address2 = new UserAddress(2, "公眾號：霸道的程式猿）", "1", "王老師", "987654321", "N");
  return Arrays.asList(address1,address2);
 }

}

 

註意的是之前在上面搭建的spring項目中使用的@Service註解是spring的註解，而這裡使用的dubbo的註解

import com.alibaba.dubbo.config.annotation.Service;

 

為了區分spring的@Service註解，所以使用spring的@Componment註解。

dubbo的@Service註解的作用是指定要暴露的服務，讓別人能引用。其作用就是上面在provider.xml中使用dubbo-service標簽

暴露服務一樣

 

 

然後在SpringBoot的主程式中添加註解@EnableDubbo時支持dubbo

package com.badao.gmall;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;

@EnableDubbo   //開啟基於註解的dubbo功能
@SpringBootApplication
public class BootUserServiceProviderApplication {

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

}

 

啟動提供者主程式

 

 

使用上面博客中搭建好的管理平臺可見服務提供者搭建成功

新建服務消費者

參照上面搭建服務提供者的流程，新建服務消費者

 

 

此時添加web依賴

 

 

此時的pom.xml同樣引入公共介面依賴與dubbo和dubbo-starter相關依賴

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>2.2.2.RELEASE</version>
  <relativePath/> <!-- lookup parent from repository -->
 </parent>
 <groupId>com.badao</groupId>
 <artifactId>boot-order-service-consumer</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <name>boot-order-service-consumer</name>
 <description>Demo project for Spring Boot</description>

 <properties>
  <java.version>1.8</java.version>
 </properties>

 <dependencies>
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <dependency>
   <groupId>com.badao.gmall</groupId>
   <artifactId>gmall-interface</artifactId>
   <version>0.0.1-SNAPSHOT</version>
  </dependency>
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-test</artifactId>
   <scope>test</scope>
   <exclusions>
    <exclusion>
     <groupId>org.junit.vintage</groupId>
     <artifactId>junit-vintage-engine</artifactId>
    </exclusion>
   </exclusions>
  </dependency>
  <!-- 引入dubbo -->
  <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
  <dependency>
   <groupId>com.alibaba</groupId>
   <artifactId>dubbo</artifactId>
   <version>2.6.2</version>
  </dependency>
  <!-- 註冊中心使用的是zookeeper，引入操作zookeeper的客戶端 -->
  <dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-framework</artifactId>
   <version>2.12.0</version>
  </dependency>
  <!-- Dubbo Spring Boot Starter -->
     <dependency>
         <groupId>com.alibaba.boot</groupId>
         <artifactId>dubbo-spring-boot-starter</artifactId>
         <version>0.2.1.RELEASE</version>
     </dependency>
     
 </dependencies>

 <build>
  <plugins>
   <plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
   </plugin>
  </plugins>
 </build>

</project>

 

 

然後打開其配置文件進行相關配置

 

server.port=8081

dubbo.application.name=boot-order-service-consumer
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.monitor.protocol=registry

 

 

註意：這裡修改埠號是因為8080已經被dubbo-monitor所占用，

具體配置的作用參照上面博客。

然後將服務消費者的介面實現複製過來

package com.badao.gmall.service.impl;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.alibaba.dubbo.config.annotation.Reference;
import com.badao.gmall.bean.UserAddress;
import com.badao.gmall.service.OrderService;
import com.badao.gmall.service.UserService;

/**
 * 1、將服務提供者註冊到註冊中心（暴露服務）
 *   1）、導入dubbo依賴（2.6.2）\操作zookeeper的客戶端(curator)
 *   2）、配置服務提供者
 * 
 * 2、讓服務消費者去註冊中心訂閱服務提供者的服務地址
 * @author badao
 *
 */
@Service
public class OrderServiceImpl implements OrderService {

 //@Autowired
 @Reference
 UserService userService;
 public List<UserAddress> initOrder(String userId) {
  // TODO Auto-generated method stub
  System.out.println("用戶id："+userId);
  //1、查詢用戶的收貨地址
  List<UserAddress> addressList = userService.getUserAddressList(userId);
  for (UserAddress userAddress : addressList) {
   System.out.println(userAddress.getUserAddress());
  }
  return addressList;
 }
 
 

}

 

註意：這裡的自動註入的@Autowired註解要修改為dubbo的@Reference，其作用是能遠程引用userService的服務，自己能從服務註冊中心發現。

其作用相當於之前的consumer.xml中使用dubbo:reference標簽聲明需要調用的遠程服務介面，即生成遠程服務代理。

 

 

在包下新建controller包以及OrderController類

package com.badao.gmall.controller;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import com.badao.gmall.bean.UserAddress;
import com.badao.gmall.service.OrderService;


@Controller
public class OrderController {
 
 @Autowired
 OrderService orderService;
 
 @ResponseBody
 @RequestMapping("/initOrder")
 public List<UserAddress> initOrder(@RequestParam("uid")String userId) {
  return orderService.initOrder(userId);
 }
 

}

 

然後修改主程式開啟dubbo支持

package com.badao.gmall;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;

@EnableDubbo
@SpringBootApplication
public class BootOrderServiceConsumerApplication {

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

}

 

啟動應用主程式

此時在管理平臺就會監控到服務消費者

 

 

然後打開瀏覽器，輸入：localhost:8081/initOrder?uid=1

 

 

示例代碼下載

https://download.csdn.net/download/BADAO_LIUMANG_QIZHI/12052055


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 資料庫分庫解決方案
    當業務數據量非常大，單資料庫無法支撐的時候，有可能是單庫已經寫滿了，也可能資料庫讀寫比較頻繁，已經觸碰到單庫的io瓶頸了，這時就需要考慮分庫。 下麵聊一下該怎麼分庫，如何優化： 剛開始只有資料庫A, 後來又加了資料庫B。 假如數據表都是有時間戳欄位，而且數據查詢條件都帶一個時間戳欄位，這樣我們可以根 ...
  • 理解vue數據驅動
    vue是雙向數據綁定的框架，數據驅動是他的靈魂，他的實現原理眾所周知是Object.defineProperty方法實現的get、set重寫，但是這樣說太牽強外門了。本文將巨集觀介紹他的實現 + "使用vue" + "分析Object.defineProperty" + "簡單的源碼解析" + "一切 ...
  • k8s~部署EFK框架
    EFK,ELK都是目前最為流行的分散式日誌框架,主要實現了日誌的收集,存儲,分析等,它可以與docker容器進行結合,來收集docker的控制台日誌,就是stdout日誌. elasticsearch.master_data_client說明 預設情況下，每個節點都有成為主節點的資格，也會存儲數據， ...
  • 架構到底是什麼？來聽聽程式老兵怎麼說！
    架構師，老兵哥剛參加工作那些年業界還沒有這個職位，那時候跟技術相關的崗位就是開發工程師、測試工程師和系統工程師，後來隨著軟體規模不斷增長而產生的，尤其是在互聯網浪潮下用戶數和訪問量都是海量化的。在各種機緣巧合下，老兵哥結合個人喜好選擇了走架構師路徑，從懵懵懂懂邊做邊學，到現在總算摸出了些門道，回顧這... ...
  • Redis安裝（單機及各類集群，阿裡雲）
    Redis安裝（單機及各類集群，阿裡雲） 前言 上周，我朋友突然悄悄咪咪地指著手機上的一篇博客說，這是你的博客吧。我看了一眼，是之前發佈的《Rabbit安裝（單機及集群，阿裡雲》。我朋友很哈皮地告訴我，我的博客被某個Java平臺進行了微信推送。看到許多人閱讀，並認同了我的博客，心理還是很開心的。 好 ...
  • HTTP 協議的前世今生
    HTTP 協議全稱是超文本傳輸協議（Hypertext Transfer Protocol），這裡面需要理解三個地方：超文本、傳輸、協議，下麵就從 HTTP 協議的歷史講起。 20 世紀 60 年代，美國國防部高等研究計劃署（ARPA）建立了 ARPA 網，它有四個分佈在世界各地的節點，被認為是互聯 ...
  • Java日期時間API系列12-----Jdk8中java.time包中的新的日期時間API類，日期格式化，常用日期格式大全，2020年日期，鼠年農曆等格式化
    通過Java日期時間API系列10 Jdk8中java.time包中的新的日期時間API類的DateTimeFormatter， 可以看出java8的DateTimeFormatter完美解決了SimpleDateFormat線程安全問題。下麵是關於DateTimeFormatter的使用實例，包括 ...
  • golang自定義error
    系統自身的error處理一般是 errors.New()或fmt.Errorf()等，對一些需要複雜顯示的，不太友好，我們可以擴展下error。 error在標準庫中被定義為一個介面類型，該介面只有一個Error()方法 那麼，自定義error只要擁有Error()方法，就實現了error介面,這裡 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類