8

相互運用性要件のないカスタム イントラネット アプリケーションがあります。メッセージを渡すための二重モードの NetTcp チャネルをプログラムで構築します。メッセージのエンコーディングを変更したかったのですが、それを実現する方法がわかりませんでした。

私たちが取った (失敗した) アプローチは、次のように NetTcpBinding を LeanTcpBinding と呼ばれる新しいクラスに拡張することでした。


internal class LeanTcpBinding : NetTcpBinding
{
    private static readonly ILog _log =
        LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

    public override BindingElementCollection CreateBindingElements()
    {
        BindingElementCollection bindingElementCollection = base.CreateBindingElements();
        BindingElement encodingElement = bindingElementCollection.FirstOrDefault(
            bindingElement => bindingElement is BinaryMessageEncodingBindingElement);
        if (encodingElement != null)
        {
            int index = bindingElementCollection.IndexOf(encodingElement);
            bindingElementCollection.RemoveAt(index);
            bindingElementCollection.Insert(index, new LeanBinaryMessageEncodingBindingElement());
        }
        else
        {
            _log.Warn("Encoding not found");
        }

        return bindingElementCollection;
    }
}

明らかに、デフォルトの BinaryMessageEncodingBindingElement を独自のものに置き換えようとしています。使用を開始するためだけに、LeanBinaryMessageEncodingBindingElement は、次のように BinaryMessageEncodingBindingElement の拡張です。


 internal class LeanBinaryMessageEncodingBindingElement : MessageEncodingBindingElement
 {
        private readonly BinaryMessageEncodingBindingElement _bindingElement;

        /// 
        /// Initializes a new instance of the  class.
        /// 
        public LeanBinaryMessageEncodingBindingElement()
        {
            _bindingElement = new BinaryMessageEncodingBindingElement();
        }

        /// 
        /// Initializes a new instance of the  class.
        /// 
        /// The binding element.
        public LeanBinaryMessageEncodingBindingElement(BinaryMessageEncodingBindingElement bindingElement)
        {
            _bindingElement = bindingElement;
        }

        /// 
        /// Initializes a new instance of the  class.
        /// 
        /// The element to be cloned.
        /// The binding element.
        public LeanBinaryMessageEncodingBindingElement(MessageEncodingBindingElement elementToBeCloned, BinaryMessageEncodingBindingElement bindingElement)
            : base(elementToBeCloned)
        {
            _bindingElement = bindingElement;
        }

        /// 
        /// When overridden in a derived class, returns a copy of the binding element object.
        /// 
        /// 
        /// A  object that is a deep clone of the original.
        /// 
        public override BindingElement Clone()
        {
            return new LeanBinaryMessageEncodingBindingElement(
                (BinaryMessageEncodingBindingElement)_bindingElement.Clone());
        }

        /// 
        /// When overridden in a derived class, creates a factory for producing message encoders.
        /// 
        /// 
        /// The  used to produce message encoders.
        /// 
        public override MessageEncoderFactory CreateMessageEncoderFactory()
        {
            return new LeanBinaryMessageEncoderFactory(_bindingElement.CreateMessageEncoderFactory());
        }

        /// 
        /// When overridden in a derived class, gets or sets the message version that can be handled by the message encoders produced by the message encoder factory.
        /// 
        /// 
        /// The  used by the encoders produced by the message encoder factory.
        /// 
        public override MessageVersion MessageVersion
        {
            get { return _bindingElement.MessageVersion; }
            set { _bindingElement.MessageVersion = value; }
        }
 }

バインディングを使用しようとすると、それがすべきだと思うことを正確に行います... BinaryMessageEncodingBindingElementを置き換えます。ただし、メッセージがチャネル全体で交換されていても、LeanBinaryMessageEncodingBindingElement.CreateMessageEncoderFactory() への呼び出しはまったくありません。

これを適切に行う方法について何か提案はありますか?

4

2 に答える 2

7

Kenny Wolfは何が欠けているのかを明らかにし、それは以下のブログエントリに文書化されています。

http://kennyw.com/?p=170

せっかちな人にとっての問題は、デフォルトでは、MessageEncoderBindingElementがコンテキストのバインディングパラメータにそれ自体を追加しないことです。その結果、トランスポートが後でMessageEncoderBindingElementを見つけようとすると、私（またはあなた）が作成したものを見つけることができず、元の投稿で指摘したサイレントエラーが発生します。

残念ながら、コンテキストのバインディングパラメータにバインディング要素を確実に追加するには、次のようにすべてのCanBuildXXXメソッドとBuildXXXメソッドをオーバーライドする必要があります。


        public override bool CanBuildChannelFactory(BindingContext context)
        {
            if (context == null) {
                throw new ArgumentNullException("context");
            }

            context.BindingParameters.Add(this);
            return context.CanBuildInnerChannelFactory();
        }

        public override bool CanBuildChannelListener(BindingContext context)
        {
            if (context == null) {
                throw new ArgumentNullException("context");
            }

            context.BindingParameters.Add(this);
            return context.CanBuildInnerChannelListener();
        }

        public override IChannelFactory BuildChannelFactory(BindingContext context)
        {
            if (context == null) {
                throw new ArgumentNullException("context");
            }

            context.BindingParameters.Add(this);
            return context.BuildInnerChannelFactory();
        }

        public override IChannelListener BuildChannelListener(BindingContext context)
        {
            if (context == null) {
                throw new ArgumentNullException("context");
            }

            context.BindingParameters.Add(this);
            return context.BuildInnerChannelListener();
        }
于 2010-01-06T05:05:05.273 に答える
2

あなたが持っている NetTcpBinding 構成から代わりに CustomBinding を作成しようとしましたか? このようなもの：

NetTcpBinding binding = new NetTcpBinding(); // get binding from somewhere
var elements = binding.CreateBindingElements();
BindingElementCollection newElements = new BindingElementCollection();
foreach ( var e in elements ) {
   if ( e is MessageEncodingBindingElement ) {
      newElements.Add(new MyMessageEncodingBindingElement());
   } else {
      newElements.Add(e);
   }
}
CustomBinding cb = new CustomBinding(newElements);
于 2010-01-05T16:05:46.107 に答える