C# WCFで大容量通信時のエラーに関して

Question

お世話になっております。

行いたいこと
同一PC内で2つのソフトウェア間でbyte配列の受け渡しを行いたいと思っています。
クライアント側から要求があった際にホスト側からbyte配列を送信する仕様にしたいと思っています。
配列の大きさは最大11,059,200byteを予定しています。

問題点
大量のデータを送信しようすると下記のようなエラーが出力されます。
最後にソースコードを記載しています。

エラー
Hostクラスのcallback.SendByteArr(arr);にて
System.ServiceModel.CommunicationException: 'パイプ パイプを閉じています。 (232, 0xe8) への書き込みエラーが発生しました。'
内部例外
PipeException: パイプ パイプを閉じています。 (232, 0xe8) への書き込みエラーが発生しました。

試したこと
エラー内容で調べたところ帯域不足の可能性があるなどの情報が得られたので
構成エディター ツール (SvcConfigEditor.exe)でソースコード＞App.configのように帯域の値を大きくしてみました。このページなどを参考にしました。
→ 同じエラーが出力される

Host側のarrのサイズ変更
(1) var arr = new byte[500]; → ○
(2) var arr = new byte[65000]; → ○
(3) var arr = new byte[65500]; → ×
上記の(3)よりデフォルトの帯域最大値である65535より小さい値でも同一のエラーが出力されることが分かりました。
これにより帯域以外に原因があるのではと考えました。

質問
・エラーの原因・解決策などありましたら教示いただけないでしょうか。
・また、WCF以外にプロセス間で大量データをやりとりする手法があれば教えて頂ければ幸いです。

ソースコード

        // サーバー・クライアント共通インターフェース
        [ServiceContract(CallbackContract = typeof(ICallback))]
        internal interface IHost
        {
            [OperationContract(IsOneWay = true)]
            void ByteArrRequest();
        }

        [ServiceContract]
        internal interface ICallback
        {
            [OperationContract(IsOneWay = true)]
            void SendByteArr(byte[] bs);
        }

        // ホスト側
        [ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall, ConcurrencyMode = ConcurrencyMode.Multiple, UseSynchronizationContext = false)]
        public class Host : IHost
        {
            public void ByteArrRequest()
            {
                Console.WriteLine("[HOST]: CLIENTから要求あり");

                var callback = OperationContext.Current.GetCallbackChannel<ICallback>();

                var arr = new byte[65500];
                callback.SendByteArr(arr); // ★ここでエラーが出力される
            }
        }

        ServiceHost sh;
        public MainWindow()
        {
            InitializeComponent();

            const string addr = "net.pipe://localhost/test1";
            var binding = new NetNamedPipeBinding(NetNamedPipeSecurityMode.None);
            // 追記1(解決策)
            binding.MaxReceivedMessageSize = 64000000;
            binding.MaxBufferSize = 64000000;
            var readerQuotas = new XmlDictionaryReaderQuotas();
            readerQuotas.MaxArrayLength = 64000000;
            readerQuotas.MaxStringContentLength = 64000000;
            readerQuotas.MaxDepth = 32;
            binding.ReaderQuotas = readerQuotas;
            // 追記1ここまで
            sh = new ServiceHost(typeof(Host));
            sh.AddServiceEndpoint(typeof(IHost), binding, addr);
            sh.Open();
        }

        // クライアント側
        class Callback : ICallback
        {
            public void SendByteArr(byte[] message)
            {
                Console.WriteLine(message.Length);
            }
        }

        public MainWindow()
        {
            InitializeComponent();

            const string addr = "net.pipe://localhost/test1";
            var binding = new NetNamedPipeBinding(NetNamedPipeSecurityMode.None);
            // 解決策
            binding.MaxReceivedMessageSize = 64000000;
            binding.MaxBufferSize = 64000000;
            var readerQuotas = new XmlDictionaryReaderQuotas();
            readerQuotas.MaxArrayLength = 64000000;
            readerQuotas.MaxStringContentLength = 64000000;
            readerQuotas.MaxDepth = 32;
            binding.ReaderQuotas = readerQuotas;
            // 解決策ここまで
            var host = DuplexChannelFactory<IHost>.CreateChannel(new InstanceContext(new Callback()), binding, new EndpointAddress(addr));

            host.ByteArrRequest();
        }

