1

私は、WINDOWSサービスでホストされる計算エンジンを開発するためにWCFを使用するための最初の一歩を踏み出しました。このサービスはうまく機能していますが、すべての呼び出しに1つのスレッドしか使用していないようですが、スケーラブルでマルチスレッドを使用する必要があります。

このアプリケーションの人々の非常に初期の段階であるため、コードなどのすべてのトレースを無視してください。

サービスの起動時に情報をメモリに読み取るサードパーティソフトウェア(COM)(ThirdParty.Initialise(strInit))を呼び出し、ProcessInformationを呼び出すたびに、指定されたXML文字列から計算結果が返されます。

これまでのところ、ServiceBehavior attsを何に設定しても、また使用する個別のコンシューマーの数に関係なく、すべての呼び出しは1つのスレッドを使用しているように見えます-誰か助けてもらえますか?

コードの概要:

[ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Multiple, InstanceContextMode = InstanceContextMode.PerCall, UseSynchronizationContext = false)]
public class TestWCFService : ITestWCFService
{
    private static ThirdPartyLib.ThirdPartyComClass ThirdParty;

    private static bool initCalled = false;
    private static int cntInit = 0;
    private static int cntTrans = 0;

    public TestWCFService()
    {
        if (ThirdParty == null)
        {
            ThirdParty = new ThirdPartyLib.ThirdPartyComClass();
        }
    }

    public bool InitialiseThirdParty(string strInit, out string strError)
    {
        try
        {
            if (!initCalled)
            {
                cntInit++;
                ThirdParty.Initialise(strInit);
                initCalled = true;
            }
            strError = "Call Num " + cntInit;
            return true;
        }
        catch (Exception ex)
        {
            strError = "ThirdParty.Initialise exception " + ex.Message + " 0n call number " + cntInit;
            return false;
        }
    }

    public bool ProcessInformation(string strRequestXML, int quoteMarker, out string strResponseXML, out string strError, out int quoteMarkerReturned)
    {
        try
        {
            cntTrans++;
            quoteMarkerReturned = quoteMarker;
            ThirdParty.ProcessInformation(strRequestXML, out strResponseXML);
            strError = "Call Trans Num " + cntTrans;
            return true;
        }
        catch (Exception ex)
        {
            strError = ex.Message + " On call trans num " + cntTrans;
            strResponseXML = "Error";
            quoteMarkerReturned = quoteMarker;
            return false;
        }
    }
}

構成:

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <system.web>
    <compilation debug="true" />
  </system.web>
  <system.serviceModel>
    <bindings>
      <wsHttpBinding>
        <binding name="TestServiceBinding" bypassProxyOnLocal="true"
          useDefaultWebProxy="false">
          <readerQuotas maxDepth="524288" maxStringContentLength="524288"
            maxArrayLength="524288" maxBytesPerRead="524288" maxNameTableCharCount="524288" />
          <reliableSession inactivityTimeout="00:30:00" enabled="true" />
        </binding>
      </wsHttpBinding>
      <mexHttpBinding>
        <binding name="MEXTestServiceBinding" openTimeout="00:02:00"
          sendTimeout="00:02:00" />
      </mexHttpBinding>
    </bindings>
    <services>
      <service behaviorConfiguration="TestWcfServiceLibrary.TestWCFServiceBehavior"
        name="TestWcfServiceLibrary.TestWCFService">
        <endpoint address="" binding="wsHttpBinding" bindingConfiguration="TestServiceBinding"
          name="" contract="TestWcfServiceLibrary.ITestWCFService">
          <identity>
            <dns value="localhost" />
          </identity>
        </endpoint>
        <endpoint address="mex" binding="mexHttpBinding" bindingConfiguration="MEXTestServiceBinding"
          contract="IMetadataExchange" />
        <host>
          <baseAddresses>
            <add baseAddress="http://localhost:8731/Design_Time_Addresses/TestWcfServiceLibrary/TestWCFService/" />
          </baseAddresses>
        </host>
      </service>
    </services>
    <behaviors>
      <serviceBehaviors>
        <behavior name="TestWcfServiceLibrary.TestWCFServiceBehavior">
          <serviceMetadata httpGetEnabled="True"/>
          <serviceThrottling maxConcurrentCalls="100" maxConcurrentSessions="100" maxConcurrentInstances="100"/>
          <serviceDebug includeExceptionDetailInFaults="False" />
        </behavior>
      </serviceBehaviors>
    </behaviors>
  </system.serviceModel>
</configuration>
4

3 に答える 3

2

