如何使用redis cli不断地从流中消费和输出消息？我尝试了下面的命令，但是它只使用了最后一条消息，但是我想从redis cli中得到的是在发布者不断发布消息的同时，在屏幕上不断地使用和输出消息
浏览 16提问于2021-07-17得票数 0
我用3台机器处理Redis上的事件。但我不希望如果有任何事件由x机器处理，其他机器就不会处理它。我看到了和，但它们真的很旧了。也许有更好的方法。
浏览 0提问于2018-10-27得票数 1
1回答
据我所知，kafka source通过streamname-kafka-offsets主题维护MyCompositeModule使用的消息的偏移量(这是一个接收器，因为它是通过'module compose此外，当我从kafka源推送消息时，消息在redis传输中排队，然后模块从这个队列中获取它们。如果kafka消费者模块开始消费kafka redis队列中的1000条消息</em
浏览 0提问于2015-12-18得票数 1
我正在开发两个带有NestJS和类型记录的微服务，用于在两个不同的队列上消费和发布消息。方案如下：
消息消耗是用来自库Consumer的kafka-node实现的。这些消息被正确地使用并且可以被记录。微服务之间的通信
浏览 1提问于2019-05-23得票数 0
回答已采纳
I操作这些更新的多个服务(例如，LoggerSvc和Enforcement-Svc) --注意:消费者服务需要所有更新，而且不能错过更新。我正在使用Redis作为我的协调员(代理)，但我对如何实现它感到有点困惑。队列)，而使用者则从队列中获取元素
消费者并不会接受所有的更新，但是每个用户都会得到一个部分列表。选项3:每个MonSvc#队列更新到多个Redis列表(队列)(队列/消费者)，而使用</e
浏览 5提问于2020-01-30得票数 1
回答已采纳
如果订阅的客户端和发布消息的服务器都保持连接，那么Redis是否保证即使在客户端和/或服务器压力很大的情况下，最终也会始终将发布的消息传递给订阅的客户端？或者我应该考虑到这样一种可能性，Redis可能会在事情变得“热门”时偶尔丢弃消息？
浏览 31提问于2014-05-15得票数 16
1回答
我们正在考虑使用redis流作为集群范围内的消息传递总线，其中集群中的每个节点都有一个唯一的id。这样做的想法是，每个节点在生成时都会创建一个具有唯一id的使用者组，该用户组具有一个中央redis流，以保证集群中的每个节点都得到每个消息的副本。在编排的环境中，集群节点将被动态生成和删除，每个节点都有一个唯一的id。随着时间的推移，我可以看到，有100，甚至1000的老/未
浏览 10提问于2021-12-10得票数 1
回答已采纳
2回答
我正在构建一个扑克牌系统，并且我已经决定使用SSE的pub/sub系统来保持客户端的更新。我面临的一个问题是保留消息以供以后查询。一种用例是玩家在游戏中加入一张桌子。我目前使用的是redis的pub/sub，但这些消息都是短暂的。我对rabbitMQ做了一些深入的研究，看起来也是这样。Kafka似乎有一些重放功能？不过，我不知道它是否像我希望的那样细粒度。我可以让一个消费者运行，只是为了获取事件并存储它们。然而，这看起来很沉重，有太多失败的机会。
我还想查询旧的事件，
浏览 21提问于2020-05-09得票数 0
回答已采纳
1回答
我对Redis streams非常感兴趣。(看起来有可能构建由append-log驱动的小型系统，如Kafka，但没有Kafka的所有开销。)它看起来很简单，可以通过XADD访问日志/流，并使用日志/流中的条目。但是如果你想跨两个流加入呢？ Kafka Streams、Flink、Spark等提供了这样做的方法。在Redis宇宙中有没有等价物？ 如果不是，我想我只需要实现我自己的东西，从两个流中<
浏览 12提问于2019-03-23得票数 6
1回答
我通过使用redis pub/subscribe来实现它：
RedisMessageListenerContainer container = new RedisMessageListenerContainer难道没有任何方法可以阻止redis发布已经发送的事件吗？
浏览 2提问于2020-07-17得票数 1
我知道我可以用xlen或xinfo stream mystream full.得到流的总长度 我还知道，我可以使用xpending来获取挂起队列的长度，即尚未确认的项。
浏览 33提问于2020-09-24得票数 4
1回答
我有一些关于卡夫卡流以及它们是如何工作的问题，我对卡夫卡的消费者和生产者范式有着丰富的经验，然而，这是我第一次尝试使用卡夫卡流。问题：
一般来说，卡夫卡消费者模型我们订阅了一个主题并开始从一个分区开始消费，为了简单起见，为了简单起见，我们有一个分区和一个消费者，现在如果我们想要增加我们的处理，我们增加了分区的数量，并且增加了更多的消费者，这在Kafka流中是<
浏览 1提问于2018-12-22得票数 1
回答已采纳
2回答
鉴于我有一个服务P(生产者)和C(消费者)，我的P服务需要：
从C的角度来看，是否有一种方法可以保证它拥有成功的持久性所需的所有信息？我知道像Kafka和Redis
浏览 13提问于2022-07-12得票数 0
回答已采纳
我正在使用python (aioredis)和redis流。我有一个生产者-多个(分组的)消费者场景，并希望确保消费者以有序的方式处理发送到流的(批量)消息，这意味着:当第一个消息完成时，处理流中的下一个消息，依此类推。这也意味着消费者组中的一个消费者正在一次处理，而其他消费者将等待。
我还希望依赖于第二个、第
浏览 1提问于2021-04-28得票数 0
3回答
我试图代表主题，和副主题在卡夫卡。例子:主题‘运动’，副标题‘足球’，‘手球’
正如我所知，卡夫卡不支持这一点。我现在使用的是像'Sports_Football'，'Sports_Handball'...这样的主题这不是真正的功能，因为当我们需要时，当我们想要的主题‘体育’与所有的潜艇，我们需要查询所有的主题为它我们还使用Redis和Apache 。那么，有什么更好的方法吗？
浏览 0提问于2018-02-14得票数 0
回答已采纳
2回答
我有一个生产者和消费者框架。每个生产者推入一个队列，消费者从队列中消费。在任何时间点，都可以有一个或多个队列，每个使用者从单个队列中消费。但是生产者可以生产到任何队列。如果消费者慢下来，它就会不断地堆满消息。我试图提供一个框架，在这个框架中，我可以加载平衡的使用者，这样所有的使用者队列都有几乎相等的消息
浏览 1提问于2018-08-17得票数 3
回答已采纳
我很难在NodeJs应用程序中使用Redis。在我的Mysql数据库中，我有所有的国家名称，城市，邮政编码。它有成千上万的记录。所以，通过我的应用程序搜索城市需要花费很多时间。作为解决方案，我们为节点js找到了Redis。它可以修复解决方案，但问题是将数据存储在Redis中的初始状态。我有一个很大的数据集，所以使用createEntity需要很长时间，因为它应该与循环一起使用。const {Client, Entity, Schema, Reposit
浏览 2提问于2022-10-22得票数 0
1回答
我正在尝试用redis流实现一个java应用程序，在这个应用程序中，每个consomer只消耗一条消息。就像一个管道/队列，每个使用者都只接收一条消息，处理它，在完成它之后，接收到流中到目前为止还没有处理的下一条消息。起作用的是每条消息都是由一个使用者(与xreadgroup一起使用)使用的。我从开始 RedisClie
浏览 0提问于2020-08-17得票数 1
回答已采纳
云服务器
ICP备案
实时音视频
云直播
对象存储
腾讯云开发者
