搜索

webflux reactive-feign 分页的实现 - 白衣风云 -


发布时间: 2022-11-24 23:23:01    浏览次数:49 次

生产者

  • respository

package com.fengyun.medical.productservice.repositories;

import com.fengyun.medical.domain.Handbook;

import org.springframework.data.domain.Pageable;
import org.springframework.data.repository.reactive.ReactiveSortingRepository;
import reactor.core.publisher.Flux;

public interface HandbookRepository extends ReactiveSortingRepository<Handbook, Integer> {
    Flux<Handbook> findAllByIsActiveIsTrue(Pageable pageable);
}
  • handler

  public Mono<ServerResponse> getHandbook(ServerRequest request) {
            Integer page = Integer.valueOf(request.queryParam("page").get());
            Integer size = Integer.valueOf(request.queryParam("size").get());
            System.out.println("请求页码:" + page);
            System.out.println("请求数量:" + size);
        return this.handbookService.getHandbook(PageRequest.of(page,size))
                .flatMap(data ->ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).bodyValue(data));
    }

消费者

  • reactive-feign

 @GetMapping(value="/handbooks")
    Mono<List<Page>> getHandbookAndPaging(@RequestParam String page, @RequestParam String size);

注意:这里返回一个Page类型的List

  • postman测试结果





免责声明 webflux reactive-feign 分页的实现 - 白衣风云 - ,资源类别:文本, 浏览次数:49 次, 文件大小:-- , 由本站蜘蛛搜索收录2022-11-24 11:23:01。此页面由程序自动采集,只作交流和学习使用,本站不储存任何资源文件,如有侵权内容请联系我们举报删除, 感谢您对本站的支持。 原文链接:https://www.cnblogs.com/baiyifengyun/p/16923840.html