日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢(xún)
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問(wèn)題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案
Dubbo先啟動(dòng)客戶(hù)端再啟動(dòng)服務(wù)端，線上收銀系統(tǒng)崩了

線上發(fā)生事故了

前天晚上上線一波，發(fā)生了一個(gè)挺有意思的事，昨天復(fù)盤(pán)了一下，今天分享一下。

創(chuàng)新互聯(lián)建站成都網(wǎng)站建設(shè)按需制作，是成都網(wǎng)站設(shè)計(jì)公司,為水泥攪拌車(chē)提供網(wǎng)站建設(shè)服務(wù),有成熟的網(wǎng)站定制合作流程，提供網(wǎng)站定制設(shè)計(jì)服務(wù)：原型圖制作、網(wǎng)站創(chuàng)意設(shè)計(jì)、前端HTML5制作、后臺(tái)程序開(kāi)發(fā)等。成都網(wǎng)站制作熱線：028-86922220

晚上的時(shí)候，我負(fù)責(zé)的系統(tǒng)和收銀系統(tǒng)同時(shí)上線一波(用的是Dubbo)。然后很神奇的事情發(fā)生了，收銀系統(tǒng)用@Reference注解注入我的接口，然后這個(gè)接口的實(shí)現(xiàn)類(lèi)居然為空。

其實(shí)我們當(dāng)時(shí)沒(méi)排查出來(lái)是什么原因?

「重啟了一下就好了，畢竟重啟大法好?！?但本著不能給用戶(hù)充錢(qián)的路上造成阻礙，還是要排查一波這個(gè)代理對(duì)象為空是如何造成的。

「線上dubbo的版本為2.8.9，注意包名是(com.alibaba)」

為了方便大家理解我說(shuō)的內(nèi)容，簡(jiǎn)單說(shuō)一下RPC框架的執(zhí)行流程。

  1. Server將服務(wù)信息注冊(cè)到Registry，Client從Registry拉取Server的信息。
  2. Client通過(guò)代理對(duì)象(Client Stub)發(fā)送發(fā)送網(wǎng)絡(luò)請(qǐng)求，Server通過(guò)代理對(duì)象(Server Stub)執(zhí)行本地方法
  3. 網(wǎng)絡(luò)傳輸過(guò)程中有編解碼和序列化的過(guò)程

「在Dubbo中Client Stub和Server Stub都是Invoker對(duì)象」

我們繼續(xù)，注入的接口實(shí)現(xiàn)類(lèi)居然能為空?我就看了一下他寫(xiě)的代碼，只用了一個(gè)@Reference注解，沒(méi)有設(shè)置任何屬性。

 
 
 
 
    
  
  
  
  
  1. @Documented 
    2. 
  
  
  
  
  2. @Retention(RetentionPolicy.RUNTIME) 
    3. 
  
  
  
  
  3. @Target({ElementType.FIELD, ElementType.METHOD, ElementType.ANNOTATION_TYPE}) 
    4. 
  
  
  
  
  4. public @interface Reference { 
    5. 
  
  
  
  
  5.  
    6. 
  
  
  
  
  6.     // 省略其他屬性 
    7. 
  
  
  
  
  7.     boolean check() default true; 
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9. } 
    10.

那么check=true，即沒(méi)有服務(wù)提供者的時(shí)候，服務(wù)消費(fèi)者都不能正常啟動(dòng)，因?yàn)闀?huì)拋出IllegalStateException異常。既然能正常啟動(dòng)，那這個(gè)代理對(duì)象正常創(chuàng)建了啊，不可能為null啊

 
 
 
 
    
  
  
  
  
  1. // 2.8.9版本 
    2. 
  
  
  
  
  2. // ReferenceConfig#createProxy 
    3. 
  
  
  
  
  3. Boolean c = check; 
    4. 
  
  
  
  
  4. if (c == null && consumer != null) { 
    5. 
  
  
  
  
  5.     c = consumer.isCheck(); 
    6. 
  
  
  
  
  6. } 
    7. 
  
  
  
  
  7. if (c == null) { 
    8. 
  
  
  
  
  8.     c = true; // default true 
    9. 
  
  
  
  
  9. } 
    10. 
  
  
  
  
  10. if (c && !invoker.isAvailable()) { 
    11. 
  
  
  
  
  11.     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()); 
    12. 
  
  
  
  
  12. } 
    13.

