最近公司開發新的一套系統,開發出來的方案會基於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的架構

調用關系說明:
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接口。開始學起來。
個人公眾號

