Bagaimana menyelesaikan masalah penukaran jenis user_id semasa menggunakan aliran redis untuk melaksanakan beratur mesej dalam bahasa Go?

Pergi Redis Stream Message Queue: Cleverly menyelesaikan masalah penukaran jenis user_id

Apabila membina beratur mesej menggunakan aliran Go dan Redis, masalah penukaran jenis integer seperti user_id sering melanda pemaju. Artikel ini akan meneroka isu ini secara mendalam dan menyediakan penyelesaian yang berkesan.

Katakan aplikasi anda perlu menulis data yang mengandungi user_id (jenis integer) ke aliran redis. Anda mungkin menghadapi masalah berikut:

Penerangan Soalan:

Selepas menulis terus ke Redis Stream, user_id menjadi jenis rentetan apabila dibaca. Contohnya:

Tulis: xadd mystream * user_id 123

Baca: xread block 0 streams mystream $ ( user_id Read adalah rentetan "123")

Punca Analisis:

Redis adalah rentetan dalam penyimpanan asas semua data. Walaupun anda menulis integer, Redis akan menukarnya ke penyimpanan rentetan. Oleh itu, apa yang anda dapat secara semulajadi apabila membaca adalah jenis rentetan.

Penyelesaian: Serialization dan deserialization

Untuk mengekalkan integriti jenis data, kita perlu bersiri sebelum menulis kepada redis dan deserialize selepas membaca. Adalah disyorkan untuk menggunakan JSON untuk bersiri dan deserialization.

Berikut adalah kod sampel yang menunjukkan cara menyelesaikan masalah ini menggunakan JSON:

 Pakej utama

import (
    "Pengekodan/JSON"
    "FMT"
    "github.com/go-redis/redis/v8"
)

Taipkan Struktur Mesej {
    Userid int `json:" user_id "`
    // ... bidang lain
}

func main () {
    Pelanggan: = Redis.NewClient (& redis.Options {
        Addr: "Localhost: 6379",
    })

    // Tulis mesej data: = mesej {userid: 123}
    jsondata, err: = json.marshal (mesej)
    jika err! = nil {
        panik (err)
    }

    err = client.xadd (& redis.xaddargs {
        Stream: "Mystream",
        Nilai: peta [string] antara muka {} {
            "Data": Jsondata, // Data JSON STORE sebagai nilai},
    }). Err ()
    jika err! = nil {
        panik (err)
    }

    // Baca aliran data, err: = client.xread (& redis.xreadargs {
        Streams: [] String {"Mystream", "0"},
        Blok: 0,
    }). Hasil ()
    jika err! = nil {
        panik (err)
    }

    untuk _, mesej: = aliran pelbagai [0] .messages {
        var yang diterima mesej
        json.unmarshal ([] byte (message.values ​​["data"]. (String)), & menerimaMessage) // deserialize json data fmt.printf ("id pengguna yang diterima: %d \ n", diterima.userid)
    }
}

Kod ini terlebih dahulu bersiri struktur Message ke dalam rentetan JSON, dan kemudian menyimpan rentetan JSON ke dalam aliran Redis. Apabila membaca, deserialize rentetan JSON kembali ke struktur Message , dengan itu memulihkan jenis integer user_id . Ini memastikan jenis konsistensi data semasa penyimpanan dan bacaan di Redis. Harap contoh ini dapat membantu anda menyelesaikan masalah penukaran jenis dengan berkesan dalam barisan mesej aliran redis.

Atas ialah kandungan terperinci Bagaimana menyelesaikan masalah penukaran jenis user_id semasa menggunakan aliran redis untuk melaksanakan beratur mesej dalam bahasa Go?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!