Конвейеры отказоустойчивости
Объединяйте стратегии в конвейеры отказоустойчивости.
«Конвейеры отказоустойчивости» — бесплатный урок C# Academy на CoddyKit. Это урок 4 из 4. Ты можешь прочитать весь урок бесплатно ниже — а потом практиковать его прямо в браузере с встроенным редактором кода и ИИ-репетитором 24/7. Это часть пути обучения C# Academy, и твой прогресс синхронизируется между веб-версией и приложением CoddyKit. Курс C# Academy содержит 4 уроков всего.
Объединение стратегий
В реальных приложениях для отказоустойчивости обычно требуется совместная работа нескольких стратегий. Polly v8 позволяет объединить их в единый конвейер отказоустойчивости с помощью ResiliencePipelineBuilder.
ResiliencePipelineBuilder
Вы выстраиваете цепочку вызовов Add... и завершаете её с помощью Build(). В результате получается повторно используемый и безопасный для многопоточности ResiliencePipeline, через который выполняются вызовы.
var pipeline = new ResiliencePipelineBuilder()
.AddRetry(new RetryStrategyOptions())
.AddTimeout(TimeSpan.FromSeconds(5))
.Build();Порядок важен
Стратегии выполняются снаружи внутрь: первая добавленная стратегия оборачивает остальные. Распространённый правильный порядок — ограничение времени ожидания каждой попытки внутри повторных попыток, а общее ограничение времени ожидания и автоматический выключатель — вокруг них.
var pipeline = new ResiliencePipelineBuilder()
.AddTimeout(TimeSpan.FromSeconds(10)) // overall
.AddRetry(new RetryStrategyOptions())
.AddCircuitBreaker(new CircuitBreakerStrategyOptions())
.AddTimeout(TimeSpan.FromSeconds(2)) // per attempt
.Build();Типизированные конвейеры
Когда стратегии анализируют результат (например, резервный вариант или повторная попытка на основе результата), используйте обобщённый ResiliencePipelineBuilder<T>, чтобы конвейер знал тип возвращаемого значения.
var pipeline = new ResiliencePipelineBuilder<HttpResponseMessage>()
.AddRetry(new HttpRetryStrategyOptions())
.Build();Выполнение с состоянием
Чтобы избежать выделения памяти под замыкания, передавайте состояние в ExecuteAsync; Polly передаст его обратно вашей функции обратного вызова.
await pipeline.ExecuteAsync(
static async (state, token) => await state.CallAsync(token),
myService);Поставщик конвейеров отказоустойчивости
Вместо создания конвейеров непосредственно в месте использования зарегистрируйте именованные конвейеры в DI и получайте их через ResiliencePipelineProvider. Это централизует настройку.
builder.Services.AddResiliencePipeline("db", pipeline =>
{
pipeline.AddRetry(new RetryStrategyOptions())
.AddTimeout(TimeSpan.FromSeconds(3));
});Получение именованного конвейера
Внедрите ResiliencePipelineProvider<string> и получайте свой конвейер по ключу в любом необходимом месте.
public class OrderService
{
private readonly ResiliencePipeline _pipeline;
public OrderService(ResiliencePipelineProvider<string> provider)
{
_pipeline = provider.GetPipeline("db");
}
}Отказоустойчивость для HttpClient
Метод расширения AddResilienceHandler подключает конвейер к типизированному или именованному HttpClient и применяет его к каждому исходящему запросу.
builder.Services.AddHttpClient<CatalogClient>()
.AddResilienceHandler("catalog", b =>
{
b.AddRetry(new HttpRetryStrategyOptions());
b.AddCircuitBreaker(new HttpCircuitBreakerStrategyOptions());
});Стандартный обработчик отказоустойчивости
Microsoft предоставляет готовый обработчик AddStandardResilienceHandler, объединяющий разумные стратегии повторных попыток, автоматического выключателя, ограничения времени ожидания и ограничения частоты запросов в рекомендуемом порядке.
builder.Services.AddHttpClient<CatalogClient>()
.AddStandardResilienceHandler();Конвейеры можно повторно использовать без больших затрат
Создайте конвейер один раз и используйте его повторно для множества выполнений. Конвейеры неизменяемы и безопасны для многопоточного использования, поэтому делиться ими безопасно и эффективно.
Механизмы наблюдаемости
Каждая стратегия предоставляет функции обратного вызова (OnRetry, OnOpened, OnTimeout, OnFallback), а Polly отправляет телеметрию, которую можно подключить к ведению журнала и метрикам для полной наблюдаемости.
Быстрая проверка
Проверьте свои знания о конвейерах отказоустойчивости.
Итоги
ResiliencePipelineBuilder объединяет повторные попытки, автоматический выключатель, ограничение времени ожидания и резервный вариант в единый повторно используемый конвейер; стратегии выполняются снаружи внутрь, поэтому порядок важен. Используйте обобщённый построитель для стратегий, учитывающих результат, регистрируйте именованные конвейеры с помощью AddResiliencePipeline и получайте их через ResiliencePipelineProvider. Для HTTP каждый запрос защищает AddResilienceHandler или AddStandardResilienceHandler.
Часто задаваемые вопросы
Урок «Конвейеры отказоустойчивости» бесплатный?
Да — полный текст урока «Конвейеры отказоустойчивости» бесплатно доступен здесь в веб-версии. Чтобы практиковать его интерактивно (встроенный редактор кода и ИИ-репетитор 24/7) и разблокировать остальной курс C# Academy, подпишись на CoddyKit PRO. Курс C# Academy содержит 4 уроков всего.
Чему я научусь в уроке «Конвейеры отказоустойчивости»?
Объединяйте стратегии в конвейеры отказоустойчивости. Ты практикуешь C# Academy с помощью реального кода, который запускаешь прямо в браузере, и ИИ-репетитор 24/7 отвечает на твои вопросы во время урока.
Нужен ли мне опыт, чтобы начать C# Academy?
Предыдущий опыт не требуется. C# Academy на CoddyKit структурирован для всех уровней — от новичков до продвинутых, поэтому ты можешь начать отсюда или с самого начала и учиться в своем темпе. Это урок 4 из 4.
Сколько времени занимает урок «Конвейеры отказоустойчивости»?
Большинство уроков CoddyKit занимают около 5–10 минут. Каждый из них компактный и интерактивный, поэтому ты постоянно делаешь прогресс и продолжаешь с того же места в веб-версии и приложении.
Можно ли писать и запускать код в этом уроке C# Academy?
Да. Каждый урок C# Academy включает встроенный редактор кода, поэтому ты пишешь и запускаешь реальный код прямо в браузере и получаешь моментальную обратную связь от AI — локальная установка не требуется.
Все уроки этого курса
- Политики повторных попыток
- Шаблон автоматического размыкателя
- Политики тайм-аутов и резервных вариантов
- Конвейеры отказоустойчивости