使用 Pub/Sub 建立設有防火牆的 Google Chat 應用程式

Java

• 擁有可存取 Google Chat 的 Google Workspace 帳戶。
• Google Cloud 專案。
• 確認您已開啟 Cloud 專案的計費功能。瞭解如何驗證專案的帳單狀態。
• Java 11 以上版本。
• Apache Maven

Java

1. 在 CLI 中提供服務帳戶憑證：

   export GOOGLE_APPLICATION_CREDENTIALS=SERVICE_ACCOUNT_FILE_PATH
   

2. 在工作目錄中，建立名為 pom.xml 的檔案。

3. 在 pom.xml 檔案中，貼上下列程式碼：

   <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
   
   <groupId>com.google.chat.pubsub</groupId>
   <artifactId>java-pubsub-app</artifactId>
   <version>0.1.0</version>
   
   <name>java-pubsub-app</name>
   
   <properties>
     <maven.compiler.target>11</maven.compiler.target>
     <maven.compiler.source>11</maven.compiler.source>
   </properties>
   
   <dependencyManagement>
     <dependencies>
       <dependency>
         <groupId>com.google.cloud</groupId>
         <artifactId>libraries-bom</artifactId>
         <version>26.26.0</version>
         <type>pom</type>
         <scope>import</scope>
       </dependency>
     </dependencies>
   </dependencyManagement>
   
   <dependencies>
     <dependency>
       <groupId>com.google.code.gson</groupId>
       <artifactId>gson</artifactId>
       <version>2.9.1</version>
     </dependency>
     <dependency>
       <groupId>com.google.api-client</groupId>
       <artifactId>google-api-client</artifactId>
       <version>1.32.1</version>
     </dependency>
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>google-cloud-pubsub</artifactId>
     </dependency>
     <dependency>
       <groupId>com.fasterxml.jackson.core</groupId>
       <artifactId>jackson-databind</artifactId>
       <version>2.14.2</version>
     </dependency>
   </dependencies>
   
   <build>
     <pluginManagement>
       <plugins>
         <plugin>
           <artifactId>maven-compiler-plugin</artifactId>
           <version>3.8.0</version>
         </plugin>
       </plugins>
     </pluginManagement>
   </build>
   </project>
   

4. 在工作目錄中，建立目錄結構 src/main/java。

5. 在 src/main/java 目錄中，建立名為 Main.java 的檔案。

