Multiple certificates push error!

[simondongji]

I have multiple certificates, and I need to create multiple ApnsClient's and push messages to multiple APP's, but they come with message push failures or long message delays。

code:

    @Override
    public void createOrUpdateApnsClient(String channelCode, ApnsProperties.Certificate certificate) {
        String certificatePath = apnsProperties.getRootDir() + "/" + certificate.getName();
        File certificateFile = new File(certificatePath);
        Assert.isTrue(certificateFile.exists(), String.format("APNS证书(%s) 不存在", channelCode));

        String apnsHost = ApnsClientBuilder.PRODUCTION_APNS_HOST;
        if(certificate.getDev()){
            apnsHost = ApnsClientBuilder.DEVELOPMENT_APNS_HOST;
        }

        ApnsClient apnsClient;
        try {
            apnsClient = new ApnsClientBuilder().setApnsServer(apnsHost)
                    .setClientCredentials(certificateFile, certificate.getPassword())
                    .setConcurrentConnections(4).setEventLoopGroup(eventLoopGroup).build();
        } catch (IOException e) {
            throw new IllegalArgumentException(String.format("配置(%s-%s) 创建 APNS Client 失败", channelCode, certificate));
        }
        channelCodeClients.put(channelCode, apnsClient);
        topics.put(channelCode, certificate.getTopic());
    }

@Slf4j
public class ApnsUtils {

    private static final Semaphore semaphore = new Semaphore(10000);

    /**
     * TODO 需要封装返回结果
     *
     * @param client
     * @param notifications
     */
    public static void sendSimpleApnsPushNotification(String chancelCode, ApnsClient client, List<SimpleApnsPushNotification> notifications) {
        int total = notifications.size();
        long startTime = System.currentTimeMillis();
        final CountDownLatch latch = new CountDownLatch(notifications.size());
        final AtomicLong successCut = new AtomicLong(0);
        notifications.forEach(pushNotification -> {

            try {
                semaphore.acquire();
            } catch (InterruptedException e) {
                log.error("Push get semaphore failed", e);
            }

            log.info("Start Push notification：chancelCode=【{}】,token=【{}】;topic=【{}】;payload=【{}】", chancelCode, pushNotification.getToken(), pushNotification.getTopic(), pushNotification.getPayload());

            final PushNotificationFuture<SimpleApnsPushNotification, PushNotificationResponse<SimpleApnsPushNotification>>
                    sendNotificationFuture = client.sendNotification(pushNotification);
            sendNotificationFuture.whenComplete((pushNotificationResponse, cause) -> {
                if (pushNotificationResponse != null) {
                    // Handle the push notification response as before from here.
                    if (pushNotificationResponse.isAccepted()) {
                        successCut.incrementAndGet();
                        log.info("Push notification accepted by APNs gateway：chancelCode=【{}】, token=【{}】;payload=【{}】", chancelCode, pushNotification.getToken(), pushNotification.getPayload());
                    } else {
                        log.error("Notification rejected by the APNs gateway: chancelCode=【{}】, token=【{}】;reason=【{}】", chancelCode, pushNotification.getToken(),
                                pushNotificationResponse.getRejectionReason());

                        pushNotificationResponse.getTokenInvalidationTimestamp().ifPresent(timestamp -> {
                            log.error("\t…and the token is invalid as of " + timestamp);
                        });
                    }
                } else {
                    // Something went wrong when trying to send the notification to the
                    // APNs server. Note that this is distinct from a rejection from
                    // the server, and indicates that something went wrong when actually
                    // sending the notification or waiting for a reply.
                    log.error("Send notification device chancelCode=【{}】, token=【{}】 is failed：【{}】", chancelCode, pushNotification.getToken(), pushNotification.getPayload());
                }
                latch.countDown();
                semaphore.release();
            });
        });
        try {
            latch.await(20, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            log.error("Push latch await failed!", e);
        }
        long endTime = System.currentTimeMillis();
        log.info("Push timeCost:{}, total:{},success:{},fail:{}", endTime - startTime, total, successCut.get(), total - successCut.get());
    }
}

error message:

2022-09-26 18:06:13.103  WARN 13478 --- [nioEventLoopGroup-2-3] c.eatthepath.pushy.apns.ApnsChannelPool  : Failed to create channel

java.io.IOException: Stream closed before a reply was received
	at com.eatthepath.pushy.apns.ApnsClientHandler.<clinit>(ApnsClientHandler.java:84)
	at com.eatthepath.pushy.apns.ApnsClientHandler$ApnsClientHandlerBuilder.build(ApnsClientHandler.java:138)
	at com.eatthepath.pushy.apns.ApnsClientHandler$ApnsClientHandlerBuilder.build(ApnsClientHandler.java:91)
	at io.netty.handler.codec.http2.AbstractHttp2ConnectionHandlerBuilder.buildFromCodec(AbstractHttp2ConnectionHandlerBuilder.java:550)
	at io.netty.handler.codec.http2.AbstractHttp2ConnectionHandlerBuilder.buildFromConnection(AbstractHttp2ConnectionHandlerBuilder.java:539)
	at io.netty.handler.codec.http2.AbstractHttp2ConnectionHandlerBuilder.build(AbstractHttp2ConnectionHandlerBuilder.java:503)
	at com.eatthepath.pushy.apns.ApnsClientHandler$ApnsClientHandlerBuilder.build(ApnsClientHandler.java:145)
	at com.eatthepath.pushy.apns.ApnsChannelFactory$1.initChannel(ApnsChannelFactory.java:129)
	at com.eatthepath.pushy.apns.ApnsChannelFactory$1.initChannel(ApnsChannelFactory.java:97)
	at io.netty.channel.ChannelInitializer.initChannel(ChannelInitializer.java:129)
	at io.netty.channel.ChannelInitializer.handlerAdded(ChannelInitializer.java:112)
	at io.netty.channel.AbstractChannelHandlerContext.callHandlerAdded(AbstractChannelHandlerContext.java:938)
	at io.netty.channel.DefaultChannelPipeline.callHandlerAdded0(DefaultChannelPipeline.java:609)
	at io.netty.channel.DefaultChannelPipeline.access$100(DefaultChannelPipeline.java:46)
	at io.netty.channel.DefaultChannelPipeline$PendingHandlerAddedTask.execute(DefaultChannelPipeline.java:1463)
	at io.netty.channel.DefaultChannelPipeline.callHandlerAddedForAllHandlers(DefaultChannelPipeline.java:1115)
	at io.netty.channel.DefaultChannelPipeline.invokeHandlerAddedIfNeeded(DefaultChannelPipeline.java:650)
	at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:514)
	at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
	at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.lang.Thread.run(Thread.java:748)

[jchambers]

I have multiple certificates, and I need to create multiple ApnsClient's…

Do things work as expected if you use only a single client/certificate? Are there any other messages in the logs around the connection attempt?

[simondongji]

Using a single connection just works.

No more logs are available.

[jchambers]

What happens if you reduce your concurrent connection account? It looks like you're using four concurrent connections now; if you use one concurrent connection per client, can you successfully use four clients?

[zhoutongxin]

I have same question! If I user one concurrent connection per client, how many eventLookGroup should by create?