濮阳杆衣贸易有限公司

主頁 > 知識庫 > 剖析美團(tuán)內(nèi)部所采用的網(wǎng)站壓力測試方案

剖析美團(tuán)內(nèi)部所采用的網(wǎng)站壓力測試方案

熱門標(biāo)簽:百度地圖標(biāo)注和認(rèn)領(lǐng) 南京外呼系統(tǒng)價(jià)格 什么地圖標(biāo)注定位 外呼總是換線路 昆明地圖標(biāo)注員 宿遷電商外呼系統(tǒng)平臺(tái) 外呼系統(tǒng)中的坐席號是什么意思 青海電銷外呼系統(tǒng)違法嗎 阿里云能申請400電話

美團(tuán)內(nèi)部的RPC服務(wù)大多構(gòu)建在Thrift之上,在日常開發(fā)服務(wù)的過程中,需要針對這些服務(wù)進(jìn)行壓力測試(以下簡稱壓測)來發(fā)現(xiàn)潛在問題。常用的方法有:

1.使用一些腳本語言如:Python、Ruby等,讀取線上日志構(gòu)建請求,用多線程模擬用戶請求進(jìn)行壓測
2.使用開源工具進(jìn)行壓測
然而,無論采取哪種方法,壓測都是一個(gè)十分耗時(shí)而又繁瑣的過程,主要痛點(diǎn)有:

需要寫很多代碼解析日志,還原請求,對于比較復(fù)雜的請求,解析很容易出錯(cuò)
需要搭建腳本或者工具的運(yùn)行環(huán)境,通常這一過程比較耗時(shí)
由于打壓方法沒有統(tǒng)一,導(dǎo)致打壓的結(jié)果指標(biāo)比較混亂,有的結(jié)果甚至以終端輸出的方式展示,非常不直觀
對一個(gè)應(yīng)用的打壓測試,由于環(huán)境、代碼的問題,導(dǎo)致組內(nèi)同學(xué)很難共享
針對上述問題,提供一個(gè)簡單好用的壓測工具是十分有必要的。

是否有必要重復(fù)造輪子
在構(gòu)建壓測工具之前,對于一些現(xiàn)有的開源工具進(jìn)行了調(diào)研?,F(xiàn)在主流的壓測工具主要有以下幾個(gè):

JMeter
JMeter是一個(gè)比較老牌的壓測工具,主要針對HTTP服務(wù)進(jìn)行打壓,該工具在以下方面并不滿足美團(tuán)內(nèi)部的壓測需求:

1.默認(rèn)不支持Thrift的打壓測試
2.需要本地安裝,并且配置復(fù)雜
3.對于用戶操作并不友好

twitter/iago
iago 是一個(gè)由Twitter開源的壓測工具,支持對HTTP、Thrift等服務(wù)進(jìn)行壓測,其主要問題如下:

對每個(gè)壓測應(yīng)用都需要?jiǎng)?chuàng)建一個(gè)項(xiàng)目
壓測結(jié)果并不直觀
流量重放依賴本地文件
項(xiàng)目依賴于一個(gè)較老版本的Scala,搭建不便
相關(guān)文檔比較少
除此之外,當(dāng)時(shí)還考察了Gatling、Grinder、Locust 等一些常見的壓測工具,都因?yàn)檫m用場景和美團(tuán)的需求有些出入而排除了。

綜上,針對當(dāng)前壓測工具的一些現(xiàn)狀,構(gòu)建一個(gè)簡單易用的壓測工具還是很有必要的。

目標(biāo)
針對之前提到的痛點(diǎn),新的壓測工具主要提供以下功能:

線上流量拷貝
1.簡單易用的操作界面(接入壓測的時(shí)間應(yīng)該控制在1小時(shí)以內(nèi))
2.清晰的圖表能反映壓測應(yīng)用的各項(xiàng)指標(biāo)
3.滿足包括Thrift、HTTP等服務(wù)的壓測需求


