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

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

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

集合 swoole 的框架設(shè)計

為了減少理解度，我盡量的從源頭開始引入

1. nsq

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

啟動命令:

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

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

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

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

2. php 訂閱

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

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

NSQ 消息的處理

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

requeue 沒有消費消息的重新投遞

3. 引入 swoole

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

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

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

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

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

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

轉(zhuǎn)載請注明本文地址：http://specialneedsforspecialkids.com/yun/31619.html

相關(guān)文章

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

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

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

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

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

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

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

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

Riddler 2019-07-01 12:39 評論0 收藏0
swoole入門4-初識swoole

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

forsigner 2019-07-01 11:00 評論0 收藏0