Wie löste ich das Problem des Typs des user_id -Typs bei der Verwendung von Redis -Stream, um Nachrichtenwarteschlangen in GO -Sprache zu implementieren?

GO REDIS Stream Message Warteschlange: Löst das Conversion -Problem des user_id -Typs geschickt

Beim Erstellen von Nachrichtenwarteschlangen mit dem GO- und REDIS -Stream plagen die Konvertierungsprobleme von Ganzzahltypen wie user_id häufig Entwickler. In diesem Artikel wird dieses Problem eingehend untersucht und wirksame Lösungen bereitstellen.

Angenommen, Ihre Anwendung muss Daten mit user_id (Ganzzahltyp) zum Redis -Stream schreiben. Sie können auf die folgenden Probleme stoßen:

Frage Beschreibung:

Nach dem direkten Schreiben von Redis Stream wird user_id beim Lesen zum Zeichenfolge -Typ. Zum Beispiel:

Schreiben Sie: xadd mystream * user_id 123

Lesen Sie: xread block 0 streams mystream $ ( user_id ist die Zeichenfolge "123").

Ursache Analyse:

Redis ist eine Zeichenfolge in der zugrunde liegenden Speicherung aller Daten. Selbst wenn Sie eine Ganzzahl schreiben, wandelt sich Redis in einen Stringspeicher um. Was Sie beim Lesen natürlich erhalten, ist der String -Typ.

Lösung: Serialisierung und Deserialisierung

Um die Integrität des Datentyps aufrechtzuerhalten, müssen wir vor dem Schreiben nach dem Lesen serialisieren, um sie zu entfernen und zu deserialisieren. Es wird empfohlen, JSON zur Serialisierung und Deserialisierung zu verwenden.

Hier ist ein Beispielcode, der zeigt, wie dieses Problem mit JSON gelöst werden kann:

 Paket Main

importieren (
    "Codierung/JSON"
    "fmt"
    "github.com/go-redis/redis/v8"
)

Geben Sie die Nachrichtenstruktur {ein
    UserID int `JSON:" user_id "`
    // ... andere Felder
}

func main () {
    Client: = redis.newclient (& redis.options {
        ADDR: "Localhost: 6379",
    })

    // Datennachricht schreiben: = message {userId: 123}
    JSondata, err: = json.marshal (Nachricht)
    Wenn er! = nil {
        Panik (ähm)
    }

    Err = client.xadd (& redis.xaddargs {
        Stream: "Mystream",
        Werte: Karte [String] Schnittstelle {} {
            "Daten": JSondata, // JSON -Daten als Wert}, speichern,.
    }). Err ())
    Wenn er! = nil {
        Panik (ähm)
    }

    // Datenstrom lesen, err: = client.xread (& redis.xreadargs {
        Streams: [] String {"MyStream", "0"},
        Block: 0,
    }).Ergebnis()
    Wenn er! = nil {
        Panik (ähm)
    }

    Für _, Nachricht: = Bereichsstream [0] .Messages {
        var empfangene Message -Nachricht
        Json.unmarshal ([] byte (message.values ​​["data"]. (String)) & empfangeneMessage) // Deserialize JSON Data fmt.printf ("Empfangene Benutzer -ID: %d \ n", empfangeneMessage.userid)
    }
}

Dieser Code serialisiert zuerst die Message in einen JSON -String und speichert dann die JSON -Zeichenfolge in einen Redis -Stream. Beim Lesen wird die JSON -Zeichenfolge auf die Message zurückgeführt, wodurch der ganzzahlige Typ user_id wiederhergestellt wird. Dies gewährleistet die Typ -Konsistenz von Daten während des Speichers und Lesens in Redis. Ich hoffe, dieses Beispiel kann Ihnen helfen, das Problem der Typ -Konvertierung in der GoTis -Stream -Nachrichtenwarteschlange effektiv zu lösen.

Das obige ist der detaillierte Inhalt vonWie löste ich das Problem des Typs des user_id -Typs bei der Verwendung von Redis -Stream, um Nachrichtenwarteschlangen in GO -Sprache zu implementieren?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!