Google Pub/Sub Javaの例

Question

javaを使用してpub/subからメッセージを読む方法を見つけることができません。

public static void main(String... args) throws Exception { 

     // Your Google Cloud Platform project ID 
     String projectId = ServiceOptions.getDefaultProjectId(); 

     // Your topic ID 
     String topicId = "my-new-topic-1"; 
     // Create a new topic 
     TopicName topic = TopicName.create(projectId, topicId); 
     try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) { 
      topicAdminClient.createTopic(topic); 
     } 
} 

上記のコードは確かに、私がすることができますうまく機能して：私は新しいトピックを作成するには、このmainメソッドを実装し

<dependency> 
    <groupId>com.google.cloud</groupId> 
    <artifactId>google-cloud-pubsub</artifactId> 
    <version>0.17.2-alpha</version> 
</dependency> 

私は私のポンポンでこのMavenの依存関係を使用していますGoogleのクラウドコンソールを使用して作成した新しいトピックをご覧ください。

私は私のトピックにメッセージを書き込むために、次のmainメソッドを実装し：

public static void main(String a[]) throws InterruptedException, ExecutionException{ 
     String projectId = ServiceOptions.getDefaultProjectId(); 
     String topicId = "my-new-topic-1"; 

     String payload = "Hellooooo!!!"; 
     PubsubMessage pubsubMessage = 
        PubsubMessage.newBuilder().setData(ByteString.copyFromUtf8(payload)).build(); 

     TopicName topic = TopicName.create(projectId, topicId); 

     Publisher publisher; 
     try { 
      publisher = Publisher.defaultBuilder(
        topic) 
        .build(); 
      publisher.publish(pubsubMessage); 

      System.out.println("Sent!"); 
     } catch (IOException e) { 
      System.out.println("Not Sended!"); 
      e.printStackTrace(); 
     } 
} 

は今、私はこのメッセージが本当に送信されたかどうかを確認することはできませんよ。 トピックの購読を使用してメッセージリーダーを実装したいと思います。 誰かが、トピックからメッセージを読むことについて正しい、働いているJavaの例を私に示してもらえますか？

誰でも手伝ってもらえますか？ ありがとうございます！

Answer 1

Cloud Pub/Sub Pull Subscriber Guideには、トピックからメッセージを読み取るためのサンプルコードがあります。

Answer 2

メッセージリーダーが加入者に注入されています。 codeのこの部分は、次のメッセージを処理します。

MessageReceiver receiver = 
    new MessageReceiver() { 
     @Override 
     public void receiveMessage(PubsubMessage message, AckReplyConsumer consumer) { 
     // handle incoming message, then ack/nack the received message 
     System.out.println("Id : " + message.getMessageId()); 
     System.out.println("Data : " + message.getData().toStringUtf8()); 
     consumer.ack(); 
     } 
    };