「然后我同事說(shuō)有沒(méi)有可能是客戶(hù)端先啟動(dòng)，沒(méi)有服務(wù)提供者導(dǎo)致代理對(duì)象為空的?」

我說(shuō)不可能的，客戶(hù)端先啟動(dòng)，check屬性為true，不可能啟動(dòng)成功的!再說(shuō)每次上線，新服務(wù)正常啟動(dòng)后，才會(huì)關(guān)閉舊服務(wù)的，服務(wù)提供者一定會(huì)有的。

「為什么會(huì)發(fā)生這種情況，是真心搞不懂，只能google “@Reference 注入對(duì)象為null”」

答案基本一致，沒(méi)有服務(wù)提供者導(dǎo)致代理對(duì)象為空的，只要把@Reference的check屬性設(shè)置為false即可，至于原因沒(méi)一篇文章說(shuō)過(guò)

「接下來(lái)就是驗(yàn)證網(wǎng)上的方法了」

  1. 先啟動(dòng)producer，再啟動(dòng)consumer，正常調(diào)用
  2. 先啟動(dòng)consumer(check=true)，再啟動(dòng)producer，代理對(duì)象為空，完美復(fù)現(xiàn)
  3. 先啟動(dòng)consumer(check=false)，再啟動(dòng)producer，正常調(diào)用

「和我的想法不一致，學(xué)dubbo的時(shí)候沒(méi)聽(tīng)過(guò)必須先啟動(dòng)producer再啟動(dòng)consumer才能正常調(diào)用啊?」

我就拿出我學(xué)dubbo時(shí)用的例子測(cè)試了一波，dubbo的版本為2.7.3注意包名是(org.apache)

先啟動(dòng)producer，再啟動(dòng)consumer，正常調(diào)用

先啟動(dòng)consumer(check=true)，此時(shí)沒(méi)有producer，啟動(dòng)失敗

先啟動(dòng)consumer(check=false)，再啟動(dòng)producer，正常調(diào)用

「這才符合我的想法啊」

揭秘真相

既然@Reference注入的對(duì)象為null，那說(shuō)明Spring Bean的生命周期中屬性賦值階段有問(wèn)題

再來(lái)分析一下@Reference注解的注入邏輯，和@Autowired，@Resource之類(lèi)的注入邏輯基本差不多。

當(dāng)你加入Dubbo的spring boot starter時(shí)，會(huì)往容器中注入ReferenceAnnotationBeanPostProcessor，看一下這個(gè)類(lèi)的繼承關(guān)系

其中最主要的部分你只需要知道這個(gè)類(lèi)重寫(xiě)了 InstantiationAwareBeanPostProcessor#postProcessPropertyValues(這個(gè)方法在后面的版本中被postProcessProperties方法替代)，而這個(gè)方法正是用來(lái)屬性賦值的，看上面的Bean生命周期圖

 
 
 
 
    
  
  
  
  
  1. public class ReferenceAnnotationBeanPostProcessor { 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.  // 省略了繼承類(lèi)和方法 
    4. 
  
  
  
  
  4.     // 這個(gè)方法給@Reference屬性賦值 
    5. 
  
  
  
  
  5.     @Override 
    6. 
  
  
  
  
  6.     public PropertyValues postProcessPropertyValues( 
    7. 
  
  
  
  
  7.             PropertyValues pvs, PropertyDescriptor[] pds, Object bean, String beanName) throws BeanCreationException { 
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9.         InjectionMetadata metadata = findReferenceMetadata(beanName, bean.getClass(), pvs); 
    10. 
  
  
  
  
  10.         try { 
    11. 
  
  
  
  
  11.             metadata.inject(bean, beanName, pvs); 
    12. 
  
  
  
  
  12.         } catch (BeanCreationException ex) { 
    13. 
  
  
  
  
  13.             throw ex; 
    14. 
  
  
  
  
  14.         } catch (Throwable ex) { 
    15. 
  
  
  
  
  15.             throw new BeanCreationException(beanName, "Injection of @Reference dependencies failed", ex); 
    16. 
  
  
  
  
  16.         } 
    17. 
  
  
  
  
  17.         return pvs; 
    18. 
  
  
  
  
  18.     } 
    19. 
  
  
  
  
  19.  
    20. 
  
  
  
  
  20. } 
    21.

