import org.spongepowered.api.network.PlayerConnection; //导入依赖的package包/类
public boolean handlePacket(PlayerConnection player, T packet) {
    if(handlers == null) return false;

    for(PacketHandler<T> handler : handlers) {
        try {
            if(handler.handle(player, packet)) {
                return true;
            }
        } catch(Exception ex) {
            // If a plugin does something that throws an exception in handle, we'll catch it
            ex.printStackTrace();
        }
    }

    return false;
}
 

import org.spongepowered.api.network.PlayerConnection; //导入依赖的package包/类
@Listener
public void onServerAboutToStart(GameAboutToStartServerEvent event) {

    // register plugin message channel
    channel = game.getChannelRegistrar().createRawChannel(this, BridgeProtocolConstants.CHANNEL);
    channel.addListener(Platform.Type.SERVER, (data, connection, side) -> {
        if (connection instanceof PlayerConnection) {
            Player player = ((PlayerConnection) connection).getPlayer();
            DataInput input = new DataInputStream(new ChannelBufInputStream(data));
            try {
                bridge.onMessage(player, input);
            } catch (Throwable e) {
                rlExecutor.execute(() -> {
                    logger.error("Unexpected error", e);
                });
            }
        }
    });

    // init bridge
    initBridge();
}
 

import org.spongepowered.api.network.PlayerConnection; //导入依赖的package包/类
@Override
public void sendPacket(Packet packet, PlayerConnection connection) {
    if(connection instanceof NetworkManager) {
        ((NetworkManager)connection).sendPacket((net.minecraft.network.Packet)packet);
    } else if(connection instanceof NetHandlerPlayServer) {
        ((NetHandlerPlayServer)connection).sendPacket((net.minecraft.network.Packet)packet);
    } else {
        sendPacket(packet, connection.getPlayer());
    }
}
 

import org.spongepowered.api.network.PlayerConnection; //导入依赖的package包/类
@Override
public void handleMessage(Message message, RemoteConnection connection, Type side) {
	if(!(connection instanceof PlayerConnection)){
		CustomSkinServer.logger.warning("[CustomSkinServer] RemoteConnection not instanceof PlayerConnection.");
		return;
	}
	PlayerConnection pc=(PlayerConnection) connection;
	Player p=pc.getPlayer();
	CustomSkinServer.onPluginMessage(new SpongePlayer(p),message.text);
}
 

import org.spongepowered.api.network.PlayerConnection; //导入依赖的package包/类
@Nullable
@Override
public SpongeConnection apply(PlayerConnection input) {
    try {
        ChannelPipeline pipeline = ((Channel) channel.get(netManager.get(input))).pipeline();
        SpongeConnectionEventListener handler = pipeline.get(SpongeConnectionEventListener.class);
        return handler == null ? null : handler.getConnection();
    } catch (IllegalAccessException e) {
        throw new RuntimeException(e);
    }
}
 

import org.spongepowered.api.network.PlayerConnection; //导入依赖的package包/类
@Override
public PlayerConnection getConnection() {
	return this.player.getConnection();
}
 

import org.spongepowered.api.network.PlayerConnection; //导入依赖的package包/类
public static SpongeConnection get(PlayerConnection playerConnection) {
    return spongeConnectionAccessor.apply(playerConnection);
}
 

import org.spongepowered.api.network.PlayerConnection; //导入依赖的package包/类
/**
 * Handles an incoming/outgoing packet
 *
 * @param con The connection sending/receiving the packet
 * @param packet The packet
 * @return Whether the packet should not be sent
 */
boolean handle(PlayerConnection con, P packet);
 

import org.spongepowered.api.network.PlayerConnection; //导入依赖的package包/类
/**
 * Sends a packet to a connection
 *
 * @param packet The packet
 * @param connection The connection
 */
void sendPacket(Packet packet, PlayerConnection connection);