首页
开发手册
应用中心
工具
用户中心
DBO应用：Redis 队列
中文简体
中文简体
English
上一篇
下一篇
##DBO应用：Redis 队列 `redis 队列方便快速实现推送功能，例如：微信模板消息、短信群发、应用通知等。` `FoundPHP redis 集成队列方式采用先进先出模式。` ####插入消息 ```php <?php $config['redis']['dbtype'] = 'redis'; //redis 类型 $config['redis']['dbhost'] = '127.0.0.1'; //服务器地址 $config['redis']['dbname'] = '1'; //库必须为数字,有密码则无效 $config['redis']['dbport'] = '6379'; //服务器端口 $config['redis']['dbpass'] = 'FoundPHP'; //密码 //声明类 $redis = load('class/database/dbo','FoundPHP_dbo',$config['redis']); //设置随机数字值 echo $txt = rand(123,100000); //数据名FoundPHP_push $redis->insert('FoundPHP_push',$txt); //关闭数据库 $redis->close(); ?> ``` <br> ####执行队列 ```php <?php define('FoundPHP.com',true); define('PLUGIN', 'index'); //入口识别 //linux用途切换到项目目录下 if ($_SERVER['PWD']){ chdir(dirname($_SERVER['SCRIPT_NAME'])); } //引入核心库 require 'plugin/controller.php'; $config['redis']['dbtype'] = 'redis'; //redis 类型 $config['redis']['dbhost'] = '127.0.0.1'; //服务器地址 $config['redis']['dbname'] = '1'; //库必须为数字,有密码则无效 $config['redis']['dbport'] = '6379'; //服务器端口 $config['redis']['dbpass'] = 'FoundPHP'; //密码 $redis = load('class/database/dbo','FoundPHP_dbo',$config['redis']); //循环数据 while(1){ //读取数据 FoundPHP_push $id = $redis->query('FoundPHP_push'); if($res){ //获得数据 echo 'dbo Redis:'.$id."\r\n"; //编写自己的逻辑 } //设置延时时间 sleep(0.5); } ?> ``` 实现效果： 