import com.comphenix.protocol.Packets; //导入依赖的package包/类
@Override
public PacketContainer createLoginPacket() {
    PacketContainer container = createPacket(Packets.Server.LOGIN);
    World world = Bukkit.getWorlds().get(0);
    Class<Object> gameModeCls = getGameModeCls();
    Object gameMode = getGameMode(gameModeCls);

    container.getIntegers()
            .write(0, NMSUtils.getNextEntityCount())
            .write(1, world.getEnvironment().getId());
    container.getWorldTypeModifier().write(0, world.getWorldType());
    container.getSpecificModifier(gameModeCls).write(0, gameMode);
    container.getBooleans().write(0, Bukkit.getServer().isHardcore());
    container.getBytes()
            .write(0, (byte) world.getDifficulty().getValue())
            .write(1, (byte) world.getMaxHeight())
            .write(2, (byte) Bukkit.getMaxPlayers());

    return container;
}
 

import com.comphenix.protocol.Packets; //导入依赖的package包/类
@Override
public void onPacketReceiving(PacketEvent event) {
    Player player = event.getPlayer();
    int id = event.getPacketID();
    holder.holdIfPresent(event);
    if (id == Packets.Client.HANDSHAKE) {
        cacher.caching(player);
    }
    if (id == Packets.Client.TRANSACTION) {
        PacketContainer packet = event.getPacket();
        int pId = packet.getShorts().read(0);
        if (pId == Short.MIN_VALUE) {
            latch.countDown(player);
        }
    }
}
 

import com.comphenix.protocol.Packets; //导入依赖的package包/类
@EventHandler
public void onAsync(AsyncPlayerPreLoginEvent event) {
    cacher.removeAndGet(event.getAddress()).ifPresent(player -> {
        sendPacket(player, factory.createLoginPacket());
        Bukkit.getScheduler().runTask(plugin, () -> ignore.addIgnore(player, Packets.Server.LOGIN));
        holder.addPlayer(player);

        sendPacket(player, factory.createTransactionPacket(0, Short.MIN_VALUE, false));
        if (latch.await(player)) {
            holder.flush(player);
            players.add(player.getAddress().getAddress().toString());
        } else {
            event.disallow(AsyncPlayerPreLoginEvent.Result.KICK_OTHER, Lang.BOT_DETECT.withSpacingPrefix());
            counter.incrementAndGet();
        }
        holder.release(player);
        latch.release(player);
        cacher.release(player);
    });
}
 

import com.comphenix.protocol.Packets; //导入依赖的package包/类
private void addListeners() {
    // Arm Animation
    protocolManager.addPacketListener(new PacketAdapter(plugin,
            ConnectionSide.CLIENT_SIDE,
            ListenerPriority.NORMAL,
            Packets.Client.ARM_ANIMATION) {

        @Override
        public void onPacketReceiving(PacketEvent event) {
            if (event.getPacketID() == Packets.Client.ARM_ANIMATION) {
                PacketContainer packet = event.getPacket();
                //System.out.println("Arm animation from "+packet.getIntegers().read(0));
            }
        }
    });
}
 

import com.comphenix.protocol.Packets; //导入依赖的package包/类
@Override
public PacketContainer createTransactionPacket(int id, int value, boolean bool) {
    PacketContainer container = createPacket(Packets.Server.TRANSACTION);
    container.getIntegers().write(0, id);
    container.getShorts().write(0, (short) value);
    container.getBooleans().write(0, bool);

    return container;
}
 

import com.comphenix.protocol.Packets; //导入依赖的package包/类
protected AbstractPacket(PacketContainer handle, int packetID)
{
	if (handle == null)
		throw new IllegalArgumentException("Packet handle cannot be NULL.");
	if (handle.getID() != packetID) {
		throw new IllegalArgumentException(handle.getHandle() + " is not a packet " + 
				Packets.getDeclaredName(packetID) + "(" + packetID + ")");
	}
	this.handle = handle;
}
 

import com.comphenix.protocol.Packets; //导入依赖的package包/类
public List<PacketContainer> createPackets(int entityId) {
	List<PacketContainer> packetList = new ArrayList<PacketContainer>();
	for (int i = 0; i < 5; i++) {
		ItemStack stack = this.getSlot(i);

		PacketContainer packet = FakeMobsPlugin.getPlugin().getProtocolManager().createPacket(Packets.Server.ENTITY_EQUIPMENT);
		packet.getIntegers().write(0, entityId);
		packet.getIntegers().write(1, i);
		packet.getItemModifier().write(0, stack);

		packetList.add(packet);
	}
	return packetList;
}