Изменение уровней совместного использования кэша для действий «Send»

Расширение SendMessageChannelCache позволяет изменить уровни доступа к кэшу, настройки кэша фабрик каналов и настройки кэша канала для рабочих потоков, направляющих сообщения в конечные точки с использованием действий обмена сообщениями Send. Эти рабочие процессы обычно являются клиентскими, но также могут быть службами рабочих процессов, размещенными в WorkflowServiceHost. Кэш фабрик каналов содержит кэшированные объекты ChannelFactory<TChannel>. Кэш каналов содержит кэшированные каналы.

Уровни совместного использования кэша

По умолчанию в рабочем процессе, размещенном в WorkflowServiceHost, кэш, используемый действиями отправки сообщений Send, совместно используется всеми экземплярами рабочих потоков в WorkflowServiceHost (кэширование уровня узла). Для клиентского рабочего процесса, не размещенного в WorkflowServiceHost, кэш доступен только для экземпляра рабочего процесса (кэширование уровня экземпляра). Кэш доступен только для действий Send, не использующих конечные точки, определенные в конфигурации, если только не включено небезопасное кэширование.

Ниже приводятся различные уровни совместного использования кэширования, доступные для действий Send в рабочем процессе, и рекомендации по их использованию.

• Уровень узла. На уровне общего доступа узла кэш доступен только для экземпляров рабочих процессов, размещенных в узле службы рабочих процессов. Кэш может также совместно использоваться узлами служб рабочих процессов в кэше всего процесса.

• Уровень экземпляра. На уровне общего доступа экземпляра кэш доступен для определенного экземпляра рабочего процесса в течение всего времени существования, но кэш недоступен другим экземплярам рабочих процессов.

• Нет кэша: кэш отключен по умолчанию, если у вас есть рабочий процесс, использующий конечные точки, определенные в конфигурации. В этом случае также рекомендуется отключить кэширование, поскольку его использование может быть небезопасным. Например, если для каждой операции отправки требуется отдельный идентификатор (другие учетные данные или олицетворение).

Изменение уровня совместного использования кэша для клиентского рабочего процесса

Чтобы задать совместное использование кэша в клиентском рабочем процессе, добавьте экземпляр класса SendMessageChannelCache в качестве расширения к требуемому набору экземпляров рабочих процессов. Это приведет к совместному использованию кэша всеми экземплярами рабочих процессов. В следующих примерах кода показано выполнение этих шагов.

Сначала объявите экземпляр типа SendMessageChannelCache.

// Create an instance of SendMessageChannelCache with default cache settings.  
static SendMessageChannelCache sharedChannelCacheExtension =  
    new SendMessageChannelCache();  

Затем добавьте расширение кэша каждому экземпляру клиентского рабочего процесса.

WorkflowApplication clientInstance1 = new WorkflowApplication(new clientWorkflow1());  
WorkflowApplication clientInstance2 = new WorkflowApplication(new clientWorkflow2());  
  
// Share the cache extension object
  
clientInstance1.Extensions.Add(sharedChannelCacheExtension);  
clientInstance2.Extensions.Add(sharedChannelCacheExtension);  

Изменение уровня совместного использования кэша для размещенной службы рабочего процесса

Чтобы задать совместное использование кэша в размещенной службе рабочего процесса, добавьте экземпляр класса SendMessageChannelCache в качестве модуля всем узлам служб рабочих процессов. Это приведет к совместному использованию кэша всеми узлами служб рабочих процессов. В следующих примерах кода показано выполнение этих шагов.

Сначала объявите экземпляр типа SendMessageChannelCache на уровне класса.

// Create static instance of SendMessageChannelCache with default cache settings.  
static SendMessageChannelCache sharedChannelCacheExtension = new  
    SendMessageChannelCache();  

Затем добавьте статическое расширение кэша каждому узлу службы рабочего процесса.

WorkflowServiceHost host1 = new WorkflowServiceHost(new serviceWorkflow1(), new Uri(baseAddress1));  
WorkflowServiceHost host2 = new WorkflowServiceHost(new serviceWorkflow2(), new Uri(baseAddress2));  
  
// Share the static cache to get an AppDomain level cache.  
host1.WorkflowExtensions.Add(sharedChannelCacheExtension);  
host2.WorkflowExtensions.Add(sharedChannelCacheExtension);  

Чтобы перевести совместное использование кэша в размещенной службе рабочего процесса до уровня экземпляра, добавьте делегат Func<SendMessageChannelCache> в качестве расширения в узел службы рабочего процесса и присвойте его коду, который создаст новый экземпляр класса SendMessageChannelCache. Это приведет к использованию разного кэша для каждого отдельно взятого экземпляра рабочего процесса вместо одного кэша для всех экземпляров рабочих процессов на узле службы рабочего процесса. В следующем примере кода показано выполнение этой операции при помощи лямбда-выражения с целью прямого определения модуля SendMessageChannelCache, на который указывает делегат.

serviceHost.WorkflowExtensions.Add(() => new SendMessageChannelCache  
{  
    // Use FactorySettings property to add custom factory cache settings.  
    FactorySettings = new ChannelCacheSettings
    { MaxItemsInCache = 5, },  
    // Use ChannelSettings property to add custom channel cache settings.  
    ChannelSettings = new ChannelCacheSettings
    { MaxItemsInCache = 10 },  
});  

