阅读模式:

php+redis实现消息队列

查看:1690  回复: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

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

扫描二维码手机查看

发布评论:


登录:
  表情:
评论话题
推荐阅读:
mysql5.7开启sql日志的配置   阅读:2464简单的DOS攻击之死亡之ping详解   阅读:15146javascript点击复制内容   阅读:2051把php session 会话保存到redis   阅读:2700shell脚本破解十位数内的所有纯数字rar加密压缩包脚本   阅读:3182linux教程,鸟哥私房菜(pdf全集)   阅读:1933比phpexcel还要简单的excel CSV 一键导入数据到数据库   阅读:2133centos7.3安装mongodb3.6   阅读:2910mysql数据库性能的基本优化   阅读:2012centos 7 安装 php-7.1.3   阅读:8970php连接redis   阅读:2292linux教程,鸟哥私房菜(pdf全集)   阅读:1933crontab+shell脚本实现定时备份mysql数据库   阅读:2178javascript对cookie操作详细代码函数   阅读:1952javascript对cookie操作详细代码函数   阅读:1952centos 7 安装 redis 3.2.9   阅读:2852centos 7 安装 redis 3.2.9   阅读:2852面试的时候回去等通知,等电话的真实意思   阅读:8776centos7.3安装mongodb3.6   阅读:2910linux时间戳有趣的情人节秒1234567890   阅读:1634php生成二维码   阅读:2202centos 7.2 添加php7 的 php-fpm 开机启动   阅读:10349php显示刚刚、几分钟前、几小时前、几天前的函数   阅读:2470centos 7 安装 mysql-5.7   阅读:2490封装php redis缓存操作类   阅读:2545给php7安装redis扩展库   阅读:2748给网站添加一键新浪微博登录的功能   阅读:2838nginx编译安装后对nginx进行平滑升级   阅读:702linux rarcrack破解rar、zip和7z压缩包简单密码的工具   阅读:3240人性漫画:打工与创业的残酷区别   阅读:1636mysql共享锁和排他锁详解   阅读:2305一步步带你,如何网站架构   阅读:1614javascript点击复制内容   阅读:2051centos7.3安装mongodb3.6   阅读:2910php 读取和设置redis的键值   阅读:3213分享:淘宝技术这十年   阅读:1851javascript获取两个日期间的所有日期   阅读:66html5 离线缓存的使用   阅读:1695给网站添加一键新浪微博登录的功能   阅读:2838centos 7 开启网络   阅读:1946mysql 为什么添加索引可以提高访问速度   阅读:2219linux rarcrack破解rar、zip和7z压缩包简单密码的工具   阅读:3240人性漫画:打工与创业的残酷区别   阅读:1636php 读取和设置redis的键值   阅读:3213最简单的Banner轮播淡入淡出效果代码及实现思路(附带源码)   阅读:7024mysql数据一键导出到csv文件   阅读:2014mysql5.7开启sql日志的配置   阅读:2464一步步带你,如何网站架构   阅读:1614Mysql在大型网站的应用架构演变   阅读:1942php 获取当前前后年、月、星期、日、时分秒的时间   阅读:2161