Dubbo 入門系列之基於 Dubbo API 開發微服務應用

来源:https://www.cnblogs.com/apache-dubbo/archive/2023/02/02/17085885.html
-Advertisement-
Play Games

基礎 我是在ruoyi-vue已經安裝了mybatis-plus的基礎上進行的修改 關於SQLite SQLite 是一個軟體庫，實現了自給自足的、無伺服器的、零配置的、事務性的 SQL 資料庫引擎。 SQLite主頁：https://www.sqlite.org/index.html 1. pom ...


目標

從零上手開發基於 Dubbo 的微服務

難度

低

環境要求

  • 系統：Windows、Linux、MacOS

  • JDK 8 及以上（推薦使用 JDK17）

  • Git

  • IntelliJ IDEA（可選）

  • Docker （可選）

動手實踐

本章將通過手把手的教程一步一步教你如何從零開發一個微服務應用。

1. 啟動註冊中心

對於一個微服務化的應用來說，註冊中心是不可或缺的一個組件。只有通過註冊中心，消費端才可以成功發現服務端的地址信息，進而進行調用。

為了讓本教程更易於上手，我們提供了一個基於 Apache Zookeeper 註冊中心的簡易啟動器，如果您需要在生產環境部署註冊中心，請參考生產環境初始化一文部署高可用的註冊中心。

Windows:
git clone --depth=1 --branch master [email protected]:apache/dubbo-samples.git
cd dubbo-samples
./mvnw.cmd clean compile exec:java -pl tools/embedded-zookeeper

Linux / MacOS:
git clone --depth=1 --branch master [email protected]:apache/dubbo-samples.git
cd dubbo-samples
./mvnw clean compile exec:java -pl tools/embedded-zookeeper

Docker:
docker run --name some-zookeeper --restart always -d zookeeper

2. 初始化項目

從本小節開始，將基於 IntelliJ IDEA 進行工程的搭建以及測試。

如上圖所示，可以建立一個基礎的項目。

在初始化完項目之後，需要在 src/main/java 目錄下創建 org.apache.dubbo.samples.api 、org.apache.dubbo.samples.client 和 org.apache.dubbo.samples.provider 三個 package。

後續我們將在 api 下創建對應的介面，在 client 下創建對應客戶端訂閱服務的功能，在 provider 下創建對應服務端的實現以及發佈服務的功能。

上述三個 package 分別對應了應用共同依賴的 api、消費端應用的模塊、服務端應用的模塊。在實際部署中需要拆成三個工程，消費端和服務的共同依賴 api 模塊。從簡單出發，本教程將在同一個工程中進行開發，區分多個啟動類。

3. 添加 Maven 依賴

在初始化完項目以後，我們需要先添加 Dubbo 相關的 maven 依賴。

編輯 pom.xml 這個文件，添加下列配置。

    <dependencies>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>3.2.0-beta.4</version>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-x-discovery</artifactId>
            <version>4.3.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.8.0</version>
            <exclusions>
                <exclusion>
                    <groupId>io.netty</groupId>
                    <artifactId>netty-handler</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>io.netty</groupId>
                    <artifactId>netty-transport-native-epoll</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

在這份配置中，定義了 dubbo 和 zookeeper（以及對應的連接器 curator）的依賴。

添加了上述的配置以後，可以通過 IDEA 的 Maven - Reload All Maven Projects 刷新依賴。

4. 定義服務介面

服務介面 Dubbo 中溝通消費端和服務端的橋梁。

在 org.apache.dubbo.samples.api 下建立 GreetingsService 介面，定義如下：

package org.apache.dubbo.samples.api;

public interface GreetingsService {

    String sayHi(String name);
}

在 GreetingsService 中，定義了 sayHi 這個方法。後續服務端發佈的服務，消費端訂閱的服務都是圍繞著 GreetingsService 介面展開的。

5. 定義服務端的實現

定義了服務介面之後，可以在服務端這一側定義對應的實現，這部分的實現相對於消費端來說是遠端的實現，本地沒有相關的信息。

在 org.apache.dubbo.samples.provider 下建立 GreetingsServiceImpl 類，定義如下：

