chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixed packet write batch

Browse Source
This commit is contained in:
agapple
2019-03-28 21:52:51 +08:00
parent f63ce4ffe6
commit d715ff64b4
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/PacketManager.java
View File

@@ -1,5 +1,6 @@
package com.alibaba.otter.canal.parse.driver.mysql.utils; package com.alibaba.otter.canal.parse.driver.mysql.utils;
import java.io.ByteArrayOutputStream;
import java.io.IOException; import java.io.IOException;
import com.alibaba.otter.canal.parse.driver.mysql.packets.HeaderPacket; 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 { 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 { public static void writeBody(SocketChannel ch, byte[] body) throws IOException {