↓ App.config(ホスト・クライアント共に同一内容)

  <system.serviceModel>
    <bindings>
      <netNamedPipeBinding>
        <binding name="NewBinding0" closeTimeout="00:20:00" openTimeout="00:20:00"
          receiveTimeout="00:20:00" sendTimeout="00:20:00" maxBufferSize="64000000"
          maxReceivedMessageSize="64000000">
          <readerQuotas maxDepth="32" maxStringContentLength="8192" maxArrayLength="64000000"
            maxBytesPerRead="64000000" />
        </binding>
      </netNamedPipeBinding>
    </bindings>
    <behaviors>
      <endpointBehaviors>
        <behavior name="NewBehavior0">
          <dataContractSerializer maxItemsInObjectGraph="10000000" />
        </behavior>
      </endpointBehaviors>
      <serviceBehaviors>
        <behavior name="MyBehavior">
          <dataContractSerializer maxItemsInObjectGraph="100000000" />
          <serviceMetadata httpGetEnabled="true" />
          <serviceDebug includeExceptionDetailInFaults="true" />
        </behavior>
      </serviceBehaviors>
    </behaviors>
  </system.serviceModel>

環境
C# .Net F/W 4.6.1
WPF

Comments

[hihijiji]

sh = new ServiceHost(typeof(Host));
のshはどこにあるのかコードで示してください。

[kawauso]

ホスト側のソースコードを修正しました。
MainWindow()内でshを宣言してもエラー内容は同一でした。

[hihijiji]

そのコードで検証しているとしたら、後始末をしていないので繰り返すうちに不具合は出てきそうですね。

[kawauso]

配列を送信できるのか試したかった為、このようなコードで試しています。
ホスト側起動→クライアント側起動の初回通信で必ず質問文のエラーが出力されます。
修正するにあたってヒントなどはないでしょうか。よろしくお願いします。

[moredeep]

WCFのプロトコルについてよく知らないので間違っているかもしれないのですが。。。
>上記の(3)よりデフォルトの帯域最大値である65535より小さい値
これはどうなんだろう？って思いました。
この帯域ってヘッダ等を含まず、データのみなのでしょうか？
IPv4ヘッダやTCPヘッダでも20バイトあり、WCFでは呼ばれた先に(どのメソッドを実行すべきか等)指示する必要もあると思うので、65500がダメだから65536未満でもエラーになるというのは間違っている可能性があるんじゃないかなと。
WCFのヘッダサイズが分かれば、65536-ヘッダサイズで試してみれば早いのですが。

[hihijiji]

とりあえずServiceHostのCloseとDisposeを呼んでから終了するようにするといいと思います。

[kawauso]

ご回答ありがとうございます。
moredeepさん
ヘッダサイズは不明でしたが、ヘッダを含んだ帯域がデフォルトで65535のようです。
ご指摘の通り帯域は関係ないというのは否定できなくなりました。
App.configにて帯域を大きな数値に設定していますが、同様のエラーが出力されます。
なにか不備など分かることはありますでしょうか。

hihijijiさん
ClosingイベントでCloseメソッドを呼ぶようにしました。
(Disposeメソッドは実装されていない？ようでした)
しかし、同様のエラーが出力されます。

[hihijiji]

Disposeはないみたいですね、失礼しました。
あと　NetNamedPipeBinding の MaxReceivedMessageSize などがApp.configで設定した値になっているか確認してください。

[kawauso]

MaxReceivedMessageSize などはApp.configで設定した値になっておらず、デフォルト値の65536でした。
コードまたはApp.configで設定等が必要なのでしょうか。
プロジェクト作成時に生成されるApp.configにSvcConfigEditor.exeで追記しています。
<system.serviceModel>以外には<configSections>,<runtime>,<userSettings>が記述されています。

[hihijiji]

それは後で考えるとして、コードでMaxReceivedMessageSizeを変更して解決したら自己解決にしてください。

[kawauso]

質問文のコードに追記しました。
bindingの各プロパティは変更されていますが、結果は変わりませんでした。
maxItemsInObjectGraphなどもコードで変更したかったのですが、方法が分かりませんでした。

[hihijiji]

クライアント側もなおしてね

[kawauso]

クライアント側も変更したところ解決しました。
自己解決を投稿します。ありがとうございました。

Answer 1

ホスト・クライアント側でbindingのMaxReceivedMessageSizeなどのプロパティなどを直接変更することで解決しました。
hihijijiさんありがとうございました。

            // ホスト・クライアント側に下記のコードを追加
            binding.MaxReceivedMessageSize = 64000000;
            binding.MaxBufferSize = 64000000;
            var readerQuotas = new XmlDictionaryReaderQuotas();
            readerQuotas.MaxArrayLength = 64000000;
            readerQuotas.MaxStringContentLength = 64000000;
            readerQuotas.MaxDepth = 32;
            binding.ReaderQuotas = readerQuotas;