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