【swoole】結(jié)合swoole 和 nsq 的實(shí)際應(yīng)用

AdolphLWQ 發(fā)布于2019-07-01 12:51 / 2438人閱讀

摘要：并且注冊(cè)回調(diào)函數(shù)。在重寫的回調(diào)函數(shù)中，實(shí)現(xiàn)了的訂閱功能消息的處理簡(jiǎn)單封裝了重復(fù)消息的判斷沒有消費(fèi)消息的重新投遞引入就是構(gòu)造方法引入的實(shí)例化同時(shí)，重寫的方法。所以當(dāng)執(zhí)行腳本的時(shí)候，也就是啟動(dòng)了對(duì)應(yīng)的服務(wù)。當(dāng)然更好的是使用協(xié)程。

集合 swoole 的框架設(shè)計(jì)為了減少理解度，我盡量的從源頭開始引入

1. nsq

案例中是使用 swoole 結(jié)合一個(gè)php 框架實(shí)現(xiàn)的是 NSQ 訂閱功能。

啟動(dòng)命令:

sudo bash /www/webserver/bin/swoole.sh start nsq adminexport

解釋上面一個(gè)指令，使用 bash 執(zhí)行一個(gè)項(xiàng)目中的腳本。

start 對(duì)應(yīng)啟動(dòng)命令
nsq ：代表對(duì)應(yīng)使用NSQ 服務(wù)
adminexport ：對(duì)應(yīng)的是NSQ 的topic

腳本的本質(zhì)，通過框架的入口文件，根據(jù)傳參，進(jìn)入到的不同的消息中間件，及對(duì)應(yīng)的服務(wù)

2. php 訂閱

AdminexportService 繼承封裝好的 SwooleService。在init方法中，初始化 swoole服務(wù)。并且注冊(cè)回調(diào)函數(shù)。

AdminexportService 在重寫的 swooleWorkerStart 回調(diào)函數(shù)中，實(shí)現(xiàn)了NSQ 的訂閱功能

NSQ 消息的處理

簡(jiǎn)單封裝了重復(fù)消息的判斷

requeue 沒有消費(fèi)消息的重新投遞

3. 引入 swoole

就是構(gòu)造方法引入 swoole 的實(shí)例化
同時(shí)，重寫 workerStart 的方法。

所以當(dāng)執(zhí)行腳本的時(shí)候，也就是啟動(dòng)了對(duì)應(yīng)的swoole 服務(wù)。啟動(dòng)了訂閱者的客戶端。
不斷的消費(fèi)來自nsq topic 的消息

看吧，swoole 其實(shí)也很簡(jiǎn)單。把它當(dāng)做一個(gè)工具類，拿來用就可以了。在實(shí)現(xiàn)的時(shí)候引入它，通過 WorkerStart 處理分發(fā)的消息即可。

當(dāng)然更好的是使用協(xié)程。
另外吹一波，協(xié)程就是厲害

GPU云服務(wù)器云服務(wù)器 Swoole swoole+websocket php_swoole think-swoole

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/31619.html

相關(guān)文章

【swoole 學(xué)習(xí)筆記】swoole 真的優(yōu)秀一個(gè)框架

摘要：所以，我感覺學(xué)習(xí)，需要一個(gè)引導(dǎo)。學(xué)習(xí)參考鏈接喵星球特別厲害的一個(gè)官網(wǎng)的幾個(gè)框架文檔優(yōu)勢(shì)先看一下的結(jié)構(gòu)設(shè)計(jì)的應(yīng)用場(chǎng)景的設(shè)計(jì)項(xiàng)目中引入一個(gè)簡(jiǎn)易的具體參考一篇文章，集合和的簡(jiǎn)易實(shí)例項(xiàng)目中引入結(jié)合致敬前期學(xué)完了操作系統(tǒng)，特別是知道了進(jìn)程，線程調(diào)度的問題?；貋砜?，發(fā)現(xiàn)了很多細(xì)節(jié)。第三次看文檔，最初經(jīng)一個(gè)高手朋友的介紹，看swoole，說文檔寫的賊好。但是看的時(shí)候，也是很一頭霧水，只知道把de...

