欢迎来到php自学网~
阅读模式:

php+redis实现消息队列

查看:450  回复:0  类型:  来源: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 0

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

扫描二维码手机查看

发布评论:


登录:
  表情:
评论话题
推荐阅读:
shell脚本批量删除几天前的文件   阅读:1727linux教程,鸟哥私房菜(pdf全集)   阅读:1445php中地址引用&的真正理解-变量引用、函数引用、对象引用   阅读:1225面试的时候回去等通知,等电话的真实意思   阅读:5480linux命令中执行php脚本   阅读:1338php 统计网页打开耗时和脚本运行内存   阅读:1908封装php redis缓存操作类   阅读:1474企业让你去面试,可能不是真的招人   阅读:1385HTTP 1.1 协议详解   阅读:1531HTTP 1.1 协议详解   阅读:1531php连接redis   阅读:1663linux php7安装yaf扩展   阅读:1074用php从1加到100的值   阅读:2716centos 7 添加 redis 3.2.9 开机启动脚本   阅读:2724霍金24岁博士毕业论文在线预览   阅读:1137十张GIF让你弄懂递归等概念   阅读:1485centos 7 开启网络   阅读:1459crontab+shell脚本实现定时备份mysql数据库   阅读:1498爱编程,也爱健康   阅读:861最新centos7 搭建LNMP环境(centos7.2+php7+mysql5.7+nginx1.11+redis3.2)   阅读:3281centos 7 安装 nginx-1.11.10   阅读:2870php 统计网页打开耗时和脚本运行内存   阅读:1908“米粉节”背后的故事——小米网抢购系统开发实践   阅读:998linux top命令详解   阅读:1260给 centos 7 安装桌面环境   阅读:7414phpexcel 超简单从excel表格一键导入数据到数据库教程   阅读:4512centos 7 添加 redis 3.2.9 开机启动脚本   阅读:2724session与cookie的区别   阅读:1345mysql中文分词全文搜索索引讯搜的安装   阅读:1391霍金24岁博士毕业论文在线预览   阅读:1137给网站添加一键qq登录的功能   阅读:2032PHP 鸟哥:我也曾经是“不适合”编程的人   阅读:2314centos 7 添加 redis 3.2.9 开机启动脚本   阅读:2724centos7开启交换内存   阅读:2014ajax+php 实现一个简单的在线聊天室功能(附带源码)   阅读:2732php 使用 smtp.php 类在线发送邮件功能   阅读:1615面试的时候和你谈理想,是理想or入坑?   阅读:1222php 统计网页打开耗时和脚本运行内存   阅读:1908php文件下载防盗链   阅读:2874php冒泡排序法   阅读:1103纯干货,程序员面试的超实用技巧   阅读:1086centos 7 安装 nginx-1.11.10   阅读:2870纯干货,程序员面试的超实用技巧   阅读:1086栈和堆的区别   阅读:1183php 使用 smtp.php 类在线发送邮件功能   阅读:1615php打印九九乘法表   阅读:1558php连接redis   阅读:1663什么是天使轮?什么是A轮融资?B轮融资?   阅读:908php显示刚刚、几分钟前、几小时前、几天前的函数   阅读:1716Nginx 配置文件详解   阅读:1366