0

我想试试 ServiceStack 的自动批量请求功能。但它似乎不适用于服务器端。我有这样的服务:

public class HelloService : Service
{
    public object Any(HelloRequestDTO request)
    {
        return new HelloResponseDTO { Greetings = "Hello, " + request.Name };
    }


    /// <summary>This method does not get invoked.</summary>
    public object Any(HelloRequestDTO[] requests)
    {
        return new HelloResponseDTO { Greetings = "Hello, " + string.Join(", ", requests.Select(r => r.Name).ToArray()) };
    }
}

这是 DTO,它们位于共享库中,因此客户端和服务器都可以使用它们。

[ProtoContract]
public class HelloRequestDTO : IReturn<HelloResponseDTO>
{
    [ProtoMember(1)]
    public string Name { get; set; }
}

[ProtoContract]
public class HelloResponseDTO
{
    [ProtoMember(1)]
    public string Greetings { get; set; }
}

我使用以下代码从控制台应用程序发送请求:

var requests = new[]
                           {
                               new HelloRequestDTO { Name = "PersonA" },
                               new HelloRequestDTO { Name = "PersonB" },
                               new HelloRequestDTO { Name = "PersonC" }
                           };

        const string host = "MY-MACHINE:5667";
        var serviceUrl = string.Format("http://{0}/api/hello?", host);

        var protoClient = new ProtoBufServiceClient(serviceUrl);
        var jsonClient = new JsonServiceClient(serviceUrl);

        //var protoResponses = protoClient.SendAll(requests);
        var jsonResponses = jsonClient.SendAll(requests);

当 JSON 序列化请求到达服务器时,抛出异常:

类型定义应以'{'开头,期望序列化类型'HelloRequestDTO',字符串以:[{"Name":"PersonA"},{"Name":"PersonB"},{"Name":"Pe

我检查了请求是否有效,这是我用 Fiddler 捕获的:

发布http://MY-MACHINE:5667/api/hello?/json/reply/HelloRequestDTO[] HTTP /1.1

接受:应用程序/json

用户代理:ServiceStack .NET 客户端 4,038

接受编码:gzip,deflate

内容类型:应用程序/json

主机:我的机器:5667

内容长度:58

期望:100-继续

连接:保持活动

[{"Name":"PersonA"},{"Name":"PersonB"},{"Name":"PersonC"}]

当 protobuf 序列化请求到达时,仅调用非数组处理程序(公共对象 Any(HelloRequestDTO 请求))并且参数为“PersonC”,其他两个 DTO 被丢弃。

似乎我缺少某种开关,ServiceStack 无法识别它正在处理自动批处理请求。

如果有帮助,我也可以上传我的测试解决方案。

4

1 回答 1

0

ServiceClient 中的 url 应该只包含BaseUrlServiceStack 实例的 url,而不是特定服务的 url。

将 URL 更改为:

var baseUrl = "http://{0}/api/".Fmt(host);
var protoClient = new ProtoBufServiceClient(baseUrl);
var jsonClient = new JsonServiceClient(baseUrl);
于 2015-04-01T02:03:55.270 回答