如何構(gòu)建
抽象
目標(biāo)已經(jīng)明確,怎么實(shí)現(xiàn)呢?首先是抽象壓測的過程。
一個(gè)典型的壓測過程如圖所示,首先在init方法里面,進(jìn)行一些初始化的工作,比如連接數(shù)據(jù)庫,創(chuàng)建客戶端等。接下來,在run方法里面發(fā)出壓測請求,為了保證能夠?qū)Ψ?wù)產(chǎn)生足夠的壓力,這里通常采用多線程并發(fā)訪問,同時(shí)記錄每次請求的發(fā)起時(shí)間和結(jié)束時(shí)間,這兩個(gè)時(shí)間的簡單相減就能夠得到每次請求的響應(yīng)時(shí)間,利用該結(jié)果就可以計(jì)算出TP90、平均響應(yīng)時(shí)間、最大響應(yīng)時(shí)間等指標(biāo),等壓測結(jié)束后,通過destroy方法進(jìn)行資源回收等工作。

以上過程可以用接口表示,無論是壓測Thrift服務(wù)還是HTTP服務(wù),本質(zhì)上都是這三個(gè)方法實(shí)現(xiàn)的不同??紤]到壓測工具的靈活性和通用性,壓測工具可以將這個(gè)接口交給打壓測試的同學(xué)實(shí)現(xiàn),而壓測工具則重點(diǎn)實(shí)現(xiàn)多線程打壓,打壓結(jié)果的聚合等比較耗時(shí)的工作。

復(fù)制代碼
代碼如下:

interface Runner {
def init(Test app) // 初始化壓測
def run(Test app, String log) // 每次打壓請求,傳入log方便構(gòu)建請求
def destroy(Test app) // 壓測完畢后,回收資源
}


拷貝流量
Thrift服務(wù)打壓的難點(diǎn)之一就是如何簡單地拷貝線上真實(shí)流量用來構(gòu)建打壓請求。一些大型的Thrift服務(wù)數(shù)據(jù)結(jié)構(gòu)非常復(fù)雜,寫打壓腳本的時(shí)候需要很多代碼來解析日志,而且容易出錯(cuò)。 因此提供一個(gè)簡單好用的拷貝流量方法是十分有必要的。

在這里壓測工具提供了一個(gè)叫VCR(錄像機(jī))的工具來拷貝流量。VCR能夠?qū)⒕€上的請求序列化后寫到Redis里面。

考慮到用戶需要查看具體請求和易用性等需求,最終選取了JSON格式作為序列化和反序列化的協(xié)議。同時(shí)需要部署在生產(chǎn)環(huán)境,為了降低對線上服務(wù)的影響,這里采取了單線程異步寫的方式來拷貝流量。

聚合數(shù)據(jù)
應(yīng)用打壓完成后,需要一些指標(biāo)來評估壓測結(jié)果,常見的指標(biāo)有:

1.最大響應(yīng)時(shí)間
2.平均響應(yīng)時(shí)間
3.QPS
4.TP90
5.TP50
壓測工具采用了 InfluxDB 來完成數(shù)據(jù)的聚合工作。
以TP90為例子,僅需要一行查詢就能實(shí)現(xiàn)需求。

SQL Code復(fù)制內(nèi)容到剪貼板
  1. SELECT PERCENTILE(response_time, 90) FROM test_series GROUP BY time(10s)  

架構(gòu)
整體而言,整個(gè)打壓過程如下:

實(shí)踐
拷貝流量
美團(tuán)內(nèi)部的服務(wù)大多使用Java來構(gòu)建,VCR以Maven Package的方式提供給用戶。

對用戶來說只需要2行代碼可以拷貝流量。

為了不影響線上服務(wù),通常選取單臺(tái)機(jī)器進(jìn)行流量拷貝工作。

Java Code復(fù)制內(nèi)容到剪貼板
  1. public class TestAppRPC implements TestApp.Iface {   
  2.   
  3.     private Vcr _vcr = new Vcr("testapp"); // 指定拷貝流量的key   
  4.   
  5.     @Override  
  6.     public TestResponse echo(TestRequest req) throws TException {   
  7.         _vcr.copy(req); // 拷貝操作   
  8.         long start = System.currentTimeMillis();   
  9.         TestResponse response = new TestResponse();   
  10.         return response;   
  11.     }   
  12. }  

