From bde4b7985df15a118ae7cf4ba86f400eafe63dd1 Mon Sep 17 00:00:00 2001
From: eson <eson.hsm@nonolive.com>
Date: Wed, 8 Jun 2022 18:08:33 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E8=BF=9B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../java/com/yuandian/dataflow/master/Header.java | 13 +++++++++++++
.../dataflow/proto/decode/BacktrackingFlow.java | 3 ---
2 files changed, 13 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/yuandian/dataflow/master/Header.java b/src/main/java/com/yuandian/dataflow/master/Header.java
index 2f2b9f6..a1cdb8c 100644
--- a/src/main/java/com/yuandian/dataflow/master/Header.java
+++ b/src/main/java/com/yuandian/dataflow/master/Header.java
@@ -47,5 +47,18 @@ public class Header {
log.error("{}", pheader);
log.error("{}",PacketBase.createPacketBase(pheader));
+
+ //60010流需要解压
+ byte[] unzipbodydata = null;
+ if (pheader.getTableID() == 20) {
+
+ pheader.parseNextHeader_60010(in);
+
+ byte[] zipbodydata = new byte[packetHeader.getMsg_len()];
+ readTillLength(zipbodydata, packetHeader.getMsg_len());
+ unzipbodydata = ZlibUtil.Inflate(zipbodydata);
+
+ }
+
}
}
diff --git a/src/main/java/com/yuandian/dataflow/proto/decode/BacktrackingFlow.java b/src/main/java/com/yuandian/dataflow/proto/decode/BacktrackingFlow.java
index 83aa13d..6cf81ba 100644
--- a/src/main/java/com/yuandian/dataflow/proto/decode/BacktrackingFlow.java
+++ b/src/main/java/com/yuandian/dataflow/proto/decode/BacktrackingFlow.java
@@ -29,9 +29,6 @@ public class BacktrackingFlow extends PacketBase{
private long appGroupId;// 4 app组ID
private long mplsLabel;// 4
-
-
-
@Override
public PacketBase Parse(PacketHeader header,ByteBuffer data) throws Exception {