Настройка параметров кэша

Параметры кэша можно настраивать для кэша фабрик каналов и кэша каналов. Параметры кэша определяются в классе ChannelCacheSettings. Класс SendMessageChannelCache определяет параметры кэша по умолчанию для кэша фабрики каналов и кэша каналов в его конструкторе без параметров. Далее приведена таблица, в которой перечислены значения по умолчанию для этих параметров кэша по каждому типу кэша.

Для изменения параметров кэша фабрик и кэша каналов создайте экземпляр класса SendMessageChannelCache при помощи параметризованного конструктора SendMessageChannelCache и передайте новый экземпляр ChannelCacheSettings с пользовательскими значениями каждому из параметров factorySettings и channelSettings. Далее добавьте новый экземпляр этого класса как расширение для узла службы рабочего процесса или экземпляра рабочего процесса. В следующем примере кода показано выполнение этих шагов для экземпляра рабочего процесса.

ChannelCacheSettings factorySettings = new ChannelCacheSettings{  
                        MaxItemsInCache = 5,
                        IdleTimeout = TimeSpan.FromMinutes(5),
                        LeaseTimeout = TimeSpan.FromMinutes(20)};  
  
ChannelCacheSettings channelSettings = new ChannelCacheSettings{  
                        MaxItemsInCache = 5,
                        IdleTimeout = TimeSpan.FromMinutes(2),  
                        LeaseTimeout = TimeSpan.FromMinutes(10) };  
  
SendMessageChannelCache customChannelCacheExtension =
    new SendMessageChannelCache(factorySettings, channelSettings);  
  
clientInstance.Extensions.Add(customChannelCacheExtension);  

Чтобы включить кэширование, если у службы рабочего процесса имеются конечные точки, определенные в конфигурации, создайте экземпляр класса SendMessageChannelCache, используя параметризованный конструктор SendMessageChannelCache, и задайте параметру allowUnsafeCaching значение true. Далее добавьте новый экземпляр этого класса как расширение для узла службы рабочего процесса или экземпляра рабочего процесса. В следующем примере кода показано включение кэширования для экземпляра рабочего процесса.

SendMessageChannelCache customChannelCacheExtension =
    new SendMessageChannelCache{ AllowUnsafeCaching = true };  
  
clientInstance.Extensions.Add(customChannelCacheExtension);  

Чтобы отключить кэш полностью для фабрик каналов и каналов, отключите кэш фабрик каналов. При этом также будет отключен кэш каналов, поскольку каналы принадлежат соответствующим фабрикам каналов. Чтобы отключить кэш фабрик каналов, передайте параметр factorySettings конструктору SendMessageChannelCache, инициализированному для экземпляра ChannelCacheSettings, со значением MaxItemsInCache, установленным в 0. Это показано в следующем примере кода.

// Disable the factory cache. This results in the channel cache to be turned off as well.  
ChannelCacheSettings factorySettings = new ChannelCacheSettings  
    { MaxItemsInCache = 0 };  
  
ChannelCacheSettings channelSettings = new ChannelCacheSettings();  
  
SendMessageChannelCache customChannelCacheExtension =
    new SendMessageChannelCache(factorySettings, channelSettings);
  
clientInstance.Extensions.Add(customChannelCacheExtension);  

Можно использовать кэш фабрик каналов и отключить кэш каналов, передав параметр channelSettings конструктору SendMessageChannelCache, инициализированному для экземпляра ChannelCacheSettings, со значением MaxItemsInCache, установленным в 0. Это показано в следующем примере кода.

ChannelCacheSettings factorySettings = new ChannelCacheSettings();  
// Disable only the channel cache.  
ChannelCacheSettings channelSettings = new ChannelCacheSettings  
    { MaxItemsInCache = 0};  
  
SendMessageChannelCache customChannelCacheExtension =
    new SendMessageChannelCache(factorySettings, channelSettings);
  
clientInstance.Extensions.Add(customChannelCacheExtension);  

В размещенной службе рабочего процесса в файле конфигурации приложения можно указать параметры кэша фабрики и канала. Для этого необходимо создать поведение службы, содержащее параметры для кэша фабрики и канала, и добавить это поведение в службу. В следующем примере показано содержимое файла конфигурации, содержащего MyChannelCacheBehavior поведение службы с параметрами пользовательского кэша фабрики и кэша каналов. Это поведение службы добавляется в службу с помощью атрибута behaviorConfiguration .

<configuration>
  <system.serviceModel>  
    <!-- List of other config sections here -->
    <behaviors>  
      <serviceBehaviors>  
        <behavior name="MyChannelCacheBehavior">  
          <sendMessageChannelCache allowUnsafeCaching ="false" >  
            <!-- Control only the host level settings -->
            <factorySettings maxItemsInCache = "8" idleTimeout = "00:05:00" leaseTimeout="10:00:00" />  
            <channelSettings maxItemsInCache = "32" idleTimeout = "00:05:00" leaseTimeout="00:06:00" />  
          </sendMessageChannelCache>  
        </behavior>  
      </serviceBehaviors>  
    </behaviors>  
    <services>  
      <service name="MyService" behaviorConfiguration="MyChannelCacheBehavior" />  
    </services>  
  </system.serviceModel>  
</configuration>