Persistent lagring af streammeddelelser

Hver post i en Redis Stream får et entydigt post-id. Dette id genereres automatisk af Redis og består af to dele:

• Tidsstempel (millisekunder): Det tidspunkt, hvor posten blev tilføjet.
• Sekvensnummer: En tæller for poster, der tilføjes inden for samme millisekund.

Eksempel: 1678886400000-0

Vi bruger kommandoen XADD til at føje nye poster til en stream. * fortæller Redis, at post-id'et skal genereres automatisk, så det bliver entydigt og giver den korrekte rækkefølge.

Hver post indeholder også felt-værdi-par, ligesom et lille hash-kort.

Hvis du vil læse poster fra en stream, bruger du kommandoen XREAD. Du angiver streamens navn og det id, hvor læsningen skal begynde.

Det er vigtigt, at læsning af en post ikke fjerner den fra streamen. Den bliver der til andre forbrugere eller til senere gennemgang.

Her adskiller Redis Streams sig markant fra Redis Pub/Sub (publicering/abonnering).

• Streams: Meddelelser er persistente. De gemmes og kan læses flere gange, også af forbrugere, der opretter forbindelse senere.
• Pub/Sub: Meddelelser er midlertidige. De leveres én gang til aktive abonnenter og forsvinder derefter.

Med Pub/Sub går en meddelelse ganske enkelt tabt, hvis ingen klient abonnerer på en kanal, når meddelelsen publiceres. Der findes ingen kø eller historik.

Det minder om en direkte udsendelse: Hvis du ikke lytter med, går du glip af den. Det er velegnet til meddelelser i realtid, hvor historik ikke er nødvendig.

De automatisk genererede post-id'er i Redis Streams garanterer streng kronologisk rækkefølge. Meddelelser gemmes og hentes altid i præcis den rækkefølge, de blev tilføjet i.

Det er afgørende for programmer, hvor hændelsernes rækkefølge har betydning, f.eks. ved logføring, kontrol eller hændelseskildeindlæsning.

Vælg Redis Streams, når du har brug for:

• Pålidelige hændelseslogge: En komplet historik over hændelser i rækkefølge.
• Genafspilning af meddelelser: Mulighed for, at nye forbrugere kan behandle tidligere hændelser.
• Kontrol og analyse: Historiske data til analyse.
• Afkoblede mikrotjenester: Tjenester kan behandle hændelser i deres eget tempo.

I denne lektion undersøgte vi de vigtigste aspekter ved Redis Streams: persistent meddelelseslagring og garanteret levering i rækkefølge.

• Streams gemmer alle poster og danner dermed en uforanderlig log.
• Hver post har et entydigt, tidsbaseret id, der sikrer en streng rækkefølge.
• Denne persistens og rækkefølge er vigtige forskelle fra Redis Pub/Sub og gør Streams ideelle til pålidelig hændelsesbehandling og historiske data.