azure - Service Fabric : System. ArgumentException:找不到具有此 ID 的接口(interface) -488762776

Question

我正在开发一个简单的 Service Fabric 群集，我想在其中从无状态 ASP.NET Core 2.0 Web API 调用无状态服务。

我做的第一件事是创建一个具有简单接口(interface)和 DTO 的 .NET Standard 2.0 类库:

public interface IMicroService : IService
{
    Task<MyDto> GetMahDto(int id);
}

public class MyDto
{
    public string Name { get; set; }
}

然后，我用它创建了一个 NuGet 包，并将该包作为依赖项添加到我的 Web API(MyServiceApi 项目)和无状态服务 (MyService)。

服务的监听器定义为

        protected override IEnumerable<ServiceInstanceListener> CreateServiceInstanceListeners()
    {
        var fabricListener = new ServiceInstanceListener((context) =>
        {
            var fabricRemotingListener = new FabricTransportServiceRemotingListener(
            serviceContext: context,
            serviceRemotingMessageHandler: null,
            remotingListenerSettings: new Microsoft.ServiceFabric.Services.Remoting.FabricTransport.Runtime.FabricTransportRemotingListenerSettings()
            {
                EndpointResourceName = "myendpoint"
            },
            serializationProvider: null);


            return fabricRemotingListener;
        },
       "mylistener");

        return new ServiceInstanceListener[] { fabricListener };
    }

接口(interface)实现很简单

public Task<MyDto> GetMahDto(int id)
    {
        return Task.FromResult(new MyDto() { Name=$"Hallo from TheService in FabricSandbox3 project, id: {id}" });
    }

在 MyServiceApi 中，我有一个看起来像这样的 Controller 方法

[HttpGet]
    public async Task<MyDto> Get()
    {

        var svc = ServiceProxy.Create<ContractsStandard.IMicroService>(new Uri("fabric:/FabricSandbox4/TheService"), listenerName: "mylistener");

        return await svc.GetMahDto(23);
    }

当我启动调试器时，我可以单步执行 MyServiceApi 的 Controller 方法，但它会抛出以下异常:

System.AggregateException:“发生一个或多个错误。 (异常 System.ArgumentException 在服务上未处理，无法序列化以传输到客户端。详细的远程异常信息:System.ArgumentException:找不到此 Id 的接口(interface) -488762776 在 Microsoft.ServiceFabric.Services.Remoting.V2.ServiceRemotingMessageSerializersManager.GetInterfaceDetails(Int32 interfaceId) 在 Microsoft.ServiceFabric.Services.Remoting.V2.ServiceRemotingMessageSerializersManager.CreateSerializers(Int32 InterfaceId) 在 System.Collections.Concurrent.ConcurrentDictionary2.GetOrAdd(TKey key, Func2 valueFactory) 在 Microsoft.ServiceFabric.Services.Remoting.V2.ServiceRemotingMessageSerializersManager.GetRequestBodySerializer(Int32 interfaceId) 在 Microsoft.ServiceFabric.Services.Remoting.V2.FabricTransport.Runtime.FabricTransportMessageHandler.CreateRemotingRequestMessage(FabricTransportMessage FabricTransportMessage，秒表秒表) 在 Microsoft.ServiceFabric.Services.Remoting.V2.FabricTransport.Runtime.FabricTransportMessageHandler.d__7.MoveNext())'

我在诊断事件中没有发现任何看起来有希望的内容，而且我所看到的类似问题(在此站点和其他地方)的唯一提及通常涉及不同程序集中的类型，鉴于此，这不是问题共享接口(interface)包含在 NuGet 包中。

有什么想法我可能会出错吗？

Answer 1

请参阅此答案的底部以直接找到最终解决方案。

我找到了一个部分令人满意的答案。但是，我并不完全知道它为什么有效。我偶然发现这一点纯属偶然。我一直在研究一种通过结构请求无缝传递 header 的方法，这就是我最终实现这一点的方法。

引用上面的监听器代码，特别注意这一行:

 serviceRemotingMessageHandler: null,

为了使其正常工作，我创建了自己的 IServiceRemotingMessageHandler 实现。请注意，它只是将调用委托(delegate)给基本类型:

class TestRemotingDispatcher : ServiceRemotingMessageDispatcher, IServiceRemotingMessageHandler
{

    public TestRemotingDispatcher(
        ServiceContext serviceContext, IService serviceImplementation, IServiceRemotingMessageBodyFactory serviceRemotingMessageBodyFactory = null) :
        base(serviceContext, serviceImplementation, serviceRemotingMessageBodyFactory)
    {

    }

    public override void HandleOneWayMessage(IServiceRemotingRequestMessage requestMessage)
    {
        base.HandleOneWayMessage(requestMessage);
    }

    public override Task<IServiceRemotingResponseMessageBody> HandleRequestResponseAsync(
        ServiceRemotingDispatchHeaders requestMessageDispatchHeaders, IServiceRemotingRequestMessageBody requestMessageBody, CancellationToken cancellationToken)
    {

        return base.HandleRequestResponseAsync(requestMessageDispatchHeaders, requestMessageBody, cancellationToken);
    }

    public override Task<IServiceRemotingResponseMessage> HandleRequestResponseAsync(IServiceRemotingRequestContext requestContext, IServiceRemotingRequestMessage requestMessage)
    {

        return base.HandleRequestResponseAsync(requestContext, requestMessage);
    }
}

然后监听器就变成了

var fabricListener = new ServiceInstanceListener((context) =>
        {
        var fabricRemotingListener = new FabricTransportServiceRemotingListener(
        serviceContext: context,
        serviceRemotingMessageHandler: new TestRemotingDispatcher(context, this),
            remotingListenerSettings: new Microsoft.ServiceFabric.Services.Remoting.FabricTransport.Runtime.FabricTransportRemotingListenerSettings()
            {
                EndpointResourceName = "mngendpoint"
            },
            serializationProvider: null);


            return fabricRemotingListener;
        },
      "mnglistener");

这按预期工作。如果我弄清楚原因，我会更新。

编辑:我还没有弄清楚为什么显式分配 serviceRemotingMessageHandler 有效，但上面显示的 ServiceRemotingMessageDispatcher 的子类型不是必需的。它将通过分配内置实现来工作:

 serviceRemotingMessageHandler: new ServiceRemotingMessageDispatcher(context, serviceInstance)

最终解释

这一切都归咎于我的错误。请注意，我首先将 null 分配给 serviceRemotingMessageHandler，这是不正确的。查看源代码后，有一个构造函数将为您创建一个调度程序。通过按照我的方式分配 null，监听器中不存在调度程序。

 public FabricTransportServiceRemotingListener(
        ServiceContext serviceContext,
        IService serviceImplementation,
        FabricTransportRemotingListenerSettings remotingListenerSettings = null,
        IServiceRemotingMessageSerializationProvider serializationProvider = null)
        : this(
              serviceContext,
              new ServiceRemotingMessageDispatcher(
                serviceContext,
                serviceImplementation,
                GetMessageBodyFactory(serializationProvider, remotingListenerSettings)),
              remotingListenerSettings,
              serializationProvider)
    {
    }

异常消息肯定让我走上了错误的道路，但至少对(自己造成的)问题有一个很好的解释。