網(wǎng)易首頁(yè) > 網(wǎng)易號(hào) > 正文申請(qǐng)入駐

滿屏 Service 注入混亂？用Lambda封裝個(gè)統(tǒng)一調(diào)用組件，直接起飛！

2025-12-24 10:29:06　來(lái)源: Java精選

北京舉報(bào)

分享至

Java精選面試題（微信小程序）：5000+道面試題和選擇題，包含Java基礎(chǔ)、并發(fā)、JVM、線程、MQ系列、Redis、Spring系列、Elasticsearch、Docker、K8s、Flink、Spark、架構(gòu)設(shè)計(jì)、大廠真題等，在線隨時(shí)刷題！

兄弟們，咱做 Spring 項(xiàng)目的時(shí)候，是不是總遇到這些破事：

每個(gè)Controller 里都要寫(xiě)@Autowired UserService userService，注入一大堆 Service，代碼又亂又冗余；
想統(tǒng)一加個(gè)日志/異常處理，得在每個(gè) Service 方法里寫(xiě)一遍，改起來(lái)要瘋；
偶爾還會(huì)手滑把Service類(lèi)名/方法名寫(xiě)錯(cuò)，編譯不報(bào)錯(cuò)，跑起來(lái)才出問(wèn)題，排查半天。

今天給大家分享個(gè)我自己寫(xiě)的ServiceManager組件，用Lambda搞定這些破事 —— 不用手動(dòng)注入Service，調(diào)用方法像寫(xiě)公式一樣簡(jiǎn)單，還能自動(dòng)緩存、統(tǒng)一處理異常，新手也能秒懂秒用！

先說(shuō)說(shuō)這組件能解決啥實(shí)際問(wèn)題？

舉個(gè)栗子：以前咱調(diào)用用戶查詢接口，得這么寫(xiě)：

// 1. 先注入Service
@Autowired
private UserService userService;
// 2. 再調(diào)用方法
public SerResult 

   
getUser(Long userId) {
    try {
        log.info("開(kāi)始查用戶，ID：{}", userId);
        UserDTO user = userService.queryUser(userId);
        log.info("查詢成功，結(jié)果：{}", user);
        return SerResult.success(user);
    } catch (Exception e) {
        log.error("查詢失敗", e);
        return SerResult.fail("查用戶出錯(cuò)了");
    }
}

又是注入又是日志又是try-catch，重復(fù)代碼一堆。

用了ServiceManager之后，直接寫(xiě)成這樣：

public SerResult 

   
getUser(Long userId) {
    // 一行搞定：傳方法+參數(shù)，其他全幫你做
    return ServiceManager.call(UserService::queryUser, userId);
}

注入？沒(méi)了。日志？組件自動(dòng)打。異常？組件自動(dòng)處理。爽不爽？

組件核心邏輯：大白話拆解

其實(shí)這組件就干了 3 件事：

你傳個(gè) Lambda（比如UserService::queryUser），它幫你找到對(duì)應(yīng)的 Service 實(shí)例；
把找到的實(shí)例和方法緩存起來(lái)，下次調(diào)用更快；
統(tǒng)一執(zhí)行方法，順便把日志、異常處理都包了。

下面咱一步步來(lái)，代碼都給你貼好，復(fù)制過(guò)去改改就能用。

第一步：先搭基礎(chǔ) —— 需要的依賴和工具類(lèi)

首先得有幾個(gè)小工具，不用自己寫(xiě)，直接復(fù)制：

1. 統(tǒng)一返回結(jié)果類(lèi)（SerResult）

不管調(diào)用成功還是失敗，都返回同一個(gè)格式，前端好處理：

package org.pro.wwcx.ledger.common.dto;
import lombok.Data;
// 服務(wù)調(diào)用的統(tǒng)一返回結(jié)果，前端拿到就知道是成功還是失敗
@Data
publicclass SerResult {
    privateint code;       // 200=成功，500=失敗，前端一看就懂
    private String msg;     // 提示信息，比如“操作成功”“查不到用戶”
    private T data;         // 成功時(shí)返回的數(shù)據(jù)，比如用戶信息
    // 成功的時(shí)候調(diào)用這個(gè)方法，把數(shù)據(jù)傳進(jìn)去
    publicstatic 

   
SerResult 

   
success(T data) {
        SerResult 

 result =  
new SerResult<>();
        result.setCode(200);
        result.setMsg("操作成功");
        result.setData(data);
        return result;
    }
    // 失敗的時(shí)候調(diào)用這個(gè)方法，傳錯(cuò)誤信息
    publicstatic 

   
SerResult 

   
fail(String msg) {
        SerResult 

 result =  
new SerResult<>();
        result.setCode(500);
        result.setMsg(msg);
        result.setData(null);
        return result;
    }
}

