如何實現回調和spring的LambdaSafe類

這篇文章主要介紹如何實現回調和spring的LambdaSafe類，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

   在閱讀spring boot源碼時發現了WebServerFactoryCustomizerBeanPostProcessor類中有

LambdaSafe.callbacks(WebServerFactoryCustomizer.class, getCustomizers(), webServerFactory)
                .withLogger(WebServerFactoryCustomizerBeanPostProcessor.class)
                .invoke((customizer) -> customizer.customize(webServerFactory));

的用法。搜索了一下國內網站，發現沒有相關資料，所以只能去spring官方網站上查閱文檔學習一下。
   我們知道一切皆可“類”化的java中沒有函數指針，而函數指針可以用來實現編程中較為普遍使用的“回調”。所謂“回調“是和“調用”相反的過程，如果用類和消息來理解就是，類A調用類B的方法，可以認為是類A向類B發送了一個消息，這個過程被稱為”調用”。對于類B來說，B 被動 接收了這個消息。但是如果類B的方法在處理這個消息的過程中，又需要類A才有的數據或者類A才有能力拿到的數據，這時候類B需要向類A發送一個消息(調用類A的方法)，主動 請求獲取數據。這時候類B就需要知道類A的方法如何調用，這個過程稱為”回調”。
   如果是c/c++,可以直接給類B傳入一個類A方法的函數指針。但是java中不存在現成的“函數指針”可以使用，所以出現了幾種類“函數指針”的形式。一種是比較常見的使用接口+方法的形式實現類函數指針的方式，這種接口被稱為函數式接口，另一種是java 8中的新特性lambda表達式，本質上也是一種函數式接口。
   Java中定義了一個 @FunctionalInterface注解來修飾接口實現的”函數指針”，但是這個注解并不是必須的，只要滿足函數式接口標準的接口都可以作為”函數指針”。如果一個接口不滿足函數式接口標準，同時注解了 @FunctionalInterface，那么編譯器就會報錯，這個注解相當于能夠更好的方便編譯器進行檢查。現在我們以上面代碼中涉及的函數式接口來舉例。

@FunctionalInterface
public interface WebServerFactoryCustomizer<T extends WebServerFactory> {
    void customize(T factory);
}

WebServerFactoryCustomizer是一個提供給用戶用來定制WebServerFactory實例的接口。這個函數式接口的使用是在上面代碼的invoke方法的lambda表達式中，主要是處理傳入的WebServerFactory實例的bean，然后繼承這個函數式接口就可以對這個實例為所欲為。
好了，基礎介紹完了，終于到我們的主角LambdaSafe類了。spring 官方文檔給的解釋是

Utility that can be used to invoke lambdas in a safe way. Primarily designed to help support generically typed callbacks where class cast exceptions need to be dealt with due to class erasure.

。大意就是說LambdaSafe可以用來安全的運行lambda表達式，所謂的安全就是指可以支持處理在“回調”過程中因為類型擦除（java泛型中的概念）而需要拋出異常的情況。
   那么實際上如何實現的呢？先看LambdaSafe.callbacks方法。在上面代碼中，LambdaSafe.callbacks傳入了WebServerFactoryCustomizer.class、getCustomizers()和需要被為所欲為的WebServerFactory實例。getCustomizers()的返回值會獲取所有WebServerFactoryCustomizer函數式接口的實現類，可以理解獲取了一堆函數指針。

private List<WebServerFactoryCustomizer<?>> customizers;
private Collection<WebServerFactoryCustomizer<?>> getCustomizers() {
  if (this.customizers == null) {
    // Look up does not include the parent context
    this.customizers = new ArrayList<>(getWebServerFactoryCustomizerBeans());
    this.customizers.sort(AnnotationAwareOrderComparator.INSTANCE);
    this.customizers = Collections.unmodifiableList(this.customizers);
  }
  return this.customizers;
}

callbacks方法返回的是

public static <C, A> Callbacks<C, A>
callbacks(Class<C> callbackType,
                    Collection<? extends C> callbackInstances,
                    A argument,
                    Object... additionalArguments);

LambdaSafe中的內部類LambdaSafe.Callback,其中A和C是兩個泛型，這里分別對應的是WebServerFactoryCustomizer.class和WebServerFactoryCustomizer.然后這個類有一個withLogger方法用來打印日志，這樣在執行lambda表達式的過程中就能記錄拋出的異常日志，并且日志頭打印的是傳入參數WebServerFactoryCustomizerBeanPostProcessor.class類（不會被擦除效果影響），最后這個withLogger方法返回的參數是SELF，代表LambdaSafe.Callback自己。這樣LambdaSafe.Callback實例又調用了自己的invoke參數，執行了getCustomizers方法返回的所有WebServerFactoryCustomizer函數式接口的實現類的customize方法。
   具體看下invoke的代碼，也挺有意思的。

private final Collection<? extends C> callbackInstances;
public void invoke(Consumer<C> invoker) {
  this.callbackInstances.forEach((callbackInstance) -> {
    invoke(callbackInstance, () -> {
      invoker.accept(callbackInstance);
      return null;
    });
  });
}

Consumer也是一種函數式接口，這里用來代表(customizer) -> customizer.customize(webServerFactory)的lambda表達式。callbackInstances存儲了上面說到的所有WebServerFactoryCustomizer函數式接口的實現類，這里邊遍歷邊通過invoker.accept(）方法執行每個函數式接口的customize方法。這樣整個代碼邏輯就完全了。

以上是“如何實現回調和spring的LambdaSafe類”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注億速云行業資訊頻道！