在分布式系统里，多个服务之间的调用链路复杂，如果某个下游服务出现响应缓慢或者故障，大量并发请求会持续占用系统线程、连接池等资源，最终可能导致整个应用崩溃。Polly的Bulkhead Isolation（舱壁隔离）模式就是针对这类问题设计的防护策略，它通过限制某个服务的并发调用数量，把不同服务的资源使用隔离开，避免单个服务的资源耗尽问题扩散到其他服务。
舱壁隔离模式的核心作用
舱壁隔离的概念来源于船舶设计，船舱被分隔成多个独立的舱室，即使一个舱室进水也不会影响其他舱室，避免整艘船沉没。在系统设计中，该模式的作用主要体现在三个方面：
- 限制并发资源占用：针对每个下游服务配置最大并发调用数，超出限制的请求会被直接拒绝，不会占用额外的线程、连接等资源。
- 故障隔离：某个服务的调用出现问题，只会消耗该服务对应的舱壁资源，不会影响到其他服务的正常调用。
- 快速失败：超出并发限制的请求会立即返回异常，不需要等待超时，减少无效等待带来的资源浪费。
C#中Polly舱壁隔离的实现步骤
要在C#项目中使用Polly的舱壁隔离模式，首先需要安装Polly的NuGet包，然后按照以下步骤配置和使用策略。
1. 安装依赖包
在项目中通过NuGet安装Polly包，当前最新稳定版本支持完整的舱壁隔离功能，安装命令如下：
dotnet add package Polly
2. 配置舱壁隔离策略
舱壁隔离策略需要配置两个核心参数：最大并发调用数、最大等待队列长度。最大并发调用数表示同时允许多少个请求调用该服务，最大等待队列长度表示超出并发数后最多有多少个请求可以排队等待，超出队列长度的请求会被直接拒绝。
下面是创建舱壁隔离策略的示例代码：
using Polly;
using Polly.Bulkhead;
using System;
using System.Threading.Tasks;
public class BulkheadPolicyBuilder
{
// 定义舱壁隔离策略，最大并发数为5，最大等待队列为10
public static IAsyncPolicy<HttpResponseMessage> BuildBulkheadPolicy()
{
return Policy
.BulkheadAsync<HttpResponseMessage>(
maxParallelization: 5, // 最大并发调用数
maxQueuedActions: 10, // 最大等待队列长度
onBulkheadRejectedAsync: (context) => // 请求被拒绝时的回调
{
Console.WriteLine($"请求被舱壁隔离策略拒绝，拒绝时间：{DateTime.Now}");
return Task.CompletedTask;
}
);
}
}
3. 封装服务调用逻辑
将需要防护的服务调用逻辑和舱壁隔离策略结合，所有针对该服务的调用都经过策略执行，确保并发限制生效。
using System;
using System.Net.Http;
using System.Threading.Tasks;
public class UserService
{
private readonly IAsyncPolicy<HttpResponseMessage> _bulkheadPolicy;
private readonly HttpClient _httpClient;
public UserService()
{
_bulkheadPolicy = BulkheadPolicyBuilder.BuildBulkheadPolicy();
_httpClient = new HttpClient();
_httpClient.BaseAddress = new Uri("http://ipipp.com/api/");
}
// 获取用户信息的调用方法，使用舱壁隔离策略包裹
public async Task<string> GetUserInfoAsync(int userId)
{
try
{
// 执行策略，内部封装HTTP调用
var response = await _bulkheadPolicy.ExecuteAsync(async () =>
{
return await _httpClient.GetAsync($"user/{userId}");
});
if (response.IsSuccessStatusCode)
{
return await response.Content.ReadAsStringAsync();
}
return $"调用失败，状态码：{response.StatusCode}";
}
catch (BulkheadRejectedException ex)
{
// 捕获舱壁拒绝异常，返回友好提示
return $"当前服务调用繁忙，请稍后再试。异常信息：{ex.Message}";
}
catch (Exception ex)
{
return $"服务调用出现异常：{ex.Message}";
}
}
}
4. 验证策略效果
我们可以编写简单的测试代码，模拟大量并发请求，观察舱壁隔离策略的生效情况：
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
class Program
{
static async Task Main(string[] args)
{
var userService = new UserService();
var tasks = new List<Task>();
// 模拟20个并发请求
for (int i = 0; i < 20; i++)
{
int userId = i;
tasks.Add(Task.Run(async () =>
{
var result = await userService.GetUserInfoAsync(userId);
Console.WriteLine($"请求{userId}结果：{result}");
}));
}
await Task.WhenAll(tasks);
}
}
运行上述代码后，你会发现最多只有5个请求同时执行，10个请求会进入等待队列，剩下的5个请求会被直接拒绝，返回服务繁忙的提示，这就是舱壁隔离策略的实际效果。
使用注意事项
- 不同下游服务应该配置独立的舱壁隔离策略，避免不同服务的资源限制互相影响。
- 最大并发数和队列长度需要根据服务的实际处理能力配置，过小会导致大量请求被拒绝，过大起不到隔离效果。
- 舱壁隔离策略通常可以和重试、熔断等Polly其他策略组合使用，形成更完善的服务防护体系。
- 被拒绝的请求抛出的异常是
BulkheadRejectedException，需要单独捕获处理，返回符合业务场景的提示信息。
PollyBulkhead_IsolationC#.NET熔断隔离修改时间：2026-06-16 12:24:36