全网整合营销服务商

电脑端+手机端+微信端=数据同步管理

免费咨询热线:400-708-3566

php结合redis高并发下发帖、发微博的实现方法

发帖、发微博、点赞、评论等这些操作很频繁的动作如果并发量小,直接入库是最简单的

但是并发量一大,数据库肯定扛不住,这时可采取延迟发布:先将发布动作保存在队列里,后台进程循环获取再入库

模拟发布微博先进入redis队列

weibo_redis.php

<?php
//此处需要安装phpredis扩展
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis->auth("php001");
//连接redis
$web_info= array(
	'uid' => $_REQUEST[uid], //发布者id
	'username' => $_REQUEST[username],//发布者用户名
	'content' =>$_REQUEST[content],//微博内容
);


//将数组转成json来存储
$list = json_encode($web_info);
//lpush向KEY对应的头部添加一个字符串元素
$redis->lpush('weibo_lists',$list);
$redis->close();
var_dump($list);
?>

模拟后台进程从redis队列获取微博

Pdodb.class.php

<?php
class Pdodb{
	public function post($uid='',$username='',$content=''){
		try{
			$dsn = "mysql:localhost;dbname=localhost;dbname=big";
			$db = new PDO($dsn,'big','123456');	
			$db->exec("SET NAMES UTF8");
			$sql ="insert into ih_weibo(uid,username,content)values('$uid','$username','$content')";
			//echo $sql;
			$db->exec($sql);
		}catch(PDOException $e){
			echo $e->getMessage();
		}
	}
}

weibo_mysql.php

<?php
require_once 'Pdodb.class.php';
set_time_limit(0); // 取消脚本运行时间的超时上限


$pdo = new Pdodb();
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);


while (true) {
	//返回的列表的大小。如果列表不存在或为空,该命令返回0。如果该键不是列表,该命令返回false
	if($redis -> lsize('weibo_lists')){
		//从LIST头部删除并返回删除数据
		$info = $redis->rpop('weibo_lists');
		$info = json_decode($info);
		$pdo->post($info->uid,$info->username,$info->content);
	}
	$redis->close();
	sleep(10);//延时10秒
}

后台执行weibo_mysql.php

nohup php /var/www/html/big/weibo_mysql.php &

以上这篇php结合redis高并发下发帖、发微博的实现方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。


# redis  # 高并发  # PHP并发场景的三种解决方案代码实例  # php并发加锁问题分析与设计代码实例讲解  # PHP解决高并发的优化方案实例  # php多进程模拟并发事务产生的问题小结  # PHP利用Mysql锁解决高并发的方法  # php curl批处理实现可控并发异步操作示例  # php处理抢购类功能的高并发请求  # PHP+Redis 消息队列 实现高并发下注册人数统计的实例  # PHP开发中解决并发问题的几种实现方法分析  # PHP使用Redis实现防止大并发下二次写入的方法  # 详解php处理大并发大流量大存储  # 给大家  # 一大  # 希望能  # 不存在  # 这篇  # 最简单  # 先将  # 小编  # 转成  # 大家多多  # 为空  # 再入  # uid  # id  # _REQUEST  # auth  # array  # web_info  # KEY  # lpush 


相关文章: 详解ASP.NET 生成二维码实例(采用ThoughtWorks.QRCode和QrCode.Net两种方式)  建站主机SSH密钥生成步骤及常见问题解答?  如何选择适配移动端的WAP自助建站平台?  广州商城建站系统开发成本与周期如何控制?  SAX解析器是什么,它与DOM在处理大型XML文件时有何不同?  建站之星官网登录失败?如何快速解决?  如何通过FTP空间快速搭建安全高效网站?  大连网站设计制作招聘信息,大连投诉网站有哪些?  在线流程图制作网站手机版,谁能推荐几个好的CG原画资源网站么?  韩国网站服务器搭建指南:VPS选购、域名解析与DNS配置推荐  建站之星下载版如何获取与安装?  网站制作外包价格怎么算,招聘网站上写的“外包”是什么意思?  如何破解联通资金短缺导致的基站建设难题?  建站之星CMS五站合一模板配置与SEO优化指南  已有域名如何免费搭建网站?  学校免费自助建站系统:智能生成+拖拽设计+多端适配  广州网站建站公司选择指南:建站流程与SEO优化关键词解析  宠物网站制作html代码,有没有专门介绍宠物如何养的网站啊?  昆明网站制作哪家好,昆明公租房申请网上登录入口?  整蛊网站制作软件,手机不停的收到各种网站的验证码短信,是手机病毒还是人为恶搞?有这种手机病毒吗?  唐山网站制作公司有哪些,唐山找工作哪个网站最靠谱?  深圳网站制作案例,网页的相关名词有哪些?  C++如何使用std::optional?(处理可选值)  宿州网站制作公司兴策,安徽省低保查询网站?  网站制作公司排行榜,四大门户网站排名?  如何通过二级域名建站提升品牌影响力?  如何用VPS主机快速搭建个人网站?  制作网站的网址是什么,请问后缀为.com和.com.cn还有.cn的这三种网站是分别是什么类型的网站?  如何快速查询域名建站关键信息?  ,想在网上投简历,哪几个网站比较好?  如何选择建站程序?包含哪些必备功能与类型?  实例解析angularjs的filter过滤器  网站制作软件有哪些,制图软件有哪些?  单页制作网站有哪些,朋友给我发了一个单页网站,我应该怎么修改才能把他变成自己的呢,请求高手指点迷津?  创业网站制作流程,创业网站可靠吗?  如何实现建站之星域名转发设置?  山东云建站价格为何差异显著?  广德云建站网站建设方案与建站流程优化指南  如何快速上传自定义模板至建站之星?  网站制作服务平台,有什么网站可以发布本地服务信息?  怀化网站制作公司,怀化新生儿上户网上办理流程?  如何高效利用200m空间完成建站?  广州建站公司哪家好?十大优质服务商推荐  标准网站视频模板制作软件,现在有哪个网站的视频编辑素材最齐全的,背景音乐、音效等?  如何获取PHP WAP自助建站系统源码?  网站制作免费,什么网站能看正片电影?  广州网站设计制作一条龙,广州巨网网络科技有限公司是干什么的?  制作网站的过程怎么写,用凡科建站如何制作自己的网站?  如何通过IIS搭建网站并配置访问权限?  如何在建站主机中优化服务器配置? 

您的项目需求

*请认真填写需求信息,我们会在24小时内与您取得联系。