2

根据文档示例，代理的创建方式如下：

IMyService helloWorldClient = ServiceProxy.Create<IMyService>(new 
Uri("fabric:/MyApplication/MyHelloWorldService"));

string message = await helloWorldClient.HelloWorldAsync();

但是如果我需要限制最大响应时间，我通常会创建 CancellationToken 并将其传递给调用。有没有办法将令牌传递给代理，以便它取消等待远程服务的结果？

4

3 回答 3

2

您可以在 V2 堆栈中执行此操作，我还没有尝试过 V1 堆栈，但它也可能在那里工作。在方法签名中添加一个 CancellationToken 类型的参数：

void HelloWorldAsync(CancellationToken cancellationToken);

然后，此令牌将通过代理传递给 ServicePartitionClient.InvokeWithRetryAsync 方法。

生成的代理方法如下所示：

Task<string> IMyService.HelloWorldAsync(CancellationToken cancellationToken)
{
    IServiceRemotingRequestMessageBody serviceRemotingRequestMessageBody = base.CreateRequestMessageBodyV2("MyNamespace.IMyService", "HelloWorldAsync", 1);
    Task<IServiceRemotingResponseMessageBody> task = base.InvokeAsyncV2(
    1, -1, "HelloWorldAsync", serviceRemotingRequestMessageBody,
    cancellationToken);
    return base.ContinueWithResultV2<ServiceInfoResponse>(task);
}

如果没有 CancellationToken 参数，代理方法如下所示：

Task<string> IMyService.HelloWorldAsync()
{
    IServiceRemotingRequestMessageBody serviceRemotingRequestMessageBody = base.CreateRequestMessageBodyV2("MyNamespace.IMyService", "HelloWorldAsync", 1);
    Task<IServiceRemotingResponseMessageBody> task = base.InvokeAsyncV2(
    1, -1, "HelloWorldAsync", serviceRemotingRequestMessageBody,
    CancellationToken.None);
    return base.ContinueWithResultV2<ServiceInfoResponse>(task);
}

如果要检查生成的代理程序集，请在 EntryPoint 程序集或定义了服务接口的程序集中使用以下属性：

[assembly: CodeBuilder(EnableDebugging = true)]
于 2018-09-11T18:24:04.917 回答
1

对于仍然有兴趣正确执行此线程要求的人，下面的链接可以是答案吗？

https://blogs.msdn.microsoft.com/azureservicefabric/2016/02/23/service-fabric-sdk-v1-5-175-and-the-adoption-of-virtual-machine-scale-sets/

内容：

对 IService/IActor 的 CancellationToken 支持

Reliable Service 和 Reliable Actor 方法现在支持可以通过 ActorProxy 和 ServiceProxy 远程访问的取消令牌，允许您实现协作取消。想要取消长时间运行的服务或参与者方法的客户端可以发出取消令牌的信号，并且取消意图将传播到参与者/服务方法。然后，该方法可以通过查看其取消令牌参数的状态来确定何时停止执行。

例如，一个参与者的合约可能有一个可能长时间运行的方法可以建模如下所示：

    public interface IPrimeNumberActorInterface : IActor
    {

        Task<ulong> FindNextPrimeNumberAsync
            (ulong previous, CancellationToken cancellationToken);

    }

希望取消方法执行的客户端代码可以通过取消取消令牌来传达其意图。

于 2018-10-26T17:00:21.813 回答
0

据我所知，不可能将取消令牌传递给调用，因为它只是一个代理，它只接受您在接口中描述的方法的参数。

要完成您想要的，在一定时间后取消操作，您必须配置FabricTransportRemotingListenerSettings并将 OperationTimeout 设置为所需的超时。默认值为 5 分钟。

您也可以通过服务 settings.xml 中的 TransportSettings 进行此设置。

以下链接将显示如何设置 FabricTransportRemotingListenerSettings 或 TransportSettings 配置的两个示例。 https://docs.microsoft.com/en-us/azure/service-fabric/service-fabric-reliable-services-secure-communication

文档没有显示，但您必须设置的参数是：OperationTimeout

演员也可以这样做，请参见此处，注意演员的某些设置是不同的。

于 2018-07-13T15:53:36.327 回答