获取数据时,ServiceStack MsgPackServiceClient失败,但JsonServiceClient
本文关键字:失败 JsonServiceClient MsgPackServiceClient ServiceStack 数据 获取 | 更新日期: 2023-09-27 18:10:58
我正在摆弄ServiceStack,并尝试着理解这项技术。
我有一个非常简单的设置(完整的解决方案可下载):
- 使用ServiceStack(自托管)的独立AppHost 我启动服务器
- 则查询
Article
数据列表。
我安装了ServiceStack.Pluging.MsgPack
的nuget包,添加了参考并正确设置了AppHost插件,如下面的main()
代码所示。
DTO和Service类
这些是我使用的数据类,DTO和服务类:
public class Article : IReturn<Article>
{
public string AR_REF { get; set; }
public string AR_DESIGN { get; set; }
public string AR_CODEBARRE { get; set; }
public string FA_CODEFAMILLE { get; set; }
public string CT_INTITULE { get; set; }
}
public class Articles : IReturn<List<Article>> { }
public class ArticleService : Service
{
public List<Article> Get(Articles request) {
return new List<Article>() {
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
};
}
}
所有这些都允许客户端获得16个虚拟Articles
的列表。
服务器端和客户端请求
static void Main() {
var appHost = new AppHost();
appHost.Plugins.Add(new MsgPackFormat());
appHost.Init();
appHost.Start("http://localhost:8883");
// Fails when calling client.Get()
var client = new MsgPackServiceClient("http://localhost:8883");
List<Article> response = client.Get(new Articles());
appHost.Stop();
}
与AppHost定义为:
public class AppHost : AppHostHttpListenerBase
{
static readonly ConfigurationResourceManager AppSettings = new ConfigurationResourceManager();
public AppHost() : base("Test", typeof(Article).Assembly) { }
public override void Configure(Funq.Container container) { }
}
会发生什么调用client.Get(...)
失败,SerializationException
说:
解包器尚未读取任何数据。解包器可能永远不会读取或底层流为空。
当我使用超过15条记录的
MsgPackServiceClient()
时,会发生异常。
奇怪的是,如果我返回15个或更少的Articles
实例,它可以工作。如果我使用
JsvServiceClient()
或JsonServiceClient()
代替,我没有问题返回数千条记录。
我真的不知道是我做错了什么,还是有别的什么东西在起作用。
附加信息和下载
我使用VS2012与ServiceStack 3.9.43(包括MsgPack插件)通过nuget安装。
不管编译选项是什么(AnyCPU/x86),都会出现这个问题。未启用代码优化(每个解决方案/项目选项都是默认选项)。
您可以下载完整的解决方案并亲自尝试。
所以,我不太确定问题是什么。它似乎特定于在AppHost的同一应用程序中使用MsgPackServiceClient。如果您从浏览器向http://localhost:8883/Articles?format=x-msgpack
之类的东西发出请求,它似乎可以工作。
编写测试(如底部的测试)似乎可以确认MessagePackSerializer是否正常工作。
添加一个写OutputStream的响应过滤器(如下)似乎可以纠正您的问题。我尝试了16和32个记录。
希望对你有帮助。
appHost.ResponseFilters.Add((httpReq, httpRes, dto) =>
{
if (httpReq.ResponseContentType == ContentType.MsgPack)
{
using (var ms = new MemoryStream())
{
var serializer = MessagePackSerializer.Create(dto.GetType());
serializer.PackTo(Packer.Create(ms), dto);
var bytes = ms.ToArray();
var listenerResponse = (HttpListenerResponse)httpRes.OriginalResponse;
listenerResponse.OutputStream.Write(bytes, 0, bytes.Length);
httpRes.EndServiceStackRequest();
}
}
});
MessagePackSerializer测试
[Test]
public void test()
{
var arts = new List<Article>() {
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
new Article() {AR_CODEBARRE = "987654", AR_REF = "1002.ARRGHHH", AR_DESIGN = "BLAH BLAH TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "50FAM"} ,
new Article() {AR_CODEBARRE = "123456", AR_REF = "515.VEROTEST", AR_DESIGN = "THIS IS A TEST", CT_INTITULE = "ACME", FA_CODEFAMILLE = "10FAM"} ,
};
var serializer = MessagePackSerializer.Create<List<Article>>();
var ms = new MemoryStream();
serializer.PackTo(Packer.Create(ms), arts);
ms.Position = 0;
try
{
var obj = serializer.Unpack(ms);
Assert.IsNotNull(obj);
}
catch (Exception ex)
{
throw ex;
}
ms.Close();
}