NewLife/NewLife.RocketMQ

更新本地测试环境
郗云飞 authored at 2019-04-08 15:32:11
e206a94
Tree
1 Parent(s) 96a0345
Summary: 3 changed files with 19 additions and 10 deletions.
Modified +0 -0
Modified +16 -2
Modified +3 -8
Modified +0 -0
diff --git a/DLL/NewLife.Core.dll b/DLL/NewLife.Core.dll
index d289569..ae685d2 100644
Binary files a/DLL/NewLife.Core.dll and b/DLL/NewLife.Core.dll differ
Modified +16 -2
diff --git a/DLL/NewLife.Core.xml b/DLL/NewLife.Core.xml
index 0d3b839..01e279c 100644
--- a/DLL/NewLife.Core.xml
+++ b/DLL/NewLife.Core.xml
@@ -2270,6 +2270,10 @@
             <summary>返回数据段</summary>
             <returns></returns>
         </member>
+        <member name="M:NewLife.Data.Packet.ToSegments">
+            <summary>返回数据段集合</summary>
+            <returns></returns>
+        </member>
         <member name="M:NewLife.Data.Packet.GetStream">
             <summary>获取封包的数据流形式</summary>
             <returns></returns>
@@ -9898,10 +9902,12 @@
         <member name="T:NewLife.Serialization.IJsonHost">
             <summary>Json序列化接口</summary>
         </member>
-        <member name="M:NewLife.Serialization.IJsonHost.Write(System.Object,System.Boolean)">
+        <member name="M:NewLife.Serialization.IJsonHost.Write(System.Object,System.Boolean,System.Boolean,System.Boolean)">
             <summary>写入对象,得到Json字符串</summary>
             <param name="value"></param>
-            <param name="indented">是否缩进</param>
+            <param name="indented">是否缩进。默认false</param>
+            <param name="nullValue">是否写控制。默认true</param>
+            <param name="camelCase">是否驼峰命名。默认false</param>
             <returns></returns>
         </member>
         <member name="M:NewLife.Serialization.IJsonHost.Read(System.String,System.Type)">
@@ -9928,6 +9934,14 @@
             <param name="indented">是否缩进</param>
             <returns></returns>
         </member>
+        <member name="M:NewLife.Serialization.JsonHelper.ToJson(System.Object,System.Boolean,System.Boolean,System.Boolean)">
+            <summary>写入对象,得到Json字符串</summary>
+            <param name="value"></param>
+            <param name="indented">是否缩进。默认false</param>
+            <param name="nullValue">是否写控制。默认true</param>
+            <param name="camelCase">是否驼峰命名。默认false</param>
+            <returns></returns>
+        </member>
         <member name="M:NewLife.Serialization.JsonHelper.ToJsonEntity(System.String,System.Type)">
             <summary>从Json字符串中读取对象</summary>
             <param name="json"></param>
Modified +3 -8
diff --git a/Test/Program.cs b/Test/Program.cs
index f5d0194..3125660 100644
--- a/Test/Program.cs
+++ b/Test/Program.cs
@@ -33,7 +33,6 @@ namespace Test
                 //SecretKey = "BvX6DpQffUz8xKIQ0u13EMxBW6YJmp",
 
                 Topic = "ntest",
-                Group = "abctestw",
                 NameServerAddress = "10.9.20.106:9876",
 
                 //Log = XTrace.Log,
@@ -47,7 +46,6 @@ namespace Test
 
             var entity = JsonHelper.ToJsonEntity<ProblemModel>(str);
 
-
             for (int i = 0; i < 10000; i++)
             {
                 entity.ScanDate = entity.ScanDate.AddSeconds(i);
@@ -55,7 +53,6 @@ namespace Test
                 var sr = mq.Publish(xtr, "TagA");
             }
 
-
             //for (var i = 0; i < 1000000; i++)
             //{
             //    //var str = "学无先后达者为师" + i;
@@ -86,11 +83,11 @@ namespace Test
                 //AccessKey = "LTAINsp1qKfO61c5",
                 //SecretKey = "BvX6DpQffUz8xKIQ0u13EMxBW6YJmp",
 
-                Topic = "ott",
+                Topic = "ntest",
                 Group = "test",
                 NameServerAddress = "10.9.20.106:9876",
 
-                //FromLastOffset = true,
+                FromLastOffset = false,
                 BatchSize = 20,
 
                 Log = XTrace.Log,
@@ -102,9 +99,7 @@ namespace Test
 
                 foreach (var item in ms.ToList())
                 {
-                    //if (item.Tags != "OTTDetail") continue;
-
-                    Console.WriteLine("消息:" + item.Body.ToStr());
+                    Console.WriteLine($"消息:主键【{item.Keys}】,产生时间【{item.BornTimestamp.ToDateTime()}】,内容【{item.Body.ToStr()}】");
                 }
 
                 return true;