3.2 太震撼！高可用架构设计原来可以这样做？
在构建现代分布式系统时，高可用性是一个至关重要的设计目标。高可用架构能够确保系统在面对各种故障和异常情况时依然能够正常运行，为用户提供持续稳定的服务。本节将深入探讨高可用架构的设计原则和实现方法，并通过实际的Go代码示例展示如何构建一个高可用的通知平台。
高可用架构设计原则
1. 冗余设计
冗余是高可用架构的基础，通过在多个节点上部署相同的服务，避免单点故障。
2. 故障隔离
将系统划分为多个独立的模块或服务，确保一个模块的故障不会影响其他模块。
3. 自动故障转移
当检测到某个节点或服务故障时，能够自动将流量切换到健康的节点。
4. 负载均衡
通过负载均衡器将请求分发到多个服务实例，避免单个实例过载。
5. 监控与告警
实时监控系统状态，及时发现并处理潜在问题。
高可用架构实现
服务注册与发现
服务注册与发现是实现高可用架构的关键组件，它允许服务实例动态注册和发现其他服务实例。
// ServiceRegistry 服务注册中心接口typeServiceRegistryinterface{// Register 注册服务Register(service*ServiceInstance)error// Deregister 注销服务Deregister(serviceIDstring)error// Discover 发现服务Discover(serviceNamestring)([]*ServiceInstance,error)// Watch 监听服务变化Watch(serviceNamestring)<-chan[]*ServiceInstance}// ServiceInstance 服务实例typeServiceInstancestruct{// 服务IDIDstring`json:"id"`// 服务名称Namestring`json:"name"`// 服务地址Addressstring`json:"address"`// 服务端口Portint`json:"port"`// 服务标签Tags[]string`json:"tags"`// 健康检查地址HealthCheckURLstring`json:"health_check_url"`// 权重Weightint`json:"weight"`// 注册时间RegisteredAt time.Time`json:"registered_at"`}// EtcdServiceRegistry 基于Etcd的服务注册中心实现typeEtcdServiceRegistrystruct{// Etcd客户端client*clientv3.Client// 租约IDleaseID clientv3.LeaseID// 租约TTL（秒）ttlint64}// NewEtcdServiceRegistry 创建基于Etcd的服务注册中心funcNewEtcdServiceRegistry(endpoints[]string,ttlint64)(*EtcdServiceRegistry,error){// 创建Etcd客户端client,err:=clientv3.New(clientv3.Config{Endpoints:endpoints,DialTimeout:5*time.Second,})iferr!=nil{returnnil,fmt.Errorf("failed to create etcd client: %w",err)}return&EtcdServiceRegistry{client:client,ttl:ttl,},nil}// Register 注册服务func(esr*EtcdServiceRegistry)Register(service*ServiceInstance)error{// 创建租约leaseResp,err:=esr.client.Grant(context.Background(),esr.ttl)iferr!=nil{returnfmt.Errorf("failed to create lease: %w",err)}esr.leaseID=leaseResp.ID// 序列化服务实例data,err:=json.Marshal(service)iferr!=nil{returnfmt.Errorf("failed to marshal service instance: %w",err)}// 注册服务key:=fmt.Sprintf("/services/%s/%s",service.Name,service.ID)_,err=esr.client.Put(context.Background(),key,string(data),clientv3.WithLease(leaseResp.ID))iferr!=nil{returnfmt.Errorf("failed to register service: %w",err)}// 启动租约续期goesr.keepAlive()returnnil}// keepAlive 保持租约活跃func(esr*EtcdServiceRegistry)keepAlive(){// 创建租约续期通道ch,err:=esr.client.KeepAlive(context.Background(),esr.leaseID)iferr!=nil{log.Printf("failed to keep alive: %v",err)return}// 监听租约续期响应forrangech{// 租约续期成功}}// Deregister 注销服务func(esr*EtcdServiceRegistry)Deregister(serviceIDstring)error{// 删除服务注册信息key:=fmt.Sprintf("/services/%s",serviceID)_,err:=esr.client.Delete(context.Background(),key)iferr!=nil{returnfmt.Errorf("failed to deregister service: %w",err)}returnnil}// Discover 发现服务func(esr*EtcdServiceRegistry)Discover(serviceNamestring)([]*ServiceInstance,error){// 获取服务实例列表prefix:=fmt.Sprintf("/services/%s/",serviceName)resp,err:=esr.client.Get(context.Background(),prefix,clientv3.WithPrefix
