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
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>
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;