Merge pull request #169 from dotnet-campus/t/lvyi/compatibility

加回序列化和反序列化消息的方法，因为上次升级发生了不兼容的 API 变化

Author: lindexi

src/dotnetCampus.Ipc/CompilerServices/GeneratedProxies/Contexts/GeneratedIpcJointResponse.cs

@@ -1,4 +1,5 @@
 using dotnetCampus.Ipc.CompilerServices.GeneratedProxies.Models;
+using dotnetCampus.Ipc.Context;
 using dotnetCampus.Ipc.Messages;
 using dotnetCampus.Ipc.Serialization;
 
@@ -26,7 +27,7 @@ internal static async Task<GeneratedIpcJointResponse> FromAsyncReturnModel(
         var returnModel = await asyncReturnModel.ConfigureAwait(false);
         var message = returnModel is null
             ? new IpcMessage()
-            : serializer.SerializeToIpcMessage(returnModel, "Return");
+            : serializer.SerializeToIpcMessage((ulong)KnownMessageHeaders.RemoteObjectMessageHeader, returnModel, "Return");
         return new GeneratedIpcJointResponse(message);
     }
 }

src/dotnetCampus.Ipc/CompilerServices/GeneratedProxies/PublicIpcJointManager.cs

@@ -70,7 +70,8 @@ public void AddPublicIpcObject(Type contractType, GeneratedIpcJoint joint, strin
         /// </returns>
         public bool TryJoint(IIpcRequestContext request, out Task<IIpcResponseMessage> responseTask)
         {
-            if (Context.ObjectSerializer.TryDeserializeFromIpcMessage<GeneratedProxyMemberInvokeModel>(request.IpcBufferMessage, out var requestModel)
+            if (Context.ObjectSerializer.TryDeserializeFromIpcMessage<GeneratedProxyMemberInvokeModel>(
+                    request.IpcBufferMessage, (ulong)KnownMessageHeaders.RemoteObjectMessageHeader, out var requestModel)
                 && TryFindJoint(requestModel, out var joint)
                 && requestModel.MemberName is { } memberName)
             {

src/dotnetCampus.Ipc/CompilerServices/GeneratedProxies/Utils/IpcProxyInvokingHelper.cs

@@ -1,4 +1,5 @@
 using dotnetCampus.Ipc.CompilerServices.GeneratedProxies.Models;
+using dotnetCampus.Ipc.Context;
 using dotnetCampus.Ipc.Exceptions;
 using dotnetCampus.Ipc.Serialization;
 
@@ -92,10 +93,11 @@ internal string TypeName
             return null;
         }
 
-        var requestMessage = Context.ObjectSerializer.SerializeToIpcMessage(model, model.ToString());
+        var header = (ulong)KnownMessageHeaders.RemoteObjectMessageHeader;
+        var requestMessage = Context.ObjectSerializer.SerializeToIpcMessage(header, model, model.ToString());
         //requestMessage = new IpcMessage(requestMessage.Tag, requestMessage.Body, CoreMessageType.JsonObject);
         var responseMessage = await PeerProxy.GetResponseAsync(requestMessage).ConfigureAwait(false);
-        if (Context.ObjectSerializer.TryDeserializeFromIpcMessage<GeneratedProxyMemberReturnModel>(responseMessage, out var returnModel))
+        if (Context.ObjectSerializer.TryDeserializeFromIpcMessage<GeneratedProxyMemberReturnModel>(responseMessage, header, out var returnModel))
         {
             return returnModel;
         }

src/dotnetCampus.Ipc/Serialization/JsonIpcMessageSerializer.cs

@@ -15,22 +15,76 @@ namespace dotnetCampus.Ipc.Serialization;
 /// <summary>
 /// 如果某 IPC 消息计划以 JSON 格式传输，那么可使用此类型来序列化和反序列化。
 /// </summary>
-internal static class JsonIpcMessageSerializer
+public static class JsonIpcMessageSerializer
 {
+#if UseNewtonsoftJson
+    /// <summary>
+    /// 将 IPC 模块自动生成的内部模型序列化成可供跨进程传输的 IPC 消息。
+    /// </summary>
+    /// <param name="tag"></param>
+    /// <param name="model"></param>
+    /// <returns></returns>
+    [Obsolete("因为 AOT 需要，此方法已计划删除。请自行序列化后，通过 new IpcMessage(tag, new IpcMessageBody(data), header) 创建 IPC 消息。")]
+    public static IpcMessage Serialize(string tag, object model)
+    {
+        return SerializeToIpcMessage(IpcConfiguration.DefaultNewtonsoftJsonSerializer, 0, model, tag);
+    }
+
+    /// <summary>
+    /// 尝试将跨进程传输过来的 IPC 消息反序列化成 IPC 模块自动生成的内部模型。
+    /// </summary>
+    /// <param name="message">IPC 消息。</param>
+    /// <param name="model"></param>
+    /// <returns></returns>
+    [Obsolete("因为 AOT 需要，此方法已计划删除。请自行序列化后，通过 new IpcMessage(tag, new IpcMessageBody(data), header) 创建 IPC 消息。")]
+    public static bool TryDeserialize<T>(IpcMessage message, [NotNullWhen(true)] out T? model) where T : class, new()
+    {
+        return IpcConfiguration.DefaultNewtonsoftJsonSerializer.TryDeserializeFromIpcMessage(message, 0, out model);
+    }
+#else
+    /// <summary>
+    /// 将 IPC 模块自动生成的内部模型序列化成可供跨进程传输的 IPC 消息。
+    /// </summary>
+    /// <param name="tag"></param>
+    /// <param name="model"></param>
+    /// <returns></returns>
+    [Obsolete("因为 AOT 需要，此方法已删除。请自行序列化后，通过 new IpcMessage(tag, new IpcMessageBody(data), header) 创建 IPC 消息。", true)]
+    public static IpcMessage Serialize(string tag, object model)
+    {
+        return SerializeToIpcMessage(IpcConfiguration.DefaultSystemTextJsonIpcObjectSerializer, 0, model, tag);
+    }
+
+    /// <summary>
+    /// 尝试将跨进程传输过来的 IPC 消息反序列化成 IPC 模块自动生成的内部模型。
+    /// </summary>
+    /// <param name="message">IPC 消息。</param>
+    /// <param name="model"></param>
+    /// <returns></returns>
+    [Obsolete("因为 AOT 需要，此方法已删除。请自行序列化后，通过 new IpcMessage(tag, new IpcMessageBody(data), header) 创建 IPC 消息。", true)]
+    public static bool TryDeserialize<T>(IpcMessage message, [NotNullWhen(true)] out T? model) where T : class, new()
+    {
+        return IpcConfiguration.DefaultSystemTextJsonIpcObjectSerializer.TryDeserializeFromIpcMessage(message, 0, out model);
+    }
+#endif
+
     /// <summary>
     /// 将 IPC 内部模型序列化成可供跨进程传输的 IPC 消息。
     /// </summary>
     /// <param name="serializer">IPC 对象序列化器。</param>
+    /// <param name="header">消息头。</param>
     /// <param name="model">要序列化的 IPC 内部模型。</param>
     /// <param name="tag">用于追踪调试的消息标签。</param>
     /// <returns>用于 IPC 传输的消息。</returns>
     internal static IpcMessage SerializeToIpcMessage(
         this IIpcObjectSerializer serializer,
+        ulong header,
         object model,
         string tag)
     {
         var data = serializer.Serialize(model);
-        var message = new IpcMessage(tag, new IpcMessageBody(data), (ulong) KnownMessageHeaders.RemoteObjectMessageHeader);
+        var message = header is 0
+            ? new IpcMessage(tag, new IpcMessageBody(data))
+            : new IpcMessage(tag, new IpcMessageBody(data), header);
         return message;
     }
 
@@ -39,20 +93,28 @@ internal static IpcMessage SerializeToIpcMessage(
     /// </summary>
     /// <param name="serializer"></param>
     /// <param name="message">IPC 消息。</param>
+    /// <param name="header">消息头。</param>
     /// <param name="model"></param>
     /// <returns></returns>
-    internal static bool TryDeserializeFromIpcMessage<T>(this IIpcObjectSerializer serializer, IpcMessage message, [NotNullWhen(true)] out T? model)
+    internal static bool TryDeserializeFromIpcMessage<T>(this IIpcObjectSerializer serializer,
+        IpcMessage message, ulong header, [NotNullWhen(true)] out T? model)
         where T : class, new()
     {
-        const ulong header = (ulong) KnownMessageHeaders.RemoteObjectMessageHeader;
-        if (!message.TryGetPayload(header, out var deserializeMessage))
+        IpcMessageBody body;
+        if (header is 0)
+        {
+            body = message.Body;
+        }
+        else if (!message.TryGetPayload(header, out var deserializeMessage))
         {
             // 如果业务头不对，那就不需要解析了。
             model = null;
             return false;
         }
-
-        var body = deserializeMessage.Body;
+        else
+        {
+            body = deserializeMessage.Body;
+        }
 
         try
         {