zoukankan      html  css  js  c++  java

  • WCF 第五章 控制并发实例的数量

    默认情况下，WCF 宿主将会启动尽可能多的实例来处理请求消息。如果一个服务的实例和并发行为并没有确定，WCF将会为每个进入的请求创建一个服务实例同时将按照需要分配线程来反应请求。总体来说这是一个对性能和扩展性都很好的解决方案因为服务将会最大化扩展硬件性能。

      但是有很多情况你可能想舍弃使用这种行为。为了这个目的，有三种在并发和实例上的设置可以实现。这些定义在配置文件的行为组分的serviceThrottling元素里。

      maxConcurrentInstances行为控制有多少个服务实例可以被一个服务创建。这个设置是有用的如果 ConcurrencyMode是PerCall或者PerSession,因为这两个设置都可以指导WCF按照要求创建实例。通过定义WCF可以创建的 实例的最大数目，你设置的实例数目的上限将会存储在内存中。当限制达到时，不会有更多的实例被创建除非其他实例被回收或重用。

      列表5.6显示了一个没有确定ConcurrencyMode和InstancingMode的服务，这意味着将会使用默认值Single和PerSession.服务操作花费20秒完成。

    列表5.6 使用默认并发和实例行为的服务

    01[ServiceContract]
    02public interface IStockService
    03{
    04    [OperationContract]
    05    double GetPrice(string ticker);
    06}
    07 
    08public class StockService : IStockService
    09{
    10    StockService()
    11    {
    12        Console.WriteLine("{0}:Created new instance of StockService on thread", DateTime.Now);
    13    }
    14    public StockPrice GetPrice(string ticker)
    15    {
    16        Console.WriteLine("{0}: GetPrice called on thread {1}", DateTime.Now, Thread.CurrentThread.ManagedThreadId);
    17        Thread.Sleep(2000);
    18        return 94.85;
    19    }
    20}

      列表5.7 显示了一个异步调用服务端10次的客户端

    01class Program
    02{
    03    static int c = 0;
    04    static void Main(string[] args)
    05    {
    06        Console.WriteLine();
    07        StockServiceClient p = new StockServiceClient();
    08        for (int i = 0; i < 10; i++)
    09        {
    10            Console.WriteLine("{0}: Calling GetPrice", DateTime.Now);
    11            p.BeginGetPrice("MSFT", GetPriceCallback, p);
    12            Interlocked.Increment(ref c);
    13        }
    14        while (c > 0) //wait until all responses come back
    15        {
    16            Thread.Sleep(100);
    17        }
    18        Console.ReadLine();
    19    }
    20    static void GetPriceCallback(IAsyncResult ar)
    21    {
    22        try
    23        {
    24            StockPrice p = ((StockServiceClient)ar.AsyncState).EndGetPrice(ar);
    25            Console.WriteLine("{0}: Price: {1}", DateTime.Now, p.price);
    26            ((StockServiceClient)ar.AsyncState).Close();
    27            Interlocked.Decrement(ref c);
    28        }
    29        catch (Exception ex)
    30        {
    31            Console.WriteLine(ex.InnerException.Message);
    32        }
    33    }
    34}

    列表5.8 显示了服务端的app.config文件。maxConcurrentInstances行为被设置成5，指示在服务端不会创建多于5个实例。

    列表5.8 使用maxConcurrentInstances限制并发数量

    01<?xml version="1.0" encoding="utf-8" ?>
    02<configuration>
    03    <system.serviceModel>
    04        <bindings />
    05        <behaviors>
    06            <serviceBehaviors>
    07                <behavior name="throttling">
    08                    <serviceThrottling maxConcurrentInstances="5" />
    09                </behavior>
    10            </serviceBehaviors>
    11        </behaviors>
    12        <services>
    13            <service behaviorConfiguration="throttling" name="Services.StockService">
    14                <endpoint address="" binding="basicHttpBinding" contract="Services.IStockService" />
    15                <host>
    16                    <baseAddresses>
    17                        <add baseAddress="http://localhost:8000/stockservice" />
    18                    </baseAddresses>
    19                </host>
    20            </service>
    21        </services>
    22    </system.serviceModel>
    23</configuration>

      图片5.6显示了客户端(左边)输出和服务端(右边)输出。在客户端，注意当程序启动时10次调用是如何立即执行的，然后5个结果在20秒钟后 返回而另外5个结果在另外20秒钟后返回。在服务端输出，注意前5个实例是如何在客户端请求到来时立即创建的，但是另外5个实例没有创建直到前5个实例关 闭了以后。

    图片5.6 控制并发实例的输出


    ==========

    转载自

     
  • 相关阅读:
    初学python遇到的第一个坑
    返回列表中最长的连续字符串
    输入一个数字，求每一位相加之和
    判断一个数是否为素数
    编写一个函数，它接受一个或多个单词的字符串，并返回相同的字符串，但所有五个或多个字母的单词都颠倒过来
    判断10步能不能回到原点
    完成方法/函数，以便将破折号/下划线分隔的单词转换为驼峰式大小写
    求公共汽车上的人数
    写一个函数，返回不同的计数
    对一个数的每一位数字求平方
  • 原文地址：https://www.cnblogs.com/llbofchina/p/2094053.html
Copyright © 2011-2022 走看看