обработка одновременных звонков в WCF - PullRequest
Новая
       19

обработка одновременных звонков в WCF

3 голосов
/ 30 января 2012

Я новичок в .net и очень мало знаю о WCF, так что терпите меня, если возникнут глупые вопросы. Мне интересно, как WCF обрабатывает одновременные вызовы в сценарии SELF-HOST, если мой код явно не порождает какой-либо поток. Итак, после прочтения большого количества данных в стеке, я создал тестовое приложение, но оно, похоже, не работает. Пожалуйста, порекомендуйте. Большое спасибо.

Обратите внимание ...

  1. Мой вопрос касается только WCF САМОСТОЯТЕЛЬНЫЙ ХОСТИНГ , поэтому, пожалуйста, не обращайтесь к IIS.
  2. Я использую webHttpBinding .
  3. Я понимаю, что есть maxConnection и настройки регулирования обслуживания, но меня интересуют только 2 одновременных вызова в моей настройке исследования. Так что не должно быть никаких проблем с максимальным соединением или пулом потоков.
  4. Мой тестовый сервис НЕ , использующий сеанс.

Код, как показано ниже ... 

namespace myApp
{
  [ServiceContract(SessionMode = SessionMode.NotAllowed)]
  public interface ITestService
  {
    [OperationContract]
    [WebGet(UriTemplate="test?id={id}")]
    string Test(int id);
  }

  [ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall, 
                   ConcurrencyMode = ConcurrencyMode.Multiple)]
  public class TestService : ITestService
  {
    private static ManualResetEvent done = new ManualResetEvent(false);

    public string Test(int id)
    {
      if (id == 1)
      {
        done.Reset();
        done.WaitOne();
      }
      else
      {
        done.Set();
      }
    }
  } 
}

app.config ... 

  <system.serviceModel>
    <behaviors>
      <endpointBehaviors>
        <behavior name = "TestEndpointBehavior">
          <webHttp/>
        </behavior>
      </endpointBehaviors>
    </behaviors>
    <services>
      <service name = "myApp.TestService">
        <endpoint address = "" behaviorConfiguration="TestEndpointBehavior"
                  binding = "webHttpBinding"
                  contract = "myApp.ITestService">
        </endpoint>
        <host>
          <baseAddresses>
            <add baseAddress="http://localhost:8080/test/"/>
          </baseAddresses>
        </host>
      </service>
    </services>
  </system.serviceModel>
  <system.web>
    <sessionState mode = "Off" />
  </system.web>

Как я проверял ...

Как только приложение запустилось, я открыл браузер, на всякий случай FF, сделал один вызов http://localhost:8080/test/test?id=1. Этот запрос переводит приложение в режим ожидания сигнала, т.е. WaitOne. Затем сделал еще один вызов на другой вкладке браузера на http://localhost:8080/test/test?id=2.. Ожидается, что этот запрос установит сигнал и, следовательно, сервер вернется для обоих запросов.

Но я видел, что приложение зависло, и функция Test не была введена для второго запроса. Так что, очевидно, мой код не поддерживает одновременные / параллельные вызовы. Ничего плохого?

1 Ответ

0 голосов
/ 03 апреля 2012

Вы можете использовать один класс для настройки службы wcf и отказа от интерфейса.Вам также необходимо добавить файл global.asax.После того, как вы сделаете второй вызов, все они вернутся «завершено».

Эта конфигурация делает то, что вы хотите.Создайте TestService.cs с помощью: 

[AspNetCompatibilityRequirements(RequirementsMode = AspNetCompatibilityRequirementsMode.Allowed)]
[ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall,
             ConcurrencyMode = ConcurrencyMode.Multiple)]
[ServiceContract(SessionMode = SessionMode.NotAllowed)]
public class TestService
{
    private static ManualResetEvent done = new ManualResetEvent(false);

    [OperationContract]
    [WebGet(UriTemplate = "test?id={id}")]
    public string Test(int id)
    {
        if (id == 1)
        {
            done.Reset();
            done.WaitOne();
        }
        else
        {
            done.Set();
        }
        return "finished";
    }


}

web.config: 

<configuration>
<system.web>
  <compilation debug="true" targetFramework="4.0" />
</system.web>
<system.webServer>
 <modules runAllManagedModulesForAllRequests="true" />
</system.webServer>
<system.serviceModel>
<standardEndpoints>
<webHttpEndpoint>
    <!-- 
        Configure the WCF REST service base address via the global.asax.cs file and the default endpoint 
        via the attributes on the <standardEndpoint> element below
    -->
<standardEndpoint name="" helpEnabled="false"  >    </standardEndpoint>


  </webHttpEndpoint>
</standardEndpoints>
<behaviors>
  <serviceBehaviors>
    <behavior>

      <!-- To avoid disclosing metadata information, set the value below to false and remove the metadata endpoint above before deployment -->
      <serviceMetadata httpGetEnabled="true" />
      <!-- To receive exception details in faults for debugging purposes, set the value below to true.  Set to false before deployment to avoid disclosing exception information -->
      <serviceDebug includeExceptionDetailInFaults="false" />
    </behavior>
  </serviceBehaviors>
</behaviors>

<serviceHostingEnvironment aspNetCompatibilityEnabled="true" multipleSiteBindingsEnabled="true" />
</system.serviceModel>
</configuration>

Файл Global.asax: 

public class Global : System.Web.HttpApplication
{

    protected void Application_Start(object sender, EventArgs e)
    {
        RouteTable.Routes.Add(new ServiceRoute("testservice", new WebServiceHostFactory(), typeof(TestService)));
    }
}
...