Ale*_*lex 6 c# sockets wcf multithreading net.tcp
我在WCF服务中遇到了一个非常奇怪的错误,当我使用NetTcpBinding时,它似乎以某种方式在套接字级别创建了死锁或线程饥饿.我有一个非常简单的自托管服务:
class Program
{
static void Main(string[] args)
{
using (ServiceHost serviceHost = new ServiceHost(typeof(TestService)))
{
serviceHost.Open();
Console.WriteLine("Press <ENTER> to terminate service.");
Console.ReadLine();
serviceHost.Close();
}
Uri baseAddress = new Uri("net.tcp://localhost:8014/TestService.svc");
}
}
[ServiceContract]
public interface ITestService
{
[OperationContract]
string GetData(string data);
}
public class TestService: ITestService
{
public string GetData(string data)
{
Console.WriteLine(data);
Thread.Sleep(5000);
return "Ok";
}
}
Run Code Online (Sandbox Code Playgroud)
配置部分:
<system.serviceModel>
<bindings>
<basicHttpBinding>
<binding name="basicHttpBinding" closeTimeout="00:02:00" openTimeout="00:02:00"
receiveTimeout="00:02:00" sendTimeout="00:02:00" maxBufferSize="2000000000"
maxReceivedMessageSize="2000000000" />
</basicHttpBinding>
<netTcpBinding>
<binding name="netTcpBinding" closeTimeout="00:02:00" openTimeout="00:02:00"
receiveTimeout="00:02:00" sendTimeout="00:02:00" listenBacklog="2000"
maxBufferSize="2000000000" maxConnections="1000" maxReceivedMessageSize="2000000000">
<security mode="None">
<transport protectionLevel="EncryptAndSign" />
</security>
</binding>
<binding name="TestServiceTcpEndPoint">
<security mode="None" />
</binding>
</netTcpBinding>
</bindings>
<behaviors>
<serviceBehaviors>
<behavior name="CommonServiceBehavior">
<serviceMetadata httpGetEnabled="true" />
<serviceDebug includeExceptionDetailInFaults="true" />
<serviceThrottling maxConcurrentCalls="1000" maxConcurrentSessions="1000" maxConcurrentInstances="1000" />
</behavior>
</serviceBehaviors>
</behaviors>
<services>
<service name="ServiceLauncher.TestService" behaviorConfiguration="CommonServiceBehavior">
<endpoint address="" binding="netTcpBinding" bindingConfiguration="netTcpBinding" name="TestServiceTcpEndPoint" contract="ServiceLauncher.ITestService" />
<endpoint address="" binding="basicHttpBinding" bindingConfiguration="basicHttpBinding" name="TestServiceTcpEndPoint" contract="ServiceLauncher.ITestService" />
<endpoint address="mex" binding="mexHttpBinding" bindingName="mexHttpBinding" contract="IMetadataExchange" />
<host>
<baseAddresses>
<add baseAddress="net.tcp://localhost:8014/TestService.svc"/>
<add baseAddress="http://localhost:1234/TestService.svc"/>
</baseAddresses>
</host>
</service>
</services>
</system.serviceModel>
Run Code Online (Sandbox Code Playgroud)
我有一个客户端在许多线程中使用这个服务,为每个线程创建新实例(这是一个要求):
static void Main(string[] args)
{
for (int i = 0; i < 1000; i++)
{
Thread tr = new Thread(() =>
{
using (var service = new Test.TestServiceClient())
{
var result = service.GetData(i.ToString());
Console.WriteLine(string.Format("{0}: {1} {2}",
DateTime.Now,
result,
Thread.CurrentThread.ManagedThreadId));
}
});
tr.Start();
}
Console.ReadLine();
}
Run Code Online (Sandbox Code Playgroud)
在这种情况下,在一些请求客户端引发EndpointNotFoundException,TCP错误代码10061之后,由于目标机器主动拒绝它,因此无法建立连接.请求的数量始终不同,并且它不是服务器部分,因为它仍然在正常状态下工作.而且我看到它不断收到请求,在这种情况下最奇怪的是什么.奇怪的是,它可以使你的客户端主机在异常后成为"不朽" - 所以除了系统的重启之外,你不能以任何方式杀死它.我很确定问题是在客户端的低套接字级别,并且它以某种方式与如此大量的线程连接,但我没有成功找到可以解释问题的东西.
每次我看到错误“无法建立连接,因为目标计算机主动拒绝它”。问题不在于服务。这通常是访问服务时出现问题。
\n\n一些建议:
\n\n避免using
使用 WCF 代理。您可以从几种合理的解决方法中进行选择。
阅读我对WCF 性能、延迟和可扩展性的回答。除了以老式方式启动线程之外,它基本上是相同的测试应用程序。该帖子描述了导致 \xe2\x80\x9c 无法建立连接的所有客户端原因(我能找到),因为目标计算机主动拒绝了 \xe2\x80\x9d 并提供了不同的 WCF、TCP 和线程池设置,可以予以调整。
归档时间: |
|
查看次数: |
840 次 |
最近记录: |