Redis Stream ืืื ืึท ื ืืึทืข ืึทืืกืืจืึทืงื ืืึทืื ืืืคึผ ืืึทืงืขื ืขื ืืื Redis ืืื ืืืขืจืกืืข 5.0
ืงืึทื ืกืขืคึผืืฉืืึทืื, Redis Stream ืืื ืึท ืจืฉืืื ืฆื ืืืึธืก ืืืจ ืงืขื ืขื ืืืืื ืืืื ืกื. ืืขืืขืจ ืคึผืึธืืืฆืืข ืืื ืึท ืืื ืฆืืง ืืืขื ืืืคืืขืจ. ืืืจื ืคืขืืืงืืึทื, ืื ืฉืืึทื ืืื ืืืืืึธืืึทืืืฉ ืืืฉืขื ืขืจืืืืึทื ืืื ืืืื ืึท ืืืืขืกืืึทืืคึผ. ืืขืจืืืขืจ, ืืืจ ืงืขื ืขื ืึธื ืคืจืขื ืจืืื ืืืฉืึทื ืคืื ืจืขืงืึธืจืืก ืืืืขืจ ืฆืืึทื, ืึธืืขืจ ืืึทืงืืืขื ื ืืึท ืืึทืื ืืืขื ืขืก ืงืืื ืืื ืื ืืืึทื, ืคืื ืืื ืื Unix "ืขืง -f" ืืึทืคึฟืขื ืืืืขื ื ืึท ืงืืึธืฅ ืืขืงืข ืืื ืคืจืืืื ืืฉืขืช ืืืืจืื ืคึฟืึทืจ ื ืืึทืข ืืึทืื. ืืึทืืขืจืงืื ื ืึทื ืงืืืคื ืงืืืืึทื ืฅ ืงืขื ืขื ืืขืจื ืฆื ืึท ืคืึธืืขื ืืื ืืขืจ ืืขืืืืงืขืจ ืฆืืื, ืคึผืื ืงื ืืื ืคืืืข "ืขืง -f" ืคึผืจืึทืกืขืกืึทื ืงืขื ืขื ืืืืขื ืขื ืึท ืืขืงืข ืกืืืืึทืืืืื ืืึทืกืื ืึธื ืงืึธื ืคืืืงื ืืื ืืขืืขืจ ืื ืืขืจืขืจ.
ืฆื ืคึฟืึทืจืฉืืืื ืึทืืข ืื ืืขื ืขืคืืฅ ืคืื ืื ื ืืึทืข ืืึทืื ืืืคึผ, ืืึธืื ืืื ืื ื ืขืืขื ืึท ืฉื ืขื ืงืืง ืืื ืื ืืึทื ื-ืืืืืกืืื ื Redis ืกืืจืึทืงืืฉืขืจื ืืืึธืก ืืืื ืจืขืคึผืืึทืงืืื ืื ืคืึทื ืืงืฉืึทื ืึทืืืื ืคืื Redis Stream.
ืจืขืืืก PUB/SUB
Redis Pub / Sub ืืื ืึท ืคึผืฉืื ืืขืกืืืืฉืื ื ืกืืกืืขื ืฉืืื ืืขืืืื ืืื ืืืื ืฉืืืกื-ืืืขืจื ืงืจืึธื. ืึธืืขืจ, ืคึผืึทืฉืืขืก ืงืืื ืฆื ืึท ืคึผืจืืึทื:
- ืืืื ืืขืจ ืึทืจืืืกืืขืืขืจ ืคึฟืึทืจ ืขืืืขืืข ืกืืื ืคืืืื, ืขืจ ืคืืจืืืจื ืึทืืข ืืืื ืข ืืืื ืขื ืื
- ืืขืจ ืึทืจืืืกืืขืืขืจ ืืึทืจืฃ ืืืืกื ืื ืคึผืื ืืืขื ืึทืืจืขืก ืคืื ืึทืืข ืืืึทื ืืืื ืขื ืื
- ื ืึทืจืืืกืืขืืขืจ ืงืขื ืึธืืืขืจืืึธืึทื ืืืื ืืืื ืขื ืื ืืื ืึทืจืืขื ืืืื ืืึทืื ืืขื ืขื ืืจืืืก ืคืึทืกืืขืจ ืืื ืขืก ืืื ืคึผืจืึทืกืขืกื
- ืืขืจ ืืขืกืขืืืฉ ืืืขืจื ืืืืกืืขืืขืงื ืคืื ืืขื ืืจืืืกืืขืืขืจ'ืก ืืืคืขืจ ืืืืื ื ืืื ืืจืืืกืืขืื, ื ืืฉื ืืขืงืืงื ืืืืฃ ืืืืคืื ืืืื ืขื ืื ืขืก ืืื ืืืืขืจืืขืืขืื ืืขืืืืจื ืืื ืืื ืฉื ืขื ืืื ืืืื ืืขืงืขื ื ืคืืจืืื ืืืขื ืืขื ืืขืกืขืืืฉ.
- ืึทืืข ืืืื ืขื ืื ืืืขืื ืืึทืงืืืขื ืืขื ืึธื ืืึธื ืืื ืืขืจ ืืขืืืืงืขืจ ืฆืืื. ืืืื ืขื ืื ืืื ืืืื ืขืคืขืก ืฉืืืืขื ืฆืืืืฉื ืืื ืืืขืื ืืขื ืกืืจ ืคืื ืคืืจืืื ืืืขื ืืขื ืืขืืื ืึธื ืืึธื.
- ืขืก ืืื ืงืืื ืืขืืืื-ืืื ืืขืงืึทื ืืืึทื ืฆื ืืึทืฉืืขืืืงื ืึทื ืึท ืึทืืึธื ืขื ื ืืื ืืฆืืื ืคึผืจืึทืกืขืกื ืึท ืึธื ืืึธื. ืืืื ืึท ืึทืืึธื ืขื ื ืืืงืืื ืึท ืึธื ืืึธื ืืื ืงืจืึทืฉืื ืืขืฉืึทืก ืคึผืจืึทืกืขืกืื ื, ืืขืจ ืึทืจืืืกืืขืืขืจ ืืืขื ื ืืฉื ืืืืกื ืืืขืื ืืื.
ืจืขืืืก ืจืฉืืื
Redis List ืืื ืึท ืืึทืื ืกืืจืืงืืืจ ืืืึธืก ืฉืืืฆื ืืืึทืงืื ื ืืืืขื ืขื ืงืึทืืึทื ืื. ืืืจ ืงืขื ืขื ืืืืื ืืื ืืืืขื ืขื ืึทืจืืืงืืขื ืคึฟืื ืื ืึธื ืืืื ืึธืืขืจ ืกืืฃ ืคืื ืืขืจ ืจืฉืืื. ืืึทืืืจื ืืืืฃ ืืขื ืกืืจืืงืืืจ, ืืืจ ืงืขื ืขื ืืึทืื ืึท ืืื ืึธื ืืืืื ืึธืืขืจ ืจืื ืคึฟืึทืจ ืืืื ืคืื ืื ืืขืจืืขืืืืื ืกืืกืืขื, ืืื ืืื ืจืืึฟ ืงืึทืกืขืก ืืึธืก ืืืขื ืืืื ืืขื ืื. ืืืืคึผื ืืืคืขืจืึทื ืกืื ืคืื Redis Pub / Sub:
- ืืขืจ ืึธื ืืึธื ืืื ืืืืขืจืืขืืขืื ืฆื ืืืื ืงืืืขื ื. ืืขืจ ืขืจืฉืืขืจ ืืืืขื ืขื-ืืืึทืงื ืงืืืขื ื ืืืขื ืืึทืงืืืขื ืื ืืึทืื ืขืจืฉืืขืจ.
- ืงืืื ื ืืืื ืึธื ืืืืื ืื ืืืืขื ืขื ืึธืคึผืขืจืึทืฆืืข ืคึฟืึทืจ ืืขืืขืจ ืึธื ืืึธื ืืื. ืจืฉืืื ืืืืืกื ืืึธืจื ืืฉื ืืืขืื ืงืืืืึทื ืฅ.
- ืึทืจืืืงืืขื ืืขื ืขื ืกืืึธืจื ืืื ืขืืขืฆืขืจ ืืืืขื ื ืืื ืึธืืขืจ ืืคืืจืืฉ ืืืกืืขืงื ืืื. ืืืื ืืืจ ืงืึทื ืคืืืืขืจ ืื Redis ืกืขืจืืืขืจ ืฆื ืืืกืฉืขืคึผื ืืึทืื ืฆื ืืืกืง, ืื ืจืืืืืึทืืืืึทืื ืคืื ืื ืกืืกืืขื ืื ืงืจืืกืื ืืจืึทืืึทืืืงืื.
ืืงืืื ืฆื ืกืืจืื
ืึทืืื ื ืึทื ืคึผืึธืืืฆืืข ืฆื ืึท ืืืึทื
ืงืึธืืขืงืืืื XADD ืืืกืืฃ ืึท ื ืืึทืข ืคึผืึธืืืฆืืข ืฆื ืืขื ืืืึทื. ื ืจืขืงืึธืจื ืืื ื ืืฉื ืืืืื ืึท ืฉืืจืืงื, ืขืก ืืืฉืืืื ืคืื ืืืื ืึธืืขืจ ืืขืจ ืฉืืืกื-ืืืขืจื ืคึผืขืจื. ืืืื, ืืขืืขืจ ืคึผืึธืืืฆืืข ืืื ืฉืืื ืกืืจืึทืงืืฉืขืจื ืืื ืจืืืขืืืึทืื ืื ืกืืจืืงืืืจ ืคืื ืึท ืงืกืื ืืขืงืข.
> XADD mystream * sensor-id 1234 temperature 19.8
1518951480106-0
ืืื ืืขื ืืืืฉืคึผืื ืืืืื, ืืืจ ืืืืื ืฆืืืื ืคืขืืืขืจ ืฆื ืื ืืืึทื ืืื ืื ื ืึธืืขื (ืฉืืืกื) "ืืืกืืจืื": "ืกืขื ืกืึธืจ-ืฉืืึทื" ืืื "ืืขืืคึผืขืจืึทืืืจ" ืืื ืื ืืืึทืืืขืก "1234" ืืื "19.8", ืจืืกืคึผืขืงืืืืืื. ืืื ืืขืจ ืฆืืืืืืขืจ ืึทืจืืืืขื ื, ืืขืจ ืืึทืคึฟืขื ื ืขืื ืึทื ืืืืขื ืืืคืืฆืืจื ืืืึธืก ืืืขื ืืืื ืึทืกืืื ื ืฆื ืื ืคึผืึธืืืฆืืข - ืืขืจ ืืืืขื ืืืคืืฆืืจื ืืื ืืงืื ืืืืขื ืึทืคืืื ืืขืืขืจ ืคึผืึธืืืฆืืข ืืื ืืขื ืืืึทื. ืึธืืขืจ, ืืื ืืขื ืคืึทื, ืืืจ ืืืจืืืขืืื ืืขื * ืืืืึทื ืืืจ ืืืืื Redis ืฆื ืืืฉืขื ืขืจืืื ืึท ื ืืึท ืฉืืึทื ืคึฟืึทืจ ืืื ืื. ืืขืืขืจ ื ืืึท ืฉืืึทื ืืืขื ืคืึทืจืืจืขืกืขืจื. ืืขืจืืืขืจ, ืืขืืขืจ ื ืืึท ืคึผืึธืืืฆืืข ืืืขื ืืึธืื ืึท ืืขืืขืจ ืืืขื ืืืคืืขืจ ืืื ืืึทืฆืืื ื ืฆื ืคืจืืึทืขืจืืืง ืืืื ืกื.
ืืืขื ืืืคืืขืจ ืคึฟืึธืจืืึทื
ืื ืคึผืึธืืืฆืืข ID ืืืืืขืงืขืจื ืืืจื ืื ืืึทืคึฟืขื XADD, ืืืฉืืืื ืคืื ืฆืืืื ืืืืื:
{millisecondsTime}-{sequenceNumber}
ืืืืืกืขืงืื ืื ืฆืืื - ืืื ืืงืก ืฆืืื ืืื ืืืืืกืขืงืึทื ืื (ืจืขืืืก ืกืขืจืืืขืจ ืฆืืื). ืึธืืขืจ, ืืืื ืื ืงืจืึทื ื ืฆืืื ืืื ืื ืืขืืืข ืึธืืขืจ ืืืืื ืืงืขืจ ืืื ืื ืฆืืื ืคืื ืื ืคืจืืขืจืืืงืข ืจืขืงืึธืจืืื ื, ืื ืฆืืื ืกืืึทืืคึผ ืคืื ืื ืคืจืืขืจืืืงืข ืจืขืงืึธืจืืื ื ืืื ืืขื ืืฆื. ืืขืจืืืขืจ, ืืืื ืื ืกืขืจืืืขืจ ืฆืืื ืืืื ืฆืืจืืง ืืื ืฆืืื, ืื ื ืืึทืข ืืืืขื ืืืืขื ืืืขื ื ืึธื ืืึทืืื ืื ืื ืงืจืึทืืึทื ื ืคืึทืจืืึธื.
ืกืืงืืืึทื ืกื ืืืขืจ ืืขืืืืื ื ืคึฟืึทืจ ืจืขืงืึธืจืืก ืืืฉืืคื ืืื ืืขืจ ืืขืืืืงืขืจ ืืืืืกืขืงืึทื ืืื. ืกืืงืืืึทื ืกื ืืืขืจ ืืืขื ืืืื ืืขืืืืงืกื ืืื 1 ืงืึธืจืขืื ืฆื ืื ืคืจืืขืจืืืงืข ืคึผืึธืืืฆืืข. ืืืืึทื ืื ืกืืงืืืึทื ืกื ืืืขืจ ืืื 64 ืืืฅ ืืื ืืจืืืก, ืืขืืึธืื ืืื ืคืืจ ืืืจ ืืึธื ื ืืฉื ืืืืคื ืืื ืึท ืฉืืขืืจ ืคืื ืื ื ืืืขืจ ืคืื ืจืขืงืึธืจืืก ืืืึธืก ืงืขื ืขื ืืืื ืืืฉืขื ืขืจืืืืึทื ืืื ืืืื ืืืืืกืขืงืึทื ืืื.
ืืขืจ ืคึฟืึธืจืืึทื ืคืื ืึทืืึท ืืืขื ืืืคืืขืจืก ืงืขื ืืืกืงืืืขื ืืึธืื ืข ืืืึท ืขืจืฉืืขืจ ืืืืง. ื ืืืกืืจืึทืกืืคืื ืืืืขื ืขืจ ืงืขื ืืืื ืืขืจ ืืืึธืก ืฆืืื ืืื ืืืื ืคืื ืื ืืืขื ืืืคืืขืจ. ืื ืกืืื ืืื ืึทื Redis ืกืืจืืื ืฉืืืฆื ืงืืื ืงืืืืจืื ืืืจื ืฉืืึทื. ืืื ื ืื ืืืืขื ืืืืขื ืืื ืคึฟืึทืจืืื ืื ืืื ืื ืฆืืื ืืืขื ืื ืจืขืงืึธืจื ืืื ืืืฉืืคื, ืืึธืก ืืืื ืขืก ืืขืืืขื ืฆื ืึธื ืคืจืขื ืฆืืื ืจืืื ืืืฉืึทื. ืืืจ ืืืขืื ืงืืงื ืืื ืึท ืกืคึผืขืฆืืคืืฉ ืืืึทืฉืคึผืื ืืืขื ืืืจ ืงืืงื ืืื ืื ืืึทืคึฟืขื XRANGE.
ืืืื ืคึฟืึทืจ ืขืืืขืืข ืกืืื ืืขืจ ืืึทื ืืฆืขืจ ืืึทืจืฃ ืฆื ืกืคึผืขืฆืืคืืฆืืจื ืืืื ืืืืืขื ืข ืืืืขื ืืืืขื, ืืืึธืก, ืคึฟืึทืจ ืืืึทืฉืคึผืื, ืืื ืคืืจืืื ืื ืืื ืขืืืขืืข ืคืื ืืจืืืกื ืืืง ืกืืกืืขื, ืืืจ ืงืขื ืขื ืคืึธืจื ืขืก ืฆื ืื ืืึทืคึฟืขื. XADD ืึทื ืฉืืึธื ืคืื * ืืื ืืขืืืืื ืืื ืื:
> XADD somestream 0-1 field value
0-1
> XADD somestream 0-2 foo bar
0-2
ืืืืข ืืึธื ืึทื ืืื ืืขื ืคืึทื ืืืจ ืืืื ืืึธื ืืืึธืจ ืื ืฉืืึทื ืื ืงืจืึทืืึทื ื ืืื. ืืื ืืื ืืืขืจ ืืืืฉืคึผืื, ืื ืืื ืืืื ืืืืขื ืืืืขื ืืื "0-1", ืึทืืื ืื ืืึทืคึฟืขื ืืืขื ื ืืฉื ืึธื ื ืขืืขื ืื ืื ืืขืจ ืืืืขื ืืืืขื ืืืึธืก ืืื ืืืืึทื ืฆื ืึธืืขืจ ืืืืื ืืงืขืจ ืืื "0-1".
> XADD somestream 0-1 foo bar
(error) ERR The ID specified in XADD is equal or smaller than the target stream top item
ื ืืืขืจ ืคืื ืจืขืงืึธืจืืก ืคึผืขืจ ืืืึทื
ืขืก ืืื ืืขืืืขื ืฆื ืืึทืงืืืขื ืื ื ืืืขืจ ืคืื ืจืขืงืึธืจืืก ืืื ืึท ืืืึทื ืคืฉืื ืืืจื ื ืืฆื ืื ืืึทืคึฟืขื XLEN. ืคึฟืึทืจ ืืื ืืืขืจ ืืืึทืฉืคึผืื, ืืขื ืืึทืคึฟืขื ืืืขื ืฆืืจืืงืงืืืขื ืื ืคืืืืขื ืืข ืืืขืจื:
> XLEN somestream
(integer) 2
ืงืืื ืคึฟืจืืื - XRANGE ืืื XREVRANGE
ืฆื ืืขืื ืืึทืื ืืืื ืงืืื, ืืืจ ืืึทืจืคึฟื ืฆื ืกืคึผืขืฆืืคืืฆืืจื ืฆืืืื ืืืขื ืืืคืืขืจืก - ืื ืึธื ืืืื ืืื ืื ืกืืฃ ืคืื ืื ืงืืื. ืื ืืืืืขืงืขืจื ืงืืื ืืืขื ืึทืจืืึทื ื ืขืืขื ืึทืืข ืขืืขืืขื ืื, ืึทืจืืึทื ืืขืจืขืื ื ืื ืืึทืื ืืจืื. ืขืก ืืขื ืขื ืืืื ืฆืืืื ืกืคึผืขืฆืืขืืข ืืืืขื ืืืคืืฆืืจื "-" ืืื "+", ืจืืกืคึผืขืงืืืืืื ืืืึทืืฉ ืืขืจ ืงืืขื ืกืืขืจ (ืขืจืฉืืขืจ ืจืขืงืึธืจื) ืืื ืืจืขืกืืขืจ (ืืขืฆืืข ืจืขืงืึธืจื) ืืืืขื ืืืืขื ืืื ืืขื ืืืึทื. ืืขืจ ืืืืฉืคึผืื ืืื ืื ืืืขื ืจืฉืืื ืึทืืข ืื ืืืึทื ืืืื ืกื.
> XRANGE mystream - +
1) 1) 1518951480106-0
2) 1) "sensor-id"
2) "1234"
3) "temperature"
4) "19.8"
2) 1) 1518951482479-0
2) 1) "sensor-id"
2) "9999"
3) "temperature"
4) "18.2"
ืืขืืขืจ ืืืืืขืงืขืจื ืจืขืงืึธืจื ืืื ืึท ืืขื ืืข ืคืื โโโโืฆืืืื ืขืืขืืขื ืื: ืึท ืืืขื ืืืคืืขืจ ืืื ืึท ืจืฉืืื ืคืื ืฉืืืกื-ืืืขืจื ืคึผืขืจื. ืืืจ ืืึธืื ืฉืืื ืืขืืึธืื ืึทื ืจืขืงืึธืจื ืืืืขื ืืืคืืฆืืจื ืืขื ืขื ืฉืืื ืฆื ืฆืืื. ืืขืจืืืขืจ, ืืืจ ืงืขื ืขื ืืขืื ืึท ืงืืื ืคืื ืึท ืกืคึผืขืฆืืคืืฉ ืฆืืื. ืึธืืขืจ, ืืืจ ืงืขื ืขื ืกืคึผืขืฆืืคืืฆืืจื ืืื ืืขืจ ืืงืฉื ื ืื ืื ืคืื ืืืืขื ืืืคืืฆืืจื, ืึธืืขืจ ืืืืื ืื ืืื ืืงืก ืฆืืื, ืึธืืืืืื ื ืื ืืืื ืฉืืึทืืืช ืฆื ืกืืงืืืึทื ืกื ืืืขืจ. ืื ืืืืขืจืืขืืืคึผืขืจื ืืืื ืคืื ืื ืืืืขื ืืืคืืฆืืจื ืืืขื ืืืืืึธืืึทืืืฉ ืืืื ืืึทืฉืืืื ืฆื ื ืื ืืื ืื ืึธื ืืืื ืคืื ืื ืงืืื ืืื ืฆื ืื ืืึทืงืกืืืื ืืขืืืขื ืืืขืจื ืืื ืื ืกืืฃ ืคืื ืื ืงืืื. ืื ืืขืจ ืืื ืึท ืืืืฉืคึผืื ืคืื ืืื ืืืจ ืงืขื ืขื ืืขืื ืึท ืงืืื ืคืื ืฆืืืื ืืืืืกืขืงืึทื ืื.
> XRANGE mystream 1518951480106 1518951480107
1) 1) 1518951480106-0
2) 1) "sensor-id"
2) "1234"
3) "temperature"
4) "19.8"
ืืืจ ืืึธืื ืืืืื ืืืื ืคึผืึธืืืฆืืข ืืื ืืขื ืงืืื, ืึธืืขืจ ืืื ืคืึทืงืืืฉ ืืึทืื ืฉืืขืื, ืืขืจ ืจืขืืืืืึทื ืงืขื ืืืื ืจืืืืง. ืคึฟืึทืจ ืืขื ืกืืื XRANGE ืฉืืืฆื ืื COUNT ืึธืคึผืฆืืข. ืืืจื ืกืคึผืขืฆืืคืืฆืืจื ืื ืงืืืึทื ืืืื, ืืืจ ืงืขื ืขื ืคืฉืื ืืึทืงืืืขื ืื ืขืจืฉืืขืจ N ืจืขืงืึธืจืืก. ืืืื ืืืจ ืืึทืจืคึฟื ืฆื ืืึทืงืืืขื ืื ืืืืึทืืขืจ N ืจืขืงืึธืจืืก (ืคึผืึทืืขืืขื ื), ืืืจ ืงืขื ืขื ื ืืฆื ืื ืืขืฆืืข ืืืงืืืขื ืฉืืึทื, ืคืึทืจืืจืขืกืขืจื ืขืก ืกืืงืืืึทื ืกื ืืืขืจ ืืืจื ืืืื ืขืจ ืืื ืคืจืขืื ืืืืืขืจ. ืืื ืก ืงืืง ืืื ืืขื ืืื ืื ืคืืืืขื ืืข ืืืึทืฉืคึผืื. ืืืจ ืึธื ืืืืื ืฆื ืืืืื 10 ืขืืขืืขื ืื ืืื XADD (ืึทืกืืืื ื ืืืกืืจืขืึทื ืืื ืฉืืื ืึธื ืืขืคืืื ืืื 10 ืขืืขืืขื ืื). ืฆื ืึธื ืืืืื ืื ืืืขืจืึทืืืึธื ืฆื ืืึทืงืืืขื 2 ืขืืขืืขื ืื ืคึผืขืจ ืืึทืคึฟืขื, ืืืจ ืึธื ืืืืื ืืื ืื ืคืื ืงืืื ืึธืืขืจ ืืื COUNT ืืืืึทื ืฆื 2.
> XRANGE mystream - + COUNT 2
1) 1) 1519073278252-0
2) 1) "foo"
2) "value_1"
2) 1) 1519073279157-0
2) 1) "foo"
2) "value_2"
ืฆื ืคืึธืจืืขืฆื ืืืขืจืืืืื ื ืืื ืื ืืืืึทืืขืจ ืฆืืืื ืขืืขืืขื ืื, ืืืจ ืืึทืจืคึฟื ืฆื ืืืืกืงืืืึทืื ืื ืืขืฆืืข ืฉืืึทื ืืืงืืืขื, ื"ื 1519073279157-0, ืืื ืืืืื 1 ืฆื ืกืืงืืืึทื ืกื ืืืขืจ.
ืื ืจืืืึทืืืื ื ืฉืืึทื, ืืื ืืขื ืคืึทื 1519073279157-1, ืงืขื ืขื ืืืฆื ืืืื ืืขืืืืื ื ืืื ืื ื ืืึทืข ืึธื ืืืื ืคืื ืงืืื ืึทืจืืืืขื ื ืคึฟืึทืจ ืื ืืืืึทืืขืจ ืจืืคื XRANGE:
> XRANGE mystream 1519073279157-1 + COUNT 2
1) 1) 1519073280281-0
2) 1) "foo"
2) "value_3"
2) 1) 1519073281432-0
2) 1) "foo"
2) "value_4"
ืืื ืืืื ืืืืืืขืจ. ืืืืึทื ืงืึทืืคึผืืขืงืกืืื XRANGE ืืื O(ืืึธื(N)) ืฆื ืืืื ืืื ืืขืจื ืึธื O(M) ืฆื ืฆืืจืืงืงืืืขื M ืขืืขืืขื ืื, ืืื ืืขืืขืจ ืืืขืจืึทืืืึธื ืฉืจืื ืืื ืฉื ืขื. ืืืื, ื ืืฆื XRANGE ืกืืจืืื ืงืขื ืขื ืืืื ืืืขืจืืืืื ืืคืืฉืึทื ืืื.
ืงืึธืืขืงืืืื XREVRANGE ืืื ืืขืจ ืขืงืืืืืืึทืืขื ื XRANGE, ืึธืืขืจ ืงืขืจื ืื ืขืืขืืขื ืื ืืื ืคืึทืจืงืขืจื ืกืืจ:
> XREVRANGE mystream + - COUNT 1
1) 1) 1519073287312-0
2) 1) "foo"
2) "value_10"
ืืืืข ืืึธื ืึทื ืื ืืึทืคึฟืขื XREVRANGE ื ืขืื ืงืืื ืึทืจืืืืขื ืื ืึธื ืืืื ืืื ืืึทืืื ืืื ืคืึทืจืงืขืจื ืกืืจ.
ืืืืขื ืขื ื ืืึทืข ืืืื ืกื ืืื XREAD
ืึธืคื ืื ืึทืจืืขื ืขืจืืืืึทื ืคืื ืึทืืึธื ืืจื ืฆื ืึท ืืืึทื ืืื ืืึทืงืืืขื ืืืืื ื ืืึทืข ืึทืจืืืงืืขื. ืืขืจ ืืึทืืจืืฃ ืงืขื ืืืกืงืืืขื ืขื ืืขื ืฆื Redis Pub / Sub ืึธืืขืจ ืืืึทืงืื ื Redis List, ืึธืืขืจ ืขืก ืืขื ืขื ืคืื ืืึทืืขื ืืึทื ืืืคืขืจืึทื ืกืื ืืื ืืื ืฆื ื ืืฆื Redis Stream:
- ืืขืืขืจ ื ืืึท ืึธื ืืึธื ืืื ืืืืขืจืืขืืขืื ืฆื ืืขืืขืจ ืึทืืึธื ืขื ื ืืืจื ืคืขืืืงืืึทื. ืืขืจ ืึธืคึผืคืืจืื ื ืืื ืึทื ืืขืจืฉ ืคืื ืึท ืืืึทืงืื ื ืจืขืืืก ืจืฉืืื, ืืื ืึท ื ืืึทืข ืึธื ืืึธื ืืืขื ืืืื ืืืืขื ืขื ืืืืื ืืืจื ืืืื ืึทืืึธื ืขื ื.
- ืืฉืขืช ืืื Redis Pub / Sub ืึทืืข ืึทืจืืืงืืขื ืืขื ืขื ืคืืจืืขืกื ืืื ืงืืื ืืึธื ืคึผืขืจืกืืกืืึทื, ืืื ืกืืจืื ืึทืืข ืึทืจืืืงืืขื ืืขื ืขื ืจืืืืื ื ืื ืืขืคืึทื ืึทืืื (ืกืืึทืื ืืขืจ ืงืืืขื ื ืืคืืจืืฉ ื ืืืืืฉืึทื).
- Redis Stream ืึทืืึทืื ืืืจ ืฆื ืืืคืขืจืขื ืฉืืืื ืึทืงืกืขืก ืฆื ืึทืจืืืงืืขื ืืื ืืืื ืืืึทื. ื ืกืคึผืขืฆืืคืืฉ ืึทืืึธื ืขื ื ืงืขื ืขื ืืืืื ืืขื ืืืืขืจ ืคืขืจืืขื ืืขืืข ืึธื ืืึธื ืืขืฉืืืืข.
ืืืจ ืงืขื ื ืึทืืึธื ืืจื ืฆื ืึท ืคืึธืืขื ืืื ืืึทืงืืืขื ื ืืึทืข ืึทืจืืืงืืขื ืืื ืืขื ืืึทืคึฟืขื XREAD. ืขืก ืืื ืึท ืืืกื ืืขืจ ืงืึธืืคึผืืืฆืืจื ืืื XRANGE, ืึทืืื ืืืจ ืืืขืื ืึธื ืืืืื ืืื ืื ืกืืืคึผืืขืจ ืืืืฉืคืืื ืขืจืฉืืขืจ.
> XREAD COUNT 2 STREAMS mystream 0
1) 1) "mystream"
2) 1) 1) 1519073278252-0
2) 1) "foo"
2) "value_1"
2) 1) 1519073279157-0
2) 1) "foo"
2) "value_2"
ืืขืจ ืืืืฉืคึผืื ืืืืื ืืืืืื ืึท ื ืื-ืืืึทืงืื ื ืคืึธืจืขื XREAD. ืืึทืืขืจืงืื ื ืึทื ืื COUNT ืึธืคึผืฆืืข ืืื ืึทืคึผืฉืึทื ืึทื. ืืื ืคืึทืงื, ืื ืืืืื ืคืืจืืื ืื ืืึทืคึฟืขื ืึธืคึผืฆืืข ืืื ืื STREAMS ืึธืคึผืฆืืข, ืืืึธืก ืกืคึผืขืฆืืคืืฆืืจื ืึท ืจืฉืืื ืคืื ืกืืจืืื ืฆืืืืืขื ืืื ืื ืงืึธืจืึทืกืคึผืึทื ืืื ื ืืึทืงืกืืืื ืืืืขื ืึทืคืืื. ืืืจ ืืึธืื ืืขืฉืจืืื "STREAMS mystream 0" - ืืืจ ืืืืื ืฆื ืืึทืงืืืขื ืึทืืข ืจืขืงืึธืจืืก ืคืื ืื ืืืกืืจืขืึทื ืืืึทื ืืื ืึท ืืืืขื ืืืืขื ืืจืขืกืขืจ ืืื "0-0". ืืื ืืืจ ืงืขื ืขื ืืขื ืคึฟืื ืืขื ืืืึทืฉืคึผืื, ืื ืืึทืคึฟืขื ืงืขืจื ืื ื ืึธืืขื ืคืื ืื ืคืึธืืขื ืืืืึทื ืืืจ ืงืขื ืขื ืึทืืึธื ืืจื ืฆื ืงืืืคื ืคึฟืขืืขื ืืื ืืขืจ ืืขืืืืงืขืจ ืฆืืื. ืืืจ ืงืขื ืฉืจืืึทืื, ืคึฟืึทืจ ืืืึทืฉืคึผืื, "ืกืืจืืื ืืืื ืกืืจืื ืื ืืขืจืข ืกืืจืื 0 0". ืืืืข ืืึธื ืึทื ื ืึธื ืื STREAMS ืึธืคึผืฆืืข ืืืจ ืืึทืจืคึฟื ืฆื ืขืจืฉืืขืจ ืฆืืฉืืขืื ืื ื ืขืืขื ืคืื ืึทืืข ืื ืคืืจืืื ืื ืกืืจืืื ืืื ืืืืื ืืขืืึธืื ืึท ืจืฉืืื ืคืื ืืืขื ืืืคืืขืจืก.
ืืื ืืขื ืคึผืฉืื ืคืึธืจืขื ืื ืืึทืคึฟืขื ืืื ื ืืฉื ืืึธื ืขืคึผืขืก ืกืคึผืขืฆืืขื ืงืึทืืคึผืขืจื ืืื XRANGE. ืึธืืขืจ, ืื ืืฉืืงืึทืืืข ืืึทื ืืื ืึทื ืืืจ ืงืขื ืขื ืืืืื ืืืขื ืื XREAD ืฆื ืึท ืืืึทืงืื ื ืืึทืคึฟืขื, ืกืคึผืขืฆืืคืืฆืืจื ืื BLOCK ืึทืจืืืืขื ื:
> XREAD BLOCK 0 STREAMS mystream $
ืืื ืืขื ืืืึทืฉืคึผืื ืืืืื, ืึท ื ืืึทืข BLOCK ืึธืคึผืฆืืข ืืื ืกืคึผืขืกืืคืืขื ืืื ืึท ืืืืืึทืื ืคืื 0 ืืืืืกืขืงืึทื ืื (ืืึธืก ืืืื ืืืืจืื ืื ืืขืคืึทื ืึทืืื). ืืขืจืฆื, ืึทื ืฉืืึธื ืคืื ืืืจืืืืื ืื ืืขืืืืื ืืืขื ืืืืขื ืืืืขื ืคึฟืึทืจ ืื ืืืกืืจืื ืืืึทื, ืึท ืกืคึผืขืฆืืขื ืืืืขื ืืืืขื $ ืืื ืืืจืืืขืืื ืืขื. ืืขื ืกืคึผืขืฆืืขืืข ืืืขื ืืืคืืขืจ ืืืื ืึทื XREAD ืืืื ื ืืฆื ืื ืืึทืงืกืืืื ืืืขื ืืืคืืขืจ ืืื mystream ืืื ืื ืืืขื ืืืคืืขืจ. ืึทืืื ืืืจ ืืืขืื ืืืืื ืืึทืงืืืขื ื ืืึทืข ืึทืจืืืงืืขื ืกืืึทืจืืื ื ืคืื ืืขื ืืึธืืขื ื ืืืจ ืกืืึทืจืืขื ืฆืืืขืืขืจื. ืืื ืขืืืขืืข ืืืขืื ืืึธืก ืืื ืขื ืืขื ืฆื ืื Unix "ืขืง -f" ืืึทืคึฟืขื.
ืืึทืืขืจืงืื ื ืึทื ืืืขื ืืืจ ื ืืฆื ืื BLOCK ืึธืคึผืฆืืข, ืืืจ ืืึธื ื ืื ืืึทืืืงืข ืืึทืจืคึฟื ืฆื ื ืืฆื ืื ืกืคึผืขืฆืืขืืข ืืืืขื ืืืืขื $. ืืืจ ืงืขื ืขื ื ืืฆื ืงืืื ืืืขื ืืืคืืขืจ ืืืึธืก ืืื ืืื ืืขื ืืืึทื. ืืืื ืื ืืึทื ืฉืึทืคึฟื ืงืขื ืขื ืืื ืขื ืืื ืืืขืจ ืืงืฉื ืืื ืึธื ืืืึทืงืื ื, ืขืก ืืืขื ืืึธื ืืึธืก, ืึทื ืืขืจืฉ ืขืก ืืืขื ืคืึทืจืฉืคึผืึทืจื.
ืืืึทืงืื ื XREAD ืงืขื ืขื ืืืื ืืขืจื ืฆื ืงืืืคื ืคึฟืขืืขื ืืื ืึทืืึธื, ืืืจ ื ืึธืจ ืืึทืจืคึฟื ืฆื ืกืคึผืขืฆืืคืืฆืืจื ืืืืขืจ ื ืขืืขื. ืืื ืืขื ืคืึทื, ืืขืจ ืืึทืคึฟืขื ืืืขื ืฆืืจืืงืงืืืขื ืึท ืจืขืงืึธืจื ืคืื ืืขืจ ืขืจืฉืืขืจ ืืืึทื ืืืึธืก ืืืงืืืขื ืืึทืื. ืืขืจ ืขืจืฉืืขืจ ืึทืืึธื ืขื ื ืืืึทืงื ืคึฟืึทืจ ืึท ืืขืืขืื ืคืึธืืขื ืืืขื ืืึทืงืืืขื ืืึทืื ืขืจืฉืืขืจ.
ืงืึธื ืกืืืขืจ ืืจืืคึผืขืก
ืืื ืืืืขืจ ืืึทืกืงืก, ืืืจ ืืืืื ืฆื ืืึทืืจืขื ืขืฆื ืึทืืึธื ืขื ื ืึทืงืกืขืก ืฆื ืึทืจืืืงืืขื ืืื ืืืื ืคืึธืืขื. ื ืืืืฉืคึผืื ืืืึผ ืืึธืก ืงืขื ืืืื ื ืืฆืืง ืืื ืึท ืึธื ืืึธื ืจืื ืืื ืืืึธืจืงืขืจืก ืืืึธืก ืืืขื ืืึทืงืืืขื ืคืึทืจืฉืืืขื ืข ืึทืจืืืงืืขื ืคืื ืึท ืคืึธืืขื, ืึทืืึทืืื ื ืึธื ืืึธื ืคึผืจืึทืกืขืกืื ื ืฆื ืืืึธื.
ืืืื ืืืจ ืืืึทืืืฉืึทื ืึทื ืืืจ ืืึธืื ืืจืื ืืืื ืขื ืื C1, C2, C3 ืืื ืึท ืคืึธืืขื ืืืึธืก ืึผืืื ืึทืจืืืงืืขื 1, 2, 3, 4, 5, 6, 7, ืื ืึทืจืืืงืืขื ืืืขื ืืืื ืืขืืื ื ืืื ืืื ืื ืืืึทืืจืึทืืข ืืื ืื:
1 -> C1
2 -> C2
3 -> C3
4 -> C1
5 -> C2
6 -> C3
7 -> C1
ืฆื ืืขืจืืจืืืื ืืขื ืืืืจืงืื ื, Redis Stream ื ืืฆื ืึท ืืึทืืจืืฃ ืืขืจืืคึฟื ืงืึธื ืกืืืขืจ ืืจืืคืข. ืืขืจ ืืึทืืจืืฃ ืืื ืขื ืืขื ืฆื ืึท ืคึผืกืขืืืืึธ-ืึทืืึธื ืขื ื, ืืืึธืก ืืืงืืื ืืึทืื ืคืื ืึท ืืืึทื, ืึธืืขืจ ืืื ืคืืงืืืฉ ืืขืืื ื ืืืจื ืงืืืคื ืืืื ืขื ืื ืืื ืึท ืืจืืคึผืข, ืคึผืจืึทืืืืืืื ื ืืืืขืจ ืืขืจืึทื ืืื:
- ืืขืืขืจ ืึธื ืืึธื ืืื ืืืืขืจืืขืืขืื ืฆื ืึท ืึทื ืืขืจืฉ ืึทืืึธื ืขื ื ืืื ืืขืจ ืืจืืคึผืข.
- ืืื ืึท ืืจืืคึผืข, ืืืื ืขื ืื ืืขื ืขื ืืืืขื ืึทืคืืื ืืืจื ืืืืขืจ ื ืึธืืขื, ืืืึธืก ืืื ืึท ืคืึทื-ืฉืคึผืืจืขืืืืืง ืฉืืจืืงื. ืืืื ืึท ืึทืืึธื ืขื ื ืืื ืืขืืคึผืขืจืขืจืึทืื ืึทืืืขืง ืคืื ืืขืจ ืืจืืคึผืข, ืขืจ ืงืขื ืขื ืืืื ืืขืืื ื ืฆื ืืขืจ ืืจืืคึผืข ืืื ืืืื ืืืืืขื ืข ืืื ืฆืืง ื ืึธืืขื.
- ืืขืืขืจ ืงืึธื ืกืืืขืจ ืืจืืคืข ืืืื ืื "ืขืจืฉืืขืจ ืึทื ืจืื ืึธื ืืึธื" ืืึทืืจืืฃ. ืืืขื ืึท ืึทืืึธื ืขื ื ืจืืงืืืขืก ื ืืึท ืึทืจืืืงืืขื, ืขืก ืงืขื ืขื ืืืืื ืืึทืงืืืขื ืึทืจืืืงืืขื ืืืึธืก ืืึธืื ืงืืื ืืึธื ืืขืืืขื ืคืจืืขืจ ืืืืขืจืืขืืขืื ืฆื ืงืืื ืึทืืึธื ืขื ื ืืื ืืขืจ ืืจืืคึผืข.
- ืขืก ืืื ืึท ืืึทืคึฟืขื ืฆื ืืคืืจืืฉ ืืึทืฉืืขืืืงื ืึทื ืืขืจ ืึธื ืืึธื ืืื ืืฆืืื ืคึผืจืึทืกืขืกื ืืืจื ืื ืึทืืึธื ืขื ื. ืืื ืืขื ืืึทืคึฟืขื ืืื ืืขืจืืคื, ืื ืืขืืขืื ืึธื ืืึธื ืืืขื ืืืืึทืื ืืื ืื "ืคึผืขื ืืื ื" ืกืืึทืืืก.
- ืืื ืืขืจ ืงืึธื ืกืืืขืจ ืืจืืคืข, ืืขืืขืจ ืึทืืึธื ืขื ื ืงืขื ืขื ืืขืื ืึท ืืขืฉืืืืข ืคืื โโืึทืจืืืงืืขื ืืืึธืก ืืขื ืขื ืืืืขืจืืขืืขืื ืฆื ืืื, ืึธืืขืจ ื ืึธื ื ืืฉื ืคึผืจืึทืกืขืกื (ืืื ืื "ืคึผืขื ืืื ื" ืกืืึทืืืก)
ืืื ืึท ืืื ืขื, ืื ืฉืืึทื ืคืื ืื ืืจืืคึผืข ืงืขื ืขื ืืืื ืืืืกืืขืืจืืงื ืืื ืืืื:
+----------------------------------------+
| consumer_group_name: mygroup
| consumer_group_stream: somekey
| last_delivered_id: 1292309234234-92
|
| consumers:
| "consumer-1" with pending messages
| 1292309234234-4
| 1292309234232-8
| "consumer-42" with pending messages
| ... (and so forth)
+----------------------------------------+
ืืืฆื ืขืก ืืื ืฆืืื ืฆื ืืึทืงืขื ืขื ืืื ืืื ืื ืืืืคึผื ืงืึทืืึทื ืื ืคึฟืึทืจ ืื ืงืึธื ืกืืืขืจ ืืจืืคืข, ื ืืืืื:
- XGROUP ืืขื ืืฆื ืฆื ืฉืึทืคึฟื, ืฆืขืฉืืขืจื ืืื ืคืืจื ืืจืืคึผืขืก
- XREADGROUP ืืขืืืืื ื ืฆื ืืืืขื ืขื ืกืืจืื ืืืจื ืืจืืคึผืข
- XACK - ืืขื ืืึทืคึฟืขื ืึทืืึทืื ืื ืึทืืึธื ืขื ื ืฆื ืฆืืืื ืื ืึธื ืืึธื ืืื ืืฆืืื ืคึผืจืึทืกืขืกื
ืฉืึทืคืื ื ืคืื ืงืึธื ืกืืืขืจ ืืจืืคืข
ืืื ืก ืืืขืจื ืขืืขื ืึทื mystream ืฉืืื ืืืืืกืฅ. ืืขืจื ืึธื ืื ืืึทืคึฟืขื ืฆื ืฉืึทืคึฟื ืืจืืคึผืข ืืืขื ืงืืงื ืืื:
> XGROUP CREATE mystream mygroup $
OK
ืืืขื ืืืจ ืฉืึทืคึฟื ืึท ืืจืืคึผืข, ืืืจ ืืืื ืคืึธืจื ืึท ืืืืขื ืืืืขื, ืคึฟืื ืืืึธืก ืื ืืจืืคึผืข ืืืขื ืืึทืงืืืขื ืึทืจืืืงืืขื. ืืืื ืืืจ ื ืึธืจ ืืืืื ืฆื ืืึทืงืืืขื ืึทืืข ื ืืึทืข ืึทืจืืืงืืขื, ืืืจ ืงืขื ืขื ื ืืฆื ืื ืกืคึผืขืฆืืขืืข ืืืขื ืืืคืืขืจ $ (ืืื ืืื ืืื ืืืขืจ ืืืึทืฉืคึผืื ืืืืื). ืืืื ืืืจ ืกืคึผืขืฆืืคืืฆืืจื 0 ืึทื ืฉืืึธื ืคืื ืึท ืกืคึผืขืฆืืขืืข ืืืขื ืืืคืืขืจ, ืึทืืข ืึทืจืืืงืืขื ืืื ืื ืคืึธืืขื ืืืขื ืืืื ืืืจืขืืืืื ืคึฟืึทืจ ืื ืืจืืคึผืข.
ืืืฆื ืึทื ืื ืืจืืคึผืข ืืื ืืืฉืืคื, ืืืจ ืงืขื ืขื ืืื ืึธื ืืืืื ืืืืขื ืขื ืึทืจืืืงืืขื ื ืืฆื ืืขื ืืึทืคึฟืขื XREADGROUP. ืืขื ืืึทืคึฟืขื ืืื ืืืืขืจ ืขื ืืขื ืฆื XREAD ืืื ืฉืืืฆื ืื ืึทืคึผืฉืึทื ืึทื BLOCK ืึธืคึผืฆืืข. ืึธืืขืจ, ืขืก ืืื ืึท ืคืืจืืื ืื ืืจืืคึผืข ืึธืคึผืฆืืข ืืืึธืก ืืืื ืฉืืขื ืืืง ืืืื ืกืคึผืขืกืืคืืขื ืืื ืฆืืืื ืึทืจืืืืขื ืื: ืื ืืจืืคึผืข ื ืึธืืขื ืืื ืื ืึทืืึธื ืขื ื ื ืึธืืขื. ืื COUNT ืึธืคึผืฆืืข ืืื ืืืื ืืขืฉืืืฆื.
ืืืืืขืจ ืืืืขื ืขื ืืขื ืคืึธืืขื, ืืึธืื ืืื ืื ืฉืืขืื ืขืืืขืืข ืึทืจืืืงืืขื ืืึธืจื:
> XADD mystream * message apple
1526569495631-0
> XADD mystream * message orange
1526569498055-0
> XADD mystream * message strawberry
1526569506935-0
> XADD mystream * message apricot
1526569535168-0
> XADD mystream * message banana
1526569544280-0
ืืืฆื ืืึธืื ืืื ืื ืคึผืจืืืืจื ืฆื ืืืืขื ืขื ืืขื ืืืึทื ืืืจื ืื ืืจืืคึผืข:
> XREADGROUP GROUP mygroup Alice COUNT 1 STREAMS mystream >
1) 1) "mystream"
2) 1) 1) 1526569495631-0
2) 1) "message"
2) "apple"
ืื ืืืืื ืืึทืคึฟืขื ืืืืขื ื ืืืขืจืืึทืืึทื ืืื ืืืื:
"ืืื, ืึทืืึธื ืขื ื ืึทืืืก, ืึท ืืืืืืื ืคืื ืืขืจ ืืืื ืืจืืคึผืข, ืืืืื ืฆื ืืืืขื ืขื ืืืื ืึธื ืืึธื ืคืื ืืืื ืกืืจืื ืืืึธืก ืืื ืงืืื ืืึธื ืืขืืืขื ืืืืขืจืืขืืขืื ืฆื ืืืขืจ ืขืก ืื ืคืจืืขืจ."
ืืขืืขืจ ืืึธื ืืืขื ืึท ืึทืืึธื ืขื ื ืคึผืขืจืคืึธืจืื ืึทื ืึธืคึผืขืจืึทืฆืืข ืืืืฃ ืึท ืืจืืคึผืข, ืขืจ ืืืื ืฆืืฉืืขืื ืืืื ื ืึธืืขื, ืืื ืฆืืง ืืืขื ืืืคืืื ื ืืื ืืื ืืขืจ ืืจืืคึผืข. ืขืก ืืื ื ืึธื ืึท ืืืืขืจ ืืืืืืืง ืืขืืึทื ืืื ืื ืืืืื ืืึทืคึฟืขื - ืื ืกืคึผืขืฆืืขืืข ืืืขื ืืืคืืขืจ ">". ืืขืจ ืกืคึผืขืฆืืขืืข ืืืขื ืืืคืืขืจ ืคืืืืขืจืก ืึทืจืืืงืืขื, ืืื ืืึธืื ืืืืื ืื ืืืึธืก ืืึธืื ืงืืื ืืึธื ืืขืืืขื ืืืืขืจืืขืืขืื ืคืจืืขืจ.
ืืืื, ืืื ืกืคึผืขืฆืืขื ืงืึทืกืขืก, ืืืจ ืงืขื ืขื ืกืคึผืขืฆืืคืืฆืืจื ืึท ืคืึทืงืืืฉ ืืืขื ืืืคืืขืจ ืึทืืึท ืืื 0 ืึธืืขืจ ืงืืื ืื ืืขืจืข ืืืืืืง ืืืขื ืืืคืืขืจ. ืืื ืืขื ืคืึทื, ืื ืืึทืคึฟืขื XREADGROUP ืืืขื ืฆืืจืืงืงืืืขื ืืืจ ืึท ืืขืฉืืืืข ืคืื โโืึทืจืืืงืืขื ืืื ืึท ืกืืึทืืืก ืคืื "ืคึผืขื ืืื ื" ืืืึธืก ืืขื ืขื ืืืืขืจืืขืืขืื ืฆื ืื ืกืคึผืขืกืืคืืขื ืึทืืึธื ืขื ื (ืึทืืืก) ืึธืืขืจ ื ืึธื ื ืืฉื ืืงื ืึทืืืืืฉื ืืื ืืขื ืืึทืคึฟืขื. XACK.
ืืืจ ืงืขื ืขื ืคึผืจืืืืจื ืืขื ื ืึทืืืจ ืืืจื ืืื ืกืคึผืขืฆืืคืืฆืืจื ืื ID 0, ืึธื ืื ืึธืคึผืฆืืข COUNT. ืืืจ ืืืขืื ืคืฉืื ืืขื ืึท ืืืื ืคึผืขื ืืื ื ืึธื ืืึธื, ืืึธืก ืืื, ืื ืขืคึผื ืึธื ืืึธื:
> XREADGROUP GROUP mygroup Alice STREAMS mystream 0
1) 1) "mystream"
2) 1) 1) 1526569495631-0
2) 1) "message"
2) "apple"
ืึธืืขืจ, ืืืื ืืืจ ืืึทืฉืืขืืืงื ืืขื ืึธื ืืึธื ืืื ืืฆืืื ืคึผืจืึทืกืขืกื, ืขืก ืืืขื ื ืื ืืขืจ ืืืื ืืขืืืืื:
> XACK mystream mygroup 1526569495631-0
(integer) 1
> XREADGROUP GROUP mygroup Alice STREAMS mystream 0
1) 1) "mystream"
2) (empty list or set)
ืืืฆื ืขืก ืืื ืืึธื ืก ืงืขืจ ืฆื ืืืืขื ืขื ืขืคึผืขืก:
> XREADGROUP GROUP mygroup Bob COUNT 2 STREAMS mystream >
1) 1) "mystream"
2) 1) 1) 1526569498055-0
2) 1) "message"
2) "orange"
2) 1) 1526569506935-0
2) 1) "message"
2) "strawberry"
ืืึธื, ืึท ืืืืืืื ืคืื ืืืื ืืจืืคึผืข, ืืขืืขืื ืคึฟืึทืจ ื ืื ืืขืจ ืืื ืฆืืืื ืึทืจืืืงืืขื. ืืขืจ ืืึทืคึฟืขื ืืืืื ืจืืคึผืึธืจืฅ ืึทื ืืืืืืืขืจืขื ืึทืจืืืงืืขื ืจืขืื ืฆื ืืขืจ ืกืคึผืขืฆืืขืืข ืืืืขื ืืืคึฟืืงืึทืฆืืข ">". ืืื ืืืจ ืงืขื ืขื ืืขื, ืืขืจ ืึธื ืืึธื "ืขืคึผื" ืืืขื ื ืืฉื ืืืื ืืขืืืืื ืืื ื ืขืก ืืื ืฉืืื ืืืืขืจืืขืืขืื ืฆื ืึทืืืก, ืึทืืื ืืึธื ื ืขืื "ืืึทืจืึทื ืฅ" ืืื "ืืจืืกืงืึทืืืงืข".
ืืขื ืืืขื, ืึทืืืก, ืืึธื, ืืื ืงืืื ืื ืืขืจืข ืึทืืึธื ืขื ื ืฆื ืืขืจ ืืจืืคึผืข ืงืขื ืขื ืืืืขื ืขื ืคืึทืจืฉืืืขื ืข ืึทืจืืืงืืขื ืคืื ืืขืจ ืืขืืืืงืขืจ ืืืึทื. ืืื ืงืขื ืขื ืืืื ืืืืขื ืขื ืืืืขืจ ืืขืฉืืืืข ืคืื โโืึทื ืคึผืจืึทืกืขืกื ืึทืจืืืงืืขื ืึธืืขืจ ืฆืืืื ืึทืจืืืงืืขื ืืื ืคึผืจืึทืกืขืกื.
ืขืก ืืขื ืขื ืขืืืขืืข ืืืื ืฆื ืืึทืืื ืืื ืืื ืขื:
- ืืื ืืึทืื ืืื ืืขืจ ืึทืืึธื ืขื ื ืืืื ืึทื ืื ืึธื ืืึธื ืืื ืึท ืืึทืคึฟืขื XREADGROUP, ืืขื ืึธื ืืึธื ืืืื ืืื ืื "ืคึผืขื ืืื ื" ืฉืืึทื ืืื ืืื ืึทืกืืื ื ืฆื ืืขื ืกืคึผืขืฆืืคืืฉ ืึทืืึธื ืขื ื. ืื ืืขืจืข ืืจืืคืข ืืืื ืขื ืื ืืืขืื ื ืืฉื ืงืขื ืขื ืืืืขื ืขื ืืขื ืึธื ืืึธื.
- ืืืื ืขื ืื ืืืขืจื ืืืืืึธืืึทืืืฉ ืืืฉืืคื ื ืึธื ืืขืจ ืขืจืฉืืขืจ ืืขืจืืึธื ืขื, ืขืก ืืื ื ืื ืืึทืจืคึฟื ืฆื ืืคืืจืืฉ ืืึทืื ืืื.
- ื ืืฆื XREADGROUP ืืืจ ืงืขื ืขื ืืืืขื ืขื ืึทืจืืืงืืขื ืคืื ืงืืืคื ืคืึทืจืฉืืืขื ืข ืคึฟืขืืขื ืืื ืืขืจ ืืขืืืืงืขืจ ืฆืืื, ืึธืืขืจ ืคึฟืึทืจ ืืขื ืฆื ืึทืจืืขืื ืืืจ ืืึทืจืคึฟื ืฆื ืฉืึทืคึฟื ืืจืืคึผืขืก ืืื ืื ืืขืืืข ื ืึธืืขื ืคึฟืึทืจ ืืขืืขืจ ืคืึธืืขื ื ืืฆื XGROUP
ืึธืคึผืืื ื ืึธื ืึท ืืืจืืคืึทื
ืืขืจ ืึทืืึธื ืขื ื ืงืขื ืขื ืฆืืจืืงืงืจืืื ืคืื ืืขื ืืืจืืคืึทื ืืื ืืืืขื ืขื ืืืื ืจืฉืืื ืคืื ืึทืจืืืงืืขื ืืื ืื "ืคึผืขื ืืื ื" ืกืืึทืืืก. ืึธืืขืจ, ืืื ืืขืจ ืขืืขืก ืืืขืื, ืืืื ืขื ืื ืงืขื ืืขืกืึธืฃ ืคืึทืจืืึธืื. ืืืึธืก ืืึทืคึผืึทื ื ืฆื ืึท ืึทืืึธื ืขื ื ืก ืกืืึทืง ืึทืจืืืงืืขื ืืืื ืืขืจ ืึทืืึธื ืขื ื ืืื ื ืื ืืืืืืช ืฆื ืฆืืจืืงืงืจืืื ืคืื ืึท ืืืจืืคืึทื?
ืงืึธื ืกืืืขืจ ืืจืืคืข ืึธืคืคืขืจืก ืึท ืฉืืจืื ืืืึธืก ืืื ืืขื ืืฆื ืืืืื ืคึฟืึทืจ ืึทืืึท ืงืึทืกืขืก - ืืืขื ืืืจ ืืึทืจืคึฟื ืฆื ืืืืฉื ืื ืืึทืืืฆืขืจ ืคืื ืึทืจืืืงืืขื.
ืืขืจ ืขืจืฉืืขืจ ืืึทื ืืืจ ืืึทืจืคึฟื ืฆื ืืึธื ืืื ืจืืคื ืืขื ืืึทืคึฟืขื XPENDING, ืืืึธืก ืืืกืคึผืืืื ืึทืืข ืึทืจืืืงืืขื ืืื ืืขืจ ืืจืืคึผืข ืืื ืื ืกืืึทืืืก "ืคึผืขื ืืื ื". ืืื ืืืื ืกืืืคึผืืึทืกื ืคืึธืจืขื, ืื ืืึทืคึฟืขื ืืื ืืขืจืืคึฟื ืืื ืืืืื ืฆืืืื ืึทืจืืืืขื ืื: ืื ืคืึธืืขื ื ืึธืืขื ืืื ืื ืืจืืคึผืข ื ืึธืืขื:
> XPENDING mystream mygroup
1) (integer) 2
2) 1526569498055-0
3) 1526569506935-0
4) 1) 1) "Bob"
2) "2"
ืื ืืึทื ืฉืึทืคึฟื ืืขืืืืื ืื ื ืืืขืจ ืคืื ืึทื ืคึผืจืึทืกืขืกื ืึทืจืืืงืืขื ืคึฟืึทืจ ืื ืืื ืฆืข ืืจืืคึผืข ืืื ืคึฟืึทืจ ืืขืืขืจ ืึทืืึธื ืขื ื. ืืืจ ืืึธืื ืืืืื ืืึธื ืืื ืฆืืืื ืืืืืขื ืึทืจืืืงืืขื ืืืืึทื ืื ืืืืื ืึธื ืืึธื ืืืึธืก ืึทืืืก ืืึธื ืืขืืขืื ืืื ืืืฉืืขืืืงื ืืื XACK.
ืืืจ ืงืขื ืขื ืืขืื ืืขืจ ืืื ืคึฟืึธืจืืึทืฆืืข ื ืืฆื ืืขืจ ืึทืจืืืืขื ืื:
XPENDING {key} {groupname} [{start-id} {end-id} {count} [{consumer-name}]]
{start-id} {end-id} - ืงืืื ืคืื ืืืขื ืืืคืืขืจืก (ืืืจ ืงืขื ืขื ื ืืฆื "-" ืืื "+")
{ืฆืืืื} - ื ืืืขืจ ืคืื ืขืงืกืคึผืจืขืก ืคืจืืืื
{ืงืึทื ืกืืืขืจ-ื ืึธืืขื} - ืืจืืคึผืข ื ืึธืืขื
> XPENDING mystream mygroup - + 10
1) 1) 1526569498055-0
2) "Bob"
3) (integer) 74170458
4) (integer) 1
2) 1) 1526569506935-0
2) "Bob"
3) (integer) 74170458
4) (integer) 1
ืืืฆื ืืืจ ืืึธืื ืืขืืึทืืืก ืคึฟืึทืจ ืืขืืขืจ ืึธื ืืึธื: ืฉืืึทื, ืึทืืึธื ืขื ื ื ืึธืืขื, ืืืืืืง ืฆืืื ืืื ืืืืืกืขืงืึทื ืื ืืื ืืขืกืึธืฃ ืื ื ืืืขืจ ืคืื ืขืงืกืคึผืจืขืก ืคืจืืืื. ืืืจ ืืึธืื ืฆืืืื ืึทืจืืืงืืขื ืคืื ืืึธื ืืื ืืื ืืึธืื ืฉืืื ืืืืืืง ืคึฟืึทืจ 74170458 ืืืืืกืขืงืึทื ืื, ืืืขืื 20 ืฉืขื.
ืืืืข ืืึธื ืึทื ืงืืื ืืืื ืขืจ ืืื ืกืืึธืคึผืคึผืื ื ืืื ืื ืคืื ืงืึธื ืืจืึธืืืจื ืืืึธืก ืื ืืื ืืึทืื ืคืื ืื ืึธื ืืึธื ืืื ืคืฉืื ืืืจื ื ืืฆื XRANGE.
> XRANGE mystream 1526569498055-0 1526569498055-0
1) 1) 1526569498055-0
2) 1) "message"
2) "orange"
ืืืจ ื ืึธืจ ืืึธืื ืฆื ืืืืขืจืืืจื ืื ืืขืืืข ืืืขื ืืืคืืขืจ ืฆืืืื ืืึธื ืืื ืื ืึทืจืืืืขื ืื. ืืืฆื ืึทื ืืืจ ืืึธืื ืึท ืืขืืึทื ืง, ืึทืืืก ืงืขื ืืึทืฉืืืกื ืึทื ื ืึธื 20 ืฉืขื ืคืื ืืึทืื ืืืื, ืืึธื ืืืกืืึธืืข ืืืขื ื ืืฉื ืฆืืจืืงืงืจืืื, ืืื ืขืก ืืื ืฆืืื ืฆื ืึธื ืคืจืขื ืื ืึทืจืืืงืืขื ืืื ื ืขืืขื ืืื ืืืืืขืจ ืคึผืจืึทืกืขืกืื ื ืืื ืคึฟืึทืจ ืืึธื. ืคึฟืึทืจ ืืขื ืืืจ ื ืืฆื ืื ืืึทืคึฟืขื XCLAIM:
XCLAIM {key} {group} {consumer} {min-idle-time} {ID-1} {ID-2} ... {ID-N}
ื ืืฆื ืืขื ืืึทืคึฟืขื, ืืืจ ืงืขื ืขื ืืึทืงืืืขื ืึท "ืคืจืขืื" ืึธื ืืึธื ืืืึธืก ืืื ื ืึธื ื ืืฉื ืคึผืจืึทืกืขืกื ืืืจื ืืฉืึทื ืืื ื ืื ืืึทืืืฆืขืจ ืฆื {ืงืึทื ืกืืืขืจ}. ืึธืืขืจ, ืืืจ ืงืขื ืขื ืืืื ืฆืืฉืืขืื ืึท ืืื ืืืื ืืืืืืง ืฆืืื {ืืื-ืืืืืืง ืฆืืื}. ืืึธืก ืืขืืคึผืก ืืืกืืืืื ืึท ืกืืืืึทืฆืืข ืืื ืฆืืืื ืงืืืืึทื ืฅ ืคึผืจืืืืจื ืฆื ืกืืืืึทืืืืื ืืึทืกืื ืืืืฉื ืื ืืึทืืืฆืขืจ ืคืื ืื ืืขืืืข ืึทืจืืืงืืขื:
Client 1: XCLAIM mystream mygroup Alice 3600000 1526569498055-0
Clinet 2: XCLAIM mystream mygroup Lora 3600000 1526569498055-0
ืืขืจ ืขืจืฉืืขืจ ืงืื ื ืืืขื ืืึทืฉืืขืืืง ืื ืืึทืื ืืืื ืืื ืคืึทืจืืจืขืกืขืจื ืื ืขืงืกืคึผืจืขืก ืืึธืืืึทื ืง. ืึทืืื ืืขืจ ืฆืืืืืืขืจ ืงืืืขื ื ืืืขื ื ืืฉื ืงืขื ืขื ืฆื ืืขืื ืขืก.
> XCLAIM mystream mygroup Alice 3600000 1526569498055-0
1) 1) 1526569498055-0
2) 1) "message"
2) "orange"
ืืขืจ ืึธื ืืึธื ืืื ืืฆืืื ืงืืืืื ืืืจื ืึทืืืก, ืืืึธืก ืงืขื ืขื ืืืฆื ืคึผืจืึธืฆืขืก ืืขื ืึธื ืืึธื ืืื ืืึทืฉืืขืืืงื ืขืก.
ืคึฟืื ืื ืืืืื ืืืึทืฉืคึผืื, ืืืจ ืงืขื ืขื ืืขื ืึทื ืึท ืืขืจืึธืื ืืขืื ืงืขืจื ืื ืืื ืืึทืื ืคืื ืื ืึธื ืืึธื ืืื. ืึธืืขืจ, ืืึธืก ืืื ื ืื ื ืืืืืง. ืื JUSTID ืึธืคึผืฆืืข ืงืขื ืขื ืืืื ืืขืืืืื ื ืืืืื ืฆื ืฆืืจืืงืงืืืขื ืึธื ืืึธื IDs. ืืึธืก ืืื ื ืืฆืืง ืืืื ืืืจ ืืขื ื ื ืืฉื ืืื ืืขืจืขืกืืจื ืืื ืื ืืขืืึทืืืก ืคืื ืืขื ืึธื ืืึธื ืืื ืืืจ ืืืืื ืฆื ืคืึทืจืืจืขืกืขืจื ืื ืคืึธืจืฉืืขืืื ื ืคืื ืื ืกืืกืืขื.
ืขืงืกืคึผืจืขืก ืืึธืืืึทื ืง
ืืขืจ ืืึธืืืึทื ืง ืืืจ ืืขื ืืื ืืขืจ ืจืขืืืืืึทื XPENDING ืืื ืื ื ืืืขืจ ืคืื ืขืงืกืคึผืจืขืก ืคืื ืืขืืขืจ ืึธื ืืึธื. ืึทืืึท ืึท ืืึธืืืึทื ืง ืืื ืื ืงืจืึทืืึทื ืืื ืืื ืฆืืืื ืืืขืื: ืืืขื ืึท ืึธื ืืึธื ืืื ืืฆืืื ืืขืืขืื ืืืจื XCLAIM ืึธืืขืจ ืืืขื ืึท ืจืืคื ืืื ืืขื ืืฆื XREADGROUP.
ืขืก ืืื ื ืึธืจืืึทื ืคึฟืึทืจ ืขืืืขืืข ืึทืจืืืงืืขื ืฆื ืืืื ืืืืขืจืืขืืขืื ืขืืืขืืข ืืึธื. ืื ืืืืคึผื ืืึทื ืืื ืึทื ืึทืืข ืึทืจืืืงืืขื ืืขื ืขื ืืืืขื ืืฉืึทืืืึทืื ืคึผืจืึทืกืขืกื. ืืื ืคึผืจืึธืืืขืืก ืคืึทืื ืืืขื ืคึผืจืึทืกืขืกืื ื ืึท ืึธื ืืึธื ืืืืึทื ืืขืจ ืึธื ืืึธื ืืื ืืื ืคืืจืืืจืื, ืึธืืขืจ ืึธื ืืึธื ืคึผืจืึทืกืขืกืื ื ื ืึท ืืขืืช ืืื ืื ืืึทื ืืืขืจ ืงืึธื. ืืื ืืขื ืคืึทื, ืขืก ืงืขื ืืืื ืึทื ืงืืื ืืืื ืขืจ ืืืขื ืงืขื ืขื ืฆื ืคึผืจืึธืฆืขืก ืืขื ืึธื ืืึธื. ืืื ื ืืืจ ืืึธืื ืึท ืขืงืกืคึผืจืขืก ืคึผืจืืืื ืืึธืืืึทื ืง, ืืืจ ืงืขื ืขื ื ืืฆื ืืขื ืืึธืืืึทื ืง ืฆื ืืขืืขืงื ืึทืืึท ืกืืืืึทืืืึธื ืก. ืืขืจืืืขืจ, ืึทืืึธื ืืขืจ ืขืงืกืคึผืจืขืก ืืึธืืืึทื ืง ืจืืืฉืึทื ืื ืืืื ื ืืืขืจ ืืืจ ืกืคึผืขืฆืืคืืฆืืจื, ืขืก ืืืึธืื ืืืกืืึธืืข ืืืื ืงืืืืขืจ ืฆื ืฉืืขืื ืึทืืึท ืึท ืึธื ืืึธื ืืืืฃ ืื ืื ืืขืจ ืคืึธืืขื ืืื ืฉืืงื ืึท ืึธื ืืึธื ืฆื ืื ืกืืกืืขื ืึทืืืื ืืกืืจืึทืืึธืจ.
ืคึฟืึธืืขื ืฉืืึทื
ืงืึธืืขืงืืืื XINFO ืืขืืืืื ื ืฆื ืืขืื ืคืึทืจืฉืืื ืืื ืคึฟืึธืจืืึทืฆืืข ืืืขืื ืึท ืคืึธืืขื ืืื ืืืึทื ืืจืืคึผืขืก. ืคึฟืึทืจ ืืืึทืฉืคึผืื, ืึท ืืงืขืจืืืง ืืึทืคึฟืขื ืงืืงื ืืื ืืึธืก:
> XINFO STREAM mystream
1) length
2) (integer) 13
3) radix-tree-keys
4) (integer) 1
5) radix-tree-nodes
6) (integer) 2
7) groups
8) (integer) 2
9) first-entry
10) 1) 1524494395530-0
2) 1) "a"
2) "1"
3) "b"
4) "2"
11) last-entry
12) 1) 1526569544280-0
2) 1) "message"
2) "banana"
ืืขืจ ืืึทืคึฟืขื ืืืืื ืืืกืคึผืืืื ืึทืืืขืืืื ืข ืืื ืคึฟืึธืจืืึทืฆืืข ืืืขืื ืื ืกืคึผืขืกืืคืืขื ืืืึทื. ืืืฆื ืึท ืืืกื ืืขืจ ืงืึธืืคึผืืืฆืืจื ืืืึทืฉืคึผืื:
> XINFO GROUPS mystream
1) 1) name
2) "mygroup"
3) consumers
4) (integer) 2
5) pending
6) (integer) 2
2) 1) name
2) "some-other-group"
3) consumers
4) (integer) 1
5) pending
6) (integer) 0
ืืขืจ ืืึทืคึฟืขื ืืืืื ืืืกืคึผืืืื ืึทืืืขืืืื ืข ืืื ืคึฟืึธืจืืึทืฆืืข ืคึฟืึทืจ ืึทืืข ืืจืืคึผืขืก ืคืื ืื ืกืคึผืขืกืืคืืขื ืคืึธืืขื
> XINFO CONSUMERS mystream mygroup
1) 1) name
2) "Alice"
3) pending
4) (integer) 1
5) idle
6) (integer) 9104628
2) 1) name
2) "Bob"
3) pending
4) (integer) 1
5) idle
6) (integer) 83841983
ืืขืจ ืืึทืคึฟืขื ืืืืื ืืืกืคึผืืืื ืืื ืคึฟืึธืจืืึทืฆืืข ืคึฟืึทืจ ืึทืืข ืืืื ืขื ืื ืคืื ืื ืกืคึผืขืกืืคืืขื ืืืึทื ืืื ืืจืืคึผืข.
ืืืื ืืืจ ืคืึทืจืืขืกื ืื ืืึทืคึฟืขื ืกืื ืืึทืงืก, ื ืึธืจ ืคืจืขืื ืื ืืึทืคึฟืขื ืืื ืคึฟืึทืจ ืืืืฃ:
> XINFO HELP
1) XINFO {subcommand} arg arg ... arg. Subcommands are:
2) CONSUMERS {key} {groupname} -- Show consumer groups of group {groupname}.
3) GROUPS {key} -- Show the stream consumer groups.
4) STREAM {key} -- Show information about the stream.
5) HELP -- Print this help.
ืกืืจืื ืืจืืืก ืืืืื
ืคืืืข ืึทืคึผืืึทืงืืืฉืึทื ื ืืึธื ื ืืฉื ืืืขืื ืฆื ืืึทืืืขื ืืึทืื ืืื ืึท ืืืึทื ืืืืฃ ืืืืืืง. ืขืก ืืื ืึธืคื ื ืืฆืืง ืฆื ืืึธืื ืึท ืืึทืงืกืืืื ื ืืืขืจ ืคืื ืึทืจืืืงืืขื ืขืจืืืืื ืคึผืขืจ ืคืึธืืขื. ืืื ืื ืืขืจืข ืงืึทืกืขืก, ืขืก ืืื ื ืืฆืืง ืฆื ืึทืจืืืขืจืคืืจื ืึทืืข ืึทืจืืืงืืขื ืคืื ืึท ืคืึธืืขื ืฆื ืื ืื ืืขืจ ืคึผืขืจืกืืกืืขื ื ืงืจืึธื ืืืขื ืื ืกืคึผืขืกืืคืืขื ืคืึธืืขื ืืจืืืก ืืื ืจืืืฉื. ืืืจ ืงืขื ืขื ืืึทืืจืขื ืขืฆื ืื ืืจืืืก ืคืื ืึท ืืืึทื ืืื ืื MAXLEN ืคึผืึทืจืึทืืขืืขืจ ืืื ืืขื ืืึทืคึฟืขื XADD:
> XADD mystream MAXLEN 2 * value 1
1526654998691-0
> XADD mystream MAXLEN 2 * value 2
1526654999635-0
> XADD mystream MAXLEN 2 * value 3
1526655000369-0
> XLEN mystream
(integer) 2
> XRANGE mystream - +
1) 1) 1526654999635-0
2) 1) "value"
2) "2"
2) 1) 1526655000369-0
2) 1) "value"
2) "3"
ืืืขื ื ืืฆื MAXLEN, ืึทืื ืจืขืงืึธืจืืก ืืขื ืขื ืืืืืึธืืึทืืืฉ ืืืืกืืขืืขืงื ืืืขื ืืื ืืขืจืืจืืืื ืึท ืกืคึผืขืกืืคืืขื ืืขื ื, ืึทืืื ืืขืจ ืืืึทื ืืื ืึท ืงืขืกืืืืขืจืืืง ืืจืืืก. ืึธืืขืจ, ืคึผืจืื ืื ื ืืื ืืขื ืคืึทื ืืื ื ืืฉื ืื ืืขืจืกื ืขืคืขืงืืืื ืืืขื ืืื Redis ืืึผืจืื. ืืืจ ืงืขื ืขื ืคึฟืึทืจืืขืกืขืจื ืื ืกืืืืึทืฆืืข ืืื ืืืื:
XADD mystream MAXLEN ~ 1000 * ... entry fields here ...
ืื ~ ืึทืจืืืืขื ื ืืื ืืขื ืืืึทืฉืคึผืื ืืืืื ืืืื ืึทื ืืืจ ืืึธื ื ืื ืืึทืืืงืข ืืึทืจืคึฟื ืฆื ืืึทืืจืขื ืขืฆื ืื ืืืึทื ืืขื ื ืฆื ืึท ืกืคึผืขืฆืืคืืฉ ืืืขืจื. ืืื ืืื ืืืขืจ ืืืึทืฉืคึผืื, ืืึธืก ืงืขื ืืืื ืงืืื ื ืืืขืจ ืืจืขืกืขืจ ืืื ืึธืืขืจ ืืืืึทื ืฆื 1000 (ืืืฉื, 1000, 1010 ืึธืืขืจ 1030). ืืืจ ืืึธืื ืคึผืื ืงื ืกืคึผืขืกืืคืืขื ืึทื ืืืจ ืืืขืื ืืื ืืืขืจ ืืืึทื ืฆื ืงืจืึธื ืืคึผืืืช 1000 ืจืขืงืึธืจืืก. ืืึธืก ืืืื ืืึผืจืื ืคืึทืจืืืึทืืืื ื ืคืื ืืขืจ ืขืคืขืงืืืื ืืื Redis.
ืขืก ืืื ืืืื ืึท ืืึทืืื ืืขืจ ืืึทื ืฉืึทืคึฟื XTRIM, ืืืึธืก ืืื ืื ืืขืืืข ืืึทื:
> XTRIM mystream MAXLEN 10
> XTRIM mystream MAXLEN ~ 10
ืคึผืขืจืกืืกืืขื ื ืกืืึธืจืืืืฉ ืืื ืจืขืคึผืืึทืงืืืฉืึทื
ืจืขืืืก ืกืืจืื ืืื ืืืกืื ืืงืจืึทื ืึทืกืื ืจืขืคึผืืืงืืืืื ืฆื ืฉืงืืึทืฃ ื ืึธืืื ืืื ืืขืจืืืขืืืขื ืืื ืืขืงืขืก ืืื AOF (Snapshot ืคืื ืึทืืข ืืึทืื) ืืื RDB (ืืึธื ืคืื ืึทืืข ืฉืจืืึทืื ืึทืคึผืขืจืืืฉืึทื ื). ืจืขืคึผืืึทืงืืืฉืึทื ืคืื ืงืึธื ืกืืืขืจ ืืจืืคึผืขืก ืฉืืึทื ืืื ืืืื ืืขืฉืืืฆื. ืืขืจืืืขืจ, ืืืื ืึท ืึธื ืืึธื ืืื ืืื ืื "ืคึผืขื ืืื ื" ืกืืึทืืืก ืืืืฃ ืื ืืขื ื ืึธืืข, ืืขืืึธืื ืืืืฃ ืื ืฉืงืืึทืฃ ื ืึธืืื ืืขื ืึธื ืืึธื ืืืขื ืืึธืื ืื ืืขืืืข ืกืืึทืืืก.
ืจืืืืืืื ื ืืืื ืขืืขืืขื ืื ืคืื ืึท ืืืึทื
ืขืก ืืื ืึท ืกืคึผืขืฆืืขื ืืึทืคึฟืขื ืฆื ืืืกืืขืงื ืึทืจืืืงืืขื XDEL. ืืขืจ ืืึทืคึฟืขื ืืึทืงืืืขื ืื ื ืึธืืขื ืคืื ืื ืคืึธืืขื ื ืืืืขืืื ืืขื ืืืจื ืื ืึธื ืืึธื ืืืก ืฆื ืืืขืจื ืืืืกืืขืืขืงื:
> XRANGE mystream - + COUNT 2
1) 1) 1526654999635-0
2) 1) "value"
2) "2"
2) 1) 1526655000369-0
2) 1) "value"
2) "3"
> XDEL mystream 1526654999635-0
(integer) 1
> XRANGE mystream - + COUNT 2
1) 1) 1526655000369-0
2) 1) "value"
2) "3"
ืืืขื ืืืจ ื ืืฆื ืืขื ืืึทืคึฟืขื, ืืืจ ืืึทืจืคึฟื ืฆื ื ืขืืขื ืืื ืืฉืืื ืึทื ืื ืคืึทืงืืืฉ ืืึผืจืื ืืืขื ื ืืฉื ืืืื ืคืจืื ืืื.
ื ืื ืืขื ื ืกืืจืืื
ืืขืจ ืืืืืง ืฆืืืืฉื ืกืืจืืื ืืื ืื ืืขืจืข ืจืขืืืก ืืึทืื ืกืืจืึทืงืืฉืขืจื ืืื ืึทื ืืืขื ืื ืืขืจืข ืืึทืื ืกืืจืึทืงืืฉืขืจื ืืึธืื ื ืื ืืขืจ ืขืืขืืขื ืื ืืื ืืื, ืืื ืึท ืืืึทื ืืืืจืงืื ื, ืื ืืึทืื ืกืืจืืงืืืจ ืืื ืืืขื ืืืื ืึทืืืขืงืืขื ืืืขื ืคืื ืืึผืจืื. ืึทืืื, ืคึฟืึทืจ ืืืึทืฉืคึผืื, ืื ืกืึธืจืืืจื ืฉืืขืื ืืืขื ืืืื ืืึธืจ ืึทืืืขืงืืขื ืืืขื ืืืขื ืื ZREM ืจืืคื ืจืืืืืื ืื ืืขืฆืืข ืขืืขืืขื ื. ืึทื ืฉืืึธื, ืคึฟืขืืขื ืืขื ืขื ืขืจืืืืื ืฆื ืืืืึทืื ืืื ืืึผืจืื ืืคืืื ืึธื ืงืืื ืขืืขืืขื ืื ืื.
ืกืึธืฃ
Redis Stream ืืื ืืืขืึทื ืคึฟืึทืจ ืงืจืืืืืื ื ืึธื ืืึธื ืืจืึธืงืขืจืก, ืึธื ืืึธื ืงืืื, ืืื ืึทืคืืื ืืึธืืื ื ืืื ืืขืฉืืืืข-ืืขืืขืกืงืขื ืฉืืืขืก ืกืืกืืขืืขื.
ืืื ืืื ืืื ืืืื ืืขืืืื , ืืืืื ืืขื ืขื ืึทืืืขืจืืืึทืื ืคึผืืืก ืืึทืื ืกืืจืึทืงืืฉืขืจื, ืืื Redis ืฉืืื ืืื ืืืจ ืืืืืข.
ืืงืืจ: www.habr.com