marmot-z / canal-nodejs Goto Github PK

Connect cancal server occur error RangeError: index out of range: 13548 + 1 > 13548
at indexOutOfRange (D:\Download\canal-nodejs-master\node_modules\protobufjs\src\reader.js:13:12)
at BufferReader.skip (D:\Download\canal-nodejs-master\node_modules\protobufjs\src\reader.js:344:23)
at BufferReader.Reader.skipType (D:\Download\canal-nodejs-master\node_modules\protobufjs\src\reader.js:358:18)
at Type.Messages$decode [as decode] (eval at Codegen (D:\Download\canal-nodejs-master\node_modules@protobufjs\codegen\index.js:50:33), :19:5)
at Function.decode (D:\Download\canal-nodejs-master\src\proto-util.js:55:28)
at Function.deserializer (D:\Download\canal-nodejs-master\src\canal-message-deserializer.js:15:42)
at D:\Download\canal-nodejs-master\src\simple-canal-connector.js:170:66
at processTicksAndRejections (internal/process/task_queues.js:93:5)

canal.log文件
/192.168.8.80:64695 => /192.168.8.83:11111], exception=java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:192)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379)
at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:322)
at org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:281)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:201)
at org.jboss.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.java:46)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
nodejs 控制台

buffer.js:364
throw new ERR_INVALID_OPT_VALUE.RangeError('size', size);
^

RangeError [ERR_INVALID_OPT_VALUE]: The value "-471682768" is invalid for option "size"
at Function.alloc (buffer.js:373:3)
at PSocket.extractData (D:\Download\canal-nodejs-master\src\psocket.js:78:23)
at Object.resolve (D:\Download\canal-nodejs-master\src\psocket.js:29:52)
at PSocket.onReceiveData (D:\Download\canal-nodejs-master\src\psocket.js:61:23)
at Socket.emit (events.js:315:20)
at addChunk (internal/streams/readable.js:309:12)
at readableAddChunk (internal/streams/readable.js:284:9)
at Socket.Readable.push (internal/streams/readable.js:223:10)
at TCP.onStreamRead (internal/stream_base_commons.js:188:23) {
code: 'ERR_INVALID_OPT_VALUE'
}

Connect cancal server occur error RangeError: index out of range: 4481 + 1 > 4481
at indexOutOfRange (D:\Download\canal-nodejs-master\node_modules\protobufjs\src\reader.js:13:12)
at BufferReader.skip (D:\Download\canal-nodejs-master\node_modules\protobufjs\src\reader.js:344:23)
at BufferReader.Reader.skipType (D:\Download\canal-nodejs-master\node_modules\protobufjs\src\reader.js:358:18)
at Type.Messages$decode [as decode] (eval at Codegen (D:\Download\canal-nodejs-master\node_modules@protobufjs\codegen\index.js:50:33), :19:5)
at Function.decode (D:\Download\canal-nodejs-master\src\proto-util.js:55:28)
at Function.deserializer (D:\Download\canal-nodejs-master\src\canal-message-deserializer.js:15:42)
at D:\Download\canal-nodejs-master\src\simple-canal-connector.js:170:66
at processTicksAndRejections (internal/process/task_queues.js:93:5)

检查psocket.ts文件_extractData方法中let bodySize: number = this.readHeader.readInt32BE(0);其中bodySize返回为负数-443709664导致buffer.alloc错误。
以下是报错：
RangeError [ERR_INVALID_ARG_VALUE]: The argument 'size' is invalid. Received -443709664
at Function.alloc (node:buffer:372:3)
at PSocket._extractData (C:\Users\Administrator\Desktop\canal-nodejs-master\src\psocket.ts:144:35)
at Handler.resolve (C:\Users\Administrator\Desktop\canal-nodejs-master\src\psocket.ts:65:62)
at PSocket._onReceiveData (C:\Users\Administrator\Desktop\canal-nodejs-master\src\psocket.ts:111:27)
at Socket.emit (node:events:513:28)
at Socket.emit (node:domain:489:12)
at addChunk (node:internal/streams/readable:324:12)
at readableAddChunk (node:internal/streams/readable:297:9)
at Socket.Readable.push (node:internal/streams/readable:234:10)
at TCP.onStreamRead (node:internal/stream_base_commons:190:23) {
code: 'ERR_INVALID_ARG_VALUE'
}