2. Lambda 解析工具（LambdaUtil）

這工具是核心，幫咱從 Lambda 里 “扣” 出 Service 類(lèi)名和方法名（不用懂原理，復(fù)制用就行）：

package org.pro.wwcx.ledger.common.util;
import java.io.Serializable;
import java.lang.reflect.Method;
import java.lang.invoke.SerializedLambda;
// 從Lambda表達(dá)式里拿Service信息的工具
publicclass LambdaUtil {
    // 傳個(gè)Lambda進(jìn)來(lái)，返回它對(duì)應(yīng)的“元數(shù)據(jù)”（比如哪個(gè)Service，哪個(gè)方法）
    public static SerializedLambda valueOf(Serializable lambda) {
        if (lambda == null) {
            thrownew IllegalArgumentException("Lambda不能傳空！");
        }
        try {
            // 反射拿到Lambda里的隱藏方法，不用管這行是咋回事
            Method writeReplaceMethod = lambda.getClass().getDeclaredMethod("writeReplace");
            writeReplaceMethod.setAccessible(true);
            return (SerializedLambda) writeReplaceMethod.invoke(lambda);
        } catch (Exception e) {
            thrownew RuntimeException("解析Lambda出錯(cuò)了", e);
        }
    }
}

3. Spring 工具類(lèi)（SpringUtil）

幫咱從 Spring 里拿 Service 實(shí)例（不用手動(dòng)@Autowired就是靠它）：

package org.pro.wwcx.ledger.common.util;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;
// 從Spring里拿Bean的工具，不用自己注入Service
@Component
publicclass SpringUtil implements ApplicationContextAware {
    // Spring的上下文，相當(dāng)于“Bean倉(cāng)庫(kù)”
    privatestatic ApplicationContext applicationContext;
    // 從倉(cāng)庫(kù)里按類(lèi)型拿Bean，比如拿UserService類(lèi)型的實(shí)例
    publicstatic 

   
T getBean(Class 

 requiredType) 
{
        if (applicationContext == null) {
            thrownew RuntimeException("Spring還沒(méi)初始化好呢！");
        }
        return applicationContext.getBean(requiredType);
    }
    // 下面這行是Spring自動(dòng)調(diào)用的，不用管
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        SpringUtil.applicationContext = applicationContext;
    }
}

4. 函數(shù)接口（SerialBiFunction）

這個(gè)是 Lambda 的 “規(guī)矩”，規(guī)定傳參和返回值的格式（復(fù)制就行）：

package org.pro.wwcx.ledger.common.resolver.anno;
import java.io.Serializable;
// 支持序列化的雙參數(shù)函數(shù)接口，Lambda要符合這個(gè)格式
public interface SerialBiFunction extends Serializable {
    // 方法格式：傳入T（Service實(shí)例）和U（參數(shù)），返回R（結(jié)果）
    R apply(T t, U u);
}

5. 實(shí)例構(gòu)建器（InstBuilder）

幫咱快速創(chuàng)建對(duì)象的小工具，不用寫(xiě)一堆set方法：

package org.pro.wwcx.ledger.common.resolver;
// 快速創(chuàng)建對(duì)象的工具，比如new ServiceExecutor后不用一個(gè)個(gè)set值
publicclass InstBuilder {
    privatefinal T target;
    // 初始化要?jiǎng)?chuàng)建的對(duì)象
    private InstBuilder(Class 

 clazz) 
{
        try {
            this.target = clazz.getDeclaredConstructor().newInstance();
        } catch (Exception e) {
            thrownew RuntimeException("創(chuàng)建對(duì)象失敗", e);
        }
    }
    // 靜態(tài)方法，入口：InstBuilder.of(ServiceExecutor.class)
    publicstatic 

   
InstBuilder 

   
of(Class 

 clazz) 
{
        returnnew InstBuilder<>(clazz);
    }
    // 鏈?zhǔn)絪et值：比如.set(ServiceExecutor::setParam, param)
    public  

   
InstBuilder 

   
set(Setter 

 setter, V value) 
{
        setter.set(target, value);
        returnthis;
    }
    // 最后調(diào)用build()拿到對(duì)象
    public T build() {
        return target;
    }
    // 定義setter的格式
    @FunctionalInterface
    publicinterface Setter 

 { 

        void set(T target, V value);
    }
}

