javascript - 通过同一连接(使用单个 channel )访问多个 gRPC 服务

Question

请注意，这不是 a similar question for go 的重复项，因为这使用了 grpc-node。由于某种原因，API 似乎存在差异

我执行创建 APIPackageDefinitions 和 APIPackagePbjects 的标准过程，并分别创建两个单独的客户端。

let grpc = require('grpc')
let protoLoader = require('@grpc/proto-loader')

async function createGrcpConnection() {
  const HOST = 'localhost'
  const PORT = '50053'
  const PORT2 = '50054'

  let physicalProjectAPIPackageDefinition = await protoLoader.load(
    './physical_project_api.proto',protoLoaderOptions
  )
  let configAPIPackageDefinition = await protoLoader.load(
    './config_api.proto', protoLoaderOptions
  )

  let physicalProjectAPIPackageObject = grpc.loadPackageDefinition(
    physicalProjectAPIPackageDefinition
  ).package.v1
  let configAPIPackageObject = grpc.loadPackageDefinition(
    configAPIPackageDefinition
  ).package.v1


  let grpcClient1 = physicalProjectAPIPackageObject.PhysicalProjectAPI(
    `${HOST}:${PORT}`,
    grpc.credentials.createInsecure()
  )
  let grpcClient2 = configAPIPackageObject.ConfigAPI(
    `${HOST}:${PORT2}`,
    grpc.credentials.createInsecure()
  )

  return { grpcClient1, grpcClient2 }
}

我正在寻找一种方法来创建两个共享同一连接的客户端。我认为通过创建一个新的 Channel 并将最后两个 let 语句替换为

，我已经接近解决方案了

let cc = new grpc.Channel(
  `${HOST}:${PORT}`,
  grpc.credentials.createInsecure()
)

let grpcClient1 = physicalProjectAPIPackageObject.PhysicalProjectAPI(cc)
let grpcClient2 = configAPIPackageObject.ConfigAPI(cc)

但是，我收到了 TypeError: Channel's first argument (address) must be a string。我不确定如何合并新实例化的 channel 来为每项服务创建新客户端。我在 docs 上找不到任何有用的方法。任何帮助将不胜感激。

附注目前我正在尝试使用两个服务，并为每个服务创建一个客户端，并让这两个客户端在同一 channel 上共享连接。是否可以使用两个服务，并为这两个服务创建一个单个客户端？也许我可以在这里使用 .proto 包命名空间来发挥我的优势？我在网上搜索这个问题失败了。

Answer 1

有一个 API 可以做到这一点，但它比你尝试的要尴尬一些。而且您实际上并不需要使用它来获得您想要的东西。 grpc 库在内部池化到同一服务器的连接，只要这些连接是使用相同的参数创建的。因此，在第一个代码块中创建的 Client 对象实际上将使用相同的 TCP 连接。

但是，正如前面提到的，有一种方法可以显式地执行此操作。 Client 构造函数的第三个参数是一个可选对象，具有各种附加选项，包括 channelOverride。它接受一个 Channel 对象，就像您在第二个代码块开头构造的对象一样。您仍然必须为前两个参数传递有效值，但它们实际上将被忽略，而将使用第三个参数。您可以在 the API documentation 中查看有关该构造函数参数的更多信息。 .