dubbo 自定義過濾器,打印接口調用信息


dubbo提供了web filter類似的com.alibaba.dubbo.rpc.Filter,這樣,我們可以在dubbo提供的服務提供方和消費方都可以自定義過濾 器,從而可以獲得方法調用的時間或參數、返回結果及異常信息。我們可以利用log打印出來。而且,這個過濾器機制,也是分布式跟蹤系統的一部分。

      下面代碼實例是一個自定義過濾器例子,獲得方法調用的參數、返回結果、執行時間及異常信息的log功能。

[java] view plain copy
  1. public class ElapsedTimeFilter implements Filter {  
  2.   
  3.     private static Logger log = LoggerFactory  
  4.             .getLogger(ElapsedTimeFilter.class);  
  5.   
  6.     @Override  
  7.     public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {  
  8.         long start = System.currentTimeMillis();  
  9.         Result result = invoker.invoke(invocation);  
  10.         long elapsed = System.currentTimeMillis() - start;  
  11.         if (invoker.getUrl() != null) {  
  12.   
  13.             // log.info("[" +invoker.getInterface() +"] [" + invocation.getMethodName() +"] [" + elapsed +"]" );  
  14.             log.info("[{}], [{}], {}, [{}], [{}], [{}]   ", invoker.getInterface(), invocation.getMethodName(),   
  15.                          Arrays.toString(invocation.getArguments()), result.getValue(),  
  16.                        result.getException(), elapsed);  
  17.   
  18.         }  
  19.         return result;  
  20.     }  
  21.   
  22. }  


其實,dubbo內部,也有很多已經實現好的不同功能的過濾器,如:


我們自定義了過濾器,還的按照dubbo spi機制,還得需要配置:

在服務消費方或提供方還需要配上這個過濾器,消費方例子:

 

[html] view plain copy
    1. <dubbo:consumer id="xx"  
    2.                     
    3.                     filter="elapsedTimeFilter"  
    4.                      
    5.                     retries="0"/>  
    6.                   


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM