import org.telegram.mtproto.secure.Entropy; //导入依赖的package包/类
public MTProto(AbsMTProtoState state, MTProtoCallback callback, CallWrapper callWrapper, int connectionsCount) {
    this.INSTANCE_INDEX = instanceIndex.incrementAndGet();
    this.TAG = "MTProto#" + this.INSTANCE_INDEX;
    this.exponentalBackoff = new ExponentalBackoff(this.TAG + "#BackOff");
    this.apiErrorExponentialBackoff = new ApiErrorExponentialBackoff();
    this.state = state;
    this.connectionRate = new TransportRate(state.getAvailableConnections());
    this.callback = callback;
    this.authKey = state.getAuthKey();
    this.authKeyId = substring(SHA1(this.authKey), 12, 8);
    this.protoContext = new MTProtoContext();
    this.desiredConnectionCount = connectionsCount;
    this.session = Entropy.getInstance().generateSeed(8);
    this.tcpListener = new TcpListener();
    this.scheduller = new Scheduller(this, callWrapper);
    this.schedullerThread = new SchedullerThread();
    this.schedullerThread.start();
    this.responseProcessor = new ResponseProcessor();
    this.responseProcessor.start();
    this.connectionFixerThread = new ConnectionFixerThread();
    this.connectionFixerThread.start();
}
 

import org.telegram.mtproto.secure.Entropy; //导入依赖的package包/类
public MTProto(AbsMTProtoState state, MTProtoCallback callback, CallWrapper callWrapper, int connectionsCount) {
    this.INSTANCE_INDEX = instanceIndex.incrementAndGet();
    this.TAG = "MTProto#" + INSTANCE_INDEX;
    this.exponentalBackoff = new ExponentalBackoff(TAG + "#BackOff");
    this.state = state;
    this.connectionRate = new TransportRate(state.getAvailableConnections());
    this.callback = callback;
    this.authKey = state.getAuthKey();
    this.authKeyId = substring(SHA1(authKey), 12, 8);
    this.protoContext = new MTProtoContext();
    this.desiredConnectionCount = connectionsCount;
    this.session = Entropy.generateSeed(8);
    this.tcpListener = new TcpListener();
    this.scheduller = new Scheduller(this, callWrapper);
    this.schedullerThread = new SchedullerThread();
    this.schedullerThread.start();
    this.responseProcessor = new ResponseProcessor();
    this.responseProcessor.start();
    this.connectionFixerThread = new ConnectionFixerThread();
    this.connectionFixerThread.start();
}
 

import org.telegram.mtproto.secure.Entropy; //导入依赖的package包/类
private void internalSchedule() {
    long time = System.nanoTime() / 1000000;
    if (time - this.lastPingTime > PING_INTERVAL_REQUEST) {
        this.lastPingTime = time;
        synchronized (this.contexts) {
            for (TcpContext context : this.contexts) {
                this.scheduller.postMessageDelayed(
                        new MTPingDelayDisconnect(Entropy.getInstance().generateRandomId(), PING_INTERVAL),
                        false, PING_INTERVAL_REQUEST, 0, context.getContextId(), false);
            }
        }
    }
}
 

import org.telegram.mtproto.secure.Entropy; //导入依赖的package包/类
@Override
public void run() {
    setPriority(Thread.MIN_PRIORITY);
    while (!MTProto.this.isClosed) {
        if (Logger.LOG_THREADS) {
            Logger.d(MTProto.this.TAG, "Connection Fixer Iteration");
        }
        synchronized (MTProto.this.contexts) {
            if (MTProto.this.contexts.size() >= MTProto.this.desiredConnectionCount) {
                try {
                    MTProto.this.contexts.wait();
                } catch (InterruptedException e) {
                    return;
                }
            }
        }

        ConnectionType type = MTProto.this.connectionRate.tryConnection();
        TcpContext context = new TcpContext(MTProto.this, type.getHost(), type.getPort(), MTProto.this.tcpListener);
        context.connect();
        if (MTProto.this.isClosed) {
            return;
        }
        MTProto.this.scheduller.postMessageDelayed(new MTPing(Entropy.getInstance().generateRandomId()), false, PING_TIMEOUT, 0, context.getContextId(), false);
        synchronized (MTProto.this.contexts) {
            MTProto.this.contexts.add(context);
            MTProto.this.contextConnectionId.put(context.getContextId(), type.getId());
        }
        synchronized (MTProto.this.scheduller) {
            MTProto.this.scheduller.notifyAll();
        }
    }
}
 

import org.telegram.mtproto.secure.Entropy; //导入依赖的package包/类
private void internalSchedule() {
    long time = System.nanoTime() / 1000000;
    if (time - lastPingTime > PING_INTERVAL_REQUEST) {
        lastPingTime = time;
        synchronized (contexts) {
            for (TcpContext context : contexts) {
                scheduller.postMessageDelayed(
                        new MTPingDelayDisconnect(Entropy.generateRandomId(), PING_INTERVAL),
                        false, PING_INTERVAL_REQUEST, 0, context.getContextId(), false);
            }
        }
    }
}