spring中@Reference注入為空的解決方法
線上發(fā)生事故了
前天晚上上線一波，發(fā)生了一個挺有意思的事，昨天復(fù)盤了一下，今天分享一下。
晚上的時候，我負責(zé)的系統(tǒng)和收銀系統(tǒng)同時上線一波（用的是Dubbo）。然后很神奇的事情發(fā)生了，收銀系統(tǒng)用@Reference注解注入我的接口，然后這個接口的實現(xiàn)類居然為空。
其實我們當(dāng)時沒排查出來是什么原因？
重啟了一下就好了，畢竟重啟大法好。 但本著不能給用戶充錢的路上造成阻礙，還是要排查一波這個代理對象為空是如何造成的。
線上dubbo的版本為2.8.9，注意包名是（com.alibaba）
為了方便大家理解我說的內(nèi)容，簡單說一下RPC框架的執(zhí)行流程。
Server將服務(wù)信息注冊到Registry，Client從Registry拉取Server的信息。Client通過代理對象（Client Stub）發(fā)送發(fā)送網(wǎng)絡(luò)請求，Server通過代理對象（Server Stub）執(zhí)行本地方法網(wǎng)絡(luò)傳輸過程中有編解碼和序列化的過程
在Dubbo中Client Stub和Server Stub都是Invoker對象
我們繼續(xù)，注入的接口實現(xiàn)類居然能為空？我就看了一下他寫的代碼，只用了一個@Reference注解，沒有設(shè)置任何屬性。
@Documented
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.FIELD, ElementType.METHOD, ElementType.ANNOTATION_TYPE})
public @interface Reference {
// 省略其他屬性
boolean check() default true;
}
那么check=true，即沒有服務(wù)提供者的時候，服務(wù)消費者都不能正常啟動，因為會拋出IllegalStateException異常。既然能正常啟動，那這個代理對象正常創(chuàng)建了啊，不可能為null啊
// 2.8.9版本
// ReferenceConfig#createProxy
Boolean c = check;
if (c == null && consumer != null) {
c = consumer.isCheck();
}
if (c == null) {
c = true; // default true
}
if (c && !invoker.isAvailable()) {
throw new IllegalStateException("Failed to check the status of the service " + interfaceName + ". No provider available for the service " + (group == null ? "" : group + "/") + interfaceName + (version == null ? "" : ":" + version) + " from the url " + invoker.getUrl() + " to the consumer " + NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion());
}
然后我同事說有沒有可能是客戶端先啟動，沒有服務(wù)提供者導(dǎo)致代理對象為空的？
我說不可能的，客戶端先啟動，check屬性為true，不可能啟動成功的！再說每次上線，新服務(wù)正常啟動后，才會關(guān)閉舊服務(wù)的，服務(wù)提供者一定會有的。
為什么會發(fā)生這種情況，是真心搞不懂，只能google “@Reference 注入對象為null”
答案基本一致，沒有服務(wù)提供者導(dǎo)致代理對象為空的，只要把@Reference的check屬性設(shè)置為false即可，至于原因沒一篇文章說過
接下來就是驗證網(wǎng)上的方法了
先啟動producer，再啟動consumer，正常調(diào)用
先啟動consumer（check=true），再啟動producer，代理對象為空，完美復(fù)現(xiàn)
先啟動consumer（check=false），再啟動producer，正常調(diào)用
和我的想法不一致，學(xué)dubbo的時候沒聽過必須先啟動producer再啟動consumer才能正常調(diào)用??？
我就拿出我學(xué)dubbo時用的例子測試了一波，dubbo的版本為2.7.3注意包名是（org.apache）
先啟動producer，再啟動consumer，正常調(diào)用先啟動consumer（check=true），此時沒有producer，啟動失敗先啟動consumer（check=false），再啟動producer，正常調(diào)用
這才符合我的想法啊
揭秘真相
既然@Reference注入的對象為null，那說明Spring Bean的生命周期中屬性賦值階段有問題
再來分析一下@Reference注解的注入邏輯，和@Autowired，@Resource之類的注入邏輯基本差不多。
當(dāng)你加入Dubbo的spring boot starter時，會往容器中注入ReferenceAnnotationBeanPostProcessor，看一下這個類的繼承關(guān)系
其中最主要的部分你只需要知道這個類重寫了
InstantiationAwareBeanPostProcessor#postProcessPropertyValues（這個方法在后面的版本中被postProcessProperties方法替代），而這個方法正是用來屬性賦值的，看上面的Bean生命周期圖
public class ReferenceAnnotationBeanPostProcessor {
// 省略了繼承類和方法
// 這個方法給@Reference屬性賦值
@Override
public PropertyValues postProcessPropertyValues(
PropertyValues pvs, PropertyDescriptor[] pds, Object bean, String beanName) throws BeanCreationException {
InjectionMetadata metadata = findReferenceMetadata(beanName, bean.getClass(), pvs);
try {
metadata.inject(bean, beanName, pvs);
} catch (BeanCreationException ex) {
throw ex;
} catch (Throwable ex) {
throw new BeanCreationException(beanName, "Injection of @Reference dependencies failed", ex);
}
return pvs;
}
}
接著執(zhí)行到ReferenceFieldElement#inject方法，@Reference引入的對象會被包轉(zhuǎn)為ReferenceBean
private class ReferenceFieldElement extends InjectionMetadata.InjectedElement {
@Override
protected void inject(Object bean, String beanName, PropertyValues pvs) throws Throwable {
Class<?> referenceClass = field.getType();
// 獲取 referenceBean 的邏輯在這
referenceBean = buildReferenceBean(reference, referenceClass);
ReflectionUtils.makeAccessible(field);
// 通過反射注入對象
field.set(bean, referenceBean.getObject());
}
}
經(jīng)過一系列方法調(diào)用執(zhí)行到如下方法
// AbstractAnnotationConfigBeanBuilder#build
public final B build() throws Exception {
checkDependencies();
B bean = doBuild();
configureBean(bean);
if (logger.isInfoEnabled()) {
logger.info(bean + " has been built.");
}
return bean;
}
此時日志中會打印ReferenceBean對象，這個對象繼承了AbstractConfig，所以會執(zhí)行AbstractConfig#toString方法
public abstract class AbstractConfig implements Serializable {
@Override
public String toString() {
try {
StringBuilder buf = new StringBuilder();
buf.append("<dubbo:");
buf.append(getTagName(getClass()));
Method[] methods = getClass().getMethods();
for (Method method : methods) {
try {
String name = method.getName();
if ((name.startsWith("get") || name.startsWith("is"))
&& !"getClass".equals(name) && !"get".equals(name) && !"is".equals(name)
&& Modifier.isPublic(method.getModifiers())
&& method.getParameterTypes().length == 0
&& isPrimitive(method.getReturnType())) {
int i = name.startsWith("get") ? 3 : 2;
String key = name.substring(i, i + 1).toLowerCase() + name.substring(i + 1);
Object value = method.invoke(this, new Object[0]);
if (value != null) {
buf.append(" ");
buf.append(key);
buf.append("=\"");
buf.append(value);
buf.append("\"");
}
}
} catch (Exception e) {
logger.warn(e.getMessage(), e);
}
}
buf.append(" />");
return buf.toString();
} catch (Throwable t) {
logger.warn(t.getMessage(), t);
return super.toString();
}
}
}
好家伙，打印的時候把get方法全執(zhí)行了一遍，然后執(zhí)行ReferenceBean#getObject方法異常了（就是那個沒有服務(wù)提供者拋出的異常），但是被try Catch了
因為ReferenceBean是一個FactoryBean，所以需要調(diào)用getObject方法才能獲取創(chuàng)建的對象
private class ReferenceFieldElement extends InjectionMetadata.InjectedElement {
@Override
protected void inject(Object bean, String beanName, PropertyValues pvs) throws Throwable {
Class<?> referenceClass = field.getType();
// 獲取 referenceBean 的邏輯在這
referenceBean = buildReferenceBean(reference, referenceClass);
ReflectionUtils.makeAccessible(field);
// 通過反射注入對象
field.set(bean, referenceBean.getObject());
}
}
接著調(diào)用ReferenceBean#getObject方法，好了，這就是服務(wù)導(dǎo)出的邏輯了！ 不細說了，后續(xù)單開文章寫，會執(zhí)行到ReferenceConfig#get方法
// ReferenceConfig#get
public synchronized T get() {
if (destroyed) {
throw new IllegalStateException("Already destroyed!");
}
if (ref == null) {
init();
}
return ref;
}
此時代理對象為null，執(zhí)行init方法，initialized默認為false，執(zhí)行一次變?yōu)閠rue（AbstractConfig執(zhí)行toString方法的時候哈），所以第二次執(zhí)行，直接return，此時代理對象為null，完事！
private void init() {
if (initialized) {
return;
}
initialized = true;
// 省略部分代碼
}
我學(xué)習(xí)用的版本為什么能正常工作？
public final C build() throws Exception {
checkDependencies();
C configBean = doBuild();
configureBean(configBean);
if (logger.isInfoEnabled()) {
logger.info("The configBean[type:" + configBean.getClass().getSimpleName() + "] has been built.");
}
return configBean;
}
就是打印的時候不會執(zhí)行g(shù)etObject方法了
為什么@Reference的check屬性設(shè)置為false就能正常調(diào)用？
因為第一次調(diào)用成功執(zhí)行完ReferenceBean#getObject方法，ref已經(jīng)賦值為代理對象了，第二次執(zhí)行就能將這個代理對象返回
// ReferenceConfig#get
public synchronized T get() {
if (destroyed) {
throw new IllegalStateException("Already destroyed!");
}
if (ref == null) {
init();
}
return ref;
}
至于我們的線上系統(tǒng)為什么沒獲取到服務(wù)提供者，我估計很大概率是由于網(wǎng)絡(luò)的原因
解決方案
@Reference注解的check屬性設(shè)置為false（默認為true），因為當(dāng)你的check屬性為true并且沒有服務(wù)提供者時，不會起任何作用，只會注入一個空對象，后續(xù)當(dāng)有服務(wù)提供者可用時，這個對象始終為空。當(dāng)check為false時，會注入一個代理對象，當(dāng)有服務(wù)提供者時，這個代理對象會刷新，就能正常發(fā)起調(diào)用
選擇能正常執(zhí)行的版本
到此這篇關(guān)于spring中@Reference注入為空的解決方法的文章就介紹到這了,更多相關(guān)spring @Reference注入為空內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了mybatis模糊查詢、分頁和別名配置,本文給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-09-09
這篇文章主要介紹了idea手動刷新git分支,本文給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-08-08
Redis是一個非常強大的工具,它可以用來實現(xiàn)很多有趣的應(yīng)用,還可以使用Redis來實現(xiàn)分布式鎖,這樣你就可以在多線程或多進程的環(huán)境下同步代碼,這篇文章主要介紹了Java中的Redis是什么意思,需要的朋友可以參考下2023-08-08
本篇技術(shù)文章主要對Java新api（New IO）做了詳細深入的講解，有助于程序?qū)IO有更加深入的理解。2017-12-12
這篇文章主要介紹了Jackson的用法實例分析,用于處理Java的json格式數(shù)據(jù)非常實用,需要的朋友可以參考下2014-08-08
深入分析JAVA Synchronized關(guān)鍵字
這篇文章主要介紹了析JAVA Synchronized關(guān)鍵字的相關(guān)知識，文中代碼非常詳細，幫助大家更好的理解和學(xué)習(xí)，感興趣的朋友可以了解下2020-06-06
帶你了解Java數(shù)據(jù)結(jié)構(gòu)和算法之?dāng)?shù)組
這篇文章主要為大家介紹了Java數(shù)據(jù)結(jié)構(gòu)和算法之?dāng)?shù)組，具有一定的參考價值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2022-01-01
本文非常詳細的講解了java反射的相關(guān)資料，java反射在現(xiàn)今的使用中很頻繁，希望此文可以幫大家解答疑惑，可以幫助大家理解2021-11-11
這篇文章主要介紹了java 多態(tài)實例代碼，具有一定借鑒價值,需要的朋友可以參考下2018-01-01
Jmeter壓力測試簡單教程(包括服務(wù)器狀態(tài)監(jiān)控)
Jmeter是一個非常好用的壓力測試工具。Jmeter用來做輕量級的壓力測試,非常合適，本文詳細的介紹了Jmeter的使用，感性的可以了解一下2021-11-11