Проверка работоспособности кэширования Net Core - PullRequest
Новая
       21

Проверка работоспособности кэширования Net Core

0 голосов
/ 21 февраля 2019

Net Core 2.2 имеет поддержку для выполнения проверок работоспособности для опубликованных сервисов.Я хотел бы кэшировать ответ о проверке.

Я вижу, что могу использовать HealthCheckOptions и установить значение true для свойства AllowCachingResponses . 

app.UseHealthChecks("/api/services/healthCheck", new Microsoft.AspNetCore.Diagnostics.HealthChecks.HealthCheckOptions()
            {
                AllowCachingResponses = true
            });

Но я не понимаю, как установить время кэширования.Как лучше всего установить соответствующие заголовки http (Cache-Control, Expires and e.g) и как?

Мой сервис публикуется IIS.

1 Ответ

0 голосов
/ 15 августа 2019

Указанная вами опция AllowCachingResponses относится только к тому, установлены ли заголовки HTTP с помощью HealthCheckMiddleware .Как правило, промежуточные серверы, прокси-серверы и т. Д. Могут кэшировать результат запроса GET, и эти заголовки указывают, что сервер должен повторно извлекать их каждый раз.

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

Чтобы выполнить то, что вы ищете, вам нужно написать дополнительную логику.Один из подходов заключается в написании типа HealthCheckCacher, например, следующего: 

public class HealthCheckCacher : IHealthCheck
{
    private readonly SemaphoreSlim _mutex = new SemaphoreSlim(1);
    private readonly IHealthCheck _healthCheck;
    private readonly TimeSpan _timeToLive;

    private HealthCheckResult _result;
    private DateTime _lastCheck;

    public static readonly TimeSpan DefaultTimeToLive = TimeSpan.FromSeconds(30);

    /// <summary>
    /// Creates a new HealthCheckCacher which will cache the result for the amount of time specified.
    /// </summary>
    /// <param name="healthCheck">The underlying health check to perform.</param>
    /// <param name="timeToLive">The amount of time for which the health check should be cached. Defaults to 30 seconds.</param>
    public HealthCheckCacher(IHealthCheck healthCheck, TimeSpan? timeToLive = null)
    {
        _healthCheck = healthCheck;
        _timeToLive = timeToLive ?? DefaultTimeToLive;
    }

    public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
    {
        // you could improve thread concurrency by separating the read/write logic but this would require additional thread safety checks.
        // will throw OperationCanceledException if the token is canceled while we're waiting.
        await _mutex.WaitAsync(cancellationToken);

        try
        {
            // previous check is cached & not yet expired; just return it
            if (_lastCheck > DateTime.MinValue && DateTime.Now - _lastCheck < _timeToLive)
                return _result;

            // check has not been performed or is expired; run it now & cache the result
            _result = await _healthCheck.CheckHealthAsync(context, cancellationToken);
            _lastCheck = DateTime.Now;

            return _result;
        }
        finally
        {
            _mutex.Release();
        }
    }
}
...