文章背景

最近在測試業(yè)務(wù)需求時通讀了研發(fā)指定需求的代碼，發(fā)現(xiàn)研發(fā)大佬們用到了如下的內(nèi)容，有些內(nèi)容我還不是十分的清楚，比如下述真實(shí)代碼；作為后端大佬肯定爐火純青，但是我剛剛看到這段代碼時確實(shí)有點(diǎn)懵；

快速理解的方式
直接借助joycoder解釋代碼的能力就可以快速理解

于是乎有了下述的探索

但是我為了理解的透徹點(diǎn)還是又去翻找了一些其它資料做一個記錄吧，后續(xù)萬一在遺忘了也方便快速查找

MyBatis-Plus的LambdaQueryWrapper簡介

LambdaQueryWrapper是MyBatis-Plus提供的一種類型安全的查詢條件構(gòu)造器，它利用Java 8的Lambda表達(dá)式特性，避免了硬編碼字段名，提高了代碼的可讀性和可維護(hù)性。

基本用法示例

LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper();
queryWrapper.eq(User::getName, "張三")
           .ge(User::getAge, 18)
           .orderByDesc(User::getCreateTime);
List userList = userMapper.selectList(queryWrapper);

LambdaQueryWrapper的優(yōu)勢

類型安全：通過方法引用而非字符串指定字段，編譯器可檢查類型
代碼可讀性高：鏈?zhǔn)秸{(diào)用，語義清晰
防止SQL注入：自動處理參數(shù)綁定
智能提示：IDE可自動補(bǔ)全字段名

Spring Boot的@Async異步處理

@Async是Spring框架提供的注解，用于標(biāo)記方法為異步執(zhí)行。被@Async注解的方法會在調(diào)用時立即返回，而實(shí)際執(zhí)行將發(fā)生在單獨(dú)的線程中。

基本配置

首先需要在Spring Boot啟動類或配置類上添加@EnableAsync注解：

@SpringBootApplication
@EnableAsync
public class MyApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
}

簡單使用示例

@Service
public class AsyncService {

    @Async
    public void asyncMethod() {
        // 這個方法將在單獨(dú)的線程中執(zhí)行
        System.out.println("執(zhí)行異步方法: " + Thread.currentThread().getName());
    }
}

LambdaQueryWrapper與@Async的結(jié)合實(shí)踐

將兩者結(jié)合使用可以實(shí)現(xiàn)高效的異步數(shù)據(jù)庫操作，特別適合那些不需要立即返回結(jié)果的復(fù)雜查詢或批量操作。

示例1：異步查詢用戶列表

@Service
@RequiredArgsConstructor
public class UserService {
    
    private final UserMapper userMapper;
    
    @Async
    public CompletableFuture> asyncFindUsers(String name, Integer minAge) {
        LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper();
        queryWrapper.like(StringUtils.isNotBlank(name), User::getName, name)
                   .ge(minAge != null, User::getAge, minAge);
        
        List users = userMapper.selectList(queryWrapper);
        return CompletableFuture.completedFuture(users);
    }
}

示例2：異步統(tǒng)計與保存

@Async
public void asyncStatAndSave(Long departmentId) {
    // 統(tǒng)計部門人數(shù)
    LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper();
    queryWrapper.eq(User::getDepartmentId, departmentId);
    long count = userMapper.selectCount(queryWrapper);
    
    // 更新統(tǒng)計結(jié)果
    Department department = new Department();
    department.setId(departmentId);
    department.setUserCount(count);
    departmentMapper.updateById(department);
    
    // 記錄統(tǒng)計日志
    StatLog statLog = new StatLog();
    statLog.setDepartmentId(departmentId);
    statLog.setCount(count);
    statLog.setStatTime(LocalDateTime.now());
    statLogMapper.insert(statLog);
}

高級應(yīng)用與優(yōu)化

自定義線程池配置

默認(rèn)情況下，@Async使用SimpleAsyncTaskExecutor，這不是生產(chǎn)環(huán)境的最佳選擇。我們可以自定義線程池：

@Configuration
public class AsyncConfig implements AsyncConfigurer {
    
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(50);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("AsyncExecutor-");
        executor.initialize();
        return executor;
    }
}

異常處理

異步方法的異常不會傳播到調(diào)用線程，需要特別處理：

@Async
public CompletableFuture> asyncFindUsersWithExceptionHandling(String name) {
    try {
        LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper();
        queryWrapper.like(User::getName, name);
        List users = userMapper.selectList(queryWrapper);
        return CompletableFuture.completedFuture(users);
    } catch (Exception e) {
        // 記錄日志
        log.error("異步查詢用戶失敗", e);
        // 返回空列表或拋出CompletionException
        return CompletableFuture.completedFuture(Collections.emptyList());
    }
}

事務(wù)處理

@Async方法的事務(wù)需要特別注意，默認(rèn)情況下異步方法的事務(wù)不會傳播：

@Async
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void asyncUpdateWithTransaction(User user) {
    // 這個更新操作將在新事務(wù)中執(zhí)行
    userMapper.updateById(user);
}

實(shí)際應(yīng)用場景

后臺報表生成

@Async
public void asyncGenerateUserReport(LocalDate startDate, LocalDate endDate, String reportPath) {
    LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper();
    queryWrapper.between(User::getCreateTime, startDate.atStartOfDay(), endDate.atTime(23, 59, 59))
               .orderByAsc(User::getCreateTime);
    
    List users = userMapper.selectList(queryWrapper);
    
    // 生成報表文件
    generateExcelReport(users, reportPath);
    
    // 發(fā)送通知
    sendReportReadyNotification(reportPath);
}

批量數(shù)據(jù)處理

@Async
public CompletableFuture asyncBatchProcessUsers(List userIds) {
    LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper();
    queryWrapper.in(User::getId, userIds);
    
    List users = userMapper.selectList(queryWrapper);
    
    int processedCount = 0;
    for (User user : users) {
        if (processUser(user)) {
            processedCount++;
        }
    }
    return CompletableFuture.completedFuture(processedCount);
}

性能考量與最佳實(shí)踐

合理使用異步：不是所有數(shù)據(jù)庫操作都適合異步，簡單查詢同步執(zhí)行可能更高效
控制并發(fā)量：避免過多并發(fā)數(shù)據(jù)庫連接導(dǎo)致系統(tǒng)資源耗盡
批量操作優(yōu)化：考慮使用MyBatis-Plus的批量操作方法
結(jié)果處理：使用CompletableFuture可以方便地處理異步結(jié)果
監(jiān)控：監(jiān)控異步任務(wù)的執(zhí)行情況和線程池狀態(tài)

總結(jié)

MyBatis-Plus的LambdaQueryWrapper與Spring Boot的@Async注解的結(jié)合，為Java后端開發(fā)提供了強(qiáng)大的工具組合。LambdaQueryWrapper提供了類型安全、優(yōu)雅的查詢構(gòu)建方式，而@Async則讓異步編程變得簡單。合理使用這兩者可以顯著提高應(yīng)用程序的響應(yīng)速度和處理能力，特別是在處理復(fù)雜查詢、批量操作和后臺任務(wù)時。
在實(shí)際項(xiàng)目中，開發(fā)者應(yīng)根據(jù)具體場景選擇合適的技術(shù)組合，并注意線程池配置、異常處理和事務(wù)管理等關(guān)鍵點(diǎn)，以確保系統(tǒng)的穩(wěn)定性和可靠性。

審核編輯 黃宇