spring-xd 自定义 redis-sink

Question

所以我认为我需要扩展 spring-xd 中提供的当前 redis-sink 以写入 redis Capped 列表，而不是创建一个新列表，但不幸的是它似乎变得更糟，因为我将不得不更深入地了解 spring - 集成并进一步回到 spring-data (spring-data-redis)，因为整个 redis-sink 似乎基于 redis 上的通用 pub/sub 抽象 - 或者是否有某种类型的处理程序可以在消息后定义到达通道处理程序？

为了在我推送数据 redis 时获得“封顶列表的效果”，我需要执行 redis “推送”，然后执行此处所述的“rtrim” - http://redis.io/topics/data-types-intro。如果我要构建一个自定义的 spring-integration / spring-data 模块。我相信我在这里看到了对“ltrim”但不是“rtrim”操作的支持http://docs.spring.io/spring-data/redis/docs/1.7.0.RC1/api/

任何关于如何/从哪里开始或更简单方法的建议将不胜感激。

Answer 1

其实连Redis都没有这样的RTRIMcommand。我们不需要它，因为我们使用 LTRIM 的负索引达到了相同的行为：

start 和 end 也可以是负数，表示距列表末尾的偏移量，其中 -1 是列表的最后一个元素，-2 是倒数第二个元素，依此类推。

我认为你应该使用<redis:store-outbound-channel-adapter> 并在其配置中添加类似这样的内容：

<int-redis:request-handler-advice-chain>
    <beans:bean class="org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice">
        <beans:property name="onSuccessExpression" value="#redisTemplate.boundListOps(${keyExpression}).trim(1, -1)"/>
    </beans:bean>
</int-redis:request-handler-advice-chain>

删除 Redis 列表中最旧的元素。