接著執(zhí)行到ReferenceFieldElement#inject方法，@Reference引入的對(duì)象會(huì)被包轉(zhuǎn)為ReferenceBean

 
 
 
 
    
  
  
  
  
  1. private class ReferenceFieldElement extends InjectionMetadata.InjectedElement { 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.  
    4. 
  
  
  
  
  4.     @Override 
    5. 
  
  
  
  
  5.     protected void inject(Object bean, String beanName, PropertyValues pvs) throws Throwable { 
    6. 
  
  
  
  
  6.  
    7. 
  
  
  
  
  7.         Class referenceClass = field.getType(); 
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9.         // 獲取 referenceBean 的邏輯在這 
    10. 
  
  
  
  
  10.         referenceBean = buildReferenceBean(reference, referenceClass); 
    11. 
  
  
  
  
  11.  
    12. 
  
  
  
  
  12.         ReflectionUtils.makeAccessible(field); 
    13. 
  
  
  
  
  13.  
    14. 
  
  
  
  
  14.   // 通過(guò)反射注入對(duì)象 
    15. 
  
  
  
  
  15.         field.set(bean, referenceBean.getObject()); 
    16. 
  
  
  
  
  16.  
    17. 
  
  
  
  
  17.     } 
    18. 
  
  
  
  
  18.  
    19. 
  
  
  
  
  19. } 
    20.

經(jīng)過(guò)一系列方法調(diào)用執(zhí)行到如下方法

 
 
 
 
    
  
  
  
  
  1. // AbstractAnnotationConfigBeanBuilder#build 
    2. 
  
  
  
  
  2. public final B build() throws Exception { 
    3. 
  
  
  
  
  3.  
    4. 
  
  
  
  
  4.     checkDependencies(); 
    5. 
  
  
  
  
  5.  
    6. 
  
  
  
  
  6.     B bean = doBuild(); 
    7. 
  
  
  
  
  7.  
    8. 
  
  
  
  
  8.     configureBean(bean); 
    9. 
  
  
  
  
  9.  
    10. 
  
  
  
  
  10.     if (logger.isInfoEnabled()) { 
    11. 
  
  
  
  
  11.         logger.info(bean + " has been built."); 
    12. 
  
  
  
  
  12.     } 
    13. 
  
  
  
  
  13.  
    14. 
  
  
  
  
  14.     return bean; 
    15. 
  
  
  
  
  15.  
    16. 
  
  
  
  
  16. } 
    17.