13651657101 2019-07-01 12:51 評(píng)論0 收藏0
【天贏金創(chuàng)】PHP7與Swoole

摘要：但在密集計(jì)算方面比等靜態(tài)編譯語言差幾十倍甚至上百倍。一使用棧內(nèi)存在引擎和擴(kuò)展中，經(jīng)常要?jiǎng)?chuàng)建一個(gè)的變量，底層就是一個(gè)指針。代碼中創(chuàng)建的變量也進(jìn)行了優(yōu)化，直接在棧內(nèi)存上預(yù)分配。應(yīng)用層與底層在錯(cuò)誤拋出的方式全部統(tǒng)一為異常。原文：http://rango.swoole.com/archives/440最近PHP官方終于發(fā)布了傳說中的PHP7，雖然只是alpha版。PHP7號(hào)稱是新一代的PHP...

MingjunYang 2019-06-27 11:34 評(píng)論0 收藏0
Swoole學(xué)習(xí)手記（一）初識(shí)Swoole

摘要：目錄初識(shí)創(chuàng)建服務(wù)器上創(chuàng)建服務(wù)器下異步任務(wù)持續(xù)更新中。。。參加工作有一段時(shí)間了，偶爾會(huì)聽到，對(duì)我這種小白粗略看下文檔都會(huì)覺得很牛逼。個(gè)人理解就是解決這樣應(yīng)用場(chǎng)景的。目錄初識(shí)Swoole 創(chuàng)建服務(wù)器(上) 創(chuàng)建服務(wù)器(下) 異步任務(wù)task 持續(xù)更新中。。。參加工作有一段時(shí)間了，偶爾會(huì)聽到swoole，對(duì)我這種PHP小白粗略看下文檔都會(huì)覺得很牛逼。由于學(xué)習(xí)成本比較高，自身對(duì)網(wǎng)絡(luò)異...

yeyan1996 2019-06-28 18:47 評(píng)論0 收藏0
PHP并發(fā)IO編程之路

摘要：下文如無特殊聲明將使用進(jìn)程同時(shí)表示進(jìn)程線程。收到數(shù)據(jù)后服務(wù)器程序進(jìn)行處理然后使用向客戶端發(fā)送響應(yīng)?，F(xiàn)在各種高并發(fā)異步的服務(wù)器程序都是基于實(shí)現(xiàn)的，比如。并發(fā) IO 問題一直是服務(wù)器端編程中的技術(shù)難題，從最早的同步阻塞直接 Fork 進(jìn)程，到 Worker 進(jìn)程池/線程池，到現(xiàn)在的異步IO、協(xié)程。PHP 程序員因?yàn)橛袕?qiáng)大的 LAMP 框架，對(duì)這類底層方面的知識(shí)知之甚少，本文目的就是詳細(xì)介...

Riddler 2019-07-01 12:39 評(píng)論0 收藏0
swoole入門4-初識(shí)swoole

摘要：當(dāng)某種網(wǎng)絡(luò)事件發(fā)生時(shí)，會(huì)回調(diào)用戶設(shè)置的指定回調(diào)函數(shù)。承擔(dān)了底層網(wǎng)絡(luò)事件的監(jiān)聽及各種底層事件處理，當(dāng)收到請(qǐng)求時(shí)，會(huì)觸發(fā)事件提醒，然后將控制權(quán)轉(zhuǎn)交預(yù)先注冊(cè)的事件回調(diào)函數(shù)，來進(jìn)行后續(xù)的處理。請(qǐng)求到來時(shí)創(chuàng)建，請(qǐng)求結(jié)束后銷毀。運(yùn)行流程圖 showImg(https://segmentfault.com/img/remote/1460000017207791);showImg(https://s...

forsigner 2019-07-01 11:00 評(píng)論0 收藏0