Wie löste ich das Problem der Datentypkonvertierung, wenn der Stream von Redis verwendet wird, um Nachrichtenwarteschlangen in GO -Sprache zu implementieren?

GO REDIS -Stream -Nachrichtenwarteschlange: Lösen Sie das Problem der Datentyp -Konvertierung geschickt

Beim Erstellen von Meldungswarteschlangen mit dem GO- und Redis -Stream stoßen Sie häufig auf Datentyp -Konvertierungsprobleme. In diesem Artikel wird dieses Problem eingehend untersucht und wirksame Lösungen bereitstellen.

Problembeschreibung

Nehmen wir an, Sie erstellen ein Message -Warteschlangensystem basierend auf Redis -Stream. Sie können auf die folgenden Situationen stoßen:

1. Schreiben Sie Daten: Sie schreiben Daten in den Redis -Stream, bei dem user_id ein Ganzzahltyp ( int ) ist.

    // Beispiel für das Schreiben von Data client.xadd (CTX, & redis.xaddargs {
       Stream: "Mystream",
       Werte: Karte [String] Schnittstelle {} {
           "user_id": 123,
           "Nachricht": "Hallo, Welt!",
       },
   })

2. Daten lesen: Wenn Sie Daten jedoch lesen, wird das Feld user_id zu einem String -Typ ( string ).

    // Beispiel für das Lesen von Dateneinträgen, err: = client.xread (ctx, & redis.xreadargs {
       Streams: [] String {"MyStream", "0"},
   })
   Wenn er! = nil {
       Panik (ähm)
   }
   Für _, msg: = Bereicheinträge [0] .Messages {
       fmt.printf ("user_id type: %t, Wert: %v \ n", msg.values ​​["user_id"], msg.values ​​["user_id"])
   }

Dies führt zu einem Typfehlanpassung und erfordert eine zusätzliche Verarbeitung. Warum passiert das? Müssen wir den Typ jedes Mal, wenn wir ihn lesen, manuell konvertieren?

Ursache Analyse und Lösungen

Die zugrunde liegenden Speicherdaten existieren normalerweise in Zeichenfolgenform, auch wenn Sie einen numerischen Typ schreiben. Redis -Stream ist keine Ausnahme.

Um dieses Problem zu lösen, werden die folgenden Strategien empfohlen:

1. Strukturserialisierung und Deserialisierung: Vor dem Schreiben in Redis die Datenstruktur in eine JSON -Zeichenfolge serialisieren; Deserialisieren Sie es beim Lesen zurück in die GO -Struktur.

    // Definieren Sie die Nachrichtenstruktur Typ der Nachrichtenstruktur {
       UserID int `JSON:" user_id "`
       Nachricht Zeichenfolge `JSON:" Nachricht "`
   }
   
   // Data msg schreiben: = message {userId: 123, meldung: "Hallo, Welt!"}
   Daten, err: = json.marshal (msg)
   Wenn er! = nil {
       Panik (ähm)
   }
   client.xadd (ctx & redis.xaddargs {
       Stream: "Mystream",
       Werte: Karte [String] Schnittstelle {} {
           "Daten": String (Daten),
       },
   })
   
   // Dateneinträge lesen, err: = client.xread (ctx, & redis.xreadargs {
       Streams: [] String {"MyStream", "0"},
   })
   Wenn er! = nil {
       Panik (ähm)
   }
   Für _, msg: = Bereicheinträge [0] .Messages {
       var empfangene Nachricht
       Json.unmarshal ([] Byte (msg.Values ​​["Data"]. (String)), & empfangeneMsg)
       fmt.printf ("user_id: %d, meldung: %s \ n", empfangenmsg.userid, empfangeneg.message)
   }

   Stellen Sie durch Serialisierung und Deserialisierung sicher, dass die Datentypen zwischen Redis- und GO -Programmen konsistent sind und den Ärger der Typumwandlung vermeiden.

Durch die Verwendung dieser Methode kann die Lesbarkeit und Wartbarkeit des Codes effektiv Datentypkonvertierungsprobleme vermeiden. Denken Sie daran, immer potenzielle Fehler wie JSON -Codec -Fehler zu bewältigen.

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