在SpringBoot中，我們可以理解成，一個(gè)Controller接口對(duì)應(yīng)多個(gè)ServiceImpl，使用這種方式，如果后期需要添加一個(gè)功能，僅僅創(chuàng)建一個(gè)ServiceImpl就可以滿足需求，而不用再額外創(chuàng)建一個(gè)Controller接口。

現(xiàn)在假設(shè)一個(gè)情景，前端傳入不同的用戶類型，后端返回該用戶的任務(wù)。

你可能問我，為什么不直接把（用戶類型，用戶任務(wù)）存入數(shù)據(jù)庫(kù)？

現(xiàn)在只是一個(gè)簡(jiǎn)單的場(chǎng)景而已，實(shí)際中更為復(fù)雜，無(wú)法直接存入數(shù)據(jù)庫(kù)。

代碼演示

我們先定義一個(gè)接口

public interface UserService { 
    //返回用戶的主要任務(wù)
    String task();
}

兩個(gè)實(shí)現(xiàn)類

@Service("student")
public class StudentServiceImpl implements UserService {
? ? @Override
? ? public String task() {
? ? ? ? return "學(xué)習(xí)";
? ? }
}

@Service("teacher")
public class TeacherServiceImpl implements UserService {
? ? @Override
? ? public String task() {
? ? ? ? return "教書";
? ? }
}

實(shí)現(xiàn)動(dòng)態(tài)調(diào)用的核心類

@Service
public class UserContext {?
? ? @Autowired
? ? Map<String, UserService> userMap;
?
? ? public UserService getUserService(String type) {
? ? ? ? return userMap.get(type);
? ? }
}

Spring會(huì)自動(dòng)地將形如(@Service后面的名稱，實(shí)現(xiàn)該接口的類)注入到該userMap中

在啟動(dòng)后，userMap中就存在兩個(gè)元素，("student"，StudentServiceImpl)與("teacher"，TeacherServiceImpl)

getUserService方法返回userMap中key=type的UserService對(duì)象

實(shí)體類

public class User { 
    private String type; 
    private String task; 
    public String getType() {
        return type;
    }
 
    public void setType(String type) {
        this.type = type;
    }
 
    public String getTask() {
        return task;
    }
 
    public void setTask(String task) {
        this.task = task;
    }
}

Controller層接口

@RestController
@RequestMapping("/user")
public class UserController { 
    @Autowired
    UserContext userContext;
 
    @PostMapping("/getTask")
    public String getTask(@RequestBody User user) {
        UserService userService = userContext.getUserService(user.getType());
        return userService.task();
    }
}

測(cè)試樣例：

可能用到的場(chǎng)景舉例

關(guān)于庫(kù)存的儀表盤統(tǒng)計(jì)

前端傳入?yún)^(qū)域id，倉(cāng)庫(kù)id，物品id等信息

后端依據(jù)參數(shù)動(dòng)態(tài)地選擇某一個(gè)物品實(shí)現(xiàn)類，最后返回統(tǒng)計(jì)的信息。

這里有幾個(gè)問題，為什么不一次性將所有物品id傳入，一次性獲取所有物品的庫(kù)存？

一次性傳入，可能后端處理時(shí)間邊長(zhǎng)，失敗率也高，一旦失敗，整個(gè)儀表盤沒有任何數(shù)據(jù)。而且后期可能面臨的一個(gè)需求，不同的物品，需要有不同的接口刷新速度，暢銷的物品接口調(diào)用頻率快。所以可能需要將物品分組，一個(gè)小組是同一種類型，使用一個(gè)實(shí)現(xiàn)類。

比如，這里有100種物品，按類型或者其他屬性分成了10組，每個(gè)組之間，有一個(gè)不同的屬性groupId，但10組共用一個(gè)接口，進(jìn)入接口后，再進(jìn)入10個(gè)不同的實(shí)現(xiàn)類，在實(shí)現(xiàn)類中調(diào)用具體的計(jì)算邏輯。

spring中動(dòng)態(tài)選擇實(shí)現(xiàn)類

在spring中當(dāng)一個(gè)接口有多個(gè)實(shí)現(xiàn)類的時(shí)候，通過(guò)創(chuàng)建簡(jiǎn)單工廠類，根據(jù)傳入的不同的參數(shù)獲取不同的接口實(shí)現(xiàn)類。

public interface ExecuteService {?? ?
?? ?ExecuteEnum getCode();
? ? // 業(yè)務(wù)方法
? ? void execute();
}

@Service
public class FirstExecuteServiceImpl implements ExecuteService {?? ?
?? ?@Override
?? ?public ExecuteEnum getCode() {
?? ??? ?return ExecuteEnum.FIRST;
?? ?}
?? ?
?? ?public void execute() {
?? ? ? ?System.out.println("11111111111");
?? ?}
}

@Service
public class SecondExecuteServiceImpl implements ExecuteService {?? ?
?? ?@Override
?? ?public ExecuteEnum getCode() {
?? ??? ?return ExecuteEnum.SECOND;
?? ?}
?? ?
?? ?public void execute() {
?? ? ? ?System.out.println("222222222");
?? ?}
}

?? ?public enum ExecuteEnum {
?? ??? ?FIRST,
?? ??? ?SECOND,;
?? ?}

方案一

@Component
public class ExecuteServiceFactory implements ApplicationContextAware {
?? ?
?? ?private final static Map<ExecuteEnum, ExecuteService> EXECUTE_SERVICES = new HashMap<>();
?? ?@Override
?? ?public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
?? ??? ?Map<String, ExecuteService> types = applicationContext.getBeansOfType(ExecuteService.class);
?? ??? ?types.values().forEach(e -> EXECUTE_SERVICES.putIfAbsent(e.getCode(), e));
?? ?}?? ?
}

方案二

@Component
public class ExecuteServiceFactory implements InitializingBean {
? ? @Autowired
? ? private List<ExecuteService> executeServices;
? ? public final static Map<ExecuteEnum, ExecuteService> EXECUTE_SERVICES = new HashMap<>();
? ? @Override
? ? public void afterPropertiesSet() throws Exception {
? ? ? ? executeServices.forEach(l -> EXECUTE_SERVICES.putIfAbsent(l.getCode(), l));
? ? }
}

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: