DelimiterDataPackageHandler 分隔符数据处理器 即通讯包以特定一个或一组字节分割5. 数据适配器（设计中）
+5. 数据适配器
在我们实际应用中，接收到数据包后（已经过数据处理器）大多情况下是需要将电文转化为应用中的具体数据类型 Class 或 Struct。将原始数据包转化为类或者结构体的过程由我们的数据适配器来实现
数据适配器设计思路如下
+ +SocketDataConverterAttribute 标签约定通讯数据使用那个转换类型进行转换 指定类型需继承 ISocketDataConverter
+ 接口
+ SocketDataPropertyAttribute 标签约定如何转换数据类型 （Property） 属性值[SocketDataConverter(Type = typeof(SocketDataConverter<MockEntity>))]
+class MockEntity
+{
+ [SocketDataProperty(Type = typeof(byte[]), Offset = 0, Length = 5)]
+ public byte[]? Header { get; set; }
+
+ [SocketDataProperty(Type = typeof(byte[]), Offset = 5, Length = 2)]
+ public byte[]? Body { get; set; }
+
+ [SocketDataProperty(Type = typeof(Foo), Offset = 7, Length = 1, ConverterType = typeof(FooConverter), ConverterParameters = ["test"])]
+ public string? Value1 { get; set; }
+}
+
+class FooConverter(string name) : ISocketDataPropertyConverter
+{
+ public object? Convert(ReadOnlyMemory<byte> data)
+ {
+ return new Foo() { Id = data.Span[0], Name = name };
+ }
+}
diff --git a/src/BootstrapBlazor.Server/Components/Samples/Sockets/Adapters.razor b/src/BootstrapBlazor.Server/Components/Samples/Sockets/Adapters.razor
index e1402fcef03..77df9c61d3f 100644
--- a/src/BootstrapBlazor.Server/Components/Samples/Sockets/Adapters.razor
+++ b/src/BootstrapBlazor.Server/Components/Samples/Sockets/Adapters.razor
@@ -41,8 +41,8 @@
本示例服务器端模拟了数据分包即响应数据实际是两次写入所以实际接收端是要通过两次接收才能得到一个完整的响应数据包，可通过 数据适配器 来简化接收逻辑。通过切换下方 是否使用数据适配器 控制开关进行测试查看实际数据接收情况。
private readonly DataPackageAdapter _dataAdapter = new()
{
diff --git a/src/BootstrapBlazor.Server/Components/Samples/Sockets/Adapters.razor.cs b/src/BootstrapBlazor.Server/Components/Samples/Sockets/Adapters.razor.cs
index 9125c8f7978..b8871f39141 100644
--- a/src/BootstrapBlazor.Server/Components/Samples/Sockets/Adapters.razor.cs
+++ b/src/BootstrapBlazor.Server/Components/Samples/Sockets/Adapters.razor.cs
@@ -48,10 +48,10 @@ protected override void OnInitialized()
});
_client.ReceivedCallBack += OnReceivedAsync;
- _dataAdapter.ReceivedCallBack += async Data =>
+ _dataAdapter.ReceivedCallBack += async data =>
{
// 直接处理接收的数据
- await UpdateReceiveLog(Data);
+ await UpdateReceiveLog(data);
};
}
@@ -104,7 +104,7 @@ private async ValueTask OnReceivedAsync(ReadOnlyMemory data)
private async Task UpdateReceiveLog(ReadOnlyMemory data)
{
- var payload = System.Text.Encoding.UTF8.GetString(data.Span);
+ var payload = Encoding.UTF8.GetString(data.Span);
var body = BitConverter.ToString(data.ToArray());
_items.Add(new ConsoleMessageItem
diff --git a/src/BootstrapBlazor.Server/Components/Samples/Sockets/DataEntities.razor b/src/BootstrapBlazor.Server/Components/Samples/Sockets/DataEntities.razor
index e911c693677..abc9669f65a 100644
--- a/src/BootstrapBlazor.Server/Components/Samples/Sockets/DataEntities.razor
+++ b/src/BootstrapBlazor.Server/Components/Samples/Sockets/DataEntities.razor
@@ -9,7 +9,7 @@
Name="Normal" ShowCode="false">
通过 SocketDataConverterAttribute 类标签与 SocketDataPropertyAttribute
属性标签可以将通讯数据自动转化为我们系统中需要的业务实体类，示例如下：
- [SocketDataConverter(Type = typeof(MockEntitySocketDataConverter))]
+ [SocketDataConverter(Type = typeof(SocketDataConverter<MockEntity>))]
class MockEntity
{
[SocketDataProperty(Type = typeof(byte[]), Offset = 0, Length = 5)]
@@ -26,8 +26,7 @@ class MockEntity
}
1. SocketDataConverter 参数说明：
- - Type: 自定义转换器类型，组件库内置了
SocketDataConverterBase 泛型基类，继承后非常方便扩展出自己的转换器，重载
- TryConvertTo 方法调用基类的 Parse 基本就完成了 99% 的工作量，也可以完全自己解析通讯电文到实体类的各个属性上
+ - Type: 自定义转换器类型，组件库内置了
SocketDataConverter 泛型类，建议看一下源码非常方便扩展出自己的转换器
class MockEntitySocketDataConverter : SocketDataConverterBase<MockEntity>
@@ -96,7 +95,7 @@ class MockEntity
SocketDataUInt64LittleEndianConverter 转成 ulong 无符号整形小端读取自定义数据类型转化器示例
- [SocketDataConverter(Type = typeof(MockEntitySocketDataConverter))]
+ [SocketDataConverter(Type = typeof(SocketDataConverter<MockEntity>))]
class MockEntity
{
[SocketDataProperty(Type = typeof(byte[]), Offset = 0, Length = 5)]
@@ -107,9 +106,8 @@ class MockEntity
[SocketDataProperty(Type = typeof(Foo), Offset = 7, Length = 1, ConverterType = typeof(FooConverter), ConverterParameters = ["test"])]
public string? Value1 { get; set; }
-}
-
-class FooConverter(string name) : ISocketDataPropertyConverter
+}
+ class FooConverter(string name) : ISocketDataPropertyConverter
{
public object? Convert(ReadOnlyMemory<byte> data)
{
diff --git a/src/BootstrapBlazor.Server/Locales/zh-CN.json b/src/BootstrapBlazor.Server/Locales/zh-CN.json
index 309e0b2fbd5..61a1c4dba1a 100644
--- a/src/BootstrapBlazor.Server/Locales/zh-CN.json
+++ b/src/BootstrapBlazor.Server/Locales/zh-CN.json
@@ -4839,7 +4839,7 @@
"SocketComponents": "Socket 服务",
"SocketAutoReceive": "自动接收数据",
"SocketManualReceive": "手动接收数据",
- "DataPackageAdapter": "数据处理器",
+ "DataPackageAdapter": "数据适配器",
"SocketAutoConnect": "自动重连",
"SocketDataEntity": "通讯数据转实体类",
"NetworkMonitor": "网络状态 NetworkMonitor"
diff --git a/src/BootstrapBlazor/Services/TcpSocket/DataConverter/SocketDataConverterBase.cs b/src/BootstrapBlazor/Services/TcpSocket/DataConverter/SocketDataConverter.cs
similarity index 75%
rename from src/BootstrapBlazor/Services/TcpSocket/DataConverter/SocketDataConverterBase.cs
rename to src/BootstrapBlazor/Services/TcpSocket/DataConverter/SocketDataConverter.cs
index eaff156bfbc..642cac45870 100644
--- a/src/BootstrapBlazor/Services/TcpSocket/DataConverter/SocketDataConverterBase.cs
+++ b/src/BootstrapBlazor/Services/TcpSocket/DataConverter/SocketDataConverter.cs
@@ -11,7 +11,7 @@ namespace BootstrapBlazor.Components;
/// Provides a base class for converting socket data into a specified entity type.
///
/// The type of entity to convert the socket data into.
-public abstract class SocketDataConverterBase : ISocketDataConverter
+public class SocketDataConverter : ISocketDataConverter
{
///
/// : ISocketDataConverter
///
/// data, [NotNullWhen(true)] out TEntity? entity);
+ public virtual bool TryConvertTo(ReadOnlyMemory data, [NotNullWhen(true)] out TEntity? entity)
+ {
+ var v = CreateEntity();
+ var ret = Parse(data, v);
+ entity = ret ? v : default;
+ return ret;
+ }
+
+ ///
+ /// 创建实体实例方法
+ ///
+ /// ();
///
/// 将字节数据转换为指定实体类型的实例。
diff --git a/src/BootstrapBlazor/Services/TcpSocket/SocketClientOptions.cs b/src/BootstrapBlazor/Services/TcpSocket/SocketClientOptions.cs
index 726c712d5a3..d6d525c4fbf 100644
--- a/src/BootstrapBlazor/Services/TcpSocket/SocketClientOptions.cs
+++ b/src/BootstrapBlazor/Services/TcpSocket/SocketClientOptions.cs
@@ -10,7 +10,7 @@ namespace BootstrapBlazor.Components;
///
/// Represents configuration options for a socket client, including buffer sizes, timeouts, and endpoints.
///
-/// Use this class to configure various settings for a socket client, such as connection timeouts,
+/// Use this class to configure various settings for a socket client, such as connection timeouts,
/// buffer sizes, and local or remote endpoints. These options allow fine-tuning of socket behavior to suit specific
/// networking scenarios.
public class SocketClientOptions
@@ -49,14 +49,14 @@ public class SocketClientOptions
/// Gets or sets the local endpoint for the socket client. Default value is
/// This property specifies the local network endpoint that the socket client will bind to when establishing a connection.
- public IPEndPoint LocalEndPoint { get; set; } = new IPEndPoint(IPAddress.Any, 0);
+ public IPEndPoint LocalEndPoint { get; set; } = new(IPAddress.Any, 0);
///
/// Gets or sets a value indicating whether logging is enabled. Default value is false.
///
public bool EnableLog { get; set; }
-
- ///
+
+ ///
/// Gets or sets a value indicating whether the system should automatically attempt to reconnect after a connection is lost. Default value is false.
///
public bool IsAutoReconnect { get; set; }
diff --git a/test/UnitTest/Services/TcpSocketFactoryTest.cs b/test/UnitTest/Services/TcpSocketFactoryTest.cs
index d9c977c9108..740d723558b 100644
--- a/test/UnitTest/Services/TcpSocketFactoryTest.cs
+++ b/test/UnitTest/Services/TcpSocketFactoryTest.cs
@@ -655,7 +655,7 @@ public async Task TryConvertTo_Ok()
{
DataPackageHandler = new FixLengthDataPackageHandler(29),
};
- client.SetDataPackageAdapter(adapter, new MockEntitySocketDataConverter(), t =>
+ client.SetDataPackageAdapter(adapter, new SocketDataConverter(), t =>
{
entity = t;
tcs.SetResult();
@@ -734,7 +734,7 @@ public async Task TryConvertTo_Ok()
// 测试数据适配器直接调用 TryConvertTo 方法转换数据
var adapter2 = new DataPackageAdapter();
- var result = adapter2.TryConvertTo(data, new MockEntitySocketDataConverter(), out var t);
+ var result = adapter2.TryConvertTo(data, new SocketDataConverter(), out var t);
Assert.True(result);
Assert.NotNull(t);
Assert.Equal([1, 2, 3, 4, 5], entity.Header);
@@ -751,6 +751,10 @@ public async Task TryConvertTo_Ok()
await client.SendAsync(data);
await tcs.Task;
Assert.Null(noConvertEntity);
+
+ var converter = new MockSocketDataConverter();
+ result = converter.TryConvertTo(new byte[] { 0x1, 0x2 }, out t);
+ Assert.False(result);
}
private static TcpListener StartTcpServer(int port, Func handler)
@@ -1137,18 +1141,7 @@ public void SetReceive(bool state)
}
}
- class MockEntitySocketDataConverter : SocketDataConverterBase
- {
- public override bool TryConvertTo(ReadOnlyMemory data, [NotNullWhen(true)] out MockEntity? entity)
- {
- var v = new MockEntity();
- var ret = Parse(data, v);
- entity = ret ? v : null;
- return ret;
- }
- }
-
- [SocketDataConverter(Type = typeof(MockEntitySocketDataConverter))]
+ [SocketDataConverter(Type = typeof(SocketDataConverter))]
class MockEntity
{
[SocketDataProperty(Type = typeof(byte[]), Offset = 0, Length = 5)]
@@ -1199,6 +1192,14 @@ class MockEntity
public string? Value13 { get; set; }
}
+ class MockSocketDataConverter: SocketDataConverter
+ {
+ protected override bool Parse(ReadOnlyMemory data, MockEntity entity)
+ {
+ return false;
+ }
+ }
+
class FooConverter(string name) : ISocketDataPropertyConverter
{
public object? Convert(ReadOnlyMemory data)