Azureサービスファブリックのデフォルトクライアントを使用している場合、リクエストにメッセージヘッダーを追加するにはどうすればよいですか？

Question

私は可能性がありますメッセージのインスペクタによって提供されるwcfのような要求の認証、検証または相関のような機能をfullfillにペイロードを非直列化せずに追加情報を運ぶために発信メッセージにカスタムメッセージヘッダーを挿入することができますか？

Answer 1

更新

あなたは今、（比較的）簡単に信頼性の高いサービスと俳優の両方のヘッダを変更することができます。以下の例では、簡潔にするためにいくつかのラッパーメンバーが省略されています。私たちは、プロキシの代わりに、静的ServiceProxyを作成するためにServiceProxyFactoryを使用

クライアント

。その後、IServiceRemotingClientFactoryとIServiceRemotingClientをラップし、サービスコールを傍受することができます。 ActorProxyFactoryでも同じことができます。クライアントのファクトリを明示的に指定するので、これはWcfServiceRemotingProviderAttributeなどの属性の動作をオーバーライドすることに注意してください。

_proxyFactory = new ServiceProxyFactory(c => new ServiceRemotingClientFactoryWrapper(
// we can use any factory here 
new WcfServiceRemotingClientFactory(callbackClient: c))); 

    private class ServiceRemotingClientFactoryWrapper : IServiceRemotingClientFactory 
    { 
     private readonly IServiceRemotingClientFactory _inner; 

     public ServiceRemotingClientFactoryWrapper(IServiceRemotingClientFactory inner) 
     { 
      _inner = inner; 
     } 

     public async Task<IServiceRemotingClient> GetClientAsync(Uri serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, 
      string listenerName, OperationRetrySettings retrySettings, CancellationToken cancellationToken) 
     { 
      var client = await _inner.GetClientAsync(serviceUri, partitionKey, targetReplicaSelector, listenerName, retrySettings, cancellationToken).ConfigureAwait(false); 
      return new ServiceRemotingClientWrapper(client); 
     } 
    } 

    private class ServiceRemotingClientWrapper : IServiceRemotingClient 
    { 
     private readonly IServiceRemotingClient _inner; 

     public ServiceRemotingClientWrapper(IServiceRemotingClient inner) 
     { 
      _inner = inner; 
     } 

     public Task<byte[]> RequestResponseAsync(ServiceRemotingMessageHeaders messageHeaders, byte[] requestBody) 
     { 
      // use messageHeaders.AddHeader() here 
      return _inner.RequestResponseAsync(messageHeaders, requestBody); 
     } 

     public void SendOneWay(ServiceRemotingMessageHeaders messageHeaders, byte[] requestBody) 
     { 
      // use messageHeaders.AddHeader() here 
      _inner.SendOneWay(messageHeaders, requestBody); 
     } 
    } 

サーバー

継承ServiceRemotingDispatcherとActorServiceRemotingDispatcherからヘッダを調べました。

class CustomServiceRemotingDispatcher : ServiceRemotingDispatcher 
{ 
    public override async Task<byte[]> RequestResponseAsync(IServiceRemotingRequestContext requestContext, ServiceRemotingMessageHeaders messageHeaders, byte[] requestBody) 
    { 
     // read messageHeaders here 
     // or alternatively put them in an AsyncLocal<T> scope 
     // so they can be accessed down the call chain 
     return base.RequestResponseAsync(requestContext, messageHeaders, requestBody); 
    } 
} 

このクラスを使用するには、再び我々は直接通信リスナー作成することにより、ServiceRemotingProviderAttributeをオーバーライドする必要があります。idは、クライアントのソースコードをお探し

class MyService : StatelessService 
{ 
    protected override IEnumerable<ServiceInstanceListener> CreateServiceInstanceListeners() 
    { 
      yield return new ServiceInstanceListener(context => new WcfServiceRemotingListener(context, new CustomServiceRemotingDispatcher()); 
    } 
} 

Answer 2

私は数週間前にthe same question on the MSDN forumに尋ねましたが、私はそこに返答しませんでした。

クライアントライブラリのソースコードを調べましたが、ヘッダーを追加する方法が見つかりませんでした。私は唯一の方法はメソッド呼び出しの一部としてそれらを追加することだと思います。これは、メソッド・パラメーターとしてrequest-classを使用し、それらに継承を使用することによって実行できます。 （ヘッダ[Authorization、ClientInfo、...]を含むRequestBaseクラス）。これらのヘッダーは、すべての呼び出しをラップするか、または手動で設定することによって、すべての要求に対して設定されていることを確認する必要があります。

サービスファブリックチームのさらなる明確化が大いに評価されます。 SDK v2では