Docker如何搭建簡單秒殺環(huán)境

這篇文章主要講解了“Docker如何搭建簡單秒殺環(huán)境”，文中的講解內(nèi)容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“Docker如何搭建簡單秒殺環(huán)境”吧！

創(chuàng)新互聯(lián)于2013年創(chuàng)立，先為德興等服務建站，德興等地企業(yè)，進行企業(yè)商務咨詢服務。為德興企業(yè)網(wǎng)站制作PC+手機+微官網(wǎng)三網(wǎng)同步一站式服務解決您的所有建站問題。

首先，先簡單介紹下本文中會涉及到的一些組件，如下圖所示：

jmeter：用jmeter來模擬秒殺活動中大量并發(fā)的用戶請求

seckill service：基于nodejs使用express實現(xiàn)的秒殺service，圖中的步驟2，3，4都是在這個service中處理的

redis：一個redis的docker container，在其中保存一個名為counter的數(shù)據(jù)來表示當前剩余的庫存大小

kafka: 一個kafka的docker container，其實這里還有一個zookeeper的docker container，kafka用zookeeper來存放一些元數(shù)據(jù)，在程序中并沒有涉及到，所以也就不單獨列出來說了。seckill service在更新完redis之后，會發(fā)送一條消息給kafka表示一次成功的秒殺

seckill kafka consumer: 基于nodejs的kafka consumer，會從kafka中去獲取秒殺成功的消息，處理并且存儲到MySQL中

mysql：一個mysql的docker container，最終秒殺成功的請求都會對應著數(shù)據(jù)庫表中的一條記錄

環(huán)境搭建

1 . 安裝jmeter
從下載一個jmeter的binary包，執(zhí)行bin目錄下的jmeter即可啟動，啟動后如下圖新建一個名為seckill的thread group，并且設置在5s內(nèi)發(fā)起2000次并發(fā)請求。

在這個thread group下新建一個http request的sampler并命名為seckill，按下圖配置host name，port number，http request method以及request path

2 . 安裝redis，kafka, zookeeper和mysql
為了方便搭建環(huán)境，這幾個組件會以docker container的形式啟動。在此之前需要去docker官網(wǎng)下載并安裝docker engine，docker machine和docker compose。如果是在windows或者mac上，docker官網(wǎng)提供docker for windows／docker for mac安裝程序，可以很方便的把這3個組件安裝好。

3 . 編寫docker compose文件
創(chuàng)建一個seckill項目文件夾，新建一個docker-compose.yml文件，內(nèi)容如下：

配置文件中一共配置了4個services對應4個docker container，分別是zookeeper，kafka，redis以及mysql。這里有兩個地方需要設置成你實際環(huán)境的值，一個是kafka配置下面的kafka_advertised_host_name字段，這個需要設置成本地機器的ip。另一個是mysql配置下面的mysql_root_password，你可以設置成你想要的任何值。

創(chuàng)建好這個文件之后，就可以去命令行項目根目錄中執(zhí)行docker-compose up，docker engine就會把上面配置的這4個組件全部啟動起來。

注意：在啟動完之后，需要去kafka容器中創(chuàng)建一個名為car_number的topic，去redis容器中創(chuàng)建一個名為counter的計數(shù)器(設置值為100，代表庫存初始值為100)，去mysql容器中創(chuàng)建一個名為seckill的數(shù)據(jù)表(包含一個自增長的id自段和一個timestamp格式的date字段)。

代碼片段

1 . seckill service

第1-8行，引入了程序需要用到的對象，nodejs的mvc框架express, redis, kafka等

第10行，利用express提供的方法暴露出一個path為/seckill的post方法

第12行，定義了一個方法，在54行會調(diào)用

第13-22行，新建了一個redis client并且監(jiān)聽error事件

第23行，這行代碼非常關鍵，它的作用是讓redis cilent監(jiān)視redis中的counter值，之后會啟動一個事務，如果在事務提交的時候發(fā)現(xiàn)有其它client修改了counter值的話，就會放棄這個事務。

第24行，通過redis client的異步方法獲取counter的值，因為redis的get操作是原子的，所以在這里不用擔心有并發(fā)讀寫的問題。

第25-28行，判斷返回的庫存值是否大于0，如果大于0，通過client.multi()啟動一個事務，通過decr()方法將counter值減1，最后通過exec()方法提交事務；如果小于0，則執(zhí)行第47行，打印賣完了并且關閉redis client。

第29-46行，這里我們看一下multi.exec()中的這個回調(diào)方法。在前面我們已經(jīng)使用watch對counter進行了監(jiān)視。如果在事務提交過程中有其它client修改了counter值的話，回調(diào)方法中的replies參數(shù)就會是null，可以看到第29-31行，程序會打印“可能有沖突”并且再次調(diào)用fn方法重試。
如果replies的值不為null，就會使用kafka的producer發(fā)送一條message到car_number topic。

2 . seckill_kafka_consumer

這里的代碼就比較簡單了，會初始化一個kafka consumer監(jiān)聽car_number topic，對于新獲取的消息會去mysql的seckill表里插入一條記錄。

操作步驟

啟動docker container

啟動seckill_service

啟動seckill_kafka_consumer

啟動jmeter發(fā)送2000個并發(fā)請求

結(jié)果 jmeter request results 

redis counter field

mysql seckill table

可以看到，最后redis中的counter變成0，seckill數(shù)據(jù)表中會插入100條記錄，沒有發(fā)生超賣或者少賣的情況。當然在實際生產(chǎn)環(huán)境場景中，還有許多其它需要考慮的地方，希望此文可以起到一個拋磚引玉的作用，幫助大家更好的理解秒殺場景。

感謝各位的閱讀，以上就是“Docker如何搭建簡單秒殺環(huán)境”的內(nèi)容了，經(jīng)過本文的學習后，相信大家對Docker如何搭建簡單秒殺環(huán)境這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關知識點的文章，歡迎關注！

名稱欄目：Docker如何搭建簡單秒殺環(huán)境
轉(zhuǎn)載注明：http://muchs.cn/article20/piocco.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供電子商務、網(wǎng)站策劃、手機網(wǎng)站建設、定制開發(fā)、網(wǎng)站營銷、ChatGPT

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)