From a836f03a5d1fbfa81e147d09ffdfa87ba3975c13 Mon Sep 17 00:00:00 2001
From: MrShi <1878285526@qq.com>
Date: 星期二, 18 三月 2025 16:45:02 +0800
Subject: [PATCH] 1
---
server/jtt808_parent/jtt808-server/src/test/java/org/yzh/client/JTMessageAdapter.java | 43 +++++++++++++++++++++++++++++++++++++++++++
1 files changed, 43 insertions(+), 0 deletions(-)
diff --git a/server/jtt808_parent/jtt808-server/src/test/java/org/yzh/client/JTMessageAdapter.java b/server/jtt808_parent/jtt808-server/src/test/java/org/yzh/client/JTMessageAdapter.java
new file mode 100644
index 0000000..1651ab1
--- /dev/null
+++ b/server/jtt808_parent/jtt808-server/src/test/java/org/yzh/client/JTMessageAdapter.java
@@ -0,0 +1,43 @@
+package org.yzh.client;
+
+import io.github.yezhihao.netmc.codec.MessageDecoder;
+import io.github.yezhihao.netmc.codec.MessageEncoder;
+import io.github.yezhihao.netmc.session.Session;
+import io.netty.buffer.ByteBuf;
+import org.yzh.protocol.basics.JTMessage;
+import org.yzh.protocol.codec.JTMessageDecoder;
+import org.yzh.protocol.codec.JTMessageEncoder;
+
+import java.nio.ByteBuffer;
+import java.nio.ByteOrder;
+
+/**
+ * JT娑堟伅缂栬В鐮侀�傞厤鍣�
+ * @author yezhihao
+ * https://gitee.com/yezhihao/jt808-server
+ */
+public class JTMessageAdapter implements MessageEncoder<JTMessage>, MessageDecoder<JTMessage> {
+
+ private JTMessageEncoder messageEncoder;
+
+ private JTMessageDecoder messageDecoder;
+
+ public JTMessageAdapter(JTMessageEncoder messageEncoder, JTMessageDecoder messageDecoder) {
+ this.messageEncoder = messageEncoder;
+ this.messageDecoder = messageDecoder;
+ }
+
+ public ByteBuf encode(JTMessage message, Session session) {
+ ByteBuf output = messageEncoder.encode(message);
+ return output;
+ }
+
+ @Override
+ public JTMessage decode(ByteBuf input, Session session) {
+ JTMessage message = messageDecoder.decode(input);
+ return message;
+ }
+
+ public static void main(String[] args) {
+ }
+}
--
Gitblit v1.9.3