3.3 重大发现！可用性测试竟然还能这样玩？
在构建高可用系统时，仅仅设计出高可用架构是不够的，还需要通过系统的测试和演练来验证架构的有效性。可用性测试和容灾演练是确保系统在真实故障场景下依然能够稳定运行的关键手段。本节将深入探讨如何设计和实施有效的可用性测试和容灾演练方案。
可用性测试概述
可用性测试是验证系统在各种故障场景下是否能够保持正常运行的过程。它包括以下几个方面：
- 功能测试：验证系统在正常情况下的功能是否正确
- 性能测试：验证系统在高负载情况下的性能表现
- 故障注入测试：模拟各种故障场景，验证系统的容错能力
- 恢复测试：验证系统在故障发生后能否自动恢复
故障注入测试框架
故障注入测试是可用性测试的核心，通过主动注入故障来验证系统的容错能力。
// FaultInjector 故障注入器接口typeFaultInjectorinterface{// Inject 注入故障Inject(fault*Fault)error// Recover 恢复故障Recover(fault*Fault)error}// Fault 故障定义typeFaultstruct{// 故障IDIDstring`json:"id"`// 故障类型Type FaultType`json:"type"`// 故障目标Target FaultTarget`json:"target"`// 故障参数Parametersmap[string]interface{}`json:"parameters"`// 持续时间Duration time.Duration`json:"duration"`// 创建时间CreatedAt time.Time`json:"created_at"`// 状态Status FaultStatus`json:"status"`}// FaultType 故障类型typeFaultTypestringconst(// FaultTypeNetwork 网络故障FaultTypeNetwork FaultType="network"// FaultTypeService 服务故障FaultTypeService FaultType="service"// FaultTypeDatabase 数据库故障FaultTypeDatabase FaultType="database"// FaultTypeDisk 磁盘故障FaultTypeDisk FaultType="disk"// FaultTypeCPU CPU故障FaultTypeCPU FaultType="cpu"// FaultTypeMemory 内存故障FaultTypeMemory FaultType="memory")// FaultTarget 故障目标typeFaultTargetstruct{// 目标类型Type TargetType`json:"type"`// 目标标识Identifierstring`json:"identifier"`// 目标地址Addressstring`json:"address,omitempty"`}// TargetType 目标类型typeTargetTypestringconst(// TargetTypeService 服务TargetTypeService TargetType="service"// TargetTypeHost 主机TargetTypeHost TargetType="host"// TargetTypeContainer 容器TargetTypeContainer TargetType="container"// TargetTypePod PodTargetTypePod TargetType="pod")// FaultStatus 故障状态typeFaultStatusstringconst(// FaultStatusPending 待执行FaultStatusPending FaultStatus="pending"// FaultStatusInjecting 注入中FaultStatusInjecting FaultStatus="injecting"// FaultStatusInjected 已注入FaultStatusInjected FaultStatus="injected"// FaultStatusRecovering 恢复中FaultStatusRecovering FaultStatus="recovering"// FaultStatusRecovered 已恢复FaultStatusRecovered FaultStatus="recovered"// FaultStatusFailed 失败FaultStatusFailed FaultStatus="failed")// ChaosFaultInjector 混沌故障注入器typeChaosFaultInjectorstruct{// 故障存储faultStore FaultStore// 通知器notifier Notifier// 活动管理器activityManager ActivityManager}// FaultStore 故障存储接口typeFaultStoreinterface{// SaveFault 保存故障SaveFault(fault*Fault)error// GetFaultByID 根据ID获取故障GetFaultByID(idstring)(*Fault,error)// ListFaults 列出故障ListFaults()([]*Fault,error)// UpdateFault 更新故障UpdateFault(fault*Fault)error}// Notifier 通知器接口typeNotifierinterface{// Notify 发送通知Notify(messagestring,level NotificationLevel)error}// NotificationLevel 通知级别typeNotificationLevelstringconst(// NotificationLevelInfo 信息NotificationLevelInfo NotificationLevel="info"// NotificationLevelWarning 警告NotificationLevelWarning NotificationLevel="warning"// NotificationLevelError 错误NotificationLevelError NotificationLevel="error"// NotificationLevelCritical 严重NotificationLevelCritical NotificationLevel="critical")// ActivityManager 活动管理器接口typeActivityManagerinterface{// RecordActivity 记录活动RecordActivity(activity*Activity)error}// Activity 活动记录typeActivitystruct{// 活动IDIDstring`json:"id"`// 活动类型Typestring`json:"type"`// 活动描述Descriptionstring`json:"description"`// 相关实体EntityIDstring`json:"entity_id"`// 时间戳Timestamp time.Time`json:"timestamp"`// 详情Detailsmap[string]interface{}`json:"details"`}// NewChaosFaultInjector 创建混沌故障注入器funcNewChaosFaultInjector(faultStore FaultStore,notifier Notifier,activityManager ActivityManager)*ChaosFaultInjector{return&ChaosFaultInjector{faultStore:faultStore,notifier:notifier,activityManager:activityManager,}}// Inject 注入故障func(cfi*ChaosFaultInjector)Inject(fault*Fault)error{// 更新故障状态fault.Status=FaultStatusInjecting fault.CreatedAt=time.Now()iferr:=cfi.faultStore.SaveFault(fault);err!=nil{returnfmt.Errorf("failed to save fault: %w",err)}// 记录活动cfi.recordActivity("fault_injection_started",fmt.Sprintf("开始注入故障: %s",fault.ID),fault.ID,map[string]interface{}{"fault_type":fault.Type,"target":fault.Target,})// 发送通知cfi.notifier.Notify(fmt.Sprintf("开始注入故障: %s",fault.ID),NotificationLevelInfo)// 根据故障类型执行注入varerrerrorswitchfault.Type{caseFaultTypeNetwork:err=cfi.injectNetworkFault(fault)caseFaultTypeService:err=cfi.injectServiceFault(fault)caseFaultTypeDatabase:err=cfi.injectDatabaseFault(fault)caseFaultTypeDisk:err=cfi.injectDiskFault(fault)caseFaultTypeCPU:err=cfi.injectCPUFault(fault)caseFaultTypeMemory:err=cfi.injectMemoryFault(fault)default:err=fmt.Errorf("unsupported fault type: %s",fault.Type)}iferr!=nil{fault.Status=FaultStatusFailed cfi.faultStore.UpdateFault(fault)cfi.recordActivity("fault_injection_failed",fmt.Sprintf("故障注入失败: %s, 错误: %v",fault.ID,err),fault.ID,nil)cfi.notifier.Notify(fmt.Sprintf("故障注入失败: %s",fault.ID),NotificationLevelError)returnfmt.Errorf("failed to inject fault: %w",err)}// 更新故障状态fault.Status=FaultStatusInjectediferr:=cfi.faultStore.UpdateFault(fault);err!=nil{log.Printf("failed to update fault status: %v",err)}cfi.recordActivity("fault_injected",fmt.Sprintf("故障已注入: %s",fault.ID),fault.ID,nil)cfi.notifier.Notify(fmt.Sprintf("故障已注入: %s",fault.ID
)