第二步：核心組件 ——ServiceManager

這是咱的主角，所有邏輯都在這，我一行行給你講明白：

package org.pro.wwcx.ledger.common.servicer;
import lombok.extern.slf4j.Slf4j;
import org.pro.wwcx.ledger.common.dto.SerResult;
import org.pro.wwcx.ledger.common.resolver.InstBuilder;
import org.pro.wwcx.ledger.common.resolver.anno.SerialBiFunction;
import org.pro.wwcx.ledger.common.util.LambdaUtil;
import org.pro.wwcx.ledger.common.util.SpringUtil;
import java.lang.invoke.SerializedLambda;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
// 日志注解，能打日志
@Slf4j
publicclass ServiceManager {
    // 緩存初始化大小，6666夠咱用了，不夠再改
    privatestaticfinalint INIT_COUNT = 6666;
    // 緩存Lambda對(duì)應(yīng)的Service信息，key是Lambda，value是Service元數(shù)據(jù)
    privatestaticfinal Map 

 , LambdaMeta 
> CACHE_LAMBDA; 

    // 靜態(tài)代碼塊，項(xiàng)目啟動(dòng)時(shí)就初始化緩存
    static {
        CACHE_LAMBDA = new ConcurrentHashMap<>(INIT_COUNT);
    }
    // 對(duì)外提供的調(diào)用方法：傳Lambda（比如UserService::queryUser）和參數(shù)，返回結(jié)果
    @SuppressWarnings("unchecked")
    publicstatic 

   
SerResult 

   
call(SerialBiFunction 

 fn, U param) 
{
        // 先檢查：Lambda不能傳空
        if (fn == null) {
            return SerResult.fail("服務(wù)函數(shù)不能為空！");
        }
        // 1. 從緩存拿Service信息：有就直接用，沒(méi)有就解析并緩存
        LambdaMeta 

 lambdaMeta = (LambdaMeta 

 ) CACHE_LAMBDA.computeIfAbsent(fn, k-> { 


            // 解析Lambda，拿到Service實(shí)例、類(lèi)名這些信息
            LambdaMeta 

 meta = parseSerialFunction(fn); 

            log.debug("緩存Service信息：{}", meta.getServiceName());
            return meta;
        });
        // 2. 創(chuàng)建執(zhí)行器，把Lambda、參數(shù)、Service信息傳進(jìn)去
        ServiceExecutor 

 executor = InstBuilder.of(ServiceExecutor 
.class)
                .set(ServiceExecutor::setServiceFn, fn)    // 傳Lambda方法
                .set(ServiceExecutor::setParam, param)      // 傳參數(shù)
                .set(ServiceExecutor::setLambdaMeta, lambdaMeta)  // 傳Service信息
                .build();  // 構(gòu)建執(zhí)行器
        // 3. 執(zhí)行方法，返回結(jié)果
        return executor.callService();
    }
    // 解析Lambda：從Lambda里拿到Service類(lèi)名、實(shí)例、方法名
    @SuppressWarnings("unchecked")
    privatestatic 

   
LambdaMeta 

   
parseSerialFunction(SerialBiFunction 

 fn) 
{
        // 用LambdaUtil拿到Lambda的元數(shù)據(jù)
        SerializedLambda lambda = LambdaUtil.valueOf(fn);
        // 封裝Service信息的對(duì)象
        LambdaMeta 

 lambdaMeta =  
new LambdaMeta<>();
        // 1. 解析Service類(lèi)名：Lambda里的類(lèi)名是“com/example/UserService”，要改成“com.example.UserService”
        String tClassName = lambda.getImplClass().replaceAll("/", ".");
        try {
            // 2. 拿到Service的Class對(duì)象（比如UserService.class）
            Class 

 aClass = (Class 

 ) Class.forName(tClassName); 


            // 3. 從Spring里拿Service實(shí)例（不用@Autowired就是靠這行）
            T inst = SpringUtil.getBean(aClass);
            // 4. 把信息存到lambdaMeta里
            lambdaMeta.setClazz(aClass);    // 存Service的Class
            lambdaMeta.setInst(inst);       // 存Service實(shí)例
            lambdaMeta.setServiceName(lambda.getImplMethodName());  // 存方法名（比如queryUser）
        } catch (ClassNotFoundException e) {
            // 找不到類(lèi)就拋異常
            thrownew RuntimeException("沒(méi)找到Service類(lèi)：" + tClassName, e);
        }
        return lambdaMeta;
    }
    // 封裝Service信息的內(nèi)部類(lèi)：存Class、實(shí)例、方法名
    @lombok.Data
    privatestaticclass LambdaMeta 

 { 

        private Class 

 clazz;           
// Service的Class（比如UserService.class）
        private T inst;                  // Service實(shí)例（Spring里的Bean）
        private String serviceName;      // 方法名（比如queryUser）
    }
}

