aunix/wvp-GB28181-pro
1
0
Fork 0
mirror of https://gitee.com/pan648540858/wvp-GB28181-pro.git synced 2026-05-25 14:37:53 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

1078-添加发送分包支持

Browse Source
This commit is contained in:
648540858 2024-04-29 21:24:08 +08:00
parent 91b81ceb7a
commit 9facff13b1
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/com/genersoft/iot/vmp/jt1078/codec/encode/Jt808EncoderCmd.java
View File

@ -52,17 +52,17 @@ public class Jt808EncoderCmd extends MessageToByteEncoder<Cmd> {
Header header = msg.getHeader(); Header header = msg.getHeader();
List<ByteBuf> byteBufList = new LinkedList<>(); List<ByteBuf> byteBufList = new LinkedList<>();
if (encode.readableBytes() > 1000) {
if (encode.readableBytes() > 1024) {
int index = 1; int index = 1;
int total = encode.readableBytes()/1024 + 1; int total = encode.readableBytes()%1000 == 0 ? encode.readableBytes()/1000 : (encode.readableBytes()/1000 + 1);
while (encode.isReadable()) { while (encode.isReadable()) {
ByteBuf byteBuf; ByteBuf byteBuf;
if (index == total) { if (index == total) {
byteBuf = buildMsgByte(header, id, session, packageNo, encode.readRetainedSlice(encode.readableBytes() - index * 1024), index, total); byteBuf = buildMsgByte(header, id, session, packageNo, encode.readRetainedSlice(encode.readableBytes()), index, total);
}else { }else {
byteBuf = buildMsgByte(header, id, session, packageNo, encode.readBytes(1024), index, total); byteBuf = buildMsgByte(header, id, session, packageNo, encode.readRetainedSlice(1000), index, total);
} }
byteBufList.add(byteBuf); byteBufList.add(byteBuf);
index ++; index ++;
} }