在redis streams中，我们可以通过命令获取流中的所有现有对象（假设它们正在等待我们，因为我们的应用程序处于脱机状态）： XRANGE mystream - + 然后，我们的应用程序可以通过以下方式进入阻止、“流式”状态： XREAD BLOCK 0 STREAMS mystream $ 这将为我们提供在命令运行后添加到流中的所有新项。如果在两次发布之间的几毫秒内将某些项添加到流中呢 XRANGE 以及 XREAD ? 如何确保在这些命令之间不会丢失任何项？
我是用python来做这件事的，但是我在redis命令中给出了更一般的例子。