使用反应式数据库编写业务逻辑

Question

我正在编写一个向Android手机发送通知的反应式api。发送通知的过程需要从手机访问令牌代码以将消息推送给它。为了实现这一点，我在服务器端创建了一个endpoint来接收来自手机的令牌。我的问题是保存令牌，然后在上面描述的过程中使用它。这是TokenController、TokenService、TokenRepository和Token POJO：

@RestController
@RequestMapping("/api")
public class TokenController {

    @Autowired
    private TokenService tokenService;

    @CrossOrigin
    @RequestMapping(value = "/token",
            method = RequestMethod.POST,
            consumes = MediaType.APPLICATION_JSON_VALUE,
            produces = MediaType.APPLICATION_JSON_VALUE)
    public @ResponseBody ResponseEntity<?> newToken(@RequestBody Token token) {
        return ResponseEntity.ok(tokenService.save(token));
    }
} 

//--------------------------------------------------------------- 

@Service
public class TokenServiceImpl implements TokenService {

    @Autowired
    private TokenRepository tokenRepository;

    @Override
    public Mono<Token> save(Token token) {
        return tokenRepository.save(token);
    }
}

//--------------------------------------------------------------- 

@Repository
public interface TokenRepository extends ReactiveCrudRepository<Token, Long> { }

//---------------------------------------------------------------

@Data
@Document(collection = "token")
public class Token {

    @Id
    private Long _id;

    private Long clientCode;

    private String tokenKey; // VALUE THAT IS NEEDED ON NOTIFICATION
} 

为了发送通知，我有一个通知控制器，需要访问数据库并查找令牌。阅读反应式aproach时，我无法理解如何在通知服务中使用TokenRepository读取Dabase，并使用类似“findById”的方法来检索令牌。如何使用返回的Mono对象并获取属性“tokenKey”？

Answer 1

我发现我可以将未来结果存储在CompletableFuture中，然后在它完成时存储Token对象。这是一个例子：

CompletableFuture<Token> tokenFuture = tokenRepository.findByClientCode(notificationRequest.getClientCode()).toFuture();

Token token = tokenFuture.get(5, TimeUnit.SECONDS);

它等待5秒钟，或者抛出一个TimeoutException

Answer 2

而不是响应性

 public @ResponseBody Mono<ResponseEntity<Token>> newToken(@RequestBody Token token) {
        return tokenService.save(token)
               .map(t -> ResponseEntity.ok(t));
    }

你正在将你的mono包装在一个对象中，而这个对象没有被订阅，所以将其反转。