从谷歌云平台接收数据的C++示例代码

#include <iostream>
#include <google/cloud/pubsub/subscriber.h>

void ReceiveMessage(google::cloud::pubsub::Message const& message,
                    google::cloud::pubsub::AckHandler const& ack_handler,
                    std::atomic<bool>& received_message) {
  std::cout << "Received message: " << message.data() << std::endl;
  ack_handler(message);  // Acknowledge the message
  received_message = true;
}

int main() {
  std::string const project_id = "your-project-id";
  std::string const subscription_id = "your-subscription-id";

  google::cloud::pubsub::Subscriber subscriber(
      google::cloud::pubsub::MakeSubscriberConnection());

  std::atomic<bool> received_message(false);

  auto response = subscriber.Subscribe(
      google::cloud::pubsub::Subscription(project_id, subscription_id),
      [&](google::cloud::pubsub::Message const& message,
          google::cloud::pubsub::AckHandler const& ack_handler) {
        ReceiveMessage(message, ack_handler, received_message);
      });

  if (!response) {
    std::cerr << "Error subscribing to the subscription: "
              << response.status() << std::endl;
    return 1;
  }

  std::cout << "Listening for messages..." << std::endl;

  while (!received_message) {
    std::this_thread::sleep_for(std::chrono::seconds(1));
  }

  return 0;
}