|
1. 背景隨著互聯(lián)網的發(fā)展，網站應用的規(guī)模不斷擴大，常規(guī)的垂直應用架構已無法應對，分布式服務架構以及流動計算架構勢在必行，需一個治理系統(tǒng)確保架構有條不紊的演進。 目前市場一些基本的架構： - 當網站流量很小時，只需一個應用，將所有功能都部署在一起，以減少部署節(jié)點和成本。
- 此時，用于簡化增刪改查工作量的 數據訪問框架(ORM) 是關鍵。
- 當訪問量逐漸增大，單一應用增加機器帶來的加速度越來越小，將應用拆成互不相干的幾個應用，以提升效率。
- 此時，用于加速前端頁面開發(fā)的 Web框架(MVC) 是關鍵。
- 當垂直應用越來越多，應用之間交互不可避免，將核心業(yè)務抽取出來，作為獨立的服務，逐漸形成穩(wěn)定的服務中心，使前端應用能更快速的響應多變的市場需求。
- 此時，用于提高業(yè)務復用及整合的 分布式服務框架(RPC) 是關鍵。
- 當服務越來越多，容量的評估，小服務資源的浪費等問題逐漸顯現，此時需增加一個調度中心基于訪問壓力實時管理集群容量，提高集群利用率。
- 此時，用于提高機器利用率的 資源調度和治理中心(SOA) 是關鍵。
2. 介紹Dubbo是阿里巴巴公司開源的一個高性能優(yōu)秀的服務框架，使得應用可通過高性能的RPC實現服務的輸出和輸入功能，可以和spring框架無縫集成。 Dubbo是一款高性能，輕量級的開源Java RPC框架，他提供了三大核心能力：面向接口的遠程方法調用，智能容錯和負載均衡，以及服務自動注冊和發(fā)現。 3. 原理3.1 核心Remoting：網絡通信框架，實現了sync-over-async和request-response消息機制。 RPC：一個遠程過程調用的抽象，支持負載均衡，容災和集群功能。 Registry：服務目錄框架用于服務的注冊和服務事件發(fā)布和訂閱。 3.2 架構 節(jié)點角色 - Registry：服務注冊與發(fā)現的注冊中心
- Monitor：統(tǒng)計服務的調用次數和調用時間的監(jiān)控中心
調用關系 - 1、服務提供者在啟動時，向注冊中心注冊自己提供的服務
- 2、服務消費者在啟動時，向注冊中心訂閱自己所需的服務
- 3、注冊中心返回服務提供者地址列表給消費者，如果有變更，注冊中心將基于長連接推送變更數據給消費者
- 4、服務消費者，從提供者地址列表中，基于軟負載均衡算法，選一臺提供者進行調用，如果調用失敗，再選另一臺調用
- 5、服務消費者和提供者，在內存中累計調用次數和調用時間定時每分鐘發(fā)送一次統(tǒng)計數據到監(jiān)控中心
特點 連通性，健壯性，伸縮性，以及向未來架構的升級性。想要了解更多，可直接去官網查看： https://dubbo./zh/
4. 作用1、透明化的遠程方法調用，就像調用本地方法一樣調用遠程方法，只需簡單配置，沒有任何API侵入。 2、軟負載均衡及容錯機制，可在內網替代F5等硬件負載均衡器，降低成本，減少單點。 3、服務自動注冊與發(fā)現，不再需要寫死服務提供方地址，注冊中心基于接口名查詢服務提供者的IP地址，并且能夠平滑添加或刪除服務提供者。 5. 利用Python庫調試Dubbopython想要實現dubbo接口的調用可以參考dubbo的官方文檔中提到的：dubbo可以通過telnet命令進行服務治理，可以通過telnet鏈接dubbo服務，再通過invoke方法調用dubbo接口，詳情見： https://dubbo./zh/docs/v2.7/user/references/telnet/
而在Python中有一個第三方包telnetlib，所以我們可以通過這個包來執(zhí)行telnet命令，進而對dubbo接口進行調用。 注意：python版本為2.7 pip install dubbo_telnet
#-*- coding: utf-8 -*-
import dubbo_telnet
import json
Host = '192.168.0.1' # Doubble服務器IP
Port = 9036 # Doubble服務端口
# 初始化dubbo對象
conn = dubbo_telnet.connect(Host, Port)
# 設置telnet連接超時時間
conn.set_connect_timeout(10)
# 設置dubbo服務返回響應的編碼
conn.set_encoding('gbk')
# 顯示服務列表
print conn.do("ls")
# 顯示指定服務的方法列表
print conn.do("ls XXXService")
# 方法調用
interface = 'XXXService'
method = 'userinfo'
param = user_id
result = conn.invoke(interface, method, param)
print json.dumps(result, sort_keys=True, indent=4, separators=(',', ': '), skipkeys=True, ensure_ascii=False)
# 詳見：https://hhyo./2017/10/20/python-dubbo-telnet/
|
