import net.dv8tion.jda.core.requests.SessionReconnectQueue; //导入依赖的package包/类
@Override
public void login(String token, ShardInfo shardInfo, SessionReconnectQueue reconnectQueue) throws LoginException, RateLimitedException {
    setStatus(Status.LOGGING_IN);
    if(token == null || token.isEmpty()) throw new LoginException("Provided token was null or empty!");

    setToken(token);
    verifyToken();
    this.shardInfo = shardInfo;
    JDAImpl.LOG.info("Login Successful!");

    client = new ClientWebSocketClient(this, reconnectQueue, gatewayClient);
    client.send(new JSONObject()
            .put("d", presence.getFullPresence())
            .put("op", WebSocketCode.PRESENCE).toString());

    if(shutdownHook != null) {
        Runtime.getRuntime().addShutdownHook(shutdownHook);
    }
}
 

import net.dv8tion.jda.core.requests.SessionReconnectQueue; //导入依赖的package包/类
public ClientWebSocketClient(JDAImpl api, SessionReconnectQueue reconnectQueue, GatewayClient gatewayClient) {
    super(api, reconnectQueue);
    this.gatewayClient = gatewayClient;
    try {
        gatewayClient.register(this);
    } catch(IOException e) {
        throw new UncheckedIOException(e);
    }
    ratelimitThread.interrupt();
    setupSendThread();
}
 

import net.dv8tion.jda.core.requests.SessionReconnectQueue; //导入依赖的package包/类
@Override
public void login(String token, ShardInfo shardInfo, SessionReconnectQueue reconnectQueue) throws LoginException, RateLimitedException {
    setStatus(Status.LOGGING_IN);
    if(token == null || token.isEmpty()) throw new LoginException("Provided token was null or empty!");

    setToken(token);
    verifyToken();
    this.shardInfo = shardInfo;
    JDAImpl.LOG.info("Login Successful!");

    client = new ServerWebSocketClient(this, reconnectQueue, gatewayServer);

    JSONObject cachedPresence = gatewayServer.cachedPresence;
    if(cachedPresence != null) {
        JSONObject game = cachedPresence.optJSONObject("game");
        if(game != null) {
            getPresence().setPresence(
                    OnlineStatus.fromKey(cachedPresence.getString("status")),
                    Game.of(game.getString("name"), game.optString("url")),
                    cachedPresence.getBoolean("afk")
            );
        } else {
            getPresence().setPresence(
                    OnlineStatus.fromKey(cachedPresence.getString("status")),
                    null,
                    cachedPresence.getBoolean("afk")
            );
        }
        gatewayServer.cachedPresence = null;
    }

    if(shutdownHook != null) {
        Runtime.getRuntime().addShutdownHook(shutdownHook);
    }
}
 

import net.dv8tion.jda.core.requests.SessionReconnectQueue; //导入依赖的package包/类
public static void main(String[] args) throws LoginException, RateLimitedException {
    new JDABuilder(AccountType.BOT)
            .addEventListener(new EvalCommand()) // Register the author-exclusive eval command
            .addEventListener(new MusicCommand()) // Register all music related subcommands
            .setToken(Info.TOKEN) // Set the Authentication Token
            .setBulkDeleteSplittingEnabled(false) // Performance reasons
            .setEventManager(new ThreadedEventManager()) // Allow for simultaneous command processing
            .setReconnectQueue(new SessionReconnectQueue()) // Let JDA handle reconnects
            .buildAsync(); // Finally establish a connection to Discord's servers!
}
 

import net.dv8tion.jda.core.requests.SessionReconnectQueue; //导入依赖的package包/类
public ServerWebSocketClient(JDAImpl api, SessionReconnectQueue reconnectQueue, GatewayServer gatewayServer) {
    super(api, reconnectQueue);
    this.gatewayServer = gatewayServer;
    gatewayServer.register(this);
}
 

