@iBugOne 我设想的场景是每次都是不同的邮箱然后每次 ip 也不同

@yidinghe 已贴到 github ，有空希望再看一下，谢谢

@77yf77yf77yf github.com/inusang/img/blob/main/1.png

return valueOperations.set(regCodeKey, regCode, Duration.of(10, TimeUnit.MINUTES.toChronoUnit()))
.then(reactiveRedisTemplate.hasKey(regCodeObtainRecordKey)
.doOnSuccess(hasRecordKey ->
listOperations.leftPush(regCodeObtainRecordKey, current).doOnSuccess(x -> {
if (!hasRecordKey) {
reactiveRedisTemplate.expire(regCodeObtainRecordKey, Duration.of(30, TimeUnit.DAYS.toChronoUnit()))
.doOnSuccess(opeSucc -> {
if (opeSucc) {
EmailMessageType.REGISTER.send(Lists.newArrayList(email), Lists.newArrayList(regCode));
}
}).subscribe();
}
}).subscribe()
))
.map(r -> {
if (r) {
return ResponseVO.ResponseCodeMsgMapping.SENDREG_SUCC.getResponse().toJson();
} else {
return ResponseVO.ResponseCodeMsgMapping.SYS_ERROR.getResponse().toJson();
}
});

想了想改了之后是这样的
但是还是有个问题，最后我要将整个流程完成与否的结果转化为 Mono<String>，但是如果像这样在最后 map 的话应该只是对 hasKey 的结果进行转化，有没有什么办法以最后整个流程完成的结果来转化

@hingbong 好的，谢谢了

@hingbong 那对于注解有什么替代方案吗，不然只能用反射检查？

@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
public @interface CacheKey {
Class<? extends AbstractStdCacheNaming & ICacheKeyNamingStrategy> keyGen() default EntityBasedKeyNamingStrategy.class;
...
}

public abstract class AbstractStdCacheNaming {...}

public interface ICacheKeyNamingStrategy {...}


Class<? extends AbstractStdCacheNaming & ICacheKeyNamingStrategy> keyGen() default EntityBasedKeyNamingStrategy.class;
这一句就报错了

@hingbong