轉(zhuǎn)載自??一次動(dòng)態(tài)代理的填坑之旅

背景

想在現(xiàn)有的接口加上熔斷降級(jí)或者限流的功能，比較好的方式是通過(guò)注解的方式，并基于動(dòng)態(tài)代理進(jìn)行實(shí)現(xiàn)，下面代碼是Rhino的實(shí)現(xiàn)

@Rhino public class ServiceImpl {@Degrade(rhinoKey = "syncMethod-0", ?fallBackMethod = "fallbackMethod")public void method() throws Exception {int i = 1 / 0;}private String fallbackMethod() throws Exception {return "fallback";}}

通過(guò)在方法添加@Degrade注解，很方便的賦予了method方法熔斷降級(jí)功能，在該方法的失敗率達(dá)到閾值時(shí)，就自動(dòng)熔斷，并調(diào)用降級(jí)方法。

這里的動(dòng)態(tài)代理并沒有使用Spring的AOP，而是自己實(shí)現(xiàn)了 BeanPostProcessor和 BeanFactoryPostProcessor接口，另外也實(shí)現(xiàn)了 PriorityOrdered接口。

在生成動(dòng)態(tài)代理對(duì)象的時(shí)候，根據(jù)類是否有實(shí)現(xiàn)接口，選擇使用JDK的Proxy還是使用Cglib。

/** * @param clazz * @param origin * @return */private static Object createProxyService(Class clazz, Object origin) {Object proxy;if (clazz.getInterfaces().length > 0) {proxy = Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new RhinoInvocationHandler(origin, clazz));} else {Enhancer enhancer = new Enhancer();enhancer.setSuperclass(clazz);enhancer.setCallback(new RhinoInvocationHandler(origin, clazz));proxy = enhancer.create();}return proxy; }

?

這樣的實(shí)現(xiàn)，在99%的情況下，是沒有問(wèn)題的，直到有一天，有兩個(gè)業(yè)務(wù)同時(shí)反饋了一個(gè)問(wèn)題，使用了熔斷降級(jí)的注解之后，發(fā)現(xiàn)自身的Spring AOP注解失效了或者是直接啟動(dòng)異常，WTF，這個(gè)問(wèn)題一直都沒考慮過(guò)好嗎...

為什么會(huì)這樣？Spring AOP到底干了什么，或者是自己的注解到底有什么問(wèn)題？

復(fù)現(xiàn)問(wèn)題

為了快速定位問(wèn)題，并解決問(wèn)題，最好的辦法就是復(fù)現(xiàn)該問(wèn)題，寫了一個(gè)簡(jiǎn)單的Spring AOP的例子。

@Component ?//加入到IoC容器 @Aspect ?//指定當(dāng)前類為切面類 public class Aop {@Pointcut("execution(* com.dianping.rhino.aop.*.*(..))")public void pointCut(){}@Before("pointCut()")public void begin(){System.out.println("begin");}@After("pointCut()")public void close(){System.out.println("close");}@Around(value = "@annotation(MethodLog)")public void around() {System.out.println(" MethodLog ");} }

這里簡(jiǎn)短的解釋下Spring AOP各個(gè)注解的作用 @Aspect切面，標(biāo)識(shí)該類是一個(gè)切面類 @Pointcut切入點(diǎn)，用來(lái)標(biāo)識(shí)哪些方法是需要被添加切面的 @Before在切入點(diǎn)，執(zhí)行方法之前進(jìn)行增強(qiáng) @After在切入點(diǎn)，執(zhí)行方法之后進(jìn)行增強(qiáng) @Around在該例子中，只有添加了@MethodLog注解的方法才會(huì)被增強(qiáng)

一切準(zhǔn)備就緒，開啟DEBUG之旅，Spring的內(nèi)部邏輯有點(diǎn)復(fù)雜，整個(gè)過(guò)程需要一點(diǎn)耐心。

?

通過(guò)Debug發(fā)現(xiàn)，Rhino的代理對(duì)象Processor排在Spring AOP的Processor，意味著Rhino生成的代理對(duì)象，會(huì)傳給Spring AOP的Processor再做一層代理，在Spring AOP生成代理對(duì)象的內(nèi)部邏輯中，有這么一段判斷邏輯。

?

在createProxy方法中，會(huì)根據(jù)傳入的beanClass，即上一個(gè)Processor處理過(guò)的對(duì)象，判斷是否有實(shí)現(xiàn)接口。

回到Rhino的實(shí)現(xiàn)，因?yàn)镾erviceImpl類沒有實(shí)現(xiàn)接口，所以內(nèi)部會(huì)采用CGLIB的方式創(chuàng)建代理對(duì)象，我們來(lái)看下這個(gè)對(duì)象的接口。

?

好家伙，默默的給加了一個(gè)Factory接口，這樣在Spring AOP的處理中就當(dāng)做有接口的情況進(jìn)行實(shí)現(xiàn)了。這里最大的問(wèn)題是，最終生成的代理對(duì)象是Factory類型的對(duì)象，在賦值給ServiceImpl變量時(shí)就會(huì)拋異常了。

解決問(wèn)題

終于找到了問(wèn)題的所在，那么改如何解決呢？ 無(wú)法修改Spring AOP的邏輯，但是可以控制Rhino的邏輯，只需要把Rhino的Processor移到Spring AOP的Processor之后，這樣就可以在Rhino的Proccessor中處理經(jīng)過(guò)Spring AOP的代理過(guò)的beanClass對(duì)象了，有效的避免這個(gè)問(wèn)題。

如何有效調(diào)整Processor的處理順序？ 通過(guò)分析發(fā)現(xiàn)Spring AOP的內(nèi)部實(shí)現(xiàn)基于Ordered接口，而Rhino的實(shí)現(xiàn)是基于 PriorityOrdered接口，而且處理器在初始化完成后會(huì)進(jìn)行排序，實(shí)現(xiàn) PriorityOrdered接口的會(huì)放到前面，相同類型的再根據(jù)設(shè)置的order進(jìn)行排序。很顯然，Rhino的Processor被放在前面，找到了問(wèn)題，解決方法也很簡(jiǎn)單，Rhino也換成Order接口，并且order設(shè)置成 LOWEST_PRECEDENCE，即排在最后面。

結(jié)論

經(jīng)過(guò)上面的調(diào)整之前，這個(gè)問(wèn)題確實(shí)被有效的解決了，以前遇到Spring的異常，都是一臉懵逼。所以，遇到類似的問(wèn)題，最好通過(guò)DEBUG源碼去發(fā)現(xiàn)問(wèn)題，并解決問(wèn)題，這樣可以有效的防止后續(xù)的繼續(xù)挖坑。

總結(jié)

以上是生活随笔為你收集整理的一次动态代理的填坑之旅的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。