Fix publishAsync

zbx1425 · Dec 28, 2024 · 6e0e934 · 6e0e934
1 parent e052f77
commit 6e0e934
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/common/src/main/java/cn/zbx1425/worldcomment/data/CommentEntry.java b/common/src/main/java/cn/zbx1425/worldcomment/data/CommentEntry.java
@@ -104,7 +104,7 @@ public void writeBuffer(FriendlyByteBuf dst, boolean toFile) {
     }
 
     public void writeFileStream(FileOutputStream oStream) throws IOException {
-        FriendlyByteBuf buf = new FriendlyByteBuf(Unpooled.buffer(256));
+        FriendlyByteBuf buf = new FriendlyByteBuf(Unpooled.buffer(512));
         writeBuffer(buf, true);
         fileOffset = oStream.getChannel().position();
         oStream.write(buf.array(), 0, buf.writerIndex());
@@ -139,7 +139,7 @@ public JsonObject toJson() {
     }
 
     public ByteBuf toBinaryBuffer() {
-        FriendlyByteBuf dest = new FriendlyByteBuf(Unpooled.buffer(256));
+        FriendlyByteBuf dest = new FriendlyByteBuf(Unpooled.buffer(512));
         dest.writeResourceLocation(level);
         writeBuffer(dest, false);
         return dest;

diff --git a/common/src/main/java/cn/zbx1425/worldcomment/data/sync/RedisMessage.java b/common/src/main/java/cn/zbx1425/worldcomment/data/sync/RedisMessage.java
@@ -41,9 +41,11 @@ public static RedisMessage update(CommentEntry entry) {
     }
 
     public void publishAsync(StatefulRedisConnection<String, ByteBuf> connection) {
-        ByteBuf buffer = Unpooled.buffer(content.readableBytes() + 1 + Long.BYTES);
+        ByteBuf buffer = Unpooled.buffer(content.readableBytes() + 16);
         buffer.writeByte(action.ordinal());
         buffer.writeLong(initiator);
+        buffer.writeInt(content.readableBytes());
+        buffer.writeBytes(content);
         connection.async().publish(COMMAND_CHANNEL, buffer);
     }