本文整理汇总了Java中cn.nukkit.network.protocol.DataPacket类的典型用法代码示例。如果您正苦于以下问题：Java DataPacket类的具体用法？Java DataPacket怎么用？Java DataPacket使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
DataPacket类属于cn.nukkit.network.protocol包，在下文中一共展示了DataPacket类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getPacket
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
private DataPacket getPacket(byte[] buffer) {
int start = 0;
if (buffer[0] == (byte) 0xfe) {
start++;
}
DataPacket data = this.network.getPacket(ProtocolInfo.BATCH_PACKET);
if (data == null) {
return null;
}
data.setBuffer(buffer, start);
return data;
}
开发者ID:Rsplwe，项目名称:Nukkit-Java9，代码行数:17，代码来源:RakNetInterface.java
示例2: addSound
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
public void addSound(Sound sound, Player[] players) {
DataPacket[] packets = sound.encode();
if (players == null) {
if (packets != null) {
for (DataPacket packet : packets) {
this.addChunkPacket((int) sound.x >> 4, (int) sound.z >> 4, packet);
}
}
} else {
if (packets != null) {
if (packets.length == 1) {
Server.broadcastPacket(players, packets[0]);
} else {
this.server.batchPackets(players, packets, false);
}
}
}
}
开发者ID:JupiterDevelopmentTeam，项目名称:Jupiter，代码行数:20，代码来源:Level.java
示例3: addParticle
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
public void addParticle(Particle particle, Player[] players) {
DataPacket[] packets = particle.encode();
if (players == null) {
if (packets != null) {
for (DataPacket packet : packets) {
this.addChunkPacket((int) particle.x >> 4, (int) particle.z >> 4, packet);
}
}
} else {
if (packets != null) {
if (packets.length == 1) {
Server.broadcastPacket(players, packets[0]);
} else {
this.server.batchPackets(players, packets, false);
}
}
}
}
开发者ID:JupiterDevelopmentTeam，项目名称:Jupiter，代码行数:20，代码来源:Level.java
示例4: sendChunk
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
public void sendChunk(int x, int z, DataPacket packet) {
if (!this.connected) {
return;
}
this.usedChunks.put(Level.chunkHash(x, z), true);
this.chunkLoadCount++;
this.dataPacket(packet);
if (this.spawned) {
for (Entity entity : this.level.getChunkEntities(x, z).values()) {
if (this != entity && !entity.closed && entity.isAlive()) {
entity.spawnTo(this);
}
}
}
}
开发者ID:JupiterDevelopmentTeam，项目名称:Jupiter，代码行数:19，代码来源:Player.java
示例5: batchDataPacket
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
public boolean batchDataPacket(DataPacket packet) {
if (!this.connected) {
return false;
}
try (Timing timing = Timings.getSendDataPacketTiming(packet)) {
DataPacketSendEvent event = new DataPacketSendEvent(this, packet);
this.server.getPluginManager().callEvent(event);
if (event.isCancelled()) {
timing.stopTiming();
return false;
}
if (!this.batchedPackets.containsKey(packet.getChannel())) {
this.batchedPackets.put(packet.getChannel(), new ArrayList<>());
}
this.batchedPackets.get(packet.getChannel()).add(packet.clone());
}
return true;
}
开发者ID:JupiterDevelopmentTeam，项目名称:Jupiter，代码行数:22，代码来源:Player.java
示例6: dataPacket
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
public int dataPacket(DataPacket packet, boolean needACK) {
if (!this.connected) {
return -1;
}
if(this.printPackets)
this.getServer().getLogger().info(TextFormat.YELLOW + "[SEND] " + TextFormat.WHITE + packet.getName());
try (Timing timing = Timings.getSendDataPacketTiming(packet)) {
DataPacketSendEvent ev = new DataPacketSendEvent(this, packet);
this.server.getPluginManager().callEvent(ev);
if (ev.isCancelled()) {
timing.stopTiming();
return -1;
}
Integer identifier = this.interfaz.putPacket(this, packet, needACK, false);
if (needACK && identifier != null) {
this.needACK.put(identifier.intValue(), false);
timing.stopTiming();
return identifier;
}
}
return 0;
}
开发者ID:JupiterDevelopmentTeam，项目名称:Jupiter，代码行数:27，代码来源:Player.java
示例7: directDataPacket
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
public int directDataPacket(DataPacket packet, boolean needACK) {
if (!this.connected) {
return -1;
}
if(this.printPackets)
this.getServer().getLogger().info(TextFormat.LIGHT_PURPLE + "[SEND-DIRECT] " + TextFormat.WHITE + packet.getClass().getSimpleName());
try (Timing timing = Timings.getSendDataPacketTiming(packet)) {
DataPacketSendEvent ev = new DataPacketSendEvent(this, packet);
this.server.getPluginManager().callEvent(ev);
if (ev.isCancelled()) {
timing.stopTiming();
return -1;
}
Integer identifier = this.interfaz.putPacket(this, packet, needACK, true);
if (needACK && identifier != null) {
this.needACK.put(identifier.intValue(), false);
timing.stopTiming();
return identifier;
}
}
return 0;
}
开发者ID:JupiterDevelopmentTeam，项目名称:Jupiter，代码行数:27，代码来源:Player.java
示例8: checkNetwork
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
public void checkNetwork() {
if (!this.isOnline()) {
return;
}
if (this.nextChunkOrderRun-- <= 0 || this.chunk == null) {
this.orderChunks();
}
if (!this.loadQueue.isEmpty() || !this.spawned) {
this.sendNextChunk();
}
if (!this.batchedPackets.isEmpty()) {
for (int channel : this.batchedPackets.keySet()) {
this.server.batchPackets(new Player[]{this}, batchedPackets.get(channel).stream().toArray(DataPacket[]::new), false);
}
this.batchedPackets = new TreeMap<>();
}
}
开发者ID:JupiterDevelopmentTeam，项目名称:Jupiter，代码行数:22，代码来源:Player.java
示例9: getPacket
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
private DataPacket getPacket(byte[] buffer) {
byte pid = buffer[0];
int start = 1;
if (pid == (byte) 0xfe) {
pid = buffer[1];
start++;
}
DataPacket data = this.network.getPacket(pid);
if (data == null) {
return null;
}
data.setBuffer(buffer, start);
return data;
}
开发者ID:FrontierDevs，项目名称:Jenisys3，代码行数:19，代码来源:RakNetInterface.java
示例10: handleEncapsulated
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
@Override
public void handleEncapsulated(String identifier, EncapsulatedPacket packet, int flags) {
if (this.players.containsKey(identifier)) {
DataPacket pk = null;
try {
if (packet.buffer.length > 0) {
if (packet.buffer[0] == PING_DataPacket.ID) {
PING_DataPacket pingPacket = new PING_DataPacket();
pingPacket.buffer = packet.buffer;
pingPacket.decode();
this.networkLatency.put(identifier, (int) pingPacket.pingID);
return;
}
pk = this.getPacket(packet.buffer);
if (pk != null) {
pk.decode();
this.players.get(identifier).handleDataPacket(pk);
}
}
} catch (Exception e) {
this.server.getLogger().logException(e);
if (Nukkit.DEBUG > 1 && pk != null) {
MainLogger logger = this.server.getLogger();
// if (logger != null) {
logger.debug("Packet " + pk.getClass().getName() + " 0x" + Binary.bytesToHexString(packet.buffer));
//logger.logException(e);
// }
}
if (this.players.containsKey(identifier)) {
this.handler.blockAddress(this.players.get(identifier).getAddress(), 5);
}
}
}
}
开发者ID:Rsplwe，项目名称:Nukkit-Java9，代码行数:38，代码来源:RakNetInterface.java
示例11: encode
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
@Override
public DataPacket[] encode() {
LevelEventPacket pk = new LevelEventPacket();
pk.evid = this.id;
pk.x = (float) this.x;
pk.y = (float) this.y;
pk.z = (float) this.z;
pk.data = (int) this.pitch;
return new DataPacket[]{pk};
}
开发者ID:Rsplwe，项目名称:Nukkit-Java9，代码行数:12，代码来源:LevelEventSound.java
示例12: encode
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
@Override
public DataPacket[] encode() {
LevelSoundEventPacket pk = new LevelSoundEventPacket();
pk.sound = this.type;
pk.x = (float) this.x;
pk.y = (float) this.y;
pk.z = (float) this.z;
pk.extraData = this.extraData;
pk.pitch = this.pitch;
return new DataPacket[]{pk};
}
开发者ID:Rsplwe，项目名称:Nukkit-Java9，代码行数:13，代码来源:LevelSoundEventSound.java
示例13: encode
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
@Override
public DataPacket[] encode() {
LevelEventPacket pk = new LevelEventPacket();
pk.evid = LevelEventPacket.EVENT_PARTICLE_BONEMEAL;
pk.x = (float) this.x;
pk.y = (float) this.y;
pk.z = (float) this.z;
pk.data = 0;
return new DataPacket[]{pk};
}
开发者ID:Rsplwe，项目名称:Nukkit-Java9，代码行数:12，代码来源:BoneMealParticle.java
示例14: encode
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
@Override
public DataPacket[] encode() {
LevelEventPacket pk = new LevelEventPacket();
pk.evid = LevelEventPacket.EVENT_PARTICLE_DESTROY;
pk.x = (float) this.x;
pk.y = (float) this.y;
pk.z = (float) this.z;
pk.data = this.data;
return new DataPacket[]{pk};
}
开发者ID:Rsplwe，项目名称:Nukkit-Java9，代码行数:12，代码来源:DestroyBlockParticle.java
示例15: encode
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
@Override
public DataPacket[] encode() {
LevelEventPacket packet = new LevelEventPacket();
packet.evid = LevelEventPacket.EVENT_PARTICLE_SPAWN;
packet.x = (float) this.x;
packet.y = (float) this.y;
packet.z = (float) this.z;
packet.data = (this.width & 0xff) + ((this.height & 0xff) << 8);
return new DataPacket[]{packet};
}
开发者ID:CoreXDevelopment，项目名称:CoreX，代码行数:12，代码来源:MobSpawnParticle.java
示例16: encode
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
@Override
public DataPacket[] encode() {
LevelEventPacket pk = new LevelEventPacket();
pk.evid = LevelEventPacket.EVENT_PARTICLE_PUNCH_BLOCK;
pk.x = (float) this.x;
pk.y = (float) this.y;
pk.z = (float) this.z;
pk.data = this.data;
return new DataPacket[]{pk};
}
开发者ID:Rsplwe，项目名称:Nukkit-Java9，代码行数:12，代码来源:PunchBlockParticle.java
示例17: encode
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
@Override
public DataPacket[] encode() {
LevelEventPacket pk = new LevelEventPacket();
pk.evid = LevelEventPacket.EVENT_PARTICLE_SPLASH;
pk.x = (float) this.x;
pk.y = (float) this.y;
pk.z = (float) this.z;
pk.data = this.data;
return new DataPacket[]{pk};
}
开发者ID:Rsplwe，项目名称:Nukkit-Java9，代码行数:12，代码来源:SpellParticle.java
示例18: broadcastPacket
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
public static void broadcastPacket(Player[] players, DataPacket packet) {
packet.encode();
packet.isEncoded = true;
for (Player player : players) {
player.dataPacket(packet);
}
if (packet.encapsulatedPacket != null) {
packet.encapsulatedPacket = null;
}
}
开发者ID:Rsplwe，项目名称:Nukkit-Java9，代码行数:13，代码来源:Server.java
示例19: encode
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
@Override
public DataPacket[] encode() {
LevelEventPacket pk = new LevelEventPacket();
pk.evid = (short) (LevelEventPacket.EVENT_ADD_PARTICLE_MASK | this.id);
pk.x = (float) this.x;
pk.y = (float) this.y;
pk.z = (float) this.z;
pk.data = this.data;
return new DataPacket[]{pk};
}
开发者ID:CoreXDevelopment，项目名称:CoreX，代码行数:12，代码来源:GenericParticle.java
示例20: addChunkPacket
import cn.nukkit.network.protocol.DataPacket; //导入依赖的package包/类
public void addChunkPacket(int chunkX, int chunkZ, DataPacket packet) {
Long index = Level.chunkHash(chunkX, chunkZ);
if (!this.chunkPackets.containsKey(index)) {
this.chunkPackets.put(index, new ArrayList<>());
}
this.chunkPackets.get(index).add(packet);
}
开发者ID:JupiterDevelopmentTeam，项目名称:Jupiter，代码行数:8，代码来源:Level.java
注：本文中的cn.nukkit.network.protocol.DataPacket类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论