在春季数据redis reactive中，链接redis操作的正确方法是什么

Question

在spring-data-redis-reactive中，写入操作返回redis执行结果，这使得链接运算符非常困难。以Redis in Action第1章中的reddit为例。我试着这样重新实现：

@Service
public class ArticleService {
private final ReactiveStringRedisTemplate redisTemplate;
private final long voteScore = 432L;
public ArticleService(ReactiveStringRedisTemplate redisTemplate) {
this.redisTemplate = redisTemplate;
}
public Mono<Article> createArticle(Article article) {
long now = System.currentTimeMillis();
Map<String, String> newArticle = new HashMap<>();
newArticle.put("title", article.getTitle());
newArticle.put("link", article.getLink());
newArticle.put("poster", article.getPoster());
newArticle.put("time", String.valueOf(now));
newArticle.put("votes", "1");
return redisTemplate.opsForValue()
.increment("article:")
.doOnNext(id -> redisTemplate.opsForSet().add("voted:" + id.toString(), article.getPoster()).subscribe())
.doOnNext(id -> redisTemplate.expire("votes:" + id.toString(), Duration.ofDays(7)).subscribe())
.doOnNext(id -> redisTemplate.opsForHash().putAll("article:" + id.toString(), newArticle).subscribe())
.doOnNext(id -> redisTemplate.opsForZSet().add("score:", "article:" + id.toString(), now + voteScore).subscribe())
.doOnNext(id -> redisTemplate.opsForZSet().add("time:", "article:" + id.toString(), now).subscribe())
.map(id -> {
article.setId(id);
article.setVotes("1");
return article;
});
}
}

正如您所看到的，我使用doOnNext来避免丢失increment返回的id值，并且在每个doOnNext中都有一个subscribe()来确保每个redis操作都得到执行。但我不认为这是推荐的方式。我认为应用程序应该尽量避免使用subscribe()，并主要关注流的链接。

在spring-data-redis-reactive中执行许多redis-write操作的正确方法是什么？

Answer 1

避免在两者之间订阅，如果您从WEB接口调用，Spring将在最后订阅流。以下是如何实现的示例

return redisTemplate.opsForValue()
.increment("article:")
.flatMap(id -> // Mono.zip will execute concurrently all the modifications below
Mono.zip(redisTemplate.opsForSet().add("voted:" + id.toString(), article.getPoster()),
redisTemplate.expire("votes:" + id.toString(), Duration.ofDays(7)),
redisTemplate.opsForHash().putAll("article:" + id.toString(), newArticle),
redisTemplate.opsForZSet().add("score:", "article:" + id.toString(), now + voteScore),
redisTemplate.opsForZSet().add("time:", "article:" + id.toString(), now)
)
.map(tuple -> id))
.map(id -> {
article.setId(id);
article.setVotes("1");
return article;
});

但是您应该考虑将这些修改执行到MULTIRedis命令中，以确保它以原子方式发生https://redis.io/commands/multi.因为您没有任何验证和/或限制，所以不需要EVALhttps://redis.io/commands/eval