如何通过扩展C++框架来实现微服务架构？

// 客户机代码
#include <thrift/protocol/TBinaryProtocol.h>
#include <thrift/transport/TSocket.h>
#include <thrift/transport/TTransport.h>

#include "../gen-cpp/ExampleService.h"

int main() {
  // 创建传输套接字
  boost::shared_ptr<TTransport> transport(new TSocket("localhost", 9090));

  // 创建二进制协议
  boost::shared_ptr<TProtocol> protocol(new TBinaryProtocol(transport));

  // 创建 ExampleService 的客户端
  ExampleServiceClient client(protocol);

  // 打开传输层
  transport->open();

  // 调用 ExampleService 方法
  std::string result = client.getName();

  // 打印结果
  std::cout << result << std::endl;

  // 关闭传输层
  transport->close();

  return 0;
}

// 服务端代码
#include <thrift/server/TSimpleServer.h>
#include <thrift/transport/TServerSocket.h>
#include <thrift/transport/TBufferTransports.h>
#include <thrift/protocol/TBinaryProtocol.h>

#include "../gen-cpp/ExampleService.h"

class ExampleServiceImpl : public ExampleServiceIf {
 public:
  std::string getName() override {
    return "Example Name";
  }
};

int main() {
  // 创建一个服务端套接字
  boost::shared_ptr<TServerSocket> serverSocket(new TServerSocket(9090));

  // 创建一个传输工厂
  boost::shared_ptr<TTransportFactory> transportFactory(new TBufferedTransportFactory());

  // 创建一个协议工厂
  boost::shared_ptr<TProtocolFactory> protocolFactory(new TBinaryProtocolFactory());

  // 创建一个进程工厂
  boost::shared_ptr<TProcessorFactory> processorFactory(new ExampleServiceProcessorFactory(boost::make_shared<ExampleServiceImpl>()));

  // 创建一个简单服务
  boost::shared_ptr<TSimpleServer> server(new TSimpleServer(processorFactory, serverSocket, transportFactory, protocolFactory));

  // 运行服务
  server->serve();

  return 0;
}

// 客户机代码
#include <dapr/clients.h>
#include <fmt/format.h>

int main() {
  // 从 Dapr 侧车获取 ExampleService 的引用
  dapr::client::invoker::v1::DaprInvokerClient invokerClient("example-service");

  // 调用 ExampleService 的 getName 方法
  dapr::client::invoker::v1::InvokeServiceResponse response = invokerClient.InvokeService(
    dapr::client::invoker::InvokeRequest(
      fmt::format(
        "InvocationRequest(method=\"getName\")"),
      std::vector<dapr::common::v1::Data>()
    )
  );

  // 打印结果
  std::cout << response.GetData(0).Content() << std::endl;

  return 0;
}

// 服务端代码
#include <dapr/actor.h>
#include <fmt/format.h>
#include <nlohmann/json.hpp>

namespace dapr::actors::v1 {

class ExampleActor : public Actor {
 public:
  ExampleActor(
    const std::string& actorType,
    const std::string& actorId,
    const std::string& partitionId,
    std::shared_ptr<ActorRuntime> actorRuntime)
    : Actor(actorType, actorId, partitionId, actorRuntime) {}

  grpc::Status Invoke(
    grpc::ServerContext* context,
    const google::cloud::actor::v1::InvokeActorRequest* request,
    google::cloud::actor::v1::InvokeActorResponse* response) override {
    if (request->method() == "getName") {
      response->set_error(
        fmt::format(
          "InvokeSuccessResponse(result=\"Example Name\")"));
      return grpc::Status::OK;
    } else {
      return grpc::Status(grpc::StatusCode::UNIMPLEMENTED, fmt::format("Method {} is not implemented", request->method()));
    }
  }
};

}  // dapr::actors::v1

DAPR_REGISTER_ACTOR(ExampleActor)