Duplex Mode StreamedRequest not working with Reliable Session Binding

StackOverflow https://stackoverflow.com/questions/1876460

Question

I have been struggling with this for a while and could really use some help.

I am attempting to design a WCF endpoint that allows for the streaming of images to the server and then returns imageURLs (i.e: "http://images.site.com/someimage.jpg").

Currently, the call to my WCF method looks like this: 

for (var i = 0; i <= (Request.Files.Count - 1); i++)
{
client = new SOAPFileTransferServiceClient();
fileinfo = new FileTransferInfo();
m_objFile = Request.Files[i];

if (!(m_objFile == null | string.IsNullOrEmpty(m_objFile.FileName) |  _objFile.ContentLength < 1))
   {

   fileinfo.FileSize = m_objFile.ContentLength;
   fileinfo.FileName = Path.GetFileName(m_objFile.FileName);
   fileinfo.UserID = Context.Request["sid"].ToString();

   client.UploadFile(fileinfo, m_objFile.InputStream);

   if (retParam.param2 == 0)
   imgurl.Add(retParam.param1);

  }

}

The error I am struggling with is this:

Transfer mode Streamed is not supported by ReliableSessionBindingElement.

So far, I have tried creating a custom netTcp binding with added before the message encoding element. I have also changed my transerMode attribute to streamedRequest (thanks to a suggestion by marc_s) allowing for the request to be streamed but not the response. This seems like it would do the trick but I am still getting the same error (this time "Transfer mode StreamedRequest is not...").

I am out of ideas.

Below is the file transfer service contract. I have JSON and POX in addition to SOAP endpoints. I also have two MEX endpoints (one for mexHttp and the other for netTcp). Finally, I have both http (for json and pox) and netTcp (for soap) base addresses.

Does anything look wrong? 

<service behaviorConfiguration="transferServiceBehavior" name="MyProject.API.FileTransfer.FileTransferService">
            <endpoint address="json" behaviorConfiguration="WebHttpEPBehavior"
              binding="webHttpBinding" bindingConfiguration="jsonWeb" name="MyJSONFileTransferEP"
              contract="MyProject.API.FileTransfer.IJSONFileTransferService" />
            <endpoint address="pox" behaviorConfiguration="WebHttpEPBehavior"
              binding="webHttpBinding" bindingConfiguration="poxWeb" name="MyPOXFileTransferEP"
              contract="MyProject.API.FileTransfer.IPOXFileTransferService" />
            <endpoint address="httpMex" binding="mexHttpBinding" bindingConfiguration=""
              contract="IMetadataExchange" />
            <endpoint address="soap" behaviorConfiguration="NetTcpEPBehavior"
              binding="customBinding" bindingConfiguration="netTcpCustom"
              name="MySOAPFileTransferEP" contract="MyProject.API.FileTransfer.ISOAPFileTransferService" />
            <endpoint address="nettcpMex" binding="netTcpBinding" bindingConfiguration=""
              contract="IMetadataExchange" />
            <host>
              <baseAddresses>
                <add baseAddress="http://localhost:2544/filetransfer/" />
                <add baseAddress="net.tcp://localhost:2544/filetransfer/" />
              </baseAddresses>
            </host>
          </service>

And here is my custom binding used by the service contract:

<customBinding>
    <binding name="netTcpCustom"
             closeTimeout="00:01:00"
             openTimeout="00:01:00"
             receiveTimeout="00:10:00"
             sendTimeout="00:01:00">
      <reliableSession />
      <compositeDuplex />
      <oneWay />
      <windowsStreamSecurity protectionLevel="None" />
      <mtomMessageEncoding  />
      <tcpTransport maxBufferPoolSize="524288"
                    maxReceivedMessageSize="2147483647"
                    connectionBufferSize="8192"
                    hostNameComparisonMode="StrongWildcard"
                    channelInitializationTimeout="00:01:00"
                    maxBufferSize="2147483647"
                    maxPendingConnections="20"
                    maxOutputDelay="00:00:00.2000000"
                    maxPendingAccepts="5"
                    transferMode="StreamedRequest"
                    listenBacklog="20"
                    portSharingEnabled="false"
                    teredoEnabled="false">
        <connectionPoolSettings groupName="default" leaseTimeout="00:05:00"
            idleTimeout="00:02:00" maxOutboundConnectionsPerEndpoint="20" />
      </tcpTransport>
    </binding>
  </customBinding>

