處理多個用戶端

必要條件

本教學課程是以 HLCPP 入門教學課程為基礎。

總覽

本教學課程會在一開始設計時更新 Echo 用戶端 多個連至伺服器連線的教學課程, 用於處理多個用戶端連線的 Echo 伺服器。慢跑適用 伺服器的多個執行個體 (或多個 FIDL 通訊協定),請參閱 服務教學課程。

本教學課程的完整程式碼範例位於 //examples/fidl/hlcpp/multiple_clients

實作伺服器

先前的實作中,main() 函式已初始化 單一 fidl::Binding,並將任何傳入的要求繫結至該值區:

int main(int argc, const char** argv) {
  async::Loop loop(&kAsyncLoopConfigAttachToCurrentThread);

  EchoImpl impl;
  fidl::Binding<fuchsia::examples::Echo> binding(&impl);
  impl.event_sender_ = &binding.events();
  fidl::InterfaceRequestHandler<fuchsia::examples::Echo> handler =
      [&](fidl::InterfaceRequest<fuchsia::examples::Echo> request) {
        binding.Bind(std::move(request));
      };
  auto context = sys::ComponentContext::CreateAndServeOutgoingDirectory();
  context->outgoing()->AddPublicService(std::move(handler));

  printf("Running echo server\n");
  return loop.Run();
}

也就是說,如果第二個用戶端嘗試使用相同的 則對 binding.Bind 的第二次呼叫就會覆寫管道 第一個用戶端如要支援多個客戶,請追蹤多個客戶 fidl::Binding (每個用戶端各一個) 使用 fidl::BindingSet

int main(int argc, const char** argv) {
  async::Loop loop(&kAsyncLoopConfigAttachToCurrentThread);

  EchoImpl impl;
  fidl::BindingSet<fuchsia::examples::Echo> bindings;
  auto context = sys::ComponentContext::CreateAndServeOutgoingDirectory();
  context->outgoing()->AddPublicService(bindings.GetHandler(&impl));

  printf("Running echo server\n");
  return loop.Run();
}

繫結集同時簡化了程式碼,因為不再是 就需要建立自訂處理常式繫結組合具有 GetHandler 方法 傳回處理常式,該處理常式會建立新的 Binding 並儲存在向量中。

如要使用「fidl::BindingSet」,請加入 lib/fidl/cpp/binding_set.h

實作用戶端

為了管理多個連線到通訊協定的用戶端,FIDL HLCPP 執行階段程式庫會向 fidl::BindingSet 提供異常狀況: fidl::InterfacePtrSet。使用類別編寫能產生多個 多個連線

int main(int argc, const char** argv) {
  async::Loop loop(&kAsyncLoopConfigAttachToCurrentThread);

  auto context = sys::ComponentContext::Create();

  fidl::InterfacePtrSet<fuchsia::examples::Echo> echoers;
  for (int i = 0; i < kNumClients; i++) {
    fuchsia::examples::EchoPtr proxy;
    context->svc()->Connect(proxy.NewRequest());
    proxy.set_error_handler([&loop](zx_status_t status) {
      std::cout << "Error reading incoming message: " << status << std::endl;
      loop.Quit();
    });
    echoers.AddInterfacePtr(std::move(proxy));
  }

  size_t responses = 0;
  for (auto& echoer : echoers.ptrs()) {
    (*echoer)->EchoString("Hello echoer " + std::to_string(responses++), [&](std::string response) {
      std::cout << "Got response " << response << std::endl;
      if (responses == echoers.size()) {
        loop.Quit();
      }
    });
  }

  loop.Run();
  return responses == kNumClients ? 0 : 1;
}

設定 Proxy 及發出要求的程式碼與在 用戶端教學課程 (唯一用途) 可簡化訊息廣播程序的介面指標集 一組用戶端。使用 fidl::InterfacePtrSetfidl::BindingSet 是發生 錯誤訊息會自動從集合中移除。

如要使用「fidl::InterfacePtrSet」,請加入 lib/fidl/cpp/interface_ptr_set.h

執行範例

為了讓用戶端和伺服器使用 Echo 通訊協定進行通訊, 元件架構必須從 fuchsia.examples.Echo 伺服器傳送至用戶端在本教學課程中 運作範圍 元件是 來宣告適當的功能和路徑

  1. 設定您的版本以包含 echo 領域、伺服器和用戶端:

    fx set core.x64 --with //examples/fidl/hlcpp:echo-hlcpp-multi-client
  2. 建構 Fuchsia 映像檔:

    fx build
  3. 執行 echo_realm 元件。這項操作會建立用戶端和伺服器元件 以及轉送功能:

    ffx component run /core/ffx-laboratory:echo_realm fuchsia-pkg://fuchsia.com/echo-hlcpp-multi-client#meta/echo_realm.cm
  4. 啟動 echo_client 執行個體:

    ffx component start /core/ffx-laboratory:echo_realm/echo_client

在用戶端嘗試連線至 Echo 時,伺服器元件隨即啟動 因此效能相當卓越裝置記錄中會顯示類似以下的輸出內容 (ffx log):

[echo_server][][I] Running echo server
[echo_client][][I] Got response Hello echoer 0

終止領域元件以停止執行並清除元件 執行個體:

ffx component destroy /core/ffx-laboratory:echo_realm