6-消息确认 ACK

接收到客户端的ACK响应

//ConnectionServer#init()
messageDispatcher.register(Command.ACK, () -> new AckHandler(mPushServer));

public final class AckHandler extends BaseMessageHandler<AckMessage> {
    private final AckTaskQueue ackTaskQueue;
    public AckHandler(MPushServer mPushServer) {
        this.ackTaskQueue = mPushServer.getPushCenter().getAckTaskQueue();
    }
    @Override
    public AckMessage decode(Packet packet, Connection connection) {
        return new AckMessage(packet, connection);
    }
    @Override
    public void handle(AckMessage message) {
        AckTask task = ackTaskQueue.getAndRemove(message.getSessionId());
        if (task == null) {//ack 超时了
            Logs.PUSH.info("receive client ack, but task timeout message={}", message);
            return;
        }
        task.onResponse();//成功收到客户的ACK响应
    }
}

接入服务文章目录:

• 1-心跳 HEARTBEAT
• 2-握手 HANDSHAKE
• 3-用户绑定-解绑 BIND-UNBIND
• 4-快速连接 FAST_CONNECT
• 5-客户端推送 PUSH
• 6-消息确认 ACK
• 7-HTTP代理 HTTP_PROXY