Sending single message for multiple devices with for loop

[pasake]

for (PushConfigRspDTO configRspDTO : cfgLst) {
            final SimpleApnsPushNotification pushNotification;
            final ApnsClient apnsClient = new ApnsClientBuilder()
                    .setApnsServer(ApnsClientBuilder.DEVELOPMENT_APNS_HOST)
                    .setClientCredentials(new File("cert/pushCert.p12"), "jsp2021")
                    .build();
            try {
                {
                    final ApnsPayloadBuilder payloadBuilder = new SimpleApnsPayloadBuilder();
                    payloadBuilder.setAlertTitle(pushSdkDTO.getContent());
                    payloadBuilder.setLocalizedAlertMessage(pushSdkDTO.getIntroduction(), pushSdkDTO.getLinkUrl());
                    payloadBuilder.setBadgeNumber(configRspDTO.getRecMsg());
                    final String payload = payloadBuilder.build();
                    final String token = TokenUtil.sanitizeTokenString(configRspDTO.getToken());

                    pushNotification = new SimpleApnsPushNotification(token, "com.sobey.JiangXiTV", payload);
                    final PushNotificationFuture<SimpleApnsPushNotification, PushNotificationResponse<SimpleApnsPushNotification>>
                            sendNotificationFuture = apnsClient.sendNotification(pushNotification);

                    final PushNotificationResponse<SimpleApnsPushNotification> pushNotificationResponse =
                            sendNotificationFuture.get();

                    if (pushNotificationResponse.isAccepted()) {
                        log.info("Push notification accepted by APNs gateway.");
                    } else {
                        log.info("Notification rejected by the APNs gateway: " +
                                pushNotificationResponse.getRejectionReason());

                        pushNotificationResponse.getTokenInvalidationTimestamp().ifPresent(timestamp ->
                                log.info("\t…and the token is invalid as of " + timestamp));
                    }
                    sendNotificationFuture.whenComplete((response, cause) -> {
                        if (response != null) {
                            // Handle the push notification response as before from here.
                            log.info("推送ios成功");
                            PushService pushService = SpringUtils.getBean(PushService.class);
                            pushService.updateMsgCount(configRspDTO.getId(), configRspDTO.getRecMsg() + 1);
                        } else {
                            cause.printStackTrace();
                        }
                    });
                }
            } finally {
                apnsClient.close();
            }
        }

Now there are 2 problems
1.Initialize and close the client outside of the loop , Only the first token device receives the message
2.Initialize and close the client in the loop , It will report an error if it is a device like fail create channel

How can I send messages to multiple devices

looking forward to your reply

[jchambers]

While I'm having a little trouble following your example code (you're both calling sendNotificationFuture.get AND sendNotificationFuture.whenComplete, which is a little confusing), it sounds like you're running into this frequently-asked question:

I sent a bunch of notifications, and lots (but not all) of them failed with an Http2GoAwayException or ClientNotConnectedException. How come?

My recommendation would be to do something like this:

final ApnsClient apnsClient = ...;

final CountDownLatch countDownLatch = new CountDownLatch(cfgList.size());

for (final PushConfigRspDTO configRspDTO : cfgLst) {
    final final SimpleApnsPushNotification pushNotification = ...;

    apnsClient.sendNotification(pushNotification).whenComplete((response, cause) -> {
        // Do whatever processing you need to do when you receive a response
        
        countDownLatch.countDown();
    });
}

// Wait until all sending operations are done before closing the client
countDownLatch.await();
apnsClient.close().join();

[pasake]

After replacing your code, it works successfully. Thank you very much