dapr本地托管的服務調用體驗與Java SDK的Spring Boot整合

来源:https://www.cnblogs.com/larrydpk/archive/2023/02/03/17087871.html
-Advertisement-
Play Games

1 簡介 之前在文章《dapr入門與本地托管模式嘗試》中介紹了dapr和本地托管,本文我們來介紹如果在代碼中使用dapr的服務調用功能,並把它整合到Spring Boot中。 Dapr服務調用的邏輯如下: 本次實驗會創建兩個服務: pkslow-data,提供數據服務,用於返回數據; pkslow- ...


1 簡介

之前在文章《dapr入門與本地托管模式嘗試》中介紹了dapr和本地托管,本文我們來介紹如果在代碼中使用dapr的服務調用功能,並把它整合到Spring Boot中。

Dapr服務調用的邏輯如下:

本次實驗會創建兩個服務:

pkslow-data,提供數據服務,用於返回數據;

pkslow-hello,提供查詢服務,外界調用,它會調用pkslow-data的介面獲取數據,而pkslow-data處理完,也會調用pkslow-hello的介面反饋結果。

2 創建Spring Boot項目

2.1 引入相關依賴

先創建常規的Spring Boot項目,引入Web的同時,也引入dapr的SDK:

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <dependency>
    <groupId>io.dapr</groupId>
    <artifactId>dapr-sdk-springboot</artifactId>
    <version>1.6.0</version>
  </dependency>
</dependencies>

2.2 配置dapr客戶端

我們需要Dapr的Client來調用服務,這樣就可以通過服務名、方法等信息直接調用服務了:

@Configuration
public class DaprConfig {
    private static final DaprClientBuilder BUILDER = new DaprClientBuilder();
    @Bean
    public DaprClient daprClient() {
        return BUILDER.build();
    }
}

2.3 請求返回體

請求和返回用類來定義如下:

@Data
public class PkslowRequest {
    private String name;
    private String age;
}

@Data
public class PkslowResponse {
    private int code;
    private String status;
    private String body;
}

hello請求方

hello作為請求方,需要給data發請求來獲取數據,利用DaprClient來調用,如下:

@GetMapping("/hello")
public PkslowResponse hello() {
  log.info("hello");

  PkslowRequest request = new PkslowRequest();
  request.setName("Larry Deng");
  request.setAge("18");

  PkslowResponse response = daprClient.invokeMethod(
    "pkslow-data",
    "/pkslow/data",
    request,
    HttpExtension.POST,
    PkslowResponse.class
  ).block();

  return response;
}

2.5 data返回方

返回方接收到請求後,處理返回數據給回hello,同時我們還調用hello的一個介面給反饋,這樣在這個例子中實現雙方相互調用:

@PostMapping("/data")
public PkslowResponse data(@RequestBody PkslowRequest request) {
  log.info("data");
  daprClient.invokeMethod(
    "pkslow-hello",
    "/pkslow/feedback",
    "",
    HttpExtension.GET,
    PkslowResponse.class
  ).block();


  PkslowResponse response = new PkslowResponse();
  response.setCode(200);
  response.setStatus("OK");
  response.setBody("This is data from www.pkslow.com: " + request.toString());
  return response;
}

3 打包、啟動和調用

3.1 打包

通過maven直接打包,需要以下插件:

<plugin>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-maven-plugin</artifactId>
  <version>2.4.2</version>
  <executions>
    <execution>
      <goals>
        <goal>repackage</goal>
      </goals>
      <configuration>
        <classifier>exec</classifier>
      </configuration>
    </execution>
  </executions>
</plugin>

執行打包命令如下:

mvn clean package

3.2 啟動Dapr服務

指定服務名和埠,啟動data服務如下:

$ dapr run --app-id pkslow-data --app-port 8090 --dapr-http-port 8190 -- java -jar -Dserver.port=8090 target/dapr-springboot-1.0-SNAPSHOT-exec.jar

然後啟動hello服務如下:

$ dapr run --app-id pkslow-hello --app-port 8091 --dapr-http-port 8191 -- java -jar -Dserver.port=8091 target/dapr-springboot-1.0-SNAPSHOT-exec.jar

打開Dapr Dashboard查看應用如下:

3.3 訪問hello服務

通過瀏覽器訪問hello服務如下:

3.4 查看調用鏈

打開Zipkin,可以查看調用如下:

還可以查看一些Tracing的信息如下:

4 總結

至此,我們嘗試了Dapr的服務調用功能,還是挺方便的,無須知道對方的IP和地址,直接通過名字就可以調用。這和大多數微服務架構是一樣的,因為它提供了服務發現的功能。

5 代碼

代碼請看GitHub: https://github.com/LarryDpk/pkslow-samples


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

