如何无需重启Reactor，动态更新goroutine所用的机器配置数据

我有两个服务：reactor服务会启动一批goroutine，这些goroutine以无限循环的方式监听特定操作，它们依赖的数据来自entreprise服务。

现在需要实现不用停止重启reactor，就能让它自动纳入entreprise服务推送的机器及组配置更新。具体来说，reactor启动后要定期从entreprise拉取最新的机器组/机器列表，并调整自身的监控机制以适配参数变化。

我已经在主进程里写了一个goroutine用来定期检查entreprise的数据更新：

go func() {
 previousMachineGroups := machineGroupsModel
  for {
    time.Sleep(SECONDS_BETWEEN_CHECK * time.Second)
    newMachineGroups, errGet := getMachineGroupsFromEntreprise()
    if errGet != nil {
        log.Printf("| [reactor] error retrieving machine groups while checking for modification: %s", errGet)
        continue
    }
    if !reflect.DeepEqual(previousMachineGroups, newMachineGroups) {
        machineGroupsModel = newMachineGroups
    }
}
}()

另外，我还通过循环启动了一批内部包含无限循环的goroutine，现在需要让这些goroutine也能用上更新后的数据：

var wg sync.WaitGroup
for _, machineGroup := range machineGroupsModel {
 // 一些预处理逻辑
if machine.TargetNameCommandProgram.String != "" {
 checkIntervalSeconds := int(machineGroup.WaitBetweenCommandProgramCheckSeconds.Int64)
 wg.Add(1)
 go startMachineRoutine(*machine, machineGroup, checkIntervalSeconds, verbosityLevel, debug, &wg)
}

要实现动态更新，核心是让运行中的goroutine能感知配置变化，优雅重启/更新状态，同时避免资源泄漏。可以按以下步骤实现：

1. 并发安全地共享配置数据 #

当前直接赋值machineGroupsModel = newMachineGroups存在竞态问题，多个goroutine读写该变量会导致数据不一致。改用带读写锁的结构体存储配置：

var (
    machineGroupsLock sync.RWMutex
    machineGroupsModel []MachineGroup // 替换为你的实际数据类型
)

// 更新配置的goroutine中修改逻辑：
if !reflect.DeepEqual(previousMachineGroups, newMachineGroups) {
    machineGroupsLock.Lock()
    machineGroupsModel = newMachineGroups
    machineGroupsLock.Unlock()
    previousMachineGroups = newMachineGroups
}

2. 给监控goroutine添加退出信号 #

让startMachineRoutine的无限循环能接收退出通知，这样配置更新时可以终止旧goroutine，启动新实例。用context.Context实现：

修改startMachineRoutine签名及内部逻辑：

func startMachineRoutine(ctx context.Context, machine Machine, machineGroup MachineGroup, checkIntervalSeconds int, verbosityLevel int, debug bool, wg *sync.WaitGroup) {
    defer wg.Done()
    for {
        select {
        case <-ctx.Done():
            // 收到退出信号，清理资源后退出
            log.Printf("| [reactor] stopping routine for machine %s", machine.ID)
            return
        case <-time.After(time.Duration(checkIntervalSeconds) * time.Second):
            // 执行原有监控逻辑
            // ...
        }
    }
}

3. 管理goroutine生命周期 #

在主进程中维护所有运行中监控goroutine的上下文，配置更新时先终止旧实例，再启动新实例：

var (
    routineCancelFuncs = make(map[string]context.CancelFunc) // 用机器唯一ID作为key
    routineLock sync.Mutex
)

// 配置更新逻辑中加入：
machineGroupsLock.Lock()
newGroups := newMachineGroups
machineGroupsLock.Unlock()

// 终止所有旧goroutine
routineLock.Lock()
for _, cancel := range routineCancelFuncs {
    cancel()
}
wg.Wait() // 等待旧goroutine全部退出（按需选择）
routineCancelFuncs = make(map[string]context.CancelFunc)
routineLock.Unlock()

// 启动新goroutine
routineLock.Lock()
defer routineLock.Unlock()
for _, machineGroup := range newGroups {
    // 预处理逻辑
    if machine.TargetNameCommandProgram.String != "" {
        checkIntervalSeconds := int(machineGroup.WaitBetweenCommandProgramCheckSeconds.Int64)
        ctx, cancel := context.WithCancel(context.Background())
        routineCancelFuncs[machine.ID] = cancel
        wg.Add(1)
        go startMachineRoutine(ctx, *machine, machineGroup, checkIntervalSeconds, verbosityLevel, debug, &wg)
    }
}

4. 增量更新优化（可选） #

如果配置仅部分变化，无需全量重启goroutine：

• 对比新旧配置，启动新增机器的goroutine
• 终止已删除机器的goroutine
• 对配置修改的机器，先终止旧实例再启动新实例

这样能减少资源销毁重建的开销，提升服务稳定性。

内容的提问来源于stack exchange，提问作者Romain P