共用方式為


教學課程:使用 Dapr 發佈和訂閱的微服務通訊

在此教學課程中,您會建立發行者和訂閱者微服務,以利用 Dapr pub/sub API 來使用事件驅動架構的訊息進行通訊。 您將會:

  • 建立發行者微服務和訂閱者微服務,以利用 Dapr pub/sub API 來使用事件驅動架構的訊息進行通訊。
  • 透過 Azure Developer CLI 搭配提供的 Bicep 將應用程式部署至 Azure 容器應用程式。

範例 pub/sub 專案包含:

  1. 產生特定主題訊息的訊息產生器 checkout 服務 (發行者)。
  2. 接聽特定主題 checkout 服務訊息的 order-processor 服務 (訂閱者)。

pub/sub 範例的圖表。

必要條件

在本端執行 Node.js 應用程式

將應用程式部署至 Azure 容器應用程式之前,請先使用 Dapr 和 Azure 服務匯流排在本機執行 order-processorcheckout 服務。

準備專案

  1. 範例應用程式複製到本機電腦。

    git clone https://github.com/Azure-Samples/pubsub-dapr-nodejs-servicebus.git
    
  2. 瀏覽至範例的根目錄。

    cd pubsub-dapr-nodejs-servicebus
    

使用 Dapr CLI 執行應用程式

首先,執行 order-processor 訂閱者服務。

  1. 從範例的根目錄,請將目錄變更為 order-processor

    cd order-processor
    
  2. 安裝相依性。

    npm install
    
  3. 執行 order-processor 服務。

    dapr run --app-port 5001 --app-id order-processing --app-protocol http --dapr-http-port 3501 --resources-path ../components -- npm run start
    
  4. 在新的終端機視窗中,從範例的根目錄瀏覽至 checkout 發行者服務。

    cd checkout
    
  5. 安裝相依性。

    npm install
    
  6. 執行 checkout 服務。

    dapr run --app-id checkout --app-protocol http --resources-path ../components -- npm run start
    

    預期的輸出

    在這兩個終端機中,checkout 服務會在結束前發佈 order-processor 服務所接收的 10 則訊息。

    checkout 輸出:

    == APP == Published data: {"orderId":1}
    == APP == Published data: {"orderId":2}
    == APP == Published data: {"orderId":3}
    == APP == Published data: {"orderId":4}
    == APP == Published data: {"orderId":5}
    == APP == Published data: {"orderId":6}
    == APP == Published data: {"orderId":7}
    == APP == Published data: {"orderId":8}
    == APP == Published data: {"orderId":9}
    == APP == Published data: {"orderId":10}
    

    order-processor 輸出:

    == APP == Subscriber received: {"orderId":1}
    == APP == Subscriber received: {"orderId":2}
    == APP == Subscriber received: {"orderId":3}
    == APP == Subscriber received: {"orderId":4}
    == APP == Subscriber received: {"orderId":5}
    == APP == Subscriber received: {"orderId":6}
    == APP == Subscriber received: {"orderId":7}
    == APP == Subscriber received: {"orderId":8}
    == APP == Subscriber received: {"orderId":9}
    == APP == Subscriber received: {"orderId":10}
    
  7. 執行下列命令,確定這兩個應用程式都已停止。 在簽出終端機中:

    dapr stop --app-id checkout
    

    在 order-processor 終端機中:

    dapr stop --app-id order-processor
    

使用 Azure Developer CLI 部署應用程式範本

使用 azd 將應用程式部署至 Azure 容器應用程式。

準備專案

在新的終端機視窗中,瀏覽至範例的根目錄。

cd pubsub-dapr-nodejs-servicebus

