SWBT基于beanstalkd實現(xiàn)多進程處理消息隊列的框架

XanaHopper 發(fā)布于2019-07-01 10:11 / 654人閱讀

摘要：項目地址框架目的基于和實現(xiàn)多進程處理消息隊列。文件用于配置消息隊列管道及其處理類項目配置文件文件夾下為方式運行下產(chǎn)生的日志內(nèi)容是運行時的進程信息命令查看的狀態(tài)信息查看的信息啟動啟動停止重啟其它子進程異常退出時將會自動重啟。

項目地址

SWBT框架 https://github.com/YWNA/SWBT

目的

基于Swoole和beanstalkd實現(xiàn)多進程處理消息隊列。

安裝

composer require ywna/swbt

初始化

vendor/bin/SWBT init

執(zhí)行初始化命令后將會自動生成swbt文件夾。

swbt
├── config
│?? └── SWBT.php
├── .env
└── storage
    ├── logs
    │?? ├── 2018-06-12.log
    │?? └── 2018-06-19.log
    └── master.pid

SWBT.php文件用于配置消息隊列管道及其處理類

.env項目配置文件

logs文件夾下為deamon方式運行下產(chǎn)生的日志內(nèi)容

master.pid是運行時的進程PID信息

命令

查看beanstalkd的狀態(tài)信息

vendor/bin/SWBT status

查看beanstalkd的job信息

vendor/bin/SWBT status-job

啟動（deamon）

vendor/bin/SWBT start

啟動

vendor/bin/SWBT run

停止

vendor/bin/SWBT stop

重啟

vendor/bin/SWBT restart

其它

子進程異常退出時將會自動重啟。

文章內(nèi)容更新中

云服務(wù)器 GPU云服務(wù)器消息隊列的實現(xiàn) 阿里消息隊列框架 java 消息隊列框架消息隊列實現(xiàn)

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

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

相關(guān)文章

Beanstalkd 使用記錄

摘要：的消費者，通過命令來獲取或改變的狀態(tài)。不再維持這些消息。持久化可以通過將及其狀態(tài)記錄到文件里面，在下次啟動時可以通過讀取來恢復(fù)之前的及狀態(tài)。一、安裝 1、官網(wǎng) https://kr.github.io/beanstalkd/ 2、安裝 yum install beanstalkd --enablerepo=epel 3、啟動 /usr/bin/beanstalkd -l 0.0.0....

yearsj 2019-07-01 12:12 評論0 收藏0
現(xiàn)代軟件開發(fā)流程-by 12-Factor

摘要：將開發(fā)環(huán)境和生產(chǎn)環(huán)境的差異降至最低，并使用持續(xù)交付實施敏捷開發(fā)?？梢栽诠ぞ呒軜?gòu)和開發(fā)流程不發(fā)生明顯變化的前提下實現(xiàn)擴展。我們的初衷是分享在現(xiàn)代軟件開發(fā)過程中發(fā)現(xiàn)的一些系統(tǒng)性問題，并加深對這些問題的認識。簡介如今，軟件通常會作為一種服務(wù)來交付，它們被稱為網(wǎng)絡(luò)應(yīng)用程序，或軟件即服務(wù)（SaaS）。12-Factor 為構(gòu)建如下的 SaaS 應(yīng)用提供了方法論：使用標準化流程自動配置，從...

draveness 2019-08-19 10:31 評論0 收藏0
Laravel 隊列 --- beanstalkd 驅(qū)動

摘要：上一篇文章講了通道建議先去看上篇文章與把隊列添加到數(shù)據(jù)表中把隊列添加到內(nèi)存中安裝依賴安裝到項目根目錄修改訪問路由數(shù)據(jù)將寫入到內(nèi)存中執(zhí)行命令打開日志文件打印的消息完結(jié)下一篇文章講能更直觀的看到數(shù)據(jù)添加到內(nèi)存中上一篇文章講了 database 通道建議先去看上篇文章 1.beanstalkd 與 database database：把隊列添加到數(shù)據(jù)表中beanstalkd：把隊列添加到...

Lycheeee 2019-07-01 12:47 評論0 收藏0
使用 mixphp 打造多進程異步郵件發(fā)送

摘要：消費者開發(fā)本例我們使用的多進程開發(fā)工具來完成這個需求，通常使用常駐進程來處理隊列的消費，所以我們使用的類型，模式。中進程負責(zé)執(zhí)行郵件發(fā)送任務(wù)。此時終端將打印成功收到測試郵件官網(wǎng) 注意：這個是 MixPHP V1 的范例郵件發(fā)送是很常見的需求，由于發(fā)送郵件的操作一般是比較耗時的，所以我們一般采用異步處理來提升用戶體驗，而異步通常我們使用消息隊列來實現(xiàn)。傳統(tǒng) MVC 框架由于缺少多進程...

EdwardUp 2019-07-01 10:12 評論0 收藏0
php+sockets實現(xiàn)可靠的延時隊列

摘要：支持消息刪除業(yè)務(wù)使用方，可以隨時刪除指定消息。消息傳輸可靠性消息進入到延遲隊列后，保證至少被消費一次。延遲隊列，顧名思義它是一種帶有延遲功能的消息隊列。那么，是在什么場景下我才需要這樣的隊列呢？一、背景先看看一下業(yè)務(wù)場景： 1.會員過期前3天發(fā)送召回通知 2.訂單支付成功后，5分鐘后檢測下游環(huán)節(jié)是否都正常，比如用戶購買會員后，各種會員狀態(tài)是否都設(shè)置成功 3.如何定期檢查處于退...

xumenger 2019-07-01 10:53 評論0 收藏0