6. 在 Main.java 中貼上下列程式碼：

   import com.fasterxml.jackson.databind.JsonNode;
   import com.fasterxml.jackson.databind.ObjectMapper;
   import com.fasterxml.jackson.databind.node.JsonNodeFactory;
   import com.fasterxml.jackson.databind.node.ObjectNode;
   import com.google.api.client.googleapis.auth.oauth2.GoogleCredential;
   import com.google.api.client.googleapis.javanet.GoogleNetHttpTransport;
   import com.google.api.client.http.ByteArrayContent;
   import com.google.api.client.http.GenericUrl;
   import com.google.api.client.http.HttpContent;
   import com.google.api.client.http.HttpRequest;
   import com.google.api.client.http.HttpRequestFactory;
   import com.google.api.client.http.HttpTransport;
   import com.google.cloud.pubsub.v1.AckReplyConsumer;
   import com.google.cloud.pubsub.v1.MessageReceiver;
   import com.google.cloud.pubsub.v1.Subscriber;
   import com.google.pubsub.v1.PubsubMessage;
   import com.google.pubsub.v1.ProjectSubscriptionName;
   import java.io.FileInputStream;
   import java.util.Collections;
   
   public class Main {
   
     public static final String CREDENTIALS_PATH_ENV_PROPERTY = "GOOGLE_APPLICATION_CREDENTIALS";
   
     // Google Cloud Project ID
     public static final String PROJECT_ID = PROJECT_ID;
   
     // Cloud Pub/Sub Subscription ID
     public static final String SUBSCRIPTION_ID = SUBSCRIPTION_ID
   
     public static void main(String[] args) throws Exception {
       ProjectSubscriptionName subscriptionName =
           ProjectSubscriptionName.of(PROJECT_ID, SUBSCRIPTION_ID);
   
       // Instantiate app, which implements an asynchronous message receiver.
       EchoApp echoApp = new EchoApp();
   
       // Create a subscriber for <var>SUBSCRIPTION_ID</var> bound to the message receiver
       final Subscriber subscriber =
           Subscriber.newBuilder(subscriptionName, echoApp).build();
       System.out.println("Starting subscriber...");
       subscriber.startAsync();
   
       // Wait for termination
       subscriber.awaitTerminated();
     }
   }
   
   / **
   * A demo app which implements {@link MessageReceiver} to receive messages. It simply echoes the
   * incoming messages.
   */
   class EchoApp implements MessageReceiver {
   
     // Path to the private key JSON file of the service account to be used for posting response
     // messages to Google Chat.
     // In this demo, we are using the same service account for authorizing with Cloud Pub/Sub to
     // receive messages and authorizing with Google Chat to post messages. If you are using
     // different service accounts, please set the path to the private key JSON file of the service
     // account used to post messages to Google Chat here.
     private static final String SERVICE_ACCOUNT_KEY_PATH =
         System.getenv(Main.CREDENTIALS_PATH_ENV_PROPERTY);
   
     // Developer code for Google Chat API scope.
     private static final String GOOGLE_CHAT_API_SCOPE = "https://www.googleapis.com/auth/chat.bot";
   
     // Response URL Template with placeholders for space id.
     private static final String RESPONSE_URL_TEMPLATE =
         "https://chat.googleapis.com/v1/__SPACE_ID__/messages";
   
     // Response echo message template.
     private static final String RESPONSE_TEMPLATE = "You said: `__MESSAGE__`";
   
     private static final String ADDED_RESPONSE = "Thank you for adding me!";
   
     GoogleCredential credential;
     HttpTransport httpTransport;
     HttpRequestFactory requestFactory;
   
     EchoApp() throws Exception {
       credential =
           GoogleCredential.fromStream(new FileInputStream(SERVICE_ACCOUNT_KEY_PATH))
               .createScoped(Collections.singleton(GOOGLE_CHAT_API_SCOPE));
       httpTransport = GoogleNetHttpTransport.newTrustedTransport();
       requestFactory = httpTransport.createRequestFactory(credential);
     }
   
     // Called when a message is received by the subscriber.
     @Override
     public void receiveMessage(PubsubMessage pubsubMessage, AckReplyConsumer consumer) {
       System.out.println("Id : " + pubsubMessage.getMessageId());
       // handle incoming message, then ack/nack the received message
       try {
         ObjectMapper mapper = new ObjectMapper();
         JsonNode dataJson = mapper.readTree(pubsubMessage.getData().toStringUtf8());
         System.out.println("Data : " + dataJson.toString());
         handle(dataJson);
         consumer.ack();
       } catch (Exception e) {
         System.out.println(e);
         consumer.nack();
       }
     }
   
     public void handle(JsonNode eventJson) throws Exception {
       JsonNodeFactory jsonNodeFactory = new JsonNodeFactory(false);
       ObjectNode responseNode = jsonNodeFactory.objectNode();
   
       // Construct the response depending on the event received.
   
       String eventType = eventJson.get("type").asText();
       switch (eventType) {
         case "ADDED_TO_SPACE":
           responseNode.put("text", ADDED_RESPONSE);
           // An app can also be added to a space by @mentioning it in a message. In that case, we fall
           // through to the MESSAGE case and let the app respond. If the app was added using the
           // invite flow, we just post a thank you message in the space.
           if(!eventJson.has("message")) {
             break;
           }
         case "MESSAGE":
           responseNode.put("text",
               RESPONSE_TEMPLATE.replaceFirst(
                   "__MESSAGE__", eventJson.get("message").get("text").asText()));
           // In case of message, post the response in the same thread.
           ObjectNode threadNode = jsonNodeFactory.objectNode();
           threadNode.put("name", eventJson.get("message").get("thread").get("name").asText());
           responseNode.put("thread", threadNode);
           break;
         case "REMOVED_FROM_SPACE":
         default:
           // Do nothing
           return;
       }
   
       // Post the response to Google Chat.
   
       String URI =
           RESPONSE_URL_TEMPLATE.replaceFirst(
               "__SPACE_ID__", eventJson.get("space").get("name").asText());
       GenericUrl url = new GenericUrl(URI);
   
       HttpContent content =
           new ByteArrayContent("application/json", responseNode.toString().getBytes("UTF-8"));
       HttpRequest request = requestFactory.buildPostRequest(url, content);
       com.google.api.client.http.HttpResponse response = request.execute();
     }
   }
   

   更改下列內容：

   • PROJECT_ID：Google Cloud 專案 ID。
   • SUBSCRIPTION_ID：您先前建立的 Pub/Sub 訂閱項目訂閱項目 ID。

Java

mvn compile exec:java -Dexec.mainClass=Main