SWBT基于beanstalkd实现多进程处理消息队列的框架

XanaHopper 发布于2019-07-01 10:11 / 553人阅读

摘要：项目地址框架目的基于和实现多进程处理消息队列。文件用于配置消息队列管道及其处理类项目配置文件文件夹下为方式运行下产生的日志内容是运行时的进程信息命令查看的状态信息查看的信息启动启动停止重启其它子进程异常退出时将会自动重启。

项目地址

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

目的

基于Swoole和beanstalkd实现多进程处理消息队列。

安装

composer require ywna/swbt

初始化

vendor/bin/SWBT init

执行初始化命令后将会自动生成swbt文件夹。

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

SWBT.php文件用于配置消息队列管道及其处理类

.env项目配置文件

logs文件夹下为deamon方式运行下产生的日志内容

master.pid是运行时的进程PID信息

命令

查看beanstalkd的状态信息

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

其它

子进程异常退出时将会自动重启。

文章内容更新中

云服务器 GPU云服务器消息队列的实现阿里消息队列框架 java 消息队列框架消息队列实现

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/28895.html

Beanstalkd 使用记录

摘要：的消费者，通过命令来获取或改变的状态。不再维持这些消息。持久化可以通过将及其状态记录到文件里面，在下次启动时可以通过读取来恢复之前的及状态。一、安装 1、官网 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
现代软件开发流程-by 12-Factor

摘要：将开发环境和生产环境的差异降至最低，并使用持续交付实施敏捷开发。可以在工具架构和开发流程不发生明显变化的前提下实现扩展。我们的初衷是分享在现代软件开发过程中发现的一些系统性问题，并加深对这些问题的认识。简介如今，软件通常会作为一种服务来交付，它们被称为网络应用程序，或软件即服务（SaaS）。12-Factor 为构建如下的 SaaS 应用提供了方法论：使用标准化流程自动配置，从...

draveness 2019-08-19 10:31 评论0 收藏0
Laravel 队列 --- beanstalkd 驱动

摘要：上一篇文章讲了通道建议先去看上篇文章与把队列添加到数据表中把队列添加到内存中安装依赖安装到项目根目录修改访问路由数据将写入到内存中执行命令打开日志文件打印的消息完结下一篇文章讲能更直观的看到数据添加到内存中上一篇文章讲了 database 通道建议先去看上篇文章 1.beanstalkd 与 database database：把队列添加到数据表中beanstalkd：把队列添加到...

Lycheeee 2019-07-01 12:47 评论0 收藏0
使用 mixphp 打造多进程异步邮件发送

摘要：消费者开发本例我们使用的多进程开发工具来完成这个需求，通常使用常驻进程来处理队列的消费，所以我们使用的类型，模式。中进程负责执行邮件发送任务。此时终端将打印成功收到测试邮件官网注意：这个是 MixPHP V1 的范例邮件发送是很常见的需求，由于发送邮件的操作一般是比较耗时的，所以我们一般采用异步处理来提升用户体验，而异步通常我们使用消息队列来实现。传统 MVC 框架由于缺少多进程...

EdwardUp 2019-07-01 10:12 评论0 收藏0
php+sockets实现可靠的延时队列

摘要：支持消息删除业务使用方，可以随时删除指定消息。消息传输可靠性消息进入到延迟队列后，保证至少被消费一次。延迟队列，顾名思义它是一种带有延迟功能的消息队列。那么，是在什么场景下我才需要这样的队列呢？一、背景先看看一下业务场景： 1.会员过期前3天发送召回通知 2.订单支付成功后，5分钟后检测下游环节是否都正常，比如用户购买会员后，各种会员状态是否都设置成功 3.如何定期检查处于退...

xumenger 2019-07-01 10:53 评论0 收藏0