【Spring Boot】使用 CompletableFuture 优化首页査询模块_springboot completablefuture

CompletableFuture 可以有效地并行处理多个异步任务。

加载文章列表、侧边栏和分类信息：

import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

// 模拟数据模型
class Article {
    // 文章属性
}

class Sidebar {
    // 侧边栏属性
}

class Category {
    // 分类属性
}

// 模拟数据加载方法
public class DataLoader {

    public List<Article> loadArticles() {
        // 模拟加载文章列表
        return List.of(new Article(), new Article());
    }

    public Sidebar loadSidebar() {
        // 模拟加载侧边栏
        return new Sidebar();
    }

    public List<Category> loadCategories() {
        // 模拟加载分类信息
        return List.of(new Category(), new Category());
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

使用 CompletableFuture 来并行加载这些数据：

import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class HomePageService {

    private DataLoader dataLoader = new DataLoader();

    public void loadHomePage() {
        CompletableFuture<List<Article>> articlesFuture = CompletableFuture.supplyAsync(dataLoader::loadArticles);
        CompletableFuture<Sidebar> sidebarFuture = CompletableFuture.supplyAsync(dataLoader::loadSidebar);
        CompletableFuture<List<Category>> categoriesFuture = CompletableFuture.supplyAsync(dataLoader::loadCategories);

        CompletableFuture<Void> allFutures = CompletableFuture.allOf(articlesFuture, sidebarFuture, categoriesFuture);

        try {
            // 等待所有任务完成
            allFutures.get();

            // 获取每个任务的结果
            List<Article> articles = articlesFuture.get();
            Sidebar sidebar = sidebarFuture.get();
            List<Category> categories = categoriesFuture.get();

            // 将加载的数据整合到首页
            System.out.println("Articles loaded: " + articles.size());
            System.out.println("Sidebar loaded: " + (sidebar != null));
            System.out.println("Categories loaded: " + categories.size());
            
            // 在此处将数据传递到前端页面

        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        HomePageService homePageService = new HomePageService();
        homePageService.loadHomePage();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

1. CompletableFuture.supplyAsync 方法并行地执行 loadArticles, loadSidebar, 和 loadCategories 方法。
2. CompletableFuture.allOf 用于等待所有异步任务完成。
3. 使用 get() 方法获取每个 CompletableFuture 的结果。需要注意的是，get() 方法会阻塞当前线程，直到对应的任务完成。

通过这种方式，首页的文章列表、侧边栏和分类信息将会并行加载，从而提高页面的加载效率。