WCF流端点冻结服务器
本文关键字:服务器 冻结 端点 WCF | 更新日期: 2023-09-27 18:07:21
如果这个问题已经得到了回答,我很抱歉,我似乎无法谷歌这个权利来得到我的答案。
我有一个服务器和客户端应用程序设置与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:'Data'Temp'f629c263-e0ae-4120-b002-f6091bcfa3f5'f629c263-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
修复了这个问题,这个问题实际上不是关于如何设置配置或如何设置流端点,而是如何托管端点。
我使用一个应用程序来托管和管理我所有的服务引用。当以这种方式托管服务引用时,您还需要在单独的线程中打开服务主机。
我创建了一个线程管理器,将它添加到我的应用程序的基础,以便我可以处理它。