Java-71 深入淺出 RPC Dubbo 上手 父工程配置編寫 附詳細POM與代碼

點一下關注吧!!!非常感謝!!持續更新!!!

🚀 AI篇持續更新中!(長期更新)

AI煉丹日志-29 - 字節跳動 DeerFlow 深度研究框斜體樣式架 私有部署 測試上手 架構研究,持續打造實用AI工具指南!📐🤖

💻 Java篇正式開啟!(300篇)

目前2025年07月10日更新到:
Java-68 深入淺出 分布式服務 Netty實現自定義RPC 附詳細代碼
MyBatis 已完結,Spring 已完結,Nginx已完結,Tomcat已完結,分布式服務正在更新!深入淺出助你打牢基礎!

📊 大數據板塊已完成多項干貨更新(300篇):

包括 Hadoop、Hive、Kafka、Flink、ClickHouse、Elasticsearch 等二十余項核心組件,覆蓋離線+實時數倉全棧!
大數據-278 Spark MLib - 基礎介紹 機器學習算法 梯度提升樹 GBDT案例 詳解

請添加圖片描述

Dubbo 服務調用機制詳解

基本架構與交互原理

在 Dubbo 分布式服務框架中,所有的服務調用都是基于 Java 接口進行交互的。這種接口契約式設計確保了服務提供者和消費者之間的解耦。具體工作流程如下:

  1. 接口協定:服務提供方和消費方首先需要共同定義一套標準的服務接口(通常打包為獨立的API模塊)
  2. 服務注冊:提供者實現這些接口后,將服務實例注冊到注冊中心(如Zookeeper、Nacos等)
  3. 服務發現:消費者從注冊中心獲取可用服務列表
  4. 遠程調用:消費者通過動態代理發起對提供者的RPC調用

Maven 工程結構說明

Dubbo 項目通常采用多模塊的Maven工程結構,典型布局如下:

dubbo-demo/
├── dubbo-api/         # 接口定義模塊
│   ├── src/main/java
│   │   └── com/example/DemoService.java
│   └── pom.xml
├── dubbo-provider/    # 服務提供方
│   ├── src/main/java
│   │   └── com/example/DemoServiceImpl.java
│   └── pom.xml
└── dubbo-consumer/    # 服務消費方├── src/main/java│   └── com/example/ConsumerApp.java└── pom.xml

詳細實現步驟

1. 創建API模塊

<!-- dubbo-api/pom.xml -->
<dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId><version>${dubbo.version}</version>
</dependency>

接口定義示例:

package com.example;public interface DemoService {String sayHello(String name);
}

2. 實現Provider模塊

<!-- dubbo-provider/pom.xml -->
<dependency><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>1.0.0</version>
</dependency>

服務實現示例:

package com.example;import org.apache.dubbo.config.annotation.Service;@Service(version = "1.0.0")
public class DemoServiceImpl implements DemoService {@Overridepublic String sayHello(String name) {return "Hello " + name;}
}

注冊中心配置(以Zookeeper為例):

# application.properties
dubbo.application.name=demo-provider
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880

3. 實現Consumer模塊

<!-- dubbo-consumer/pom.xml -->
<dependency><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>1.0.0</version>
</dependency>

消費方調用示例:

package com.example;import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class DemoController {@Reference(version = "1.0.0")private DemoService demoService;@GetMapping("/hello")public String sayHello(String name) {return demoService.sayHello(name);}
}

消費者配置示例:

# application.properties
dubbo.application.name=demo-consumer
dubbo.registry.address=zookeeper://127.0.0.1:2181

典型應用場景

  1. 微服務架構:將單體應用拆分為多個Dubbo服務
  2. 服務治理:通過注冊中心實現服務的自動發現和負載均衡
  3. 分布式事務:配合Seata等框架實現分布式事務管理
  4. 多版本支持:通過版本號控制實現灰度發布
  5. 服務降級:在服務不可用時自動切換到降級邏輯

父工程

創建一個父級工程,用于管理所有的模塊,移除src目錄。
我們定義基礎 POM,這里對所有的版本進行管理,方便后續的子模塊,這樣子模塊就不用再控制和管理各自的版本了:

<?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>icu.wzk</groupId><artifactId>dubbo-test</artifactId><version>1.0-SNAPSHOT</version><packaging>pom</packaging><modules><module>wzk-service-api</module><module>wzk-producer</module><module>wzk-consumer</module></modules><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><dubbo.version>2.7.5</dubbo.version></properties><dependencyManagement><dependencies><dependency><groupId>icu.wzk</groupId><artifactId>wzk-service-api</artifactId><version>1.0-SNAPSHOT</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId><version>${dubbo.version}</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-registry-zookeeper</artifactId><version>${dubbo.version}</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-rpc-dubbo</artifactId><version>${dubbo.version}</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-remoting-netty4</artifactId><version>${dubbo.version}</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-serialization-hessian2</artifactId><version>${dubbo.version}</version></dependency></dependencies></dependencyManagement></project>

