阅读模式:

php+redis实现消息队列

查看:14156  回复:2  类型:  来源:php自学网  标签 php消息队列 shell redis

        php+redis消息队列是php+mysql性能不足时的一个中间间处理方案。通过这个中间的处理,保证的数据的可用性和准确性。用于服务器瞬间请求大,数据库压力大的情况。如并发量大导致的超卖、并发量大导致的数据重复情况。

        流程:php接受请求和数据 -> php把数据写入redis队列中(入队) -> shell定时调用php读取队列数据写入mysql(出队)

        实现代码:

入队:inqueue.php

<?php
$redis = new redis();
$redis->connect('127.0.0.1',6379);
$redis -> select('1');
$redis->auth('');

$data = [a,b,c,d,e,f,g,h]; //这里可以是get或post请求过来的数据
$data = json_encode($data);
$in = $redis->rpush('queue',$data);
if($in){
    echo "入队成功";
}

出队:outqueue.php

#!/usr/bin/php
<?php
$redis = new redis();
$redis->connect('127.0.0.1',6379);
$redis -> select('1');
$redis->auth('');

$value = $redis->lpop('queue');
$value = json_decode($value,true);

shell process.sh:定时调用outqueue.php脚本

#进行每分钟调用一次
* * * * * /usr/local/nginx/html/process.sh
#!/bin/bash
#file_name : process.sh
#author : zuoping
php /usr/local/nginx/html/outqueue.php

*如果每分钟调用一次频率不够,可以执行多次调用脚本,如:

#!/bin/bash
#file_name : process.sh
#author : zuoping
php /usr/local/nginx/html/outqueue.php
php /usr/local/nginx/html/outqueue.php
php /usr/local/nginx/html/outqueue.php
php /usr/local/nginx/html/outqueue.php
php /usr/local/nginx/html/outqueue.php
php /usr/local/nginx/html/outqueue.php
php /usr/local/nginx/html/outqueue.php
php /usr/local/nginx/html/outqueue.php
php /usr/local/nginx/html/outqueue.php
php /usr/local/nginx/html/outqueue.php
php /usr/local/nginx/html/outqueue.php
#这样就一分钟调用了多次了。

查看队列中的当前数据:

<?php
$redis = new redis();
$redis->connect('127.0.0.1',6379);
$redis -> select('1');
$redis->auth('');

$list = $redis->lrange('queue',0,-1);
var_dump($list);
分享到:
0 1

*有问题之处烦请在评论中指出非常感谢!
不是我想要的内容,继续搜索:

扫描二维码手机查看

最新评论:
何 遇  发表于 2018-09-26 17:17:53  中国浙江杭州电信
沙发
这个是你自己做的网站吗? 回复
站长 回复 何 遇 嗯。自己做的个人博客
2018-09-27 14:39 中国广东深圳电信 回复
回复:[主题]
表情:
 提交评论
清空

发布评论:


登录:
  表情:
评论话题
推荐阅读:
TCP的三次握手(建立连接)和四次挥手(关闭连接)   阅读:3307php 获取当前前后年、月、星期、日、时分秒的时间   阅读:6479什么是天使轮?什么是A轮融资?B轮融资?   阅读:4795php设置cookie为HttpOnly防止XSS攻击   阅读:12427mysql5.7主从同步配置   阅读:5276php打印九九加法表   阅读:10022php打印九九加法表   阅读:10022linux rarcrack破解rar、zip和7z压缩包简单密码的工具   阅读:16874mysql的四种索引类型   阅读:22172php冒泡排序法   阅读:13970php删除一个文件夹内的所有文件夹和文件   阅读:4609Mysql在大型网站的应用架构演变   阅读:4499centos 7 添加 redis 3.2.9 开机启动脚本   阅读:9217php打印九九乘法表   阅读:9936Nginx 配置文件详解   阅读:4500分享:淘宝技术这十年   阅读:4553javascript对cookie操作详细代码函数   阅读:5143linux rarcrack破解rar、zip和7z压缩包简单密码的工具   阅读:16874php 使用 smtp.php 类在线发送邮件功能   阅读:5575php 读取和设置redis的键值   阅读:7080用php从1乘到100的值   阅读:6116mysql的四种索引类型   阅读:22172centos 7搭建zabbix3.4   阅读:6276centos7.3安装mongodb3.6   阅读:7256centos 7搭建zabbix3.4   阅读:6276网站局部小图片优化-base64编码图片   阅读:12681关于PHP程序员技术职业生涯规划   阅读:2715霍金24岁博士毕业论文在线预览   阅读:5413mysql数据库性能的基本优化   阅读:4398php 使用 smtp.php 类在线发送邮件功能   阅读:5575小米手机端商城rem适配原理   阅读:6556给网站添加一键qq登录的功能   阅读:7195给 centos 7 安装桌面环境   阅读:16639面试的时候和你谈理想,是理想or入坑?   阅读:10121csv文件一键导入数据到mysql数据库   阅读:6508php压缩页面的html代码一行显示   阅读:7168shell脚本批量删除几天前的文件   阅读:9664mysql共享锁和排他锁详解   阅读:7110centos 7 添加 redis 3.2.9 开机启动脚本   阅读:9217centos 7 安装 mysql-5.7   阅读:6802web项目高并发量网站解决方案   阅读:4473php打印九九乘法表   阅读:9936javascript获取两个日期间的所有日期   阅读:6399centos 7 设置 nginx-1.11.10 开机启动   阅读:7807php打印九九加法表   阅读:10022centos 7 安装 redis 3.2.9   阅读:6445centos 7.2 添加php7 的 php-fpm 开机启动   阅读:24113linux命令中执行php脚本   阅读:7760HTTP 1.1 协议详解   阅读:11217一步步带你,如何网站架构   阅读:3962