94 lines
3.5 KiB
C#
94 lines
3.5 KiB
C#
using IpcLibrary.Core;
|
||
using IpcLibrary.Core.Exceptions;
|
||
using IPCLibrary.Serialization;
|
||
|
||
namespace IpcLibrary.Serialization {
|
||
/// <summary>
|
||
/// 复合序列化器 - 根据数据类型选择最适合的序列化方式
|
||
/// </summary>
|
||
public class CompositeMessageSerializer : IMessageSerializer {
|
||
private readonly JsonMessageSerializer _jsonSerializer;
|
||
private readonly BinaryMessageSerializer _binarySerializer;
|
||
|
||
public CompositeMessageSerializer() {
|
||
_jsonSerializer = new JsonMessageSerializer();
|
||
_binarySerializer = new BinaryMessageSerializer();
|
||
}
|
||
|
||
public byte[] Serialize(object obj) {
|
||
if (obj == null)
|
||
return new byte[0];
|
||
|
||
// 对于简单类型和已知类型使用JSON，复杂类型使用二进制
|
||
if (IsJsonSerializable(obj.GetType())) {
|
||
var jsonData = _jsonSerializer.Serialize(obj);
|
||
var result = new byte[jsonData.Length + 1];
|
||
result[0] = 1; // JSON标识
|
||
Array.Copy(jsonData, 0, result, 1, jsonData.Length);
|
||
return result;
|
||
} else {
|
||
var binaryData = _binarySerializer.Serialize(obj);
|
||
var result = new byte[binaryData.Length + 1];
|
||
result[0] = 2; // Binary标识
|
||
Array.Copy(binaryData, 0, result, 1, binaryData.Length);
|
||
return result;
|
||
}
|
||
}
|
||
|
||
public T Deserialize<T>(byte[] data) {
|
||
if (data.Length == 0)
|
||
return default(T);
|
||
|
||
var serializationType = data[0];
|
||
var actualData = new byte[data.Length - 1];
|
||
Array.Copy(data, 1, actualData, 0, actualData.Length);
|
||
|
||
switch (serializationType) {
|
||
case 1: // JSON
|
||
return _jsonSerializer.Deserialize<T>(actualData);
|
||
case 2: // Binary
|
||
return _binarySerializer.Deserialize<T>(actualData);
|
||
default:
|
||
throw new IPCException($"未知的序列化类型: {serializationType}");
|
||
}
|
||
}
|
||
|
||
public object Deserialize(byte[] data, Type type) {
|
||
if (data.Length == 0)
|
||
return null;
|
||
|
||
var serializationType = data[0];
|
||
var actualData = new byte[data.Length - 1];
|
||
Array.Copy(data, 1, actualData, 0, actualData.Length);
|
||
|
||
switch (serializationType) {
|
||
case 1: // JSON
|
||
return _jsonSerializer.Deserialize(actualData, type);
|
||
case 2: // Binary
|
||
return _binarySerializer.Deserialize(actualData, type);
|
||
default:
|
||
throw new IPCException($"未知的序列化类型: {serializationType}");
|
||
}
|
||
}
|
||
|
||
private bool IsJsonSerializable(Type type) {
|
||
// 基本类型
|
||
if (type.IsPrimitive || type == typeof(string) || type == typeof(DateTime) || type == typeof(Guid))
|
||
return true;
|
||
|
||
// 数组
|
||
if (type.IsArray && IsJsonSerializable(type.GetElementType()))
|
||
return true;
|
||
|
||
// 已知的IPC消息类型
|
||
if (typeof(IPCMessage).IsAssignableFrom(type) ||
|
||
typeof(MethodCallRequest).IsAssignableFrom(type) ||
|
||
typeof(MethodCallResponse).IsAssignableFrom(type))
|
||
return true;
|
||
|
||
// 其他情况使用二进制序列化
|
||
return false;
|
||
}
|
||
}
|
||
}
|