package org.apache.dubbo.samples.provider;

import org.apache.dubbo.samples.api.GreetingsService;

public class GreetingsServiceImpl implements GreetingsService {
    @Override
    public String sayHi(String name) {
        return "hi, " + name;
    }
}

在 GreetingsServiceImpl 中，實現了 GreetingsService 介面，對於 sayHi 方法返回 hi, name。

6. 服務端發佈服務

在實現了服務之後，本小節將通過 Dubbo 的 API 在網路上發佈這個服務。

在 org.apache.dubbo.samples.provider 下建立 Application 類，定義如下：

package org.apache.dubbo.samples.provider;

import org.apache.dubbo.config.ProtocolConfig;
import org.apache.dubbo.config.RegistryConfig;
import org.apache.dubbo.config.ServiceConfig;
import org.apache.dubbo.config.bootstrap.DubboBootstrap;
import org.apache.dubbo.samples.api.GreetingsService;

public class Application {
    public static void main(String[] args) {
        // 定義具體的服務
        ServiceConfig<GreetingsService> service = new ServiceConfig<>();
        service.setInterface(GreetingsService.class);
        service.setRef(new GreetingsServiceImpl());

        // 啟動 Dubbo
        DubboBootstrap.getInstance()
                .application("first-dubbo-provider")
                .registry(new RegistryConfig("zookeeper://127.0.0.1:2181"))
                .protocol(new ProtocolConfig("dubbo", -1))
                .service(service)
                .start()
                .await();
    }
}

在 org.apache.dubbo.samples.provider.Application 中做了兩部分的功能：首先是基於 ServiceConfig 定義了發佈的服務信息，包括介面的信息以及對應的實現類對象；然後是配置 Dubbo 啟動器，傳入了應用名，註冊中心地址，協議的信息以及服務的信息等。

註：DubboBootstrap 中的registry 、protocol 和 service 可以多次傳入。

7. 消費端訂閱並調用

對於消費端，可以通過 Dubbo 的 API 可以進行消費端訂閱。

在 org.apache.dubbo.samples.client 下建立 Application 類，定義如下：

package org.apache.dubbo.samples.client;

import java.io.IOException;

import org.apache.dubbo.config.ReferenceConfig;
import org.apache.dubbo.config.RegistryConfig;
import org.apache.dubbo.config.bootstrap.DubboBootstrap;
import org.apache.dubbo.samples.api.GreetingsService;

public class Application {
    public static void main(String[] args) throws IOException {
        ReferenceConfig<GreetingsService> reference = new ReferenceConfig<>();
        reference.setInterface(GreetingsService.class);

        DubboBootstrap.getInstance()
                .application("first-dubbo-consumer")
                .registry(new RegistryConfig("zookeeper://127.0.0.1:2181"))
                .reference(reference);

        GreetingsService service = reference.get();
        String message = service.sayHi("dubbo");
        System.out.println("Receive result ======> " + message);
        System.in.read();
    }
}

在 org.apache.dubbo.samples.client.Application 中做了三部分的功能：

首先是基於 ReferenceConfig 定義了訂閱的服務信息，包括介面的信息。

其次是配置 Dubbo 啟動器，傳入了應用名，註冊中心地址，協議的信息以及服務的信息等。

最後是獲取到動態代理的對象併進行調用。

註：DubboBootstrap 中支持 service 和 reference 可以同時傳入，意味著一個應用可以同時即是消費端、也是服務端。

8. 啟動應用

截止第 7 步，代碼就已經開發完成了，本小節將啟動整個項目併進行驗證。

首先是啟動 org.apache.dubbo.samples.provider.Application ，等待一會出現如下圖所示的日誌（DubboBootstrap awaiting）即代表服務提供者啟動完畢，標志著該服務提供者可以對外提供服務了。

[DUBBO] DubboBootstrap awaiting ..., dubbo version: 3.2.0-beta.4, current host: 169.254.44.42

然後是啟動org.apache.dubbo.samples.client.Application ，等待一會出現如下圖所示的日誌（hi, dubbo ）即代表服務消費端啟動完畢並調用到服務端成功獲取結果。

