发布时使用自定义Json序列化

NewLifeX · Jun 29, 2024 · 5830d02 · 5830d02
1 parent d5b1acf
commit 5830d02
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/NewLife.RocketMQ/Producer.cs b/NewLife.RocketMQ/Producer.cs
@@ -1,4 +1,5 @@
 using NewLife.Log;
+using NewLife.Reflection;
 using NewLife.RocketMQ.Client;
 using NewLife.RocketMQ.Common;
 using NewLife.RocketMQ.Models;
@@ -396,6 +397,8 @@ protected virtual Message CreateMessage(Object body)
         if (body is null) throw new ArgumentNullException(nameof(body));
         if (body is Message) throw new ArgumentOutOfRangeException(nameof(body), "body不能是Message类型");
 
+        if (!body.GetType().IsBaseType()) body = JsonHost.Write(body);
+
         var msg = new Message();
         msg.SetBody(body);
 

diff --git a/NewLife.RocketMQ/Protocol/Command.cs b/NewLife.RocketMQ/Protocol/Command.cs
@@ -167,7 +167,7 @@ public Boolean Write(Stream stream, Object context = null)
         {
             // 计算头部
             //var json = Header.ToJson();
-            var json = JsonWriter.ToJson(Header, false, false, false);
+            var json = Header.ToJson(false, false, false);
             var hs = json.GetBytes();
 
             // 计算长度