此時(shí)日志中會(huì)打印ReferenceBean對(duì)象，這個(gè)對(duì)象繼承了AbstractConfig，所以會(huì)執(zhí)行AbstractConfig#toString方法

 
 
 
 
    
  
  
  
  
  1. public abstract class AbstractConfig implements Serializable { 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.     @Override 
    4. 
  
  
  
  
  4.     public String toString() { 
    5. 
  
  
  
  
  5.         try { 
    6. 
  
  
  
  
  6.             StringBuilder buf = new StringBuilder(); 
    7. 
  
  
  
  
  7.             buf.append("
  
  
  
  
  8.             buf.append(getTagName(getClass())); 
    9. 
  
  
  
  
  9.             Method[] methods = getClass().getMethods(); 
    10. 
  
  
  
  
  10.             for (Method method : methods) { 
    11. 
  
  
  
  
  11.                 try { 
    12. 
  
  
  
  
  12.                     String name = method.getName(); 
    13. 
  
  
  
  
  13.                     if ((name.startsWith("get") || name.startsWith("is")) 
    14. 
  
  
  
  
  14.                             && !"getClass".equals(name) && !"get".equals(name) && !"is".equals(name) 
    15. 
  
  
  
  
  15.                             && Modifier.isPublic(method.getModifiers()) 
    16. 
  
  
  
  
  16.                             && method.getParameterTypes().length == 0 
    17. 
  
  
  
  
  17.                             && isPrimitive(method.getReturnType())) { 
    18. 
  
  
  
  
  18.                         int i = name.startsWith("get") ? 3 : 2; 
    19. 
  
  
  
  
  19.                         String key = name.substring(i, i + 1).toLowerCase() + name.substring(i + 1); 
    20. 
  
  
  
  
  20.                         Object value = method.invoke(this, new Object[0]); 
    21. 
  
  
  
  
  21.                         if (value != null) { 
    22. 
  
  
  
  
  22.                             buf.append(" "); 
    23. 
  
  
  
  
  23.                             buf.append(key); 
    24. 
  
  
  
  
  24.                             buf.append("=\""); 
    25. 
  
  
  
  
  25.                             buf.append(value); 
    26. 
  
  
  
  
  26.                             buf.append("\""); 
    27. 
  
  
  
  
  27.                         } 
    28. 
  
  
  
  
  28.                     } 
    29. 
  
  
  
  
  29.                 } catch (Exception e) { 
    30. 
  
  
  
  
  30.                     logger.warn(e.getMessage(), e); 
    31. 
  
  
  
  
  31.                 } 
    32. 
  
  
  
  
  32.             } 
    33. 
  
  
  
  
  33.             buf.append(" />"); 
    34. 
  
  
  
  
  34.             return buf.toString(); 
    35. 
  
  
  
  
  35.         } catch (Throwable t) { 
    36. 
  
  
  
  
  36.             logger.warn(t.getMessage(), t); 
    37. 
  
  
  
  
  37.             return super.toString(); 
    38. 
  
  
  
  
  38.         } 
    39. 
  
  
  
  
  39.     } 
    40. 
  
  
  
  
  40.  
    41. 
  
  
  
  
  41. } 
    42.

「好家伙，打印的時(shí)候把get方法全執(zhí)行了一遍，然后執(zhí)行ReferenceBean#getObject方法異常了(就是那個(gè)沒(méi)有服務(wù)提供者拋出的異常)，但是被try Catch了」

因?yàn)镽eferenceBean是一個(gè)FactoryBean，所以需要調(diào)用getObject方法才能獲取創(chuàng)建的對(duì)象

 
 
 
 
    
  
  
  
  
  1. private class ReferenceFieldElement extends InjectionMetadata.InjectedElement { 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.  
    4. 
  
  
  
  
  4.     @Override 
    5. 
  
  
  
  
  5.     protected void inject(Object bean, String beanName, PropertyValues pvs) throws Throwable { 
    6. 
  
  
  
  
  6.  
    7. 
  
  
  
  
  7.         Class referenceClass = field.getType(); 
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9.         // 獲取 referenceBean 的邏輯在這 
    10. 
  
  
  
  
  10.         referenceBean = buildReferenceBean(reference, referenceClass); 
    11. 
  
  
  
  
  11.  
    12. 
  
  
  
  
  12.         ReflectionUtils.makeAccessible(field); 
    13. 
  
  
  
  
  13.  
    14. 
  
  
  
  
  14.   // 通過(guò)反射注入對(duì)象 
    15. 
  
  
  
  
  15.         field.set(bean, referenceBean.getObject()); 
    16. 
  
  
  
  
  16.  
    17. 
  
  
  
  
  17.     } 
    18. 
  
  
  
  
  18.  
    19. 
  
  
  
  
  19. } 
    20.

「接著調(diào)用ReferenceBean#getObject方法，好了，這就是服務(wù)導(dǎo)出的邏輯了!」 不細(xì)說(shuō)了，后續(xù)單開(kāi)文章寫(xiě)，會(huì)執(zhí)行到ReferenceConfig#get方法

 
 
 
 
    
  
  
  
  
  1. // ReferenceConfig#get 
    2. 
  
  
  
  
  2. public synchronized T get() { 
    3. 
  
  
  
  
  3.     if (destroyed) { 
    4. 
  
  
  
  
  4.         throw new IllegalStateException("Already destroyed!"); 
    5. 
  
  
  
  
  5.     } 
    6. 
  
  
  
  
  6.     if (ref == null) { 
    7. 
  
  
  
  
  7.         init(); 
    8. 
  
  
  
  
  8.     } 
    9. 
  
  
  
  
  9.     return ref; 
    10. 
  
  
  
  
  10. } 
    11.

