介绍
这篇文章将为大家详细讲解有关怎么在php中利用复述,高并发实现发的帖,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。
<强> weibo_redis。php 强>
& lt; php ?//此处需要安装phpredis扩展 $ redis =, new 复述(); 复述→美元连接(& # 39;127.0.0.1 # 39;,,6379); 复述→美元身份验证(“php001");//连接复述 $ web_info=,阵列( & # 39;uid # 39;,=祝辞,$ _REQUEST (uid),,//发布者id & # 39;用户名# 39;,=祝辞,$ _REQUEST(用户名)//发布者用户名 & # 39;内容# 39;,=在$ _REQUEST[内容]//微博内容 );//将数组转成json来存储 $ list =, json_encode ($ web_info);//lpush向关键对应的头部添加一个字符串元素 复述→美元lpush (& # 39; weibo_lists& # 39;,美元列表); 复述→美元close (); var_dump($列表); 祝辞;
模拟后台进程从复述队列获取微博
<强> Pdodb.class。php
强>
& lt; php ? class Pdodb { public function  post ($ uid=& # 39; & # 39;, $ username=& # 39; & # 39;, $内容=& # 39;& # 39;){ 尝试{=$ dsn “mysql: localhost, dbname=localhost, dbname=big"; db 美元;=,new PDO (dsn美元,& # 39;大# 39;,& # 39;123456 & # 39;); $ db→exec (“SET  NAMES UTF8"); sql 美元;=癷nsert into  ih_weibo (uid、用户名、内容)值(& # 39;uid # 39;美元,& # 39;用户名# 39;美元,& # 39;内容# 39;美元)“;//echo $ sql; 美元$ db→exec (sql); }捕捉(PDOException $ e) { echo $ e→getMessage (); } } }
<强> weibo_mysql。php 强>
& lt; php ? require_once & # 39; Pdodb.class.php& # 39;; set_time_limit(0);,//,取消脚本运行时间的超时上限 $ pdo =, new Pdodb (); $ redis =, new 复述(); 复述→美元连接(& # 39;127.0.0.1 # 39;,,6379); while (真实),{//返回的列表的大小。如果列表不存在或为空,该命令返回0。如果该键不是列表,该命令返回错误的 如果(redis 美元;→,lsize (& # 39; weibo_lists& # 39;)) {//从列表头部删除并返回删除数据 美元$ info =,复述,→rpop (& # 39; weibo_lists& # 39;); $ info =, json_decode ($ info); pdo→美元post(信息→美元uid,美元信息→用户名、信息→美元内容); } 复述→美元close (); 睡眠(10);//延时10秒 }
后台执行weibo_mysql。php
nohup php/var/www/html/big/weibo_mysql。php和
关于怎么在php中利用复述,高并发实现发帖就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看的到。