WCF流端点冻结服务器

Question

如果这个问题已经得到了回答，我很抱歉，我似乎无法谷歌这个权利来得到我的答案。

我有一个服务器和客户端应用程序设置与WCF通信和工作非常好。我的一个端点是将HTTP用于流目的(例如上传和下载文件)。我遇到的问题是，当上传和下载文件时，服务器应用程序挂起(冻结)，就好像它在主线程上运行一样。这可以防止其他客户端向服务器请求。

注意:已尝试不同大小的文件都执行相同的症状。

服务器上的所有其他端点(tcp)都没有遇到相同的症状，它们正在运行多线程，并且当发送和检索数据时，服务器应用程序仍然对其他客户端做出响应。

我已经尝试了一些事情1)我设置了ServiceBehaviorAttributea. InstanceContextMode = InstanceContextMode。单b. ConcurrencyMode = ConcurrencyMode。多个2)尝试设置dispatcherSynchronization行为以及asynchronousSendEnabled="true"3)增大消息大小maxReceivedMessageSize

这件事我纠结了好一会儿，找不到帮助。 服务器配置

<system.serviceModel>
<bindings>
  <basicHttpBinding>
    <binding name="FileTransferServicesBinding" transferMode="Streamed" sendTimeout="20:00:00" receiveTimeout="20:00:00" messageEncoding="Mtom" bypassProxyOnLocal="true" maxReceivedMessageSize="2147483647"></binding>
  </basicHttpBinding>
</bindings>
<services>
  <service behaviorConfiguration="MyServiceTypeBehaviors" name="DoorWay.Transfers.FileTransferService">
    <endpoint behaviorConfiguration="AsyncStreaming" address="mex" binding="basicHttpBinding" bindingConfiguration="FileTransferServicesBinding" contract="DoorWay.Transfers.IFileTransferService" />
    <host>
      <baseAddresses>
        <add baseAddress="http://localhost:1650/FileTranfer"/>
      </baseAddresses>
    </host>
  </service>
</services>
<behaviors>
  <endpointBehaviors>
    <behavior name="AsyncStreaming">
      <dispatcherSynchronization asynchronousSendEnabled="true"/>
    </behavior>
  </endpointBehaviors>
  <serviceBehaviors>
    <behavior name="MyServiceTypeBehaviors">
      <serviceMetadata httpGetEnabled="true" />
      <serviceDebug includeExceptionDetailInFaults="true" />
    </behavior>
  </serviceBehaviors>
</behaviors>

传输接口

[ServiceContract]
public interface IFileTransferService
{
    [OperationContract]
    MetaDataRecieve UploadFile(RemoteFileInfo request);
    [OperationContract]
    RemoteFileInfo DownloadFile(DownloadRequest request);
}

转移类

[ServiceBehaviorAttribute(Name = "FileTransferService", InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Multiple)]
public class FileTransferService : IFileTransferService, IFileDownload
{
    public RemoteFileInfo DownloadFile(DownloadRequest request)
    {
        // get some info about the input file
        string filePath = System.IO.Path.Combine(Paths.ClientUpdates, request.FileName);
        System.IO.FileInfo fileInfo = new System.IO.FileInfo(filePath);
        // check if exists
        if (!fileInfo.Exists)
        {
            throw new Exception("File does not exist");
        }
        // open stream
        System.IO.FileStream stream = new System.IO.FileStream(filePath, System.IO.FileMode.Open, System.IO.FileAccess.Read);
        // return result
        RemoteFileInfo result = new RemoteFileInfo();
        result.FileName = request.FileName;
        result.Length = fileInfo.Length;
        result.FileByteStream = stream;
        return result;
    }
    public MetaDataRecieve UploadFile(RemoteFileInfo request)
    {
        return new MetaDataRecieve() { FileID = this.UploadFileGeneralFile(request) };  
    }
    private long UploadFileGeneralFile(RemoteFileInfo request)
    {
        FileDownloadPresenter presenter = new FileDownloadPresenter(this);
        GeneralAttachmentHelper attachement = new GeneralAttachmentHelper
        {
            FileDataStream = request.FileByteStream,
            Version = -1,
            FileName = request.FileName,
            FileType = request.FileType,
            TableTransfer = request.TableTransfer
        };
        presenter.UploadFile(attachement);
        return this.UploadedFileID;
    }
}

客户机配置

<system.serviceModel>
    <bindings>
        <basicHttpBinding>
            <binding name="BasicHttpBinding_IFileTransferService" messageEncoding="Mtom" />
        </basicHttpBinding>
    </bindings>
    <client>
        <endpoint address="http://localhost:1650/FileTranfer/mex" binding="basicHttpBinding"
            bindingConfiguration="BasicHttpBinding_IFileTransferService"
            contract="FileTransfer.IFileTransferService" name="BasicHttpBinding_IFileTransferService" />
    </client>
</system.serviceModel>

Test code for freeze I testing

    private void DummyTransferDebugTest()
    {
        string file = @"C:DataTempf629c263-e0ae-4120-b002-f6091bcfa3f5f629c263-e0ae-4120-b002-f6091bcfa3f5.rar";
        using (FileStream fileRead = new FileStream(file, FileMode.Open))
        {
            using (MemoryStream fileStream = new MemoryStream())
            {
                fileStream.SetLength(fileRead.Length);
                fileRead.Read(fileStream.GetBuffer(), 0, (int)fileRead.Length);
                FileTransfer.FileTransferServiceClient transferPresenter = (FileTransfer.FileTransferServiceClient)this.OpenProxy(new FileTransfer.FileTransferServiceClient());
                try
                {
                    System.IO.FileInfo fileInfo = new FileInfo(file);
                    using (StreamWithProgress streamProgress = new StreamWithProgress(fileStream))
                    {
                        transferPresenter.UploadFile(fileInfo.Name, this.debugFile.ToString(), fileInfo.Length, FileTransfer.TransferTableEnum.RASTERS, streamProgress);
                    }
                }
                catch
                {
                    throw;
                }
                finally
                {
                    this.CloseProxy(transferPresenter);
                }
            }
        }
    }

如果还有什么我可以提供的

Thanks a million

Answer 1

修复了这个问题，这个问题实际上不是关于如何设置配置或如何设置流端点，而是如何托管端点。

我使用一个应用程序来托管和管理我所有的服务引用。当以这种方式托管服务引用时，您还需要在单独的线程中打开服务主机。

我创建了一个线程管理器，将它添加到我的应用程序的基础，以便我可以处理它。