问使用Java服务器发送推送通知和世博响应本机客户端

EN

    <dependency>
        <groupId>io.github.jav</groupId>
        <artifactId>expo-server-sdk</artifactId>
        <version>1.1.0</version>
    </dependency>

private static void sendPushNotification(String token, String titulo, String mensaje, Map<String, Object> data) throws PushClientException {
    if (!PushClient.isExponentPushToken(token)) throw new Error("Token:" + token + " is not a valid token.");

    ExpoPushMessage expoPushMessage = new ExpoPushMessage();
    expoPushMessage.getTo().add(token);
    expoPushMessage.setTitle(titulo);
    expoPushMessage.setBody(mensaje);
    expoPushMessage.setData(data);

    List<ExpoPushMessage> expoPushMessages = new ArrayList<>();
    expoPushMessages.add(expoPushMessage);

    PushClient client = new PushClient();
    List<List<ExpoPushMessage>> chunks = client.chunkPushNotifications(expoPushMessages);

    List<CompletableFuture<List<ExpoPushTicket>>> messageRepliesFutures = new ArrayList<>();

    for (List<ExpoPushMessage> chunk : chunks) {
        messageRepliesFutures.add(client.sendPushNotificationsAsync(chunk));
    }

    // Wait for each completable future to finish
    List<ExpoPushTicket> allTickets = new ArrayList<>();
    for (CompletableFuture<List<ExpoPushTicket>> messageReplyFuture : messageRepliesFutures) {
        try {
            allTickets.addAll(messageReplyFuture.get());
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }

    List<ExpoPushMessageTicketPair<ExpoPushMessage>> zippedMessagesTickets = client.zipMessagesTickets(expoPushMessages, allTickets);

    List<ExpoPushMessageTicketPair<ExpoPushMessage>> okTicketMessages = client.filterAllSuccessfulMessages(zippedMessagesTickets);
    String okTicketMessagesString = okTicketMessages.stream().map(p -> "Title: " + p.message.getTitle() + ", Id:" + p.ticket.getId()).collect(Collectors.joining(","));
    LOGGER.info("Recieved OK ticket for " + okTicketMessages.size() + " messages: " + okTicketMessagesString);

    List<ExpoPushMessageTicketPair<ExpoPushMessage>> errorTicketMessages = client.filterAllMessagesWithError(zippedMessagesTickets);
    String errorTicketMessagesString = errorTicketMessages.stream().map(p -> "Title: " + p.message.getTitle() + ", Error: " + p.ticket.getDetails().getError()).collect(Collectors.joining(","));
    LOGGER.error("Recieved ERROR ticket for " + errorTicketMessages.size() + " messages: " + errorTicketMessagesString);

    /**
     // Countdown 30s
     int wait = 30;
     for (int i = wait; i >= 0; i--) {
     System.out.print("Waiting for " + wait + " seconds. " + i + "s\r");
     Thread.sleep(1000);
     }
     System.out.println("Fetching reciepts...");

     List<String> ticketIds = (client.getTicketIdsFromPairs(okTicketMessages));
     CompletableFuture<List<ExpoPushReceipt>> receiptFutures = client.getPushNotificationReceiptsAsync(ticketIds);

     List<ExpoPushReceipt> receipts = new ArrayList<>();
     try {
     receipts = receiptFutures.get();
     } catch (ExecutionException | InterruptedException e) {
     e.printStackTrace();
     }

     System.out.println("Recieved " + receipts.size() + " receipts:");

     for (ExpoPushReceipt reciept : receipts) {
     System.out.println("Receipt for id: " + reciept.getId() + " had status: " + reciept.getStatus());
     }
     */
}

async function registerForPushNotificationsAsync() {
  let token;
  if (isDevice) {
    const { status: existingStatus } =
      await Notifications.getPermissionsAsync();
    let finalStatus = existingStatus;
    if (existingStatus !== "granted") {
      const { status } = await Notifications.requestPermissionsAsync();
      finalStatus = status;
    }
    if (finalStatus !== "granted") {
      alert("Failed to get push token for push notification!");
      return;
    }
    token = (await Notifications.getExpoPushTokenAsync()).data;
  }

  if (Platform.OS === "android") {
    Notifications.setNotificationChannelAsync("default", {
      name: "default",
      importance: Notifications.AndroidImportance.MAX,
      vibrationPattern: [0, 250, 250, 250],
      lightColor: "#FF231F7C",
    });
  }

  return token;
}

   useEffect(() => {
    initFirebaseApp();
    registerForPushNotificationsAsync().then(async (token) => {
      //store in some place token
    });
    // This listener is fired whenever a notification is received while the app is foregrounded
    notificationListener.current =
      Notifications.addNotificationReceivedListener(handleNotification);

    // This listener is fired whenever a user taps on or interacts with a notification (works when app is foregrounded, backgrounded, or killed)
    responseListener.current =
      Notifications.addNotificationResponseReceivedListener(
        handleNotificationResponse
      );

    return () => {
      Notifications.removeNotificationSubscription(
        notificationListener.current
      );
      Notifications.removeNotificationSubscription(responseListener.current);
    };
  }, []);

  const handleNotification = (response) => {
    // console.log(response);
  };

  const handleNotificationResponse = (response) => {
    // console.log(response)
  };