API模塊

這個模塊用于定義接口抽象類,不提供實際的實現。
后續的 Producer 和 Consumer 都將依賴這個模塊,根據該模塊定義出來的接口進行使用。

POM

該模塊直接依賴 Dubbo,版本控制都交給了父級Maven項目控制。
后續的 Producer 和 Consumer 依賴這個模塊,就不需要再單獨控制 Dubbo 模塊了:

<?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><parent><groupId>icu.wzk</groupId><artifactId>dubbo-test</artifactId><version>1.0-SNAPSHOT</version></parent><artifactId>wzk-service-api</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-registry-zookeeper</artifactId></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-rpc-dubbo</artifactId></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-remoting-netty4</artifactId></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-serialization-hessian2</artifactId></dependency></dependencies>
</project>

項目的基本結構如該圖所示:
在這里插入圖片描述
接口定義
定義接口,只寫了一個基本的方法:

package icu.wzk.service;public interface WzkHelloService {String sayHello(String name);
}

創建接口的提供者

<dependencies><dependency><groupId>icu.wzk</groupId><artifactId>wzk-service-api</artifactId></dependency>
</dependencies>

對應的內容如下所示:
在這里插入圖片描述

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/bicheng/89165.shtml
繁體地址,請注明出處:http://hk.pswp.cn/bicheng/89165.shtml
英文地址,請注明出處:http://en.pswp.cn/bicheng/89165.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

創客匠人:創始人 IP 打造的內核,藏在有效的精神成長里

當創始人 IP 成為企業增長的重要引擎&#xff0c;許多人急于尋找 “爆款公式”&#xff0c;卻忽略了一個更本質的問題&#xff1a;IP 的生命力&#xff0c;終究源于創始人的精神成長。創客匠人在深耕知識付費賽道的過程中&#xff0c;見證了無數案例&#xff1a;那些能持續實現…

GPT和MBR分區

GPT&#xff08;GUID分區表&#xff09;和MBR&#xff08;主引導記錄&#xff09;是兩種不同的磁盤分區表格式&#xff0c;用于定義硬盤上分區的布局、位置及啟動信息&#xff0c;二者在設計、功能和適用場景上有顯著差異。以下從多個維度詳細對比&#xff1a; 一、核心定義與起…

c#進階之數據結構(字符串篇)----String

1、String介紹首先我們得明白&#xff0c;string和String代表的實際上是同一個類型&#xff0c;string是C#中的關鍵字&#xff0c;代表String類型&#xff0c;因此我們直接來學習String類型。從官方的底層實現代碼可以看出&#xff0c;當前String類型實際上就是一個Char類型的聚…

快速排序遞歸和非遞歸方法的簡單介紹

基本思想為&#xff1a;任取待排序元素序列中 的某元素作為基準值&#xff0c;按照該排序碼將待排序集合分割成兩子序列&#xff0c;左子序列中所有元素均小于基準值&#xff0c;右 子序列中所有元素均大于基準值&#xff0c;然后最左右子序列重復該過程&#xff0c;直到所有元…

從零開始的云計算生活——第三十二天,四面楚歌,HAProxy負載均衡

目錄 一.HAProxy簡介 二.HAProxy特點和優點&#xff1a; 三.HAProxy保持會話的三種解決方法 四.HAProxy的balance 8種負載均衡算法 1&#xff09;RR&#xff08;Round Robin&#xff09; 2&#xff09;LC&#xff08;Least Connections&#xff09; 3&#xff09;SH&am…

策略模式及優化

策略模式&#xff08;Strategy Pattern&#xff09;是一種行為設計模式&#xff0c;其核心思想是將算法的定義與使用分離&#xff0c;使算法可以獨立于客戶端進行變化。它通過定義一系列算法&#xff0c;將每個算法封裝到獨立的類中&#xff0c;并使它們可以互相替換&#xff0…

微信小程序開發-桌面端和移動端UI表現不一致問題記錄

桌面端和移動端UI表現不一致零、引擎說明一、樣式不同1、text 單行&#xff1a;1.1 空格開發者工具不展示&#xff0c;手機/PC端正常1.2 正常展示省略號&#xff0c;需要2、點擊按鈕z-index: -1。webview - 桌面端不行&#xff0c; skyline - 移動端可以&#xff1b;3、其他說明…

極限狀態下函數開根號的計算理解(含示意圖)

遇到一個挺有意思的題做個記錄&#xff1a; 求曲線y (x21)(x2?1)0.5\frac{\left(x^{2}1\right)}{\left(x^{2}-1\right)^{0.5}}(x2?1)0.5(x21)?漸近線的條數 比較明顯的x 1是無定義點。但是在求極限的時候發現1和1-得到的極限值似乎不一樣。似乎是1是趨向于∞&#xff0c;1…

