我在Spring Boot应用程序中使用Redis Streams。在调度程序中，我经常希望获取所有挂起的消息，并检查它们已经处理了多长时间，并在必要时重新触发它们。我的问题是，我现在可以获得挂起的消息，但我不确定如何获得有效负载。 我的第一种方法使用了pending和range操作。对于读操作，我可以指定一个带有当前ID的偏移
浏览 90提问于2020-07-07得票数 0
回答已采纳
每种方法的优缺点是什么？请建议何时使用其中一个，而不是另一个。
浏览 2提问于2019-12-31得票数 27
回答已采纳
3回答
当我试图将一条消息从Stream转换到我的实体时，我一直在与中的这个异常做斗争。我认为这是由于Redis的默认反序列化程序出现问题，但是不确定如何解决。当我将这条消息发送到Redis流时
我从我的春季启动服务中得到了这个异常。at org.springframework.data.redis.stream.StreamPollTask.conve
浏览 24提问于2021-12-18得票数 0
我有几个问题，我在Redis教程中找不到答案 1)如何查看/查看Redis PubSub通道的值? Redis命令是用来调试Redis的，但我想看看之前推到通道的是什么。2)通道和队列的确切区别是什么？ 3)如何在免费的web应用中监控Redis集群？
浏览 26提问于2019-03-02得票数 0
回答已采纳
我是redis的新手，我正在使用spring data redis来实现一些任务队列特性。既然我想做一些故障转移检查，有没有办法像命令"pubsub numsub“那样获取特定通道的订阅者数量。
浏览 71提问于2021-08-02得票数 1
我想知道是否有一个命令或参数可以用来获取指定的RecordId的消息。XREADGROUP GROUP mygroup myconsumer COUNT 1 STREAMS mystream 12345-0
我想要ID为12345-0的消息，但似乎是在12345-0之后收到的第一条消息我不能使用XRANGE，因为它不更新deliveryCount和lastDeliveryTime，而且它似乎不理解消费者群体的
浏览 1提问于2020-07-08得票数 0
回答已采纳
I操作这些更新的多个服务(例如，LoggerSvc和Enforcement-Svc) --注意:消费者服务需要所有更新，而且不能错过更新。我正在使用Redis作为我的协调员(代理)，但我对如何实现它感到有点困惑。选项1:每个MonSvc#发布更新到Redis，而监视器服务订阅选项2:每个MonSvc# Enqueue更新到Redis列表(队列)，而使用者则从队列中获取元素
消费者
浏览 5提问于2020-01-30得票数 1
回答已采纳
我需要从REDIS流中读取数据，而服务器仍将写入STream。现在有两种方法。一种方法是获取已经存在的消息列表。我正在做如下所示的事情。然而，我想做一个阻塞读取，这样我的客户端控制台应用程序将等待流中的消息。我知道在REDIS-CLI中使用以下命令也可以做到这一点。我希望在C# XREAD BLOCK 1000 STREAMS #channel1 1526999626221-0中实现相同的<
浏览 29提问于2019-11-08得票数 3
我最近将我的spring boot版本升级到了1.4.0。现在我看到下面的警告。我使用spring-mongodb和spring-redis (严格用于缓存)。这是我应该关注的事情吗？发现多个Spring数据模块，正在进入严格的存储库配置模式！严格存储库配置模式的真正含义是什
浏览 2提问于2016-09-11得票数 40
我正在使用spring引导1.5.2.RELEASE和spring数据红包以及spring数据jpa。
获取方法if(null !cacheValue){
cache.delete("
浏览 5提问于2017-04-25得票数 3
我是Spring Cloud数据流的新手，我一直在阅读教程，试图在本地建立一个项目。(https://dataflow.spring.io/docs/installation/local/manual/) 我假设排队系统是服务器运行的先决条件，对吗？数据流服务器和skipper服务器如何使用此消息传递中间件？有没有办法使用db来存储状态，而不是使用队列将其从一个应用程序传递到下一个应
浏览 20提问于2020-02-01得票数 1
回答已采纳
Spring文档()建议动物园管理员以集成方式运行，以便动物园管理员能够高效地使用。关于Redis的高可用性并没有太多的细节。如果我要运行2个XD管理实例，比如说4个容器实例，我会看到3个选项或
我是否应该在一个单独的服务器上运行一个Redis实例，并配置所有XD实例来与此实
浏览 0提问于2014-07-23得票数 2
回答已采纳
我有一个带有通过Spring Cloud映射的两个流处理器的SpringBoot应用程序。每个处理器都有自己的@StreamListener用于不同的主题。一个处理器将聚集的数据写入可四分状态存储。当我通过@Service (服务从状态存储获取聚合数据)获取数据时，我在单元测试中遇到了这个问题。at org.apache.kafka.streams.state.i
浏览 10提问于2018-09-08得票数 0
我使用了spring data redis和@EnableRepositories的查询方法。我有一个带有@RedisHashAnnotation和@Indexed字段的实体。我有spring数据存储库来使用它。一切正常: crud操作，索引的键都是在redis中创建的，但如果我将query方法添加到存储库，它会抛出抽象方法错误，例如方法findByIp(String ip) (i
浏览 3提问于2016-04-29得票数 1
X将发布一条消息，可以看到特定的一组Y，这些人可以将该消息转发给他们的朋友。朋友可以看到该消息，并可以转发给他们的朋友或回复发件人。这是我的用例，我正在探索不同类型的数据库，主要是NoSQL数据库，因为我在我的网站中考虑了系统的可扩展性和性能。我已经开始使用Spring Data Redis API，并发现它对我的</e
浏览 2提问于2011-08-15得票数 0
1回答
iOS聊天应用设计
、、、
我正在使用socketsIO和一个节点后端，在iOS上构建一个简单的聊天应用程序，目的是为了好玩(并有项目可以从中获得经验)。我正在试着找出最好的消息设计。我计划使用一个mongoDB数据库，在该数据库中，每个会话都将存储其消息数据。每当客户端向服务器发送新消息时，服务器都会将其添加到数据库中相应的会话中。我也希望创建一个用户注册/登录系统，这将添加到数据库中。然而，我在
浏览 1提问于2016-05-27得票数 1
我有一个简单的redis服务器运行一个密码。我想和它谈谈我的春季引导应用程序。我看上去是，并且看到有一个spring.redis.password，所以我的应用程序-local.yml(与-Dspring.profiles.active=local一起运行)看起来像. redis:
i
浏览 7提问于2020-11-10得票数 3
回答已采纳
在使用Spring的新反应式技术时，是否可以“监听”数据存储中的任何更改，因此您可以在数据存储上获得任何更改的回调？想象一下，能够在MongoDB存储库上暂停，那么数据库中的更改将触发给定的方法？
浏览 1提问于2017-05-04得票数 1
2回答
我有一个MySQL和的应用程序。现在，启动Redis等并不是一个问题，因为我使用Docker动态分配容器进行测试。但是，验证数据实际上是从Redis缓存(而不是从Mysql )中写入和读取的正确方法是什么？
浏览 2提问于2018-04-24得票数 0
回答已采纳
当前实现对现有作业的新更改目前，我正在使用不同的KakfaTemplate对这两个主题进行写入，但问题是如何
浏览 4提问于2021-01-07得票数 1
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