第三步：執(zhí)行器 ——ServiceExecutor

這是幫咱統(tǒng)一執(zhí)行方法、打日志、處理異常的 “打工人”：

package org.pro.wwcx.ledger.common.servicer;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import org.pro.wwcx.ledger.common.dto.SerResult;
import org.pro.wwcx.ledger.common.resolver.anno.SerialBiFunction;
// 執(zhí)行Service方法的類(lèi)，統(tǒng)一打日志、處理異常
@Slf4j
@Setter
publicclass ServiceExecutor {
    private SerialBiFunction 

 serviceFn;   
// 要執(zhí)行的Lambda方法
    private U param;                               // 方法參數(shù)
    private ServiceManager.LambdaMeta 

 lambdaMeta;   
// Service信息
    // 執(zhí)行方法的核心邏輯
    public SerResult 

   
callService() {
        // 記錄開(kāi)始時(shí)間，方便算耗時(shí)
        long startTime = System.currentTimeMillis();
        String serviceName = lambdaMeta.getClazz().getSimpleName();  // 比如UserService
        String methodName = lambdaMeta.getServiceName();             // 比如queryUser
        log.info("開(kāi)始調(diào)用：{}的{}方法，參數(shù)：{}", serviceName, methodName, param);
        try {
            // 真正執(zhí)行方法：用Service實(shí)例調(diào)用Lambda方法
            R result = serviceFn.apply(lambdaMeta.getInst(), param);
            // 算耗時(shí)，打成功日志
            long costTime = System.currentTimeMillis() - startTime;
            log.info("調(diào)用成功：{}的{}方法，耗時(shí){}ms，結(jié)果：{}",
                    serviceName, methodName, costTime, result);
            // 返回成功結(jié)果
            return SerResult.success(result);
        } catch (Exception e) {
            // 出錯(cuò)了就打錯(cuò)誤日志，返回失敗結(jié)果
            long costTime = System.currentTimeMillis() - startTime;
            log.error("調(diào)用失�。簕}的{}方法，耗時(shí){}ms",
                    serviceName, methodName, costTime, e);
            return SerResult.fail("調(diào)用" + serviceName + "的" + methodName + "方法失�。�" + e.getMessage());
        }
    }
}

第四步：怎么用？舉個(gè)實(shí)際例子

咱以用戶查詢和更新為例，看 Controller 里怎么寫(xiě)：

1. 先寫(xiě)個(gè) Service（正常寫(xiě)，不用改）

package org.pro.wwcx.ledger.service;
import org.pro.wwcx.ledger.dto.UserDTO;
import org.pro.wwcx.ledger.dto.UserUpdateDTO;
import org.springframework.stereotype.Service;
// 正常的Service，該咋寫(xiě)咋寫(xiě)
@Service
publicclass UserService {
    // 查用戶：根據(jù)ID查
    public UserDTO queryUser(Long userId) {
        // 這里模擬查數(shù)據(jù)庫(kù)，實(shí)際項(xiàng)目里換JDBC/MyBatis
        UserDTO user = new UserDTO();
        user.setUserId(userId);
        user.setUserName("張三");
        user.setAge(25);
        return user;
    }
    // 更新用戶：傳ID和更新參數(shù)
    public Boolean updateUser(Long userId, UserUpdateDTO updateDTO) {
        // 這里模擬更新數(shù)據(jù)庫(kù)
        log.info("更新用戶{}的信息：{}", userId, updateDTO);
        returntrue;  // 返回更新成功
    }
}

2. Controller 里調(diào)用（重點(diǎn)看變化）

