dubbo 接口初入門


     

   最近公司開發新的一套系統,開發出來的方案會基於dubbo分布式服務框架開發的,那么什么是dubbo,身為測試的我,第一眼看到這個,我得去了解了解dubbo是啥玩意,為開展的測試工作做准備,提前先學 dubbo的相關知識。

  1.什么是dubbo

 

    Dubbo是一個分布式服務框架,致力於提供高性能和透明化的RPC遠程服務調用方案,以及SOA服務治理方案。簡單的說,dubbo就是個服務框架,如果沒有分布式的需求,其實是不需要用的,只有在分布式的時候,才有dubbo這樣的分布式服務框架的需求,並且本質上是個服務調用的東東

     其核心部分包含:
1. 遠程通訊: 提供對多種基於長連接的NIO框架抽象封裝,包括多種線程模型,序列化,以及“請求-響應”模式的信息交換方式。
2. 集群容錯: 提供基於接口方法的透明遠程過程調用,包括多協議支持,以及軟負載均衡,失敗容錯,地址路由,動態配置等集群支持。
3. 自動發現: 基於注冊中心目錄服務,使服務消費方能動態的查找服務提供方,使地址透明,使服務提供方可以平滑增加或減少機器。

  Dubbo本身支持多種遠程調用方式,例如Dubbo RPC(二進制序列化 + tcp協議)、http invoker(二進制序列化 + http協議)、hessian(二進制序列化 + http協議)、WebServices (文本序列化 + http協議)等。

  2. Dubbo能做什么?

1.透明化的遠程方法調用,就像調用本地方法一樣調用遠程方法,只需簡單配置,沒有任何API侵入。      
2.軟負載均衡及容錯機制,可在內網替代F5等硬件負載均衡器,降低成本,減少單點。
3. 服務自動注冊與發現,不再需要寫死服務提供方地址,注冊中心基於接口名查詢服務提供者的IP地址,並且能夠平滑添加或刪除服務提供者。

 

3. dubbo的架構

 

 

  

Provider
暴露服務方稱之為“服務提供者”。
 
Consumer
調用 遠程服務方稱之為“服務消費者”。
 
Registry
服務注冊與發現的中心目錄服務稱之為“服務注冊中心”。
 
Monitor
統計服務的調用次數和調用時間的日志服務稱之為“服務監控中心”。
 

          

調用關系說明:

   0 服務容器負責啟動,加載,運行服務提供者。

  1. 服務提供者在啟動時,向注冊中心注冊自己提供的服務。

  2. 服務消費者在啟動時,向注冊中心訂閱自己所需的服務。

  3. 注冊中心返回服務提供者地址列表給消費者,如果有變更,注冊中心將基於長連接推送變更數據給消費者。

  4. 服務消費者,從提供者地址列表中,基於軟負載均衡算法,選一台提供者進行調用,如果調用失敗,再選另一台調用。

  5. 服務消費者和提供者,在內存中累計調用次數和調用時間,定時每分鍾發送一次統計數據到監控中心。

 

以上均是dubbo框架的一些理論知識、那么了解了基礎的知識,我們怎么來測試dubbo提供的接口呢。

遇到這個問題我也會咨詢一些前輩,有人說java編寫代碼可以測試,但是需要的依賴多,有些人說基於python也是可以調用的,那么也是需要第三庫來支持的,

我們可以去下載對應的python庫,有的版本不支持python3 你可以下載下來源碼,對源碼中的一些代碼格式調整到python3支持的格式就好。

我這里才用的是dubbo_telnet下載安裝后我們先測試下,看代碼是否能夠正常運行。

我們拿來了官方的例子。

import dubbo_telnet
Host = '192.168.1.203' # Doubble服務器IP
Port = 28008 # Doubble服務端口
# 初始化dubbo對象
conn = dubbo_telnet.connect(Host, Port)
# 設置telnet連接超時時間
conn.set_connect_timeout(10)
# 設置dubbo服務返回響應的編碼
conn.set_encoding('gbk')
interface = 'com.zrj.pay.trade.api.QueryTradeService'#接口
method = 'tradeDetailQuery'#方法
param = '{"message": "HelloWorld"}'#參數
print (conn.invoke(interface, method, param))
command = 'invoke com.zrj.pay.trade.api.QueryTradeService.tradeDetailQuery({"message":"HelloWorld"})'
print (conn.do(command)) #打印接口返回結果

運行后,

 

這樣我們的代碼是沒有問題的,由於我本地沒有dubbo的服務,所以這里是返回None。

對於上述代碼,我做了進一步的優化。

import dubbo_telnet
def coondoubble_data(Host,Port,interface,method,param):
    try:
        # 初始化dubbo對象
        conn = dubbo_telnet.connect(Host, Port)
        # 設置telnet連接超時時間
        conn.set_connect_timeout(10)
        # 設置dubbo服務返回響應的編碼
        conn.set_encoding('gbk')
        conn.invoke(interface, method, param)
        command = 'invoke %s.%s(%s)'%(interface,method,param)
        return  conn.do(command)
    except:
        return  Exception
if __name__=="__main__":
    Host = '192.168.1.203'  # Doubble服務器IP
    Port = 28008  # Doubble服務端口
    interface = 'com.zrj.pay.trade.api.QueryTradeService'  # 接口
    method = 'tradeDetailQuery'  # 方法
    param = '{"message": "HelloWorld"}'  # 參數
    data=coondoubble_data(Host,Port,interface,method,param)
    print(data)

 

可見,我們用python是能夠調用出來我們的dubbo服務的,那么接下來就是根據現有的dubbo接口進行測試了,由於現在研發還沒有進行一系列的開發,所以我打算先自己去嘗試的按照網上例子寫一個dubbo的例子,用作自己的測試。

 

dubbo的接口測試其實也不是那么難,只要我們肯下功夫,我們一定能夠做成功的。dubbo接口。開始學起來。

 

個人公眾號


免責聲明!

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



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