Finally, for what it is worth, below is my entire system.serviceModel definition in App.config:

<system.serviceModel>
    <client>
      <endpoint address="http://localhost:2542/auth/json" behaviorConfiguration="WebHttpEPBehavior"
        binding="webHttpBinding" bindingConfiguration="jsonWeb" contract="Trezoro.WebAPI.Authentication.IJSONAuthService"
        name="MyJSONAuthEP">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
      <endpoint address="http://localhost:2542/auth/pox" behaviorConfiguration="WebHttpEPBehavior"
        binding="webHttpBinding" bindingConfiguration="poxWeb" contract="Trezoro.WebAPI.Authentication.IPOXAuthService"
        name="MyPOXAuthEP">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
      <endpoint address="http://localhost:2542/auth/soap" behaviorConfiguration="BasicHttpEPBehavior"
        binding="basicHttpBinding" bindingConfiguration="soapWeb" contract="Trezoro.WebAPI.Authentication.ISOAPAuthService"
        name="MySOAPAuthEP">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
      <endpoint address="http://localhost:2542/auth/mex" binding="mexHttpBinding"
        bindingConfiguration="" contract="IMetadataExchange" name="authmex">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
      <endpoint address="http://localhost:2543/trade/json" behaviorConfiguration="WebHttpEPBehavior"
        binding="webHttpBinding" bindingConfiguration="jsonWeb" contract="Trezoro.WebAPI.Trade.IJSONTradeService"
        name="MyJSONTradeEP">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
      <endpoint address="http://localhost:2543/trade/pox" behaviorConfiguration="WebHttpEPBehavior"
        binding="webHttpBinding" bindingConfiguration="poxWeb" contract="Trezoro.WebAPI.Trade.IPOXTradeService"
        name="MyPOXTradeEP">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
      <endpoint address="http://localhost:2543/trade/soap" behaviorConfiguration="BasicHttpEPBehavior"
        binding="basicHttpBinding" bindingConfiguration="soapWeb" contract="Trezoro.WebAPI.Trade.ISOAPTradeService"
        name="MySOAPTradeEP">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
      <endpoint address="http://localhost:2543/trade/mex" binding="mexHttpBinding"
        bindingConfiguration="" contract="IMetadataExchange" name="trademex">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
      <endpoint address="http://localhost:2544/filetransfer/json" behaviorConfiguration="WebHttpEPBehavior"
        binding="webHttpBinding" bindingConfiguration="jsonWeb" contract="Trezoro.WebAPI.FileTransfer.IJSONFileTransferService"
        name="MyJSONFileTransferEP">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
      <endpoint address="http://localhost:2544/filetransfer/pox" behaviorConfiguration="WebHttpEPBehavior"
        binding="webHttpBinding" bindingConfiguration="poxWeb" contract="Trezoro.WebAPI.FileTransfer.IPOXFileTransferService"
        name="MyPOXFileTransferEP">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
      <endpoint address="http://localhost:2545/filetransfer/soap" behaviorConfiguration="NetTcpEPBehavior"
        binding="customBinding" bindingConfiguration="netTcpCustom"
        contract="Trezoro.WebAPI.FileTransfer.ISOAPFileTransferService"
        name="MySOAPFileTransferEP">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
      <endpoint address="net.tcp://localhost:2545/filetransfer/nettcpMex"
        binding="netTcpBinding" bindingConfiguration="" contract="IMetadataExchange"
        name="filetransfermex">
        <identity>
          <certificateReference storeName="My" storeLocation="LocalMachine"
            x509FindType="FindBySubjectDistinguishedName" />
        </identity>
      </endpoint>
    </client>
    <bindings>
      <basicHttpBinding>
        <binding name="soapWeb" />
        <binding name="httpLargeMessageStream"
                 closeTimeout="00:01:00"
                 openTimeout="00:01:00"
                 receiveTimeout="00:10:00"
                 sendTimeout="00:01:00"
                 allowCookies="false"
                 bypassProxyOnLocal="false"
                 hostNameComparisonMode="StrongWildcard"
                 maxBufferSize="2147483647"
                 maxBufferPoolSize="2147483647"
                 maxReceivedMessageSize="2147483647"
                 messageEncoding="Text"
                 textEncoding="utf-8"
                 transferMode="StreamedRequest"
                 useDefaultWebProxy="true">
          <readerQuotas maxDepth="32"
                        maxStringContentLength="8192"
                        maxArrayLength="16384"
                        maxBytesPerRead="4096"
                        maxNameTableCharCount="16384" />
          <security mode="None">
            <transport clientCredentialType="None"
                       proxyCredentialType="None"
                       realm="" />
            <message clientCredentialType="UserName"
                     algorithmSuite="Default" />
          </security>
        </binding>
      </basicHttpBinding>
      <customBinding>
        <binding name="netTcpCustom"
                 closeTimeout="00:01:00"
                 openTimeout="00:01:00"
                 receiveTimeout="00:10:00"
                 sendTimeout="00:01:00">
          <reliableSession />
          <compositeDuplex />
          <oneWay />
          <windowsStreamSecurity protectionLevel="None" />
          <mtomMessageEncoding  />
          <tcpTransport maxBufferPoolSize="524288"
                        maxReceivedMessageSize="2147483647"
                        connectionBufferSize="8192"
                        hostNameComparisonMode="StrongWildcard"
                        channelInitializationTimeout="00:01:00"
                        maxBufferSize="2147483647"
                        maxPendingConnections="20"
                        maxOutputDelay="00:00:00.2000000"
                        maxPendingAccepts="5"
                        transferMode="StreamedRequest"
                        listenBacklog="20"
                        portSharingEnabled="false"
                        teredoEnabled="false">
            <connectionPoolSettings groupName="default" leaseTimeout="00:05:00"
                idleTimeout="00:02:00" maxOutboundConnectionsPerEndpoint="20" />
          </tcpTransport>
        </binding>
      </customBinding>
      <netTcpBinding>
        <binding name="netTcpWeb"
                 hostNameComparisonMode="StrongWildcard"
                 closeTimeout="00:01:00"
                 openTimeout="00:01:00"
                 receiveTimeout="00:10:00"
                 sendTimeout="00:01:00"
                 maxReceivedMessageSize="2147483647"
                 transferMode="StreamedRequest"
                 portSharingEnabled="false">
          <security mode="None" />
        </binding>
      </netTcpBinding>
      <webHttpBinding>
        <binding name="poxWeb"
                 maxBufferSize="1500000"
                 maxBufferPoolSize="1500000"
                 maxReceivedMessageSize="1500000">
          <readerQuotas maxDepth="32"
                        maxStringContentLength="656000"
                        maxArrayLength="656000"
                        maxBytesPerRead="656000"
                        maxNameTableCharCount="656000" />
        </binding>
        <binding name="jsonWeb"
                 maxBufferSize="1500000"
                 maxBufferPoolSize="1500000"
                 maxReceivedMessageSize="1500000">
          <readerQuotas maxDepth="32"
                        maxStringContentLength="656000"
                        maxArrayLength="656000"
                        maxBytesPerRead="656000"
                        maxNameTableCharCount="656000" />
        </binding>
      </webHttpBinding>
    </bindings>
    <services>
      <service behaviorConfiguration="Default" name="Trezoro.WebAPI.Authentication.AuthService">
        <endpoint address="json" behaviorConfiguration="WebHttpEPBehavior"
          binding="webHttpBinding" bindingConfiguration="jsonWeb" name="MyJSONAuthEP"
          contract="Trezoro.WebAPI.Authentication.IJSONAuthService" />
        <endpoint address="pox" behaviorConfiguration="WebHttpEPBehavior"
          binding="webHttpBinding" bindingConfiguration="poxWeb" name="MyPOXAuthEP"
          contract="Trezoro.WebAPI.Authentication.IPOXAuthService" />
        <endpoint address="soap" behaviorConfiguration="BasicHttpEPBehavior"
          binding="basicHttpBinding" bindingConfiguration="soapWeb" name="MySOAPAuthEP"
          contract="Trezoro.WebAPI.Authentication.ISOAPAuthService" />
        <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" />
        <host>
          <baseAddresses>
            <add baseAddress="http://localhost:2542/auth/" />
          </baseAddresses>
        </host>
      </service>
      <service behaviorConfiguration="Default" name="Trezoro.WebAPI.Trade.TradeService">
        <endpoint address="json" behaviorConfiguration="WebHttpEPBehavior"
          binding="webHttpBinding" bindingConfiguration="jsonWeb" name="MyJSONTradeEP"
          contract="Trezoro.WebAPI.Trade.IJSONTradeService" />
        <endpoint address="pox" behaviorConfiguration="WebHttpEPBehavior"
          binding="webHttpBinding" bindingConfiguration="poxWeb" name="MyPOXTradeEP"
          contract="Trezoro.WebAPI.Trade.IPOXTradeService" />
        <endpoint address="soap" behaviorConfiguration="BasicHttpEPBehavior"
          binding="basicHttpBinding" bindingConfiguration="soapWeb" name="MySOAPTradeEP"
          contract="Trezoro.WebAPI.Trade.ISOAPTradeService" />
        <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" />
        <host>
          <baseAddresses>
            <add baseAddress="http://localhost:2543/trade/" />
          </baseAddresses>
        </host>
      </service>
      <service behaviorConfiguration="transferServiceBehavior" name="Trezoro.WebAPI.FileTransfer.FileTransferService">
        <endpoint address="json" behaviorConfiguration="WebHttpEPBehavior"
          binding="webHttpBinding" bindingConfiguration="jsonWeb" name="MyJSONFileTransferEP"
          contract="Trezoro.WebAPI.FileTransfer.IJSONFileTransferService" />
        <endpoint address="pox" behaviorConfiguration="WebHttpEPBehavior"
          binding="webHttpBinding" bindingConfiguration="poxWeb" name="MyPOXFileTransferEP"
          contract="Trezoro.WebAPI.FileTransfer.IPOXFileTransferService" />
        <endpoint address="httpMex" binding="mexHttpBinding" bindingConfiguration=""
          contract="IMetadataExchange" />
        <endpoint address="soap" behaviorConfiguration="NetTcpEPBehavior"
          binding="customBinding" bindingConfiguration="netTcpCustom"
          name="MySOAPFileTransferEP" contract="Trezoro.WebAPI.FileTransfer.ISOAPFileTransferService" />
        <endpoint address="nettcpMex" binding="netTcpBinding" bindingConfiguration=""
          contract="IMetadataExchange" />
        <host>
          <baseAddresses>
            <add baseAddress="http://localhost:2544/filetransfer/" />
            <add baseAddress="net.tcp://localhost:2544/filetransfer/" />
          </baseAddresses>
        </host>
      </service>
    </services>
    <behaviors>
      <endpointBehaviors>
        <behavior name="WebHttpEPBehavior">
          <webHttp />
        </behavior>
        <behavior name="BasicHttpEPBehavior" />
        <behavior name="NetTcpEPBehavior" />
      </endpointBehaviors>
      <serviceBehaviors>
        <behavior name="Default">
          <serviceMetadata httpGetEnabled="true" />
          <serviceDebug includeExceptionDetailInFaults="true" />
          <dataContractSerializer maxItemsInObjectGraph="2147483647"/>
        </behavior>
        <behavior name="transferServiceBehavior">
          <serviceMetadata httpGetEnabled="true"/>
          <serviceDebug includeExceptionDetailInFaults="true" />
          <dataContractSerializer maxItemsInObjectGraph="2147483647"/>
        </behavior>
      </serviceBehaviors>
    </behaviors>
  </system.serviceModel>

Any and all suggestions much appreciated. Thanks for your help.

Was it helpful?

Solution

Well, does the StreamedRequest method work if you drop the reliable session element? Could you live with that? If you're using netTcp, you're probably behind a corporate firewall, right? So you could possibly get away without the reliable session overhead....

Also - WCF has so many options and possible combinations of features - not everything makes sense, and not everything will work together - maybe this is just a limitation in WCF, not a configuration problem on your part.

The only odd thing about your config is the mtomMessageEncoding in your netTcp custom binding - why not use the much more efficient binary encoding??

<binding name="netTcpCustom"
         closeTimeout="00:01:00"
         openTimeout="00:01:00"
         receiveTimeout="00:10:00"
         sendTimeout="00:01:00">
  <reliableSession />
  <compositeDuplex />
  <oneWay />
  <windowsStreamSecurity protectionLevel="None" />
  <mtomMessageEncoding  />
  <tcpTransport maxBufferPoolSize="524288"

Why not use 

  <binaryMessageEncoding />

instead??

Licensed under: CC-BY-SA with attribution
Not affiliated with StackOverflow
scroll top