From d715ff64b41c90b26932233062eef016aa2c6441 Mon Sep 17 00:00:00 2001 From: agapple Date: Thu, 28 Mar 2019 21:52:51 +0800 Subject: [PATCH] fixed packet write batch --- .../canal/parse/driver/mysql/utils/PacketManager.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/PacketManager.java b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/PacketManager.java index 7841205c..a6d048ee 100644 --- a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/PacketManager.java +++ b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/PacketManager.java @@ -1,5 +1,6 @@ package com.alibaba.otter.canal.parse.driver.mysql.utils; +import java.io.ByteArrayOutputStream; import java.io.IOException; import com.alibaba.otter.canal.parse.driver.mysql.packets.HeaderPacket; @@ -28,7 +29,11 @@ public abstract class PacketManager { } public static void writePkg(SocketChannel ch, byte[]... srcs) throws IOException { - ch.write(srcs); + ByteArrayOutputStream out = new ByteArrayOutputStream(); + for (byte[] src : srcs) { + out.write(src); + } + ch.write(out.toByteArray()); } public static void writeBody(SocketChannel ch, byte[] body) throws IOException {