使用 Azure Developer CLI 佈建和部署

  1. 執行 azd init 來初始化專案。

    azd init
    
  2. 在終端機出現提示時,請提供下列參數。

    參數 描述
    環境名稱 建立以保存所有 Azure 資源的資源群組前綴。
    Azure 位置 您資源的 Azure 位置。
    Azure 訂用帳戶 您資源的 Azure 訂閱。
  3. 執行 azd up 以使用單一命令佈建基礎結構,並將應用程式部署至 Azure 容器應用程式。

    azd up
    

    此程序需要一些時間才會完成。 當 azd up 命令完成時,CLI 輸出會顯示兩個 Azure 入口網站連結,以監視部署進度。 輸出也會示範如何 azd up

    • 使用 azd provision 透過 ./infra 目錄提供的 Bicep 檔案,建立和設定所有必要的 Azure 資源。 一旦透過 Azure Developer CLI 佈建後,便可以透過 Azure 入口網站存取這些資源。 佈建 Azure 資源的檔案包含下列項目:
      • main.parameters.json
      • main.bicep
      • 依功能組織的 app 資源目錄
      • 包含 azd 範本所使用的 Bicep 模組的 core 參考程式庫
    • 使用 azd deploy 部署程式碼

    預期的輸出

    Initializing a new project (azd init)
    
    
    Provisioning Azure resources (azd provision)
    Provisioning Azure resources can take some time
    
      You can view detailed progress in the Azure Portal:
      https://portal.azure.com
    
      (✓) Done: Resource group: resource-group-name
      (✓) Done: Application Insights: app-insights-name
      (✓) Done: Portal dashboard: portal-dashboard-name
      (✓) Done: Log Analytics workspace: log-analytics-name
      (✓) Done: Key vault: key-vault-name
      (✓) Done: Container Apps Environment: ca-env-name
      (✓) Done: Container App: ca-checkout-name
      (✓) Done: Container App: ca-orders-name
    
    
    Deploying services (azd deploy)
    
      (✓) Done: Deploying service checkout
      (✓) Done: Deploying service orders
      - Endpoint: https://ca-orders-name.endpoint.region.azurecontainerapps.io/
    
    SUCCESS: Your Azure app has been deployed!
    You can view the resources created under the resource group resource-group-name in Azure Portal:
    https://portal.azure.com/#@/resource/subscriptions/subscription-id/resourceGroups/resource-group-name/overview
    

確認成功部署

在 Azure 入口網站中,驗證 checkout 服務正在將訊息發佈至 Azure 服務匯流排主題。

  1. 從終端機輸出複製 checkout 容器應用程式名稱。

  2. 登入 Azure 入口網站,然後依名稱搜尋容器應用程式資源。

  3. 在「容器應用程式」儀表板中,選取「監視>記錄資料流」。

    瀏覽至 Azure 入口網站中 [記錄串流] 頁面的螢幕擷取畫面。

  4. 確認 checkout 容器正在記錄的輸出與稍早的終端機相同。

    Azure 入口網站中結帳服務容器記錄串流的螢幕擷取畫面。

  5. 請對 order-processor 服務執行相同動作。

    Azure 入口網站中訂單處理器服務容器記錄串流的螢幕擷取畫面。

發生什麼事?

azd up 命令成功完成時:

  • Azure Developer CLI 已將範例專案 ./infra 目錄中所參考的 Azure 資源佈建到您指定的 Azure 訂閱。 您現在可以透過 Azure 入口網站檢視這些 Azure 資源。
  • 應用程式會部署至 Azure 容器應用程式。 您可以從入口網站瀏覽至全部的功能應用程式。

在本機執行 Python 應用程式

將應用程式部署至 Azure 容器應用程式之前,請先使用 Dapr 和 Azure 服務匯流排在本機執行 order-processorcheckout 服務。

準備專案

  1. 範例應用程式複製到本機電腦。

    git clone https://github.com/Azure-Samples/pubsub-dapr-python-servicebus.git
    
  2. 瀏覽至範例的根目錄。

    cd pubsub-dapr-python-servicebus
    

使用 Dapr CLI 執行應用程式

