데이터 맵에서 파일을 로드하는 동안 오류 처리

문제 개요:

이 코드 조각은 파일의 데이터를 시작하는 동안 지도. 그러나 파일을 로드하는 동안 오류가 발생하면 문제가 발생합니다. 이 문제는 코드가 각각의 새 파일을 로드하기 전에 지도를 지우기 때문에 발생합니다. 이로 인해 오류가 발생하고 이전 지도 상태가 유지되지 않으면 데이터 손실이 발생할 수 있습니다.

제안된 솔루션:

이 문제를 극복하기 위해 보다 간단한 접근 방식을 채택할 수 있습니다.

1. 상태 비저장 구성 로드: 캐시할 데이터를 캡슐화하는 CustomerConfig 구조체.
2. 구성 로드 함수: 파일에서 구성 로드를 담당하는 loadConfig() 함수를 만듭니다.
3. 캐시 Manager: 구성을 관리하기 위한 ConfigCache 구조체를 도입하여 안전한 동시 액세스를 제공하고 새로 고침을 통해 변경 사항을 모니터링하는 기능을 제공합니다. goroutine.
4. 새로 고침 고루틴: 이 고루틴은 주기적으로 변경 사항을 확인하고 새 구성을 로드하여 캐시가 최신 상태인지 확인합니다.
5. 구성 액세스: GetConfig() 메서드는 최신 구성에 대한 액세스를 제공하여 항상 최신 데이터가 유지되도록 합니다. 사용할 수 있습니다.

구현:

type CustomerConfig struct {
    Data map[string]bool
    LoadedAt time.Time
}

func loadConfig() (*CustomerConfig, error) {
    cfg := &CustomerConfig{
        Data: map[string]bool{},
        LoadedAt: time.Now(),
    }
    // Load files and populate cfg.Data
    // Return error if encountered
    return cfg, nil
}

type ConfigCache struct {
    configMu sync.RWMutex
    config   *CustomerConfig
    closeCh  chan struct{}
}

func NewConfigCache() (*ConfigCache, error) {
    cfg, err := loadConfig()
    if err != nil {
        return nil, err
    }
    cc := &ConfigCache{
        config:  cfg,
        closeCh: make(chan struct{}),
    }
    go cc.refresher()
    return cc, nil
}

func (cc *ConfigCache) refresher() {
    ticker := time.NewTicker(1 * time.Minute)
    defer ticker.Stop()
    for {
        select {
        case <-ticker.C:
            // Check for changes
            changes := false // Implement logic to detect changes
            if !changes {
                continue
            }
            cfg, err := loadConfig()
            if err != nil {
                log.Printf("Failed to load config: %v", err)
                continue
            }
            cc.configMu.Lock()
            cc.config = cfg
            cc.configMu.Unlock()
        case <-cc.closeCh:
            return
        }
    }
}

func (cc *ConfigCache) Stop() {
    close(cc.closeCh)
}

func (cc *ConfigCache) GetConfig() *CustomerConfig {
    cc.configMu.RLock()
    defer cc.configMu.RUnlock()
    return cc.config
}

사용법:

cc, err := NewConfigCache()
if err != nil {
    // Handle error
}
cfg := cc.GetConfig() // Access the latest configuration