此页面由 Cloud Translation API 翻译。

处理多个客户端

前提条件

概览

本教程从使用入门开始更新 Echo 客户端与服务器建立多个连接，并更新 Echo 服务器用于处理多个客户端连接。跑步用服务器的多个实例（或多个 FIDL 协议），请参阅服务教程。

本教程的完整示例代码位于 //examples/fidl/hlcpp/multiple_clients。

实现服务器

在之前的实现中，将 main() 函数初始化为单个 fidl::Binding，并将所有传入请求绑定到该 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::BindingSet 的 fidl::Binding（每个客户端一个）：

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 的 anolog： 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;
}

设置代理和发出请求的代码与客户端教程，但它使用一个接口指针集，用于简化广播消息的过程一组客户端。使用 fidl::InterfacePtrSet 和 fidl::BindingSet 是指任何遇到错误会自动从集中删除。

如需使用 fidl::InterfacePtrSet，请添加 lib/fidl/cpp/interface_ptr_set.h。

运行示例

为使客户端和服务器使用 Echo 协议进行通信，组件框架必须将 fuchsia.examples.Echo 功能从从服务器发送到客户端在本教程中，领域组件是来声明相应的功能和路线。

配置 build，使其包含提供的软件包，其中包含 echo 领域、服务器和客户端：
```
fx set core.x64 --with //examples/fidl/hlcpp:echo-hlcpp-multi-client
```
构建 Fuchsia 映像：
```
fx build
```

运行 echo_realm 组件。这会创建客户端和服务器组件并路由功能：

ffx component run /core/ffx-laboratory:echo_realm fuchsia-pkg://fuchsia.com/echo-hlcpp-multi-client#meta/echo_realm.cm

启动 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