Receive result ======> hi, dubbo

延伸閱讀

1. Dubbo 的配置介紹

Dubbo 的主要配置入口有ReferenceConfig 、ServiceConfig 和 DubboBootstrap ，更多的細節可以參考 API 配置 | Apache Dubbo 一文。

2. 除了 API 方式其他的使用方式

Dubbo 除了 API 方式還支持 Spring XML、Annotation、Spring Boot 等配置方式，在下一個教程中將就 Spring Boot 配置方式講解如何進行快速開發。

關於 XML 和 Annotation 的細節可以參考 XML 配置 | Apache Dubbo、Annotation 配置 | Apache Dubbo 疑問。

更多

本教程介紹瞭如何基於 Dubbo 的純 API 開發一個微服務應用。下一個教程中，將介紹如何基於 Spring Boot 開發微服務項目。

歡迎在 https://github.com/apache/dubbo 給 Dubbo Star。
搜索關註官方微信公眾號：Apache Dubbo，瞭解更多業界最新動態，掌握大廠面試必備 Dubbo 技能


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

-Advertisement-
Play Games
更多相關文章
  • 《RPC實戰與核心原理》學習筆記Day16
    這篇文章主要討論如何在不知道介面的情況下進行RPC調用，以及如何在一個線上系統中支持多種不同的RPC協議。 ...
  • java介紹、環境搭建與Hello,World!
    Java版本 JavaSE 標準版，用於桌面程式、控制台等，這是最核心的部分，需要首先學習 JavaME 嵌入式開發，用於家電等（很少用） JavaEE 企業級，用於web、伺服器 一些概念 JDK Java Development Kit,Java開發工具。包含JRE、JVM，且包含一些開發工具( ...
  • Python教程：OS與sys模塊用法教程
    題目描述 給定一個 n 個元素有序的（升序）整型數組 nums 和一個目標值 target ，寫一個函數搜索 nums 中的 target，如果目標值存在返回下標，否則返回 -1。 來源：力扣（LeetCode） 鏈接：https://leetcode.cn/problems/binary-sear ...
  • Python之字典遍歷元素（4種方式）
    第一種：for in girl_dict= {"China": "小美", "Japan": "圖多天光", "Korea": "斯密達美"} for everyKey in girl_dict: print ("key:" + everyKey + "value:" + girl_dict[eve ...
  • 如何通過Java代碼向Word文檔添加文檔屬性
    Word文檔屬性包括常規、摘要、統計、內容、自定義。其中摘要包括標題、主題、作者、經理、單位、類別、關鍵詞、備註等項目。屬性相當於文檔的名片，可以添加你想要的註釋、說明等。還可以標註版權。 今天就為大家介紹一下，如何通過Java代碼向Word文檔添加文檔屬性。詳情請閱讀以下內容。 將內置文檔屬性添加 ...
  • 單調棧
    顧名思義單調棧就是具有單調性的棧 ==常見模型：找出每個數左邊離它最近的比它大/小的數== 【演算法】 int stk[N],tt = 0; // 棧中存數據 for (int i = 1; i <= n; i ++){ int x; cin >> x; while (tt && stk[tt] >= ...
  • Java裡面為什麼搞了雙重檢查鎖，寫完這篇文章終於真相大白了
    雙重檢查鎖定與延遲初始化 在 java 程式中，有時候可能需要推遲一些高開銷的對象初始化操作，並且只有在使用這些對象時才進行初始化。此時程式員可能會採用延遲初始化。但要正確實現線程安全的延遲初始化需要一些技巧，否則很容易出現問題。比如，下麵是非線程安全的延遲初始化對象的示例代碼： COPYpubli ...
  • 【分散式鏈路追蹤】Skywalking分散式鏈路追蹤基於Docker安裝與使用
    1. 服務監控三要素^1 服務監控需要滿足的三要素分別如下： 日誌監控 指標監控 請求鏈路追蹤 服務監控只要能滿足這三個要素，基本就能實現我們想要的監控效果。 1.1.主流APM系統^1 APM 系統（Application Performance Management，即應用性能管理）是對企業的應 ...
一周排行
    -Advertisement-
    Play Games
  • ASP.NET Core - 選項系統之源碼介紹
    .NET Core 選項系統的主要實現在 Microsoft.Extensions.Options 和 Microsoft.Extensions.Options.ConfigurationExtensions 兩個 Nuget 包。對於一個框架的源碼進行解讀，我們可以從我們常用的框架中的類或方法入手 ...
  • BitMap對象當前正在其他地方使用？加鎖也沒用？
    最近在工作中遇到一個問題,就是我有多個線程會調用bitmap對象，運行的時候報錯，對象當前正在其他地方使用。第一反應肯定是加鎖啊，於是我就在每個用到bitmap的地方都加了鎖，但是運行之後依然報這個錯 測試代碼如下 using System; using System.Drawing; using ...
  • 記一次 .NET 某感測器採集系統 線程爆高分析
    一：背景 1. 講故事 前段時間有位朋友微信找到我，說他的程式使用 hsl 庫之後，採集 plc 時記憶體溢出，讓我幫忙看一下怎麼回事，哈哈，貌似是分析之旅中的第二次和 hsl 打交道，既然找到我，那就上 windbg 說話吧。 二：WinDbg 分析 1. 為什麼會記憶體溢出 簡單觀察程式的提交記憶體之 ...
  • WPF日曆控制項
    在 IIS 上啟用 Websocket 在 Windows Server 2012 或更高版本上啟用對 WebSocket 協議的支持： 備註 使用 IIS Express 時無需執行這些步驟 通過“管理”菜單或“伺服器管理器”中的鏈接使用“添加角色和功能”嚮導。 選擇“基於角色或基於功能的安裝”。 ...
  • C#-垃圾回收機制(GC)
    C#-垃圾回收機制(GC) 什麼是GC 官網中有這麼一句話： The garbage collector is a common language runtime component that controls the allocation and release of managed memory ...
  • 交互觸摸大屏概念整理
    呆了2個大屏行業的公司，對大屏幕有一些瞭解，所以整理下所瞭解的觸摸屏相關概念。方便自己以及進入這個行業的小伙伴們，能有個系統、快速的認知。 觸摸屏詳細的知識點，網上其實都有。整理資料過程中，我也瞭解了更多的觸摸屏知識，像聲波屏、光學屏之類的之前就沒接觸。下麵分不同的模塊，給大家介紹 交互觸摸屏類型 ...
  • APS系統設計經驗分享(時間推導 - 2023.03)
    近段時間忙於各種項目和對【易排平臺】的優化，沒顧得上分享APS相關的小技巧，回頭看看小公眾號的關註人數早已達1500+，在此爭取時間寫一下這段時間在項目上及平臺優化過程中遇到的一些小技巧，以感謝諸位的關註。過去數月的解決的問題中，涉及最多的是規劃模型中，實現各種時間維度的功能，目前在平臺上也稍有成果 ...
  • Linux 伺服器大量的 log 日誌，如何正確看日誌快速定位錯誤？你必須學會！
    針對大量log日誌快速定位錯誤地方 動態查看日誌 tail -f catalina.ou 從頭打開日誌文件 cat catalina.ou 可以使用 >nanjiangtest.txt 輸出某個新日誌去查看 [[email protected] logs]# cat -n catalina.out |grep 7 ...
  • RocketMQ 學習
    前言 RocketMQ是阿裡巴巴旗下一款開源的MQ框架，經歷過雙十一考驗、Java編程語言實現，有非常好完整生態系統。RocketMQ作為一款純java、分散式、隊列模型的開源消息中間件，支持事務消息、順序消息、批量消息、定時消息、消息回溯等 本篇文章第一部分屬於一些核心概念和工作流程的講解；第二部 ...
  • python中類成員修飾符
    在java，c#類的成員修飾符包括，公有、私有、程式集可用的、受保護的。 對於python來說，只有兩個成員修飾符：公有成員，私有成員 成員修飾符是來修飾誰呢？當然是修飾成員了。那麼python類的成員包括什麼呢？ python成員： 欄位，方法，屬性 每個類成員的修飾符有兩種: 公有成員:內部外部 ...
所有分類