1，功能目的
平常做一些CRUD業務可能會涉及到查詢分頁列表的問題，但是有一些業務數據可能不只存在於數據庫表之中，可能在ES，mongo，redis等各種數據聚合而成，返回也需要做到有分頁效果，因此我們可以利用JDK8的新特性來實現一種簡單的分頁。
2，功能API-Stream
2.1 篩選與切片
filter：過濾流中的某些元素
limit(n)：獲取n個元素
skip(n)：跳過n元素，配合limit(n)可實現分頁
distinct：通過流中元素的 hashCode() 和 equals() 去除重復元素
Stream<Integer> stream = Stream.of(6, 4, 6, 7, 3, 9, 8, 10, 12, 14, 14);
Stream<Integer> newStream = stream.filter(s -> s > 5) //6 6 7 9 8 10 12 14 14
.distinct() //6 7 9 8 10 12 14
.skip(2) //9 8 10 12 14
.limit(2); //9 8
newStream.forEach(System.out::println);
2.2 映射
map：接收一個函數作為參數，該函數會被應用到每個元素上，並將其映射成一個新的元素。
flatMap：接收一個函數作為參數，將流中的每個值都換成另一個流，然后把所有流連接成一個流。
List<String> list = Arrays.asList("a,b,c", "1,2,3");
//將每個元素轉成一個新的且不帶逗號的元素
Stream<String> s1 = list.stream().map(s -> s.replaceAll(",", ""));
s1.forEach(System.out::println); // abc 123
Stream<String> s3 = list.stream().flatMap(s -> {
//將每個元素轉換成一個stream
String[] split = s.split(",");
Stream<String> s2 = Arrays.stream(split);
return s2;
});
s3.forEach(System.out::println); // a b c 1 2 3
2.3 排序
sorted()：自然排序，流中元素需實現Comparable接口
sorted(Comparator com)：定制排序，自定義Comparator排序器
List<String> list = Arrays.asList("aa", "ff", "dd");
//String 類自身已實現Compareable接口
list.stream().sorted().forEach(System.out::println);// aa dd ff
Student s1 = new Student("aa", 10);
Student s2 = new Student("bb", 20);
Student s3 = new Student("aa", 30);
Student s4 = new Student("dd", 40);
List<Student> studentList = Arrays.asList(s1, s2, s3, s4);
//自定義排序：先按姓名升序，姓名相同則按年齡升序
studentList.stream().sorted(
(o1, o2) -> {
if (o1.getName().equals(o2.getName())) {
return o1.getAge() - o2.getAge();
} else {
return o1.getName().compareTo(o2.getName());
}
}
).forEach(System.out::println);
Student s1 = new Student("aa", 10);
Student s2 = new Student("bb", 20);
List<Student> studentList = Arrays.asList(s1, s2);
studentList.stream()
.peek(o -> o.setAge(100))
.forEach(System.out::println);
//結果：
Student{name='aa', age=100}
Student{name='bb', age=100}
3，代碼實現
3.1 Page類
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import java.util.List;
import java.util.Map;
/**
* @author ：Eidos
* @date ：Created in 2020/12/9
* @description：分頁基礎類
* @modified By：
* @version: 1.0
*/
@ApiModel
@NoArgsConstructor
@AllArgsConstructor
public class Page<T> {
@ApiModelProperty(value = "頁碼")
@Getter
@Setter
private int currentPage;
@ApiModelProperty(value = "分頁大小")
@Getter
@Setter
private Integer pageSize;
@ApiModelProperty(value = "總數")
private Integer total;
@ApiModelProperty(value = "頁數")
@Getter
@Setter
private Integer pages;
@ApiModelProperty(value = "數據集")
@Getter
@Setter
private List<Map<String, Object>> records;
public Page(Integer pageNo, Integer pageSize) {
this.pageSize = pageSize;
this.currentPage = pageNo;
}
public Integer getTotal() {
return total;
}
public void setTotal(Integer total) {
this.total = total;
this.pages = (total + pageSize - 1) / pageSize;
}
}
3.2 分頁方法
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.extern.slf4j.Slf4j;
import java.util.List;
import java.util.stream.Collectors;
/**
* @author ： Eidos
* @date ：Created in 2020/12/28
* @description：
* @modified By：
* @version: 1.0
*/
@Slf4j
public class PageUtil {
/**
* 分頁方法
*
* @param list 要分頁的數據
* @param page 分頁
*/
public static <T> List<T> getPageResult(List<T> list, Page page) {
page.setTotal(list.size());
//模擬分頁效果
return list.stream().skip((page.getCurrent() - 1) * page.getSize())
.limit(page.getSize())
.collect(Collectors.toList());
}
}
核心思想：與平常分頁想法一致。用skip跳過前面的數據，用limit來限制中間的數據，就能得到完整的分頁結果。 可以將聚合好的數據存在服務器或者redis中， 這樣便於下次繼續使用分頁。
————————————————
版權聲明：本文為CSDN博主「EidosMephiste」的原創文章，遵循CC 4.0 BY-SA版權協議，轉載請附上原文出處鏈接及本聲明。
原文鏈接：https://blog.csdn.net/weixin_40156790/article/details/113754086