サード パーティの COM コンポーネントがアパートメント スレッド化されているため、スレッド アフィニティを持っている可能性が非常に高いようです。その場合、COM コンポーネント内で作業を行うスレッドは 1 つだけになります。

サービスの実装によって多くの .NET スレッドが使用されていますが、COM オブジェクトを呼び出すことができる唯一の STA スレッドを使用するために、すべてのスレッドがキューに入れられる必要があります。

于 2012-07-31T14:37:55.687 に答える
1

Microsoft ドキュメントごと:

同時実行の使用は、インスタンス化モードに関連しています。PerCall インスタンス化では、各メッセージが新しいサービス インスタンスによって処理されるため、同時実行性は関係ありません。

// Multiple allows concurrent processing of multiple messages by a service instance.
// The service implementation should be thread-safe. This can be used to increase throughput.
[ServiceBehavior(ConcurrencyMode=ConcurrencyMode.Multiple, InstanceContextMode = InstanceContextMode.Single)]

// Uses Thread.Sleep to vary the execution time of each operation.
public class CalculatorService : ICalculatorConcurrency
{
    int operationCount;

    public double Add(double n1, double n2)
    {
        operationCount++;
        System.Threading.Thread.Sleep(180);
        return n1 + n2;
    }

    public double Subtract(double n1, double n2)
    {
        operationCount++;
        System.Threading.Thread.Sleep(100);
        return n1 - n2;
    }

    public double Multiply(double n1, double n2)
    {
        operationCount++;
        System.Threading.Thread.Sleep(150);
        return n1 * n2;
    }

    public double Divide(double n1, double n2)
    {
        operationCount++;
        System.Threading.Thread.Sleep(120);
        return n1 / n2;
    }

    public string GetConcurrencyMode()
    {   
        // Return the ConcurrencyMode of the service.
        ServiceHost host = (ServiceHost)OperationContext.Current.Host;
        ServiceBehaviorAttribute behavior = host.Description.Behaviors.Find<ServiceBehaviorAttribute>();
        return behavior.ConcurrencyMode.ToString();
    }

    public int GetOperationCount()
    {   
        // Return the number of operations.
        return operationCount;
    }
}

出力例: ([] 内の数字はスレッド ID を示します)

2012-07-31 09:07:28,509 [9] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Leaving: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double, double) : 752.919376325402
2012-07-31 09:07:28,512 [17] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Leaving: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double, double) : 752.919376325402
2012-07-31 09:07:28,524 [13] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Leaving: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double, double) : 2143.10173334651
2012-07-31 09:07:28,524 [11] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Entering: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double n1 = 15.5665354410031, double n2 = 48.3678194919451)
2012-07-31 09:07:28,532 [22] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Entering: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double n1 = 94.7194438868758, double n2 = 29.8120223590229)
2012-07-31 09:07:28,534 [9] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Entering: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double n1 = 99.2045067247024, double n2 = 88.4957458770349)
2012-07-31 09:07:28,539 [4] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Entering: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double n1 = 99.2045067247024, double n2 = 88.4957458770349)
2012-07-31 09:07:28,539 [7] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Entering: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double n1 = 37.991849630136, double n2 = 41.7864370820049)
2012-07-31 09:07:28,539 [17] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Entering: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double n1 = 11.331077670367, double n2 = 55.5888338273339)
2012-07-31 09:07:28,539 [11] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Leaving: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double, double) : 752.919376325402
2012-07-31 09:07:28,539 [22] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Leaving: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double, double) : 2823.77817898976
2012-07-31 09:07:28,539 [17] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Leaving: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double, double) : 629.881393702645
2012-07-31 09:07:28,542 [9] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Leaving: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double, double) : 8779.17681696586
2012-07-31 09:07:28,544 [4] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Leaving: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double, double) : 8779.17681696586
2012-07-31 09:07:28,544 [7] DEBUG Microsoft.ServiceModel.Samples.CalculatorService - Leaving: Microsoft.ServiceModel.Samples.CalculatorService.Multiply(double, double) : 1587.54403419867
于 2012-07-31T11:55:45.957 に答える
0

問題は、サード パーティの DLL がシングル スレッドの COM モデルにすぎないことです。私はそれがマルチスレッドであると信じるようになりましたが、代替関数を実行することで、100% サード パーティの問題になりました。とにかく、すべての迅速な回答に感謝します。いくつかの余分なコアを利用するには、派手なフットワークが必要になるようです。MTバージョンがあるかどうか会社にメールを送りましたが、疑わしいです。再度、感謝します。

于 2012-08-01T11:26:48.960 に答える