「此時(shí)代理對(duì)象為null，執(zhí)行init方法，initialized默認(rèn)為false，執(zhí)行一次變?yōu)閠rue(AbstractConfig執(zhí)行toString方法的時(shí)候哈)，所以第二次執(zhí)行，直接return，此時(shí)代理對(duì)象為null，完事!」

 
 
 
 
    
  
  
  
  
  1. private void init() { 
    2. 
  
  
  
  
  2.     if (initialized) { 
    3. 
  
  
  
  
  3.         return; 
    4. 
  
  
  
  
  4.     } 
    5. 
  
  
  
  
  5.     initialized = true; 
    6. 
  
  
  
  
  6.     // 省略部分代碼 
    7. 
  
  
  
  
  7. } 
    8.

「我學(xué)習(xí)用的版本為什么能正常工作?」

 
 
 
 
    
  
  
  
  
  1. public final C build() throws Exception { 
    2. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  3.     checkDependencies(); 
    4. 
  
  
  
  
  4.  
    5. 
  
  
  
  
  5.     C configBean = doBuild(); 
    6. 
  
  
  
  
  6.  
    7. 
  
  
  
  
  7.     configureBean(configBean); 
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9.     if (logger.isInfoEnabled()) { 
    10. 
  
  
  
  
  10.         logger.info("The configBean[type:" + configBean.getClass().getSimpleName() + "] has been built."); 
    11. 
  
  
  
  
  11.     } 
    12. 
  
  
  
  
  12.  
    13. 
  
  
  
  
  13.     return configBean; 
    14. 
  
  
  
  
  14.  
    15. 
  
  
  
  
  15. } 
    16.

就是打印的時(shí)候不會(huì)執(zhí)行g(shù)etObject方法了

「為什么@Reference的check屬性設(shè)置為false就能正常調(diào)用?」

因?yàn)榈谝淮握{(diào)用成功執(zhí)行完ReferenceBean#getObject方法，ref已經(jīng)賦值為代理對(duì)象了，第二次執(zhí)行就能將這個(gè)代理對(duì)象返回

 
 
 
 
    
  
  
  
  
  1. // ReferenceConfig#get 
    2. 
  
  
  
  
  2. public synchronized T get() { 
    3. 
  
  
  
  
  3.     if (destroyed) { 
    4. 
  
  
  
  
  4.         throw new IllegalStateException("Already destroyed!"); 
    5. 
  
  
  
  
  5.     } 
    6. 
  
  
  
  
  6.     if (ref == null) { 
    7. 
  
  
  
  
  7.         init(); 
    8. 
  
  
  
  
  8.     } 
    9. 
  
  
  
  
  9.     return ref; 
    10. 
  
  
  
  
  10. } 
    11.

至于我們的線上系統(tǒng)為什么沒(méi)獲取到服務(wù)提供者，我估計(jì)很大概率是由于網(wǎng)絡(luò)的原因

解決方案

  • @Reference注解的check屬性設(shè)置為false(默認(rèn)為true)，因?yàn)楫?dāng)你的check屬性為true并且沒(méi)有服務(wù)提供者時(shí)，不會(huì)起任何作用，只會(huì)注入一個(gè)空對(duì)象，后續(xù)當(dāng)有服務(wù)提供者可用時(shí)，這個(gè)對(duì)象始終為空。當(dāng)check為false時(shí)，會(huì)注入一個(gè)代理對(duì)象，當(dāng)有服務(wù)提供者時(shí)，這個(gè)代理對(duì)象會(huì)刷新，就能正常發(fā)起調(diào)用
  • 選擇能正常執(zhí)行的版本

本文轉(zhuǎn)載自微信公眾號(hào)「Java識(shí)堂」，可以通過(guò)以下二維碼關(guān)注。轉(zhuǎn)載本文請(qǐng)聯(lián)系Java識(shí)堂公眾號(hào)。


當(dāng)前題目：Dubbo先啟動(dòng)客戶(hù)端再啟動(dòng)服務(wù)端，線上收銀系統(tǒng)崩了
文章起源：http://www.dlmjj.cn/article/coieheh.html