-Advertisement-
Play Games
更多相關文章
  • 慢查詢指的是資料庫中查詢時間超過了指定的閾值的SQL,這類SQL通常伴隨著執行時間長、伺服器資源占用高、業務響應慢等負面影響。隨著攜程酒店業務的不斷擴張,再加上大量的SQLServer轉MySQL項目的推進,慢查詢的數量正在飛速增長,每日的報警量也居高不下,因此慢查詢的治理優化已經是刻不容緩,此文主... ...
  • 1:apk文件結構 如圖所示: assets: 存放應用程式的靜態資源文件,如圖片資源,json配置文件,html離線資源等。註意,assets目錄下是支持任意深度的子目錄。 res: 規定的指定文件,圖標,圖片資源等,且res下文件都會生成對應的資源id, 但是assets下是不會的。 lib: ...
  • 在元素設置浮動(float)後,該元素就會脫離文檔流,並且向左或向右浮動,直至它的外邊緣遇到包含框或者另一個浮動框的邊緣。 一、浮動元素對佈局的影響 1.1、浮動元素造成父元素的高度塌陷: 原來的父元素高度是內部元素撐開的,但是當內部元素浮動後,脫離文檔流浮動起來,那父元素的高度就坍塌,變為高度 0 ...
  • 寫代碼的時候遇到這個問題了,在這裡複習一下 非箭頭函數 非箭頭函數的this指向比較好理解,就是調用這個函數的對象,舉個慄子: var obj = { foo: { bar: 3, foo:{ bar: 4, foo: function a() { console.log(this.bar) }, ...
  • 這裡給大家分享我在網上總結出來的一些知識,希望對大家有所幫助 什麼是跨域? 跨域不是問題,是一種安全機制。瀏覽器有一種策略名為同源策略,同源策略規定了部分請求不能被瀏覽器所接受。 值得一提的是:同源策略導致的跨域是瀏覽器單方面拒絕響應數據,伺服器端是處理完畢並做出了響應的。 什麼是同源策略 一個ur ...
  • 1.CSS、SCSS、Sass CSS是開發人員熟知的一種用於頁面樣式開發的語言,可以通過內容的分離控制減少代碼的重覆性,降低代碼的複雜程度。 Sass與 SCSS 都是 CSS 預處理器,可包含在基於 CSS 的 UI(用戶界面)或前端框架中以簡化開發。Sass 與 SCSS 框架在高級別的 CS ...
  • 通常,不同的公司里有著不同的編碼規範,主要是從代碼得準確性、穩定性、可讀性等地方著手制定,以提高團隊成員之間的協作效率,這裡主要是列出一些常見的編碼規範。 ...
  • 隨著移動互聯網發展,手機端購物已成為人們生活的常態。人們在搜索商品時採用的手段也越來越豐富,當前的主要搜索方式是文本搜索與拍照搜索。 ...
一周排行
    -Advertisement-
    Play Games
  • 1. 說明 /* Performs operations on System.String instances that contain file or directory path information. These operations are performed in a cross-pla ...
  • 視頻地址:【WebApi+Vue3從0到1搭建《許可權管理系統》系列視頻:搭建JWT系統鑒權-嗶哩嗶哩】 https://b23.tv/R6cOcDO qq群:801913255 一、在appsettings.json中設置鑒權屬性 /*jwt鑒權*/ "JwtSetting": { "Issuer" ...
  • 引言 集成測試可在包含應用支持基礎結構(如資料庫、文件系統和網路)的級別上確保應用組件功能正常。 ASP.NET Core 通過將單元測試框架與測試 Web 主機和記憶體中測試伺服器結合使用來支持集成測試。 簡介 集成測試與單元測試相比,能夠在更廣泛的級別上評估應用的組件,確認多個組件一起工作以生成預 ...
  • 在.NET Emit編程中,我們探討了運算操作指令的重要性和應用。這些指令包括各種數學運算、位操作和比較操作,能夠在動態生成的代碼中實現對數據的處理和操作。通過這些指令,開發人員可以靈活地進行算術運算、邏輯運算和比較操作,從而實現各種複雜的演算法和邏輯......本篇之後,將進入第七部分:實戰項目 ...
  • 前言 多表頭表格是一個常見的業務需求,然而WPF中卻沒有預設實現這個功能,得益於WPF強大的控制項模板設計,我們可以通過修改控制項模板的方式自己實現它。 一、需求分析 下圖為一個典型的統計表格,統計1-12月的數據。 此時我們有一個需求,需要將月份按季度劃分,以便能夠直觀地看到季度統計數據,以下為該需求 ...
  • 如何將 ASP.NET Core MVC 項目的視圖分離到另一個項目 在當下這個年代 SPA 已是主流,人們早已忘記了 MVC 以及 Razor 的故事。但是在某些場景下 SSR 還是有意想不到效果。比如某些靜態頁面,比如追求首屏載入速度的時候。最近在項目中回歸傳統效果還是不錯。 有的時候我們希望將 ...
  • System.AggregateException: 發生一個或多個錯誤。 > Microsoft.WebTools.Shared.Exceptions.WebToolsException: 生成失敗。檢查輸出視窗瞭解更多詳細信息。 內部異常堆棧跟蹤的結尾 > (內部異常 #0) Microsoft ...
  • 引言 在上一章節我們實戰了在Asp.Net Core中的項目實戰,這一章節講解一下如何測試Asp.Net Core的中間件。 TestServer 還記得我們在集成測試中提供的TestServer嗎? TestServer 是由 Microsoft.AspNetCore.TestHost 包提供的。 ...
  • 在發現結果為真的WHEN子句時,CASE表達式的真假值判斷會終止,剩餘的WHEN子句會被忽略: CASE WHEN col_1 IN ('a', 'b') THEN '第一' WHEN col_1 IN ('a') THEN '第二' ELSE '其他' END 註意: 統一各分支返回的數據類型. ...
  • 在C#編程世界中,語法的精妙之處往往體現在那些看似微小卻極具影響力的符號與結構之中。其中,“_ =” 這一組合突然出現還真不知道什麼意思。本文將深入剖析“_ =” 的含義、工作原理及其在實際編程中的廣泛應用,揭示其作為C#語法奇兵的重要角色。 一、下劃線 _:神秘的棄元符號 下劃線 _ 在C#中並非 ...