C++——模版(函數模版和類模版)

C 模板&#xff08;Templates&#xff09;完整介紹模板是 C 中一種強大的泛型編程機制&#xff0c;允許開發者編寫與類型無關的代碼&#xff0c;從而提高代碼的復用性和靈活性。通過模板&#xff0c;可以避免為不同數據類型重復編寫相似的函數或類&#xff0c;實現真正的代碼復…

Python之cv2:cv2(OpenCV,opencv-python)庫pip下載超時、下載失敗、無法下載的解決方案大全

Python之cv2&#xff1a;cv2(OpenCV&#xff0c;opencv-python)庫pip下載超時、下載失敗、無法下載的解決方案大全 在學習和使用 OpenCV&#xff08;Python 包名&#xff1a;opencv-python 或簡稱 cv2&#xff09;的過程中&#xff0c;很多初學者常常會遇到通過 pip install o…

asyncio 與 uvloop

事件循環 事件循環 協調所有協程執行的中央調度器&#xff0c;它通過非阻塞機制&#xff0c;實現并發執行多個異步任務。 事件循環是 異步編程的核心機制&#xff0c;用一句話概括就是&#xff1a; 事件循環不斷檢查任務隊列&#xff0c;一旦某個異步任務完成&#xff0c;它…

一文讀懂循環神經網絡(RNN)—語言模型+n元語法(1)

目錄 什么是語言模型&#xff1f; 語言模型的核心目的 一.量化文本的合理性 二.支持下游 NLP 任務 三. 語義和上下文依賴 一元語法、二元語法和三元語法詳解 核心概念&#xff1a;n-gram 模型 1. 一元語法&#xff08;Unigram&#xff09; 2. 二元語法&#xff08;Bigram…

DirectX12(D3D12)基礎教程九 間接繪制

在學習directx12 microsoft提供了很多示例&#xff0c;有簡單的也有復雜,下載網址&#xff1a;https://github.com/microsoft/DirectX-Graphics-Samples 本章對D3D12ExecuteIndirect 示例做了簡化&#xff0c;只保留間接繪制部分&#xff0c;刪除了計算著色器部分。 間接繪制…

fastApi連接數據庫

1&#xff1a;pip install tortoise-orm2&#xff1a;pip install aiomysql3&#xff1a;pip install asyncmy或者使用國內清華園pip install -i https://pypi.tuna.tsinghua.edu.cn/simple asyncmy4&#xff1a;pip install aerich通過 python -m 直接運行&#xff08;推薦&a…

Apache-web服務器環境搭建

目錄 實驗要求 思路總結 1.常規配置web服務 2.通過用戶主頁配置web服務 3.通過虛擬目錄配置web服務 4.添加DNS解析服務&#xff0c;訪問虛擬機域名&#xff1a; www.TestWeb.com 實驗要求 (ip 192.168.48.130) 1、常規配置web服務 2、通過用戶主頁配置web服務 3、通過虛…

Altium Designer 25 安裝與配置完整教程

本教程將帶您一步步完成 Altium Designer 25 的下載、安裝與激活配置 第一步&#xff1a;下載安裝包 首先&#xff0c;需要獲取 Altium Designer 25 的完整安裝程序。 &#x1f449; 下載鏈接&#xff1a; 百度網盤&#xff1a;百度網盤 請輸入提取碼 提取碼: dxei 夸克網盤…

【工具】AndroidStudio修改中文語言漢化

AndroidStudio修改中文語言漢化 https://github.com/sollyu/AndroidStudioChineseLanguagePackhttps://github.com/sollyu/AndroidStudioChineseLanguagePack

代碼隨想錄|圖論|15并查集理論基礎

并查集理論基礎 | 代碼隨想錄 并查集還是比較簡單的&#xff0c;只要搞清楚兩個事情&#xff1a; 并查集是干啥的&#xff1f;解決什么類型問題&#xff1f;并查集模板&#xff08;背下來&#xff09; 1、并查集是干啥的 并查集主要是兩個功能&#xff1a; 兩個元素添加到…

用MYSQL學習sql第一次總結和作業

總結 數據庫&#xff08;Database&#xff09; 理解為“文件夾”&#xff0c;里面可以裝很多張表。作業中要求先建一個名字叫 mydb6_product 的數據庫。 表&#xff08;Table&#xff09; 理解為“Excel 工作表”&#xff0c;由“列&#xff08;字段&#xff09;”和“行&…

SQLite技術架構解析,適用場景有哪些?

一、SQLite技術架構解析 SQLite是一款輕量級、無服務器、嵌入式關系型數據庫&#xff0c;其架構設計圍繞“簡化復雜性、提升效率”展開&#xff0c;核心由前端&#xff08;SQL處理&#xff09;、執行引擎&#xff08;VDBE&#xff09;、存儲引擎&#xff08;B-Tree&#xff09;…