首先,執行 order-processor 訂閱者服務。

  1. 從範例的根目錄,請將目錄變更為 order-processor

    cd order-processor
    
  2. 安裝相依性。

    pip3 install -r requirements.txt
    
  3. 執行 order-processor 服務。

    dapr run --app-id order-processor --resources-path ../components/ --app-port 5001 -- python3 app.py
    
  4. 在新的終端機視窗中,從範例的根目錄瀏覽至 checkout 發行者服務。

    cd checkout
    
  5. 安裝相依性。

    pip3 install -r requirements.txt
    
  6. 執行 checkout 服務。

    dapr run --app-id checkout --resources-path ../components/ -- python3 app.py
    

    預期的輸出

    在這兩個終端機中,checkout 服務會在結束前發佈 order-processor 服務所接收的 10 則訊息。

    checkout 輸出:

    == APP == Published data: {"orderId":1}
    == APP == Published data: {"orderId":2}
    == APP == Published data: {"orderId":3}
    == APP == Published data: {"orderId":4}
    == APP == Published data: {"orderId":5}
    == APP == Published data: {"orderId":6}
    == APP == Published data: {"orderId":7}
    == APP == Published data: {"orderId":8}
    == APP == Published data: {"orderId":9}
    == APP == Published data: {"orderId":10}
    

    order-processor 輸出:

    == APP == Subscriber received: {"orderId":1}
    == APP == Subscriber received: {"orderId":2}
    == APP == Subscriber received: {"orderId":3}
    == APP == Subscriber received: {"orderId":4}
    == APP == Subscriber received: {"orderId":5}
    == APP == Subscriber received: {"orderId":6}
    == APP == Subscriber received: {"orderId":7}
    == APP == Subscriber received: {"orderId":8}
    == APP == Subscriber received: {"orderId":9}
    == APP == Subscriber received: {"orderId":10}
    
  7. 執行下列命令,確定這兩個應用程式都已停止。 在簽出終端機中:

    dapr stop --app-id checkout
    

    在 order-processor 終端機中:

    dapr stop --app-id order-processor
    

使用 Azure Developer CLI 部署應用程式範本

使用 azd 將應用程式部署至 Azure 容器應用程式。

準備專案

在新的終端機視窗中,瀏覽至範例的根目錄。

cd pubsub-dapr-python-servicebus

使用 Azure Developer CLI 佈建和部署

  1. 執行 azd init 來初始化專案。

    azd init
    
  2. 在終端機出現提示時,請提供下列參數。

    參數 描述
    環境名稱 建立以保存所有 Azure 資源的資源群組前綴。
    Azure 位置 您資源的 Azure 位置。
    Azure 訂用帳戶 您資源的 Azure 訂閱。
  3. 執行 azd up 以使用單一命令佈建基礎結構,並將應用程式部署至 Azure 容器應用程式。

    azd up
    

    此程序需要一些時間才會完成。 當 azd up 命令完成時,CLI 輸出會顯示兩個 Azure 入口網站連結,以監視部署進度。 輸出也會示範如何 azd up

    • 使用 azd provision 透過 ./infra 目錄提供的 Bicep 檔案,建立和設定所有必要的 Azure 資源。 一旦透過 Azure Developer CLI 佈建後,便可以透過 Azure 入口網站存取這些資源。 佈建 Azure 資源的檔案包含下列項目:
      • main.parameters.json
      • main.bicep
      • 依功能組織的 app 資源目錄
      • 包含 azd 範本所使用的 Bicep 模組的 core 參考程式庫
    • 使用 azd deploy 部署程式碼

    預期的輸出

    Initializing a new project (azd init)
    
    
    Provisioning Azure resources (azd provision)
    Provisioning Azure resources can take some time
    
      You can view detailed progress in the Azure Portal:
      https://portal.azure.com
    
      (✓) Done: Resource group: resource-group-name
      (✓) Done: Application Insights: app-insights-name
      (✓) Done: Portal dashboard: portal-dashboard-name
      (✓) Done: Log Analytics workspace: log-analytics-name
      (✓) Done: Key vault: key-vault-name
      (✓) Done: Container Apps Environment: ca-env-name
      (✓) Done: Container App: ca-checkout-name
      (✓) Done: Container App: ca-orders-name
    
    
    Deploying services (azd deploy)
    
      (✓) Done: Deploying service checkout
      (✓) Done: Deploying service orders
      - Endpoint: https://ca-orders-name.endpoint.region.azurecontainerapps.io/
    
    SUCCESS: Your Azure app has been deployed!
    You can view the resources created under the resource group resource-group-name in Azure Portal:
    https://portal.azure.com/#@/resource/subscriptions/subscription-id/resourceGroups/resource-group-name/overview
    

