Smack 4.1.0 GCM CCS 在一段时间后停止响应

Question

已经为聊天模块实现了 gcm ccs，我能够发送和接收消息。下面是主要的连接模块，

        config = XMPPTCPConnectionConfiguration.builder()
                .setServiceName("gcm-pesu.googleapis.com")
                .setPort(GCM_PORT)
                .setHost(GCM_SERVER)
                .setCompressionEnabled(false)
                .setConnectTimeout(30000)
                .setSecurityMode(SecurityMode.ifpossible)
                .setSendPresence(false)
                .setSocketFactory(SSLSocketFactory.getDefault())
                .build();

        connection = new XMPPTCPConnection(config);
        connection.connect();

        Roster roster = Roster.getInstanceFor(connection);
        roster.setRosterLoadedAtLogin(false);

        connection.addConnectionListener(new LoggingConnectionListener());

        // Handle incoming packets
        connection.addAsyncStanzaListener(new MyStanzaListener(), new MyStanzaFilter());

        // Log all outgoing packets
        connection.addPacketInterceptor(new MyStanzaInterceptor(), new MyStanzaFilter());

        connection.login(mProjectId + "@gcm.googleapis.com", mApiKey);
        logger.info("logged in: " + mProjectId);

        PingManager pm = PingManager.getInstanceFor(connection);
        pm.setPingInterval(300);
        pm.pingMyServer();
        pm.registerPingFailedListener(new PingFailedListener() {
            @Override
            public void pingFailed() {
                connection.disconnect();
                logger.error("GCM CCS, Ping failed !!");
            }
        });

我运行遇到的问题是没有收到来自 GCM 的任何消息，这些消息是客户端设备在一段时间后发送的。虽然，心跳看起来很正常，即使在那种情况下我也确实从 GCM 得到了乒乓球。这与 SSL 有关吗？

已经处理连接流失情况如下，

        String controlType = (String) jsonObject.get("control_type");
        volatile boolean connectionDraining = false;
        if ("CONNECTION_DRAINING".equals(controlType)) {
            connectionDraining = true;
            try {
                connection.disconnect();
                connect();
                connectionDraining = false;
            } catch (Exception e) {
                logger.error("Error establishing new connection after draining ", e);
            }
        }

Answer 1

我相信您遇到了使用 gcm css 的常见情况，这在文档中不是很明显。如果您查看文档，Control Messages 您将阅读：

Periodically, CCS needs to close down a connection to perform load balancing. Before it closes the connection, CCS sends a CONNECTION_DRAINING message to indicate that the connection is being drained and will be closed soon. "Draining" refers to shutting off the flow of messages coming into a connection, but allowing whatever is already in the pipeline to continue. When you receive a CONNECTION_DRAINING message, you should immediately begin sending messages to another CCS connection, opening a new connection if necessary. You should, however, keep the original connection open and continue receiving messages that may come over the connection (and ACKing them)—CCS handles initiating a connection close when it is ready.

Answer 2

实现了其中一个正在耗尽时的通道队列。

            private Deque<Channel> channels;
            protected void handleControlMessage(Map<String, Object> jsonObject) {
            logger.info("Control message : " + jsonObject);
            String controlType = (String) jsonObject.get("control_type");
            if ("CONNECTION_DRAINING".equals(controlType)) {
                connectionDraining = true;
            } 
        }

发送消息时创建新频道

        public void sendDownstreamMessage(String jsonRequest) {
        Channel channel = channels.peekFirst();
        try {
            if (channel.connectionDraining) {
                synchronized (channels) {
                    channel = channels.peekFirst();
                    if (channel.connectionDraining) {
                        channels.addFirst(connect());
                        channel = channels.peekFirst();
                    }
                }
            }
            channel.send(jsonRequest);
        } catch (Exception e) {
            logger.error("Message not sent. Error in connecting :", e);
        }
    }

GCM 将负责关闭另一个。这解决了问题。

Smack 4.1.0 GCM CCS 在一段时间后停止响应

Smack 4.1.0 GCM CCS stops responding after a while

java

smack

google-cloud-messaging