PHP混沌工程与故障注入测试

PHP混沌工程与故障注入测试

混沌工程通过主动引入故障来验证系统的容错能力。故障注入可以测试系统在异常情况下的表现。今天说说PHP中实现混沌工程和故障注入的方法。

故障注入是在代码层面模拟各种异常情况，验证系统的容错逻辑。

```php
class ChaosEngine
{
private array $experiments = [];
private float $enabledRate = 0;

public function __construct(float $enabledRate = 0.1)
{
$this->enabledRate = $enabledRate;
}

public function addExperiment(string $name, callable $injector, float $rate = 0.1): void
{
$this->experiments[$name] = compact('name', 'injector', 'rate');
}

public function shouldInject(string $experiment): bool
{
if (rand(0, 100) / 100 > $this->enabledRate) return false;
if (rand(0, 100) / 100 > $this->experiments[$experiment]['rate'] ?? 0) return false;
return true;
}

public function inject(string $experiment, array $context = []): void
{
if (!$this->shouldInject($experiment)) return;

$config = $this->experiments[$experiment] ?? null;
if ($config === null) return;

echo "[混沌] 注入故障: {$experiment}\n";
($config['injector'])($context);
}

public function getActiveExperiments(): array
{
return array_keys($this->experiments);
}
}

$chaos = new ChaosEngine(0.5);

// 延迟注入
$chaos->addExperiment('latency', function ($ctx) {
$delay = rand(500, 3000);
echo " 注入延迟: {$delay}ms\n";
usleep($delay * 1000);
}, 0.3);

// 异常注入
$chaos->addExperiment('exception', function ($ctx) {
$exceptionClass = $ctx['exception'] ?? \RuntimeException::class;
$message = $ctx['message'] ?? '模拟故障';
echo " 注入异常: {$message}\n";
throw new $exceptionClass($message);
}, 0.2);

// 内存溢出
$chaos->addExperiment('memory', function ($ctx) {
$size = $ctx['size'] ?? 10;
echo " 注入内存消耗: {$size}MB\n";
$data = str_repeat('x', $size * 1024 * 1024);
}, 0.05);

// 返回值篡改
$chaos->addExperiment('corrupt_return', function ($ctx) {
echo " 注入返回值篡改\n";
}, 0.1);

class DatabaseClient
{
private ChaosEngine $chaos;

public function __construct(ChaosEngine $chaos)
{
$this->chaos = $chaos;
}

public function query(string $sql): array
{
$this->chaos->inject('latency', ['service' => 'database']);

if ($this->chaos->shouldInject('exception')) {
$this->chaos->inject('exception', [
'exception' => \PDOException::class,
'message' => '数据库连接超时',
]);
}

return ['data' => "模拟结果: {$sql}"];
}
}

class HttpClient
{
private ChaosEngine $chaos;

public function __construct(ChaosEngine $chaos)
{
$this->chaos = $chaos;
}

public function get(string $url): array
{
$this->chaos->inject('latency', ['service' => 'http']);

if ($this->chaos->shouldInject('exception')) {
$this->chaos->inject('exception', [
'message' => "HTTP请求失败: {$url}",
]);
}

return ['status' => 200, 'body' => 'response'];
}
}

// 测试容错能力
$db = new DatabaseClient($chaos);
$http = new HttpClient($chaos);

for ($i = 0; $i < 10; $i++) {
echo "\n请求 #{$i}:\n";
try {
$result = $db->query("SELECT * FROM users");
echo " 数据库查询成功\n";
} catch (\Exception $e) {
echo " 数据库降级: {$e->getMessage()}\n";
}

try {
$result = $http->get("https://api.example.com/data");
echo " HTTP请求成功\n";
} catch (\Exception $e) {
echo " HTTP降级: {$e->getMessage()}\n";
}
}
?>
>

混沌工程的自动恢复验证：

```php
class RecoveryTester
{
public function testAutoRecovery(callable $operation, callable $recovery, int $timeout = 10): bool
{
$start = time();

while (time() - $start < $timeout) {
try {
$operation();
$recovery();
return true;
} catch (\Exception $e) {
echo " 恢复中: {$e->getMessage()}\n";
sleep(1);
}
}

return false;
}
}

echo "混沌工程测试完成\n";
$tester = new RecoveryTester();
?>

混沌工程帮助发现系统在异常情况下的薄弱环节。故障注入验证了熔断器是否生效、降级策略是否正常。在生产环境中执行混沌实验要格外谨慎，从非核心业务开始，逐步扩大范围。先建立监控和告警机制，再执行混沌实验。