Golang에서 캐시를 사용하여 자율주행 데이터를 처리하는 팁입니다.

var cacheMap = make(map[string]interface{})
var mutex = sync.RWMutex{}

// 获取缓存值
func GetCache(key string) (interface{}, bool) {
    mutex.RLock()
    defer mutex.RUnlock()

    value, ok := cacheMap[key]
    return value, ok
}

// 设置缓存值
func SetCache(key string, value interface{}) {
    mutex.Lock()
    defer mutex.Unlock()

    cacheMap[key] = value
}

// 设置带有过期时间的缓存值
func SetExpireCache(key string, value interface{}, ttl time.Duration) {
    mutex.Lock()
    defer mutex.Unlock()
    cacheMap[key] = expireCache{value, time.Now().Add(ttl)}
}

type expireCache struct {
    Value interface{}
    ExpireTime time.Time
}

// 获取缓存值和剩余过期时间
func GetExpireCache(key string) (interface{}, time.Duration, bool) {
    mutex.RLock()
    defer mutex.RUnlock()

    value, ok := cacheMap[key].(expireCache)
    if !ok {
        return nil, 0, false
    }

    now := time.Now()
    if now.After(value.ExpireTime) {
        delete(cacheMap, key)
        return nil, 0, false
    }

    return value.Value, value.ExpireTime.Sub(now), true
}

func (s *AutoCarServer) GetCarData(ctx context.Context, req *api.CarDataRequest) (*api.CarDataResponse, error) {
    key := fmt.Sprintf("%s_%d", req.GetVin(), req.GetTimestamp())

    // 从缓存中获取数据
    if value, ok := cache.GetCache(key); ok {
        if data, ok := value.(*api.CarData); ok {
            return &api.CarDataResponse{
                Data: data,
            }, nil
        }
    }

    // 从 Mock 服务中获取数据
    data, err := s.autoCarServiceClient.GetCarData(ctx, req)
    if err != nil {
        log.Errorf("failed to get car data from mock server, error: %v", err)
        return nil, status.Errorf(codes.Internal, "failed to get car data from mock server")
    }

    // 将数据存入缓存
    cache.SetExpireCache(key, data.GetData(), 10*time.Second)

    return &api.CarDataResponse{
        Data: data.GetData(),
    }, nil
}