一旦流量拷貝完成后,通過Web界面,用戶能夠查看日志的收集情況和單條日志的詳情。

壓測邏輯實(shí)現(xiàn)
壓測工具采用Groovy來進(jìn)行編寫。對每個(gè)應(yīng)用來說,只需要實(shí)現(xiàn)runner接口就可以實(shí)現(xiàn)對應(yīng)用的打壓。

復(fù)制代碼
代碼如下:

interface Runner {
def init(Test app)
def run(Test app, String log)
def destroy(Test app)
}

以Thrift服務(wù)為例:

Java Code復(fù)制內(nèi)容到剪貼板
  1. class TestServiceRunner implements Runner {   
  2.   
  3.     RPCService.Client _client   
  4.     TTransport _transport;   
  5.   
  6.     @Override  
  7.     def init(Test app) {   
  8.         def conf = app.config // 讀取應(yīng)用配置   
  9.         _transport = new TFramedTransport(new TSocket(conf.get("thrift_service_host") as String, conf.get("thrift_service_port") as int))   
  10.         TProtocol protocol = new TBinaryProtocol(_transport)   
  11.         _client = new RPCService.Client(protocol)   
  12.         _transport.open()   
  13.     }   
  14.   
  15.     @Override  
  16.     def run(Test app, String log) {   
  17.         TestRequest req = Vcr.deSerialize(log, TestRequest.class// 將拷貝流量反序列化   
  18.         _client.echo(req) // 發(fā)送請求   
  19.     }   
  20.   
  21.     @Override  
  22.     def destroy(Test app) {   
  23.         _transport.close() // 關(guān)閉服務(wù)   
  24.     }   
  25. }  

創(chuàng)建應(yīng)用
實(shí)現(xiàn)以上接口后,就可以對應(yīng)用進(jìn)行打壓了。

用戶可以通過Web界面創(chuàng)建應(yīng)用,除了必填配置以外,用戶可以按照應(yīng)用靈活配置。

性能指標(biāo)
用戶可以通過直觀的圖表來查看應(yīng)用的各種性能指標(biāo)。

結(jié)束語
壓測工具上線以來,已經(jīng)接入了20多個(gè)應(yīng)用,完成數(shù)百次打壓實(shí)驗(yàn),現(xiàn)在應(yīng)用的接入時(shí)間僅需要15~30分鐘。保證了美團(tuán)服務(wù)的穩(wěn)定和節(jié)省了開發(fā)同學(xué)的時(shí)間,使大家告別了以往繁瑣冗長的打壓測試。

歡迎對這方面有興趣的同學(xué)一起討論。

標(biāo)簽:遼寧 廣元 臨夏 徐州 浙江 錫林郭勒盟 廣西 肇慶

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《剖析美團(tuán)內(nèi)部所采用的網(wǎng)站壓力測試方案》,本文關(guān)鍵詞  剖析,美團(tuán),內(nèi)部,所采,用的,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《剖析美團(tuán)內(nèi)部所采用的網(wǎng)站壓力測試方案》相關(guān)的同類信息!
  • 本頁收集關(guān)于剖析美團(tuán)內(nèi)部所采用的網(wǎng)站壓力測試方案的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章
    武夷山市| 信丰县| 麻城市| 澄城县| 怀仁县| 延吉市| 鱼台县| 正镶白旗| 汾西县| 高青县| 花莲市| 桃源县| 库车县| 大安市| 凤山县| 澎湖县| 象山县| 陆良县| 台州市| 遂川县| 定陶县| 江永县| 无棣县| 河源市| 泸定县| 汕尾市| 南安市| 紫云| 中宁县| 会泽县| 肃北| 洪湖市| 新绛县| 慈利县| 大石桥市| 钟山县| 和静县| 吉林省| 平远县| 沛县| 特克斯县|