WebfluxSecurityConfig.java 文件源码

@Bean
public ReactiveUserDetailsService userDetailsRepository() {
    return new ReactiveUserDetailsService() {

        @Override
        public Mono<UserDetails> findByUsername(String username) {
            Query query = new Query();
            query.addCriteria(Criteria.where("userId").is(username));
            return operations.findOne(query, UserDetails.class);
        }
    };
}