確認成功部署

在 Azure 入口網站中,驗證 checkout 服務正在將訊息發佈至 Azure 服務匯流排主題。

  1. 從終端機輸出複製 checkout 容器應用程式名稱。

  2. 登入 Azure 入口網站,然後依名稱搜尋容器應用程式資源。

  3. 在「容器應用程式」儀表板中,選取「監視>記錄資料流」。

    瀏覽至 Azure 入口網站中 [記錄串流] 頁面的螢幕擷取畫面。

  4. 確認 checkout 容器正在記錄的輸出與稍早的終端機相同。

    Azure 入口網站中結帳服務容器記錄串流的螢幕擷取畫面。

  5. 請對 order-processor 服務執行相同動作。

    Azure 入口網站中訂單處理器服務容器記錄串流的螢幕擷取畫面。

發生什麼事?

azd up 命令成功完成時:

  • Azure Developer CLI 已將範例專案 ./infra 目錄中所參考的 Azure 資源佈建到您指定的 Azure 訂閱。 您現在可以透過 Azure 入口網站檢視這些 Azure 資源。
  • 應用程式會部署至 Azure 容器應用程式。 您可以從入口網站瀏覽至全部的功能應用程式。

在本機執行 .NET 應用程式

將應用程式部署至 Azure 容器應用程式之前,請先使用 Dapr 和 Azure 服務匯流排在本機執行 order-processorcheckout 服務。

準備專案

  1. 範例應用程式複製到本機電腦。

    git clone https://github.com/Azure-Samples/pubsub-dapr-csharp-servicebus.git
    
  2. 瀏覽至範例的根目錄。

    cd pubsub-dapr-csharp-servicebus
    

使用 Dapr CLI 執行應用程式

首先,執行 order-processor 訂閱者服務

  1. 從範例的根目錄,請將目錄變更為 order-processor

    cd order-processor
    
  2. 安裝相依性。

    dotnet build
    
  3. 執行 order-processor 服務。

    dapr run --app-id order-processor --resources-path ../components/ --app-port 7001 -- dotnet run --project .
    
  4. 在新的終端機視窗中,從範例的根目錄瀏覽至 checkout 發行者服務。

    cd checkout
    
  5. 安裝相依性。

    dotnet build
    
  6. 執行 checkout 服務。

    dapr run --app-id checkout --resources-path ../components/ -- dotnet run --project .
    

    預期的輸出

    在這兩個終端機中,checkout 服務會在結束前發佈 order-processor 服務所接收的 10 則訊息。

    checkout 輸出:

    == APP == Published data: {"orderId":1}
    == APP == Published data: {"orderId":2}
    == APP == Published data: {"orderId":3}
    == APP == Published data: {"orderId":4}
    == APP == Published data: {"orderId":5}
    == APP == Published data: {"orderId":6}
    == APP == Published data: {"orderId":7}
    == APP == Published data: {"orderId":8}
    == APP == Published data: {"orderId":9}
    == APP == Published data: {"orderId":10}
    

    order-processor 輸出:

    == APP == Subscriber received: {"orderId":1}
    == APP == Subscriber received: {"orderId":2}
    == APP == Subscriber received: {"orderId":3}
    == APP == Subscriber received: {"orderId":4}
    == APP == Subscriber received: {"orderId":5}
    == APP == Subscriber received: {"orderId":6}
    == APP == Subscriber received: {"orderId":7}
    == APP == Subscriber received: {"orderId":8}
    == APP == Subscriber received: {"orderId":9}
    == APP == Subscriber received: {"orderId":10}
    
  7. 執行下列命令,確定這兩個應用程式都已停止。 在簽出終端機中。

    dapr stop --app-id checkout
    

    在 order-processor 終端機中:

    dapr stop --app-id order-processor
    