package org.pro.wwcx.ledger.controller;
import org.pro.wwcx.ledger.common.dto.SerResult;
import org.pro.wwcx.ledger.common.servicer.ServiceManager;
import org.pro.wwcx.ledger.dto.UserDTO;
import org.pro.wwcx.ledger.dto.UserUpdateDTO;
import org.pro.wwcx.ledger.service.UserService;
import org.springframework.web.bind.annotation.*;
@RestController
@RequestMapping("/user")
publicclass UserController {
    // 查用戶：不用注入U(xiǎn)serService！一行搞定
    @GetMapping("/{userId}")
    public SerResult 

   
getUser(@PathVariable Long userId) {
        // 直接傳Lambda（UserService::queryUser）和參數(shù)（userId）
        return ServiceManager.call(UserService::queryUser, userId);
    }
    // 更新用戶：同樣不用注入
    @PutMapping("/{userId}")
    public SerResult 

   
updateUser(
            @PathVariable Long userId,
            @RequestBody UserUpdateDTO updateDTO) {
        // 這里要注意：因?yàn)閡pdateUser有兩個(gè)參數(shù)，所以要顯式指定Lambda類(lèi)型
        return ServiceManager.call(
                (UserService service, UserUpdateDTO dto) -> service.updateUser(userId, dto),
                updateDTO
        );
    }
}

3. 跑起來(lái)看看效果

查用戶的時(shí)候，日志會(huì)自動(dòng)打：

開(kāi)始調(diào)用：UserService的queryUser方法，參數(shù)：1001
調(diào)用成功：UserService的queryUser方法，耗時(shí)5ms，結(jié)果：UserDTO(userId=1001, userName=張三, age=25)

要是出錯(cuò)了，比如傳個(gè)不存在的用戶 ID（假設(shè)數(shù)據(jù)庫(kù)查不到會(huì)拋異常），日志會(huì)打錯(cuò)誤信息，返回給前端的結(jié)果是：

{
  "code": 500,
  "msg": "調(diào)用UserService的queryUser方法失�。河脩舨淮嬖�",
  "data": null
}

這組件的好處：總結(jié)一下

不用再寫(xiě) @Autowired：Controller 里干干凈凈，再也不用注入一堆 Service；
統(tǒng)一日志 / 異常：想改日志格式、加權(quán)限校驗(yàn)，只需要改ServiceExecutor，不用改每個(gè)方法；
緩存優(yōu)化：解析過(guò)的 Service 信息會(huì)緩存，下次調(diào)用更快；
類(lèi)型安全：寫(xiě) Lambda 的時(shí)候，方法名錯(cuò)了編譯就報(bào)錯(cuò)，不用等到運(yùn)行才發(fā)現(xiàn)。

注意事項(xiàng)：避坑指南

JDK 版本：用JDK8及以上，Lambda 表達(dá)式是 JDK8 才有的；
Service 要加@Service：Spring才能掃描到，不然SpringUtil拿不到實(shí)例；
多實(shí)現(xiàn)類(lèi)的情況：如果一個(gè)接口有多個(gè)實(shí)現(xiàn)（比如UserService有UserServiceImpl1和UserServiceImpl2），需要在SpringUtil里加按名稱拿 Bean 的方法。

來(lái)源：https://juejin.cn/post/7575017581036765222

公眾號(hào)“Java精選”所發(fā)表內(nèi)容注明來(lái)源的，版權(quán)歸原出處所有（無(wú)法查證版權(quán)的或者未注明出處的均來(lái)自網(wǎng)絡(luò)，系轉(zhuǎn)載，轉(zhuǎn)載的目的在于傳遞更多信息，版權(quán)屬于原作者。如有侵權(quán)，請(qǐng)聯(lián)系，筆者會(huì)第一時(shí)間刪除處理！

最近有很多人問(wèn)，有沒(méi)有讀者或者摸魚(yú)交流群！加入方式很簡(jiǎn)單，公眾號(hào)Java精選，回復(fù)“加群”，即可入群！

文章有幫助的話，點(diǎn)在看，轉(zhuǎn)發(fā)吧！

特別聲明：以上內(nèi)容(如有圖片或視頻亦包括在內(nèi))為自媒體平臺(tái)“網(wǎng)易號(hào)”用戶上傳并發(fā)布，本平臺(tái)僅提供信息存儲(chǔ)服務(wù)。

Notice: The content above (including the pictures and videos if any) is uploaded and posted by a user of NetEase Hao, which is a social media platform and only provides information storage services.