Redis Stream을 사용하여 GO Language에서 메시지 대기열을 구현할 때 User_ID 유형 변환 문제를 해결하는 방법은 무엇입니까?

go redis 스트림 메시지 대기열 : user_id 유형 변환 문제를 영리하게 해결합니다.

Go 및 Redis 스트림을 사용하여 메시지 대기열을 구축 할 때는 user_id 와 같은 정수 유형의 전환 문제가 종종 개발자를 괴롭 힙니다. 이 기사는이 문제를 심층적으로 탐색하고 효과적인 솔루션을 제공합니다.

응용 프로그램 user_id (정수 유형)가 포함 된 데이터를 redis 스트림에 작성해야한다고 가정합니다. 다음과 같은 문제가 발생할 수 있습니다.

질문 설명 :

Redis Stream에 직접 글을 쓰면 user_id 읽을 때 문자열 유형이됩니다. 예를 들어:

쓰기 : xadd mystream * user_id 123

읽기 : xread block 0 streams mystream $ ( user_id 읽기는 문자열 "123")

원인 분석 :

Redis는 모든 데이터의 기본 스토리지에서 문자열입니다. 정수를 작성하더라도 Redis는 문자열 저장소로 변환합니다. 따라서 읽을 때 자연스럽게 얻는 것은 문자열 유형입니다.

솔루션 : 직렬화 및 사막화

데이터 유형의 무결성을 유지하려면 Redis에 글을 쓰기 전에 직렬화하고 읽은 후에는 실질화해야합니다. 직렬화 및 사막화에 JSON을 사용하는 것이 좋습니다.

다음은 JSON을 사용 하여이 문제를 해결하는 방법을 보여주는 샘플 코드입니다.

 패키지 메인

수입 (수입)
    "인코딩/json"
    "FMT"
    "github.com/go-redis/redis/v8"
))

유형 Message Struct {
    userId int`json : "user_id"`
    // ... 다른 필드
}

func main () {
    클라이언트 : = redis.newclient (& redis.options {
        Addr : "Localhost : 6379",
    })

    // 데이터 메시지 : = 메시지 {userId : 123}
    jsondata, err : = json.marshal (메시지)
    err! = nil {인 경우
        공황 (err)
    }

    err = client.xadd (& redis.xaddargs {
        스트림 : "mystream",
        값 : map [string] 인터페이스 {} {
            "data": jsondata, // JSON 데이터를 값으로 저장},
    }). err ()
    err! = nil {인 경우
        공황 (err)
    }

    // 데이터 스트림 읽기, err : = client.xread (& redis.xreadargs {
        스트림 : [] 문자열 { "mystream", "0"},
        블록 : 0,
    }).결과()
    err! = nil {인 경우
        공황 (err)
    }

    _, 메시지 : = 범위 스트림 [0] .messages {
        var 수신 메시지 메시지
        json.unmarshal ([] byte (message.values ​​[ "data"]. (string)) 및 수신기) // deserialize json data fmt.printf ( "수신 된 사용자 ID : %d \ n", receptionMessage.userid)
    }
}

이 코드는 먼저 Message 구조를 JSON 문자열로 직렬화 한 다음 JSON 문자열을 Redis 스트림에 저장합니다. 읽을 때 JSON 문자열을 Message 구조로 되돌려 보내서 정수 유형의 user_id 복원합니다. 이를 통해 Redis에서 저장 및 읽기 동안 데이터의 유형 일관성을 보장합니다. 이 예제가 Go Redis 스트림 메시지 큐에서 유형 변환 문제를 효과적으로 해결하는 데 도움이되기를 바랍니다.

위 내용은 Redis Stream을 사용하여 GO Language에서 메시지 대기열을 구현할 때 User_ID 유형 변환 문제를 해결하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!