使用 Azure Developer CLI 部署應用程式範本

使用 azd 將應用程式部署至 Azure 容器應用程式。

準備專案

在新的終端機視窗中,瀏覽至範例的根目錄。

cd pubsub-dapr-csharp-servicebus

使用 Azure Developer CLI 佈建和部署

  1. 執行 azd init 來初始化專案。

    azd init
    
  2. 在終端機出現提示時,請提供下列參數。

    參數 描述
    環境名稱 建立以保存所有 Azure 資源的資源群組前綴。
    Azure 位置 您資源的 Azure 位置。
    Azure 訂用帳戶 您資源的 Azure 訂閱。
  3. 執行 azd up 以使用單一命令佈建基礎結構,並將應用程式部署至 Azure 容器應用程式。

    azd up
    

    此程序需要一些時間才會完成。 當 azd up 命令完成時,CLI 輸出會顯示兩個 Azure 入口網站連結,以監視部署進度。 輸出也會示範如何 azd up

    • 使用 azd provision 透過 ./infra 目錄提供的 Bicep 檔案,建立和設定所有必要的 Azure 資源。 一旦透過 Azure Developer CLI 佈建後,便可以透過 Azure 入口網站存取這些資源。 佈建 Azure 資源的檔案包含下列項目:
      • main.parameters.json
      • main.bicep
      • 依功能組織的 app 資源目錄
      • 包含 azd 範本所使用的 Bicep 模組的 core 參考程式庫
    • 使用 azd deploy 部署程式碼

    預期的輸出

    Initializing a new project (azd init)
    
    
    Provisioning Azure resources (azd provision)
    Provisioning Azure resources can take some time
    
      You can view detailed progress in the Azure Portal:
      https://portal.azure.com
    
      (✓) Done: Resource group: resource-group-name
      (✓) Done: Application Insights: app-insights-name
      (✓) Done: Portal dashboard: portal-dashboard-name
      (✓) Done: Log Analytics workspace: log-analytics-name
      (✓) Done: Key vault: key-vault-name
      (✓) Done: Container Apps Environment: ca-env-name
      (✓) Done: Container App: ca-checkout-name
      (✓) Done: Container App: ca-orders-name
    
    
    Deploying services (azd deploy)
    
      (✓) Done: Deploying service checkout
      (✓) Done: Deploying service orders
      - Endpoint: https://ca-orders-name.endpoint.region.azurecontainerapps.io/
    
    SUCCESS: Your Azure app has been deployed!
    You can view the resources created under the resource group resource-group-name in Azure Portal:
    https://portal.azure.com/#@/resource/subscriptions/subscription-id/resourceGroups/resource-group-name/overview
    

確認成功部署

在 Azure 入口網站中,驗證 checkout 服務正在將訊息發佈至 Azure 服務匯流排主題。

  1. 從終端機輸出複製 checkout 容器應用程式名稱。

  2. 登入 Azure 入口網站,然後依名稱搜尋容器應用程式資源。

  3. 在「容器應用程式」儀表板中,選取「監視>記錄資料流」。

    瀏覽至 Azure 入口網站中 [記錄串流] 頁面的螢幕擷取畫面。

  4. 確認 checkout 容器正在記錄的輸出與稍早的終端機相同。

    Azure 入口網站中結帳服務容器記錄串流的螢幕擷取畫面。

  5. 請對 order-processor 服務執行相同動作。

    Azure 入口網站中訂單處理器服務容器記錄串流的螢幕擷取畫面。

發生什麼事?

azd up 命令成功完成時:

  • Azure Developer CLI 已將範例專案 ./infra 目錄中所參考的 Azure 資源佈建到您指定的 Azure 訂閱。 您現在可以透過 Azure 入口網站檢視這些 Azure 資源。
  • 應用程式會部署至 Azure 容器應用程式。 您可以從入口網站瀏覽至全部的功能應用程式。

清除資源

若您不打算繼續使用此應用程式,請刪除使用下列命令佈建的 Azure 資源:

azd down

下一步