在Java微服务架构中，Feign是声明式服务调用的常用工具，但分页API的调用逻辑往往存在大量重复代码，比如手动组装页码、逐页请求、解析分页结果等，既影响开发效率也提升维护成本。通过通用抽象结合函数式优化，可以有效解决这类问题。
分页场景的痛点分析
传统的Feign分页调用通常会有以下重复逻辑：
- 每个分页接口都要单独定义当前页、每页大小、总页数等参数
- 需要手动循环页码，逐页请求并拼接结果
- 不同业务的分页响应结构不同，解析逻辑需要重复编写
- 页码边界处理、请求异常处理逻辑分散在各个调用点
分页通用抽象设计
分页请求抽象
首先定义通用的分页请求基类，统一分页参数的结构：
import lombok.Data;
/**
* 通用分页请求抽象类
*/
@Data
public abstract class BasePageRequest {
/**
* 当前页码，默认从1开始
*/
private Integer pageNum = 1;
/**
* 每页大小，默认20条
*/
private Integer pageSize = 20;
/**
* 获取业务特有的请求参数，子类需要实现
*/
public abstract Object getBizParams();
}分页响应抽象
定义通用的分页响应接口，统一分页结果的获取方式：
import java.util.List;
/**
* 通用分页响应接口
*/
public interface BasePageResponse<T> {
/**
* 获取当前页的数据列表
*/
List<T> getRecords();
/**
* 获取总数据条数
*/
Long getTotal();
/**
* 获取总页数
*/
Integer getTotalPages();
/**
* 判断是否存在下一页
*/
default boolean hasNextPage() {
if (getTotalPages() == null) {
return false;
}
// 假设pageNum从1开始计数
return getTotalPages() > 1;
}
}Feign通用分页接口定义
基于上述抽象，定义通用的Feign分页调用接口，减少重复声明：
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
/**
* 通用分页Feign客户端基类
* @param <R> 请求参数类型，继承BasePageRequest
* @param <P> 响应类型，实现BasePageResponse
*/
@FeignClient(name = "biz-service", url = "http://127.0.0.1:8080")
public interface BasePageFeignClient<R extends BasePageRequest, P extends BasePageResponse<?>> {
/**
* 通用分页查询接口，子类只需要指定具体路径
*/
@PostMapping("/page")
P pageQuery(R request);
}函数式优化分页遍历逻辑
传统分页遍历需要手动写循环，通过函数式编程可以封装通用的分页遍历方法，将业务逻辑作为参数传入：
import java.util.ArrayList;
import java.util.List;
import java.util.function.Consumer;
/**
* 分页遍历工具类
*/
public class PageQueryHelper {
/**
* 函数式分页遍历，自动处理页码循环，将每页结果回调处理
* @param firstRequest 初始分页请求
* @param feignClient Feign调用客户端
* @param pageConsumer 每页结果的处理逻辑，比如拼接数据到总列表
* @param <R> 请求类型
* @param <P> 响应类型
* @return 所有页的汇总结果
*/
public static <R extends BasePageRequest, P extends BasePageResponse<T>, T> List<T> foreachPage(
R firstRequest,
BasePageFeignClient<R, P> feignClient,
Consumer<List<T>> pageConsumer) {
List<T> totalResult = new ArrayList<>();
R currentRequest = firstRequest;
P response;
do {
// 调用Feign接口获取当前页数据
response = feignClient.pageQuery(currentRequest);
if (response == null || response.getRecords() == null) {
break;
}
// 将当前页数据加入汇总结果
totalResult.addAll(response.getRecords());
// 如果有传入自定义处理逻辑，执行回调
if (pageConsumer != null) {
pageConsumer.accept(response.getRecords());
}
// 判断是否有下一页，有则页码加1继续请求
if (response.hasNextPage()) {
currentRequest.setPageNum(currentRequest.getPageNum() + 1);
} else {
break;
}
} while (true);
return totalResult;
}
}实际使用示例
以用户分页查询场景为例，展示具体的使用方式：
业务请求定义
import lombok.Data;
import lombok.EqualsAndHashCode;
/**
* 用户分页请求
*/
@Data
@EqualsAndHashCode(callSuper = true)
public class UserPageRequest extends BasePageRequest {
/**
* 业务特有参数：用户状态
*/
private Integer status;
@Override
public Object getBizParams() {
return status;
}
}业务响定义
import lombok.Data;
import java.util.List;
/**
* 用户分页响应
*/
@Data
public class UserPageResponse implements BasePageResponse<UserDTO> {
/**
* 用户数据列表
*/
private List<UserDTO> records;
/**
* 总条数
*/
private Long total;
/**
* 总页数
*/
private Integer totalPages;
@Override
public List<UserDTO> getRecords() {
return records;
}
@Override
public Long getTotal() {
return total;
}
@Override
public Integer getTotalPages() {
return totalPages;
}
}Feign客户端定义
import org.springframework.cloud.openfeign.FeignClient;
/**
* 用户服务Feign客户端
*/
@FeignClient(name = "user-service", url = "http://127.0.0.1:8081")
public interface UserFeignClient extends BasePageFeignClient<UserPageRequest, UserPageResponse> {
// 继承通用的pageQuery方法，无需重复定义
}调用示例
import java.util.List;
import java.util.ArrayList;
public class UserService {
private final UserFeignClient userFeignClient;
public UserService(UserFeignClient userFeignClient) {
this.userFeignClient = userFeignClient;
}
public List<UserDTO> getAllValidUsers() {
// 构建初始请求
UserPageRequest request = new UserPageRequest();
request.setStatus(1);
request.setPageSize(50);
// 调用通用分页遍历方法，传入处理逻辑
return PageQueryHelper.foreachPage(
request,
userFeignClient,
// 可选：每页结果的额外处理逻辑，比如打印日志
pageRecords -> System.out.println("已处理" + pageRecords.size() + "条用户数据")
);
}
}优化效果总结
通过上述通用抽象和函数式优化，实现了以下效果：
- 分页参数、响应解析逻辑统一封装，减少重复代码
- 页码循环、边界判断等通用逻辑下沉到工具类，调用方只需要关注业务参数和业务数据处理
- 函数式回调支持自定义每页的处理逻辑，扩展性强
- 新增分页接口时只需要定义业务请求和响应，无需重复编写分页调用逻辑