import net.dv8tion.jda.core.requests.SessionReconnectQueue; //导入依赖的package包/类
public static void main(String[] args) throws LoginException, InterruptedException, RateLimitedException {
    String token = GSONUtils.getConfig().getToken();
    if (GSONUtils.getConfig().getDcoinToken() != null) {
        discoin = new Discoin4J(GSONUtils.getConfig().getDcoinToken());
        discoinManager = new DiscoinManager();
    }

    if (shards == 0) {
        System.out.println("You must enter the number of shards in your \"config.json\"! Please go back and specify it before launching.");
        System.exit(0);
    }

    if (token == null) {
        System.out.println("Token was not specified in \"config.json\"! Please go back and specify one before launching!");
    } else {
        JDABuilder builder = new JDABuilder(AccountType.BOT).setToken(token)
                .setReconnectQueue(new SessionReconnectQueue())
                .addEventListener(new Listener())
                .addEventListener(waiter)
                .addEventListener(gamesManager);

        if (shards > 1) {
            for (int i = 0; i < shards; i++) {
                jdas[i] = builder.useSharding(i, shards).buildAsync();
            }
        } else {
            jdas[0] = builder.buildAsync();
        }
        for (JDA jda : jdas) {
            CommandRegistry.getForClient(jda).registerAll(Help.help, Purge.purge, Say.say, Granddad.granddad, TicketCommand.ticket, Lenny.lenny,
                    Shrug.shrug, Credits.credits, Avatar.avatar, TagCommand.tagCommand, AddAllowedUser.addAllowedUser, AddGame.addGame, Triggered.triggered, Gril.gril,
                    Salt.salt, JustRight.justRight, GetInvite.getInvite, Ban.ban, Kick.kick, Prefix.prefix, AutoRole.autoRole, Announce.announce,
                    Broadcast.broadcast, Stats.stats, Google.google, Lmgtfy.lmgtfy, Bots.bots, Shutdown.shutdown, UrbanDictionary.UrbanDictionary,
                    Emojify.emojify, AllowedUsers.allowedUsers, CoinFlip.coinFlip, Roll.roll, ListServers.listServers, Strawpoll.strawpoll, Poll.poll,
                    Poll.vote, AddRole.addRole, RemoveRole.removeRole, Quote.quote, Support.support, Eval.eval, Byemom.byemom, Queue.queue,
                    Skip.skip, Playlist.playlist, Song.song, Stop.stop, Volume.volume, Host.host, Music.music, Pause.pause, VoteSkip.voteskip, Repeat.repeat, Invite.invite,
                    Erase.erase, Johnny.johnny, LongLive.longlive, BlockUser.blockUser, DELET.delet, AddPatron.addPatron, RemovePatron.removePatron,
                    Poosy.poosy, EightBall.eightBall, Pick.pick, GameCommand.game, ProfileCommand.profile, FullWidth.fullwidth, ShopCommand.shop, MyPlaylist.myPlaylist,
                    Rip.rip, RateWaifu.rateWaifu, Gabe.gabe, Changelog.changelog, LotteryCommand.lottery, Shuffle.shuffle, Balance.balanace, SlotMachine.slotMachine,
                    Pay.pay);
        }

        for (Action action : Action.values()) {
            List<String> responses = GSONUtils.getResponder(action).getResponses();
            KekBot.responses.put(action, responses);
        }
    }
}
 

import net.dv8tion.jda.core.requests.SessionReconnectQueue; //导入依赖的package包/类
public ProvidingSessionController(SessionReconnectQueue queue, ShardedRateLimiter rateLimiter)
{
    this.queue = queue;
    this.rateLimiter = rateLimiter;
}
 

import net.dv8tion.jda.core.requests.SessionReconnectQueue; //导入依赖的package包/类
/**
 * This method creates the internal {@link net.dv8tion.jda.core.requests.SessionReconnectQueue SessionReconnectQueue}.
 * It is intended as a hook for custom implementations to create their own queue.
 *
 * <p><b>NOTE: The default implementation will add reconnects to the same queue as connects so they don't interfere with each other
 * (they share the same rate limit). If you override this you need to take care of it yourself.</b>
 *
 * @return A new ScheduledExecutorService
 *
 * @deprecated
 *         Use {@link net.dv8tion.jda.core.utils.SessionController SessionController} directly instead
 */
@Deprecated
protected SessionReconnectQueue createReconnectQueue()
{
    return new ForwardingSessionReconnectQueue(
        jda -> queue.add(jda.getShardInfo().getShardId()),
        jda -> queue.remove(jda.getShardInfo().getShardId()));
}
 

import net.dv8tion.jda.core.requests.SessionReconnectQueue; //导入依赖的package包/类
/**
 * Sets the queue that will be used to reconnect sessions.
 * <br>This will ensure that sessions do not reconnect at the same time!
 *
 * <p><b>It is required to use the same instance of this queue for all JDA sessions of the same bot account!
 * <br>Not doing that may result in <u>API spam and finally an IP ban.</u></b>
 *
 * @param  queue
 *         {@link net.dv8tion.jda.core.requests.SessionReconnectQueue SessionReconnectQueue} to use
 *
 * @return The JDABuilder instance. Useful for chaining.
 *
 * @deprecated
 *         This system has been completely moved into a new central object {@link net.dv8tion.jda.core.utils.SessionController SessionController}.
 *         <br>Use {@link #setSessionController(SessionController)} instead!
 */
@Deprecated
public JDABuilder setReconnectQueue(SessionReconnectQueue queue)
{
    this.reconnectQueue = queue;
    return this;
}