Redisストリームを使用してGO言語でメッセージキューを実装する場合、user_idタイプの変換の問題を解決する方法は？

Go Redisストリームメッセージキュー：user_idタイプの変換問題を巧みに解決する

GoおよびRedisストリームを使用してメッセージキューを構築する場合、 user_idなどの整数タイプの変換問題が開発者を悩ませることがよくあります。この記事では、この問題を詳細に調査し、効果的なソリューションを提供します。

Redisストリームにuser_id （整数タイプ）を含むデータを記述する必要があると仮定します。次の問題に遭遇する可能性があります。

質問の説明：

Redis Streamに直接書き込むと、 user_id読み取り時に文字列型になります。例えば：

書き込み： xadd mystream * user_id 123

読み取り： xread block 0 streams mystream $ （ user_id読み取りは文字列「123」です）

原因分析：

Redisは、すべてのデータの基礎となるストレージの文字列です。整数を書いたとしても、Redisはそれを文字列ストレージに変換します。したがって、読書時に自然に得られるものは文字列タイプです。

解決策：シリアル化と降下

データ型の整合性を維持するには、読み取り後に書く前にシリアル化する必要があります。 SerializationとDeserializationにJSONを使用することをお勧めします。

JSONを使用してこの問題を解決する方法を示すサンプルコードは次のとおりです。

パッケージメイン

輸入 （
    「エンコード/json」
    「FMT」
    「github.com/go-redis/redis/v8」
））

タイプメッセージ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 {
        ストリーム：「マイストリーム」、
        値：[Map] [String] Interface {} {
            「データ」：JSondata、// jsonデータを価値として保存}、
    }）。err（）
    err！= nil {
        パニック（err）
    }

    //データストリームを読む、err：= client.xread（＆redis.xreadargs {
        ストリーム：[] string {"mystream"、 "0"}、
        ブロック：0、
    }）。結果（）
    err！= nil {
        パニック（err）
    }

    _、メッセージ：=範囲ストリーム[0] .messages {
        var receivemessageメッセージ
        json.unmarshal（[] byte（message.values ["data"]。（string））、＆receivemessage）// deserialize json data fmt.printf（ "受信ユーザーID：％d \ n"、receivemessage.userid）
    }
}

このコードは、最初にMessage構造をJSON文字列にシリアル化し、JSON文字列をRedisストリームに保存します。読むときは、JSON文字列をMessage構造に戻し、integerタイプのuser_idを復元します。これにより、レディスでのストレージと読み取り中のデータのタイプの一貫性が保証されます。この例が、GO Redisストリームメッセージキューのタイプ変換問題を効果的に解決するのに役立つことを願っています。

以上がRedisストリームを使用してGO言語でメッセージキューを実装する場合、user_idタイプの変換の問題を解決する方法は？の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。