From 559890c482f5973f06aafdfec9550fee5ba3c7f2 Mon Sep 17 00:00:00 2001
From: wenxiangchao <wenxiangchao@ihengxin.com.cn>
Date: 星期一, 09 十一月 2026 17:02:15 +0800
Subject: [PATCH] feat: CAN 模拟器 TCP 化 + 多设备并发调试 + 后台生命周期管理
---
Plugin.TestResult/Model/TcpServer.cs | 27 ++++++++++++++++++++-------
1 files changed, 20 insertions(+), 7 deletions(-)
diff --git a/Plugin.TestResult/Model/TcpServer.cs b/Plugin.TestResult/Model/TcpServer.cs
index 056e4ca..2f1fc8c 100644
--- a/Plugin.TestResult/Model/TcpServer.cs
+++ b/Plugin.TestResult/Model/TcpServer.cs
@@ -1,8 +1,6 @@
-锘縰sing ScottPlot.Colormaps;
-using SuperSocket.SocketBase;
+锘縰sing SuperSocket.SocketBase;
using SuperSocket.SocketBase.Protocol;
using System;
-using System.Collections;
using System.Collections.Generic;
using System.Text;
@@ -13,7 +11,6 @@
public override StringRequestInfo Filter(byte[] readBuffer, int offset, int length, bool toBeCopied, out int rest)
{
rest = 0;
- StringBuilder sb = new StringBuilder();
int i = offset;
List<byte> bytes = new List<byte>();
while (i < readBuffer.Length)
@@ -23,17 +20,33 @@
{
break;
}
- sb.Append((char)b);
bytes.Add(b);
}
byte[] arr = bytes.ToArray();
- return new StringRequestInfo(DateTime.Now + "", Encoding.UTF8.GetString(arr), null);//sb.ToString()
+ return new StringRequestInfo(DateTime.Now.ToString("yyyyMMddHHmmssfff"), Encoding.UTF8.GetString(arr), null);//sb.ToString()
}
}
+ public class StringParser : IRequestInfoParser<StringRequestInfo>
+ {
+
+ public StringRequestInfo ParseRequestInfo(string source)
+ {
+ return new StringRequestInfo(DateTime.Now.ToString("yyyyMMddHHmmssfff"), source, null);
+ }
+ }
+
+ //public class TcpServer : AppServer<TcpSession>
+ //{
+ // public TcpServer() : base(new DefaultReceiveFilterFactory<DTReceiveFilter, StringRequestInfo>())
+ // {
+
+ // }
+ //}
+
public class TcpServer : AppServer<TcpSession>
{
- public TcpServer() : base(new DefaultReceiveFilterFactory<DTReceiveFilter, StringRequestInfo>())
+ public TcpServer() : base(new TerminatorReceiveFilterFactory("\n", Encoding.UTF8, new StringParser()))
{
}
--
Gitblit v1.9.1