VB.net 2010 视频教程 VB.net 2010 视频教程 python基础视频教程
SQL Server 2008 视频教程 c#入门经典教程 Visual Basic从门到精通视频教程
当前位置:
首页 > 网站开发 > PHP >

  • php教程之PHP7 生产环境队列 Beanstalkd 正确使用姿势

本站最新发布   C#从入门到精通
试听地址  https://www.xin3721.com/eschool/CSharpxin3721/

应用场景

　　为什么要用呢，有什么好处？这应该放在最开头说，一件东西你只有了解它是干什么的，适合干什么，才能更好的与自己的项目相结合，用到哪里学到哪里，学了不用等于不会，我们平时就应该多考虑一些这样的问题：自己做个什么项目功能能跟 xx 技术相结合呢？这个 xx 技术放在这种业务场景下行不行呢？而不是 “学了这个 xx 技术能干嘛呢，公司现在也没有用这个的呀，学了也没用啊”，带着这样心情去学习 xx 技术，肯定很痛苦。

　　队列大家都知道是将一些耗时的操作先不去做，先埋点，再异步去处理，这样对一些发邮件发短信之类的耗时操作，用户是感觉不到的，因为埋点结束，操作也就结束了，消费队列都是在服务器上做的。主要应用在短信或邮件通知，访问第三方接口订阅消息，商城的一些秒杀活动，都可以结合队列来完成。

Beanstalkd 介绍

　　Beanstalkd 是一个高性能，轻量级的分布式内存队列，C 代码，典型的类 Memcached 设计，协议和使用方式都是同样的风格，所以使用过 memcached 的用户会觉得 Beanstalkd 似曾相识。

　　beanstalkd 的最初设计意图是在高并发的网络请求下，通过异步执行耗时较多的请求，及时返回结果，减少请求的响应延迟。

Ubuntu 安装

1
sudo apt-get install beanstalkd

　　

配置文件

1
vim /etc/default/beanstalkd

　　

查看状态

1
2
3
4
5
6
7
8
9
10
11
12
service beanstalkd status
# 命令回显 #
root@:/www/server/php/72/etc# service beanstalkd status
● beanstalkd.service - Simple, fast work queue
 Loaded: loaded (/lib/systemd/system/beanstalkd.service; enabled; vendor preset: enabled)
 Active: active (running) since Tue 2018-10-16 10:42:28 CST; 6 days ago
 Docs: man:beanstalkd(1)
 Main PID: 7033 (beanstalkd)
 Tasks: 1 (limit: 4634)
 CGroup: /system.slice/beanstalkd.service
 └─7033 /usr/bin/beanstalkd -l 0.0.0.0 -p 11300 -b /var/lib/beanstalkd
Oct 16 10:42:28 ip-10-93-2-137 systemd[1]: Started Simple, fast work queue.

　　

配置连通性 + 持久化

ip 用 0.0.0.0 允许所有连接，靠配置安全组或防火墙去约束连接，放开 -b 参数 （默认没有持久化），内存的队列消息可以落地到硬盘 binlog 实现持久化，断电可重新读取队列消息。

1
2
3
4
vim /etc/default/beanstalkd
BEANSTALKD_LISTEN_ADDR=0.0.0.0
BEANSTALKD_LISTEN_PORT=11300
BEANSTALKD_EXTRA="-b /var/lib/beanstalkd"

　　

beanstalkd 任务状态

管理工具

亲测了很多网上能找到的 beanstalkd 工具，这两款是我最中意的了，一个命令行，一个 web 的。

命令行：

web 界面：

编程语言客户端

PHP 客户端

composer require pda/pheanstalk

写入 job

1
2
3
4
5
6
7
8
9
10
11
12
<?php
//创建队列消息
require_once('./vendor/autoload.php');
use Pheanstalk\Pheanstalk;
$pheanstalk = new Pheanstalk('127.0.0.1',11300);
$tubeName = 'email_list';
$jobData = [
 'email' => '123456@163.com',
 'message' => 'Hello World !!',
 'dtime' => date('Y-m-d H:i:s'),
];
$pheanstalk->useTube( $tubeName)->put( json_encode( $jobData ) );
相关教程