Repo-Mirror/craft-engine
9
0
Fork 0
mirror of https://github.com/Xiao-MoMi/craft-engine.git synced 2025-12-28 19:39:11 +00:00
Code Issues Releases Activity

perf(bukkit): 优化mod玩家注册频道时的区块矫正数据发送逻辑

Browse Source
This commit is contained in:
jhqwqmc
2025-03-25 18:53:24 +08:00
parent eb5fb0de01
commit 9e23468589
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
bukkit/src/main/java/net/momirealms/craftengine/bukkit/plugin/network/BukkitNetworkManager.java
View File

@@ -22,6 +22,7 @@ import net.momirealms.craftengine.core.util.VersionHelper;
import net.momirealms.craftengine.core.world.ChunkPos;
import org.bukkit.Bukkit;
import org.bukkit.Chunk;
import org.bukkit.World;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.EventPriority;
@@ -175,31 +176,35 @@ public class BukkitNetworkManager implements NetworkManager, Listener {
int blockRegistrySize = RegistryUtils.currentBlockRegistrySize();
byte[] payload = ("cp:" + blockRegistrySize).getBytes(StandardCharsets.UTF_8);
player.sendPluginMessage(plugin.bootstrap(), MOD_CHANNEL, payload);
sendClientModPlayerChunk(player, user);
plugin.scheduler().async().execute(() -> sendClientModPlayerChunk(player, user));
}
private static void sendClientModPlayerChunk(Player player, NetWorkUser user) {
private void sendClientModPlayerChunk(Player player, NetWorkUser user) {
try {
Chunk centerChunk = player.getLocation().getChunk();
World world = centerChunk.getWorld();
int centerX = centerChunk.getX();
int centerZ = centerChunk.getZ();
List<Object> packets = new ArrayList<>();
for (int xOffset = -1; xOffset <= 1; xOffset++) {
for (int zOffset = -1; zOffset <= 1; zOffset++) {
int targetX = centerX + xOffset;
int targetZ = centerZ + zOffset;
Chunk chunk = centerChunk.getWorld().getChunkAt(targetX, targetZ);
if (!world.isChunkLoaded(targetX, targetZ)) continue;
Chunk chunk = world.getChunkAt(targetX, targetZ);
Object worldServer = Reflections.field$CraftChunk$worldServer.get(chunk);
Object chunkSource = Reflections.field$ServerLevel$chunkSource.get(worldServer);
Object levelChunk = Reflections.method$ServerChunkCache$getChunkAtIfLoadedMainThread.invoke(chunkSource, chunk.getX(), chunk.getZ());
Object levelChunk = Reflections.method$ServerChunkCache$getChunkAtIfLoadedMainThread.invoke(chunkSource, targetX, targetZ);
if (levelChunk == null) continue;
long chunkKey = ChunkPos.asLong(chunk.getX(), chunk.getZ());
long chunkKey = ChunkPos.asLong(targetX, targetZ);
Object chunkHolder = Reflections.method$ServerChunkCache$getVisibleChunkIfPresent.invoke(chunkSource, chunkKey);
if (chunkHolder == null) continue;
Object lightEngine = Reflections.field$ChunkHolder$lightEngine.get(chunkHolder);
Object packet = Reflections.constructor$ClientboundLevelChunkWithLightPacket.newInstance(levelChunk, lightEngine, null, null);
user.sendPacket(packet, false);
packets.add(packet);
}
}
sendPackets(user, packets);
} catch (Exception e) {
CraftEngine.instance().logger().warn("Failed to send chunk correction packet", e);
}