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 

相关文章： 如何用腾讯建站主机快速创建免费网站？  香港代理服务器配置指南：高匿IP选择、跨境加速与SEO优化技巧  如何高效搭建专业期货交易平台网站？  如何用花生壳三步快速搭建专属网站？  家具网站制作软件,家具厂怎么跑业务？  北京建设网站制作公司,北京古代建筑博物馆预约官网？  阿里云网站制作公司,阿里云快速搭建网站好用吗？  如何设置并定期更换建站之星安全管理员密码？  php条件判断怎么写_ifelse和switchcase的使用区别【对比】  国美网站制作流程,国美电器蒸汽鍋怎么用官方网站？  ui设计制作网站有哪些,手机UI设计网址吗？  如何续费美橙建站之星域名及服务？  如何快速搭建高效WAP手机网站？  如何在搬瓦工VPS快速搭建网站？  新网站制作渠道有哪些,跪求一个无线渠道比较强的小说网站，我要发表小说？  哈尔滨网站建设策划,哈尔滨电工证查询网站？  Python如何创建带属性的XML节点  如何挑选优质建站一级代理提升网站排名？  广州营销型建站服务商推荐：技术优势与SEO优化解析  如何通过服务器快速搭建网站？完整步骤解析  如何快速重置建站主机并恢复默认配置？  如何在阿里云香港服务器快速搭建网站？  如何快速生成专业多端适配建站电话？  云南网站制作公司有哪些,云南最好的招聘网站是哪个？  网站微信制作软件,如何制作微信链接？  北京网站制作的公司有哪些,北京白云观官方网站？  如何快速搭建FTP站点实现文件共享？  如何在七牛云存储上搭建网站并设置自定义域名？  IOS倒计时设置UIButton标题title的抖动问题  如何破解联通资金短缺导致的基站建设难题？  香港服务器选型指南：免备案配置与高效建站方案解析  广州顶尖建站服务：企业官网建设与SEO优化一体化方案  如何在万网ECS上快速搭建专属网站？  定制建站流程解析：需求评估与SEO优化功能开发指南  如何使用Golang安装API文档生成工具_快速生成接口文档  贸易公司网站制作流程,出口贸易网站设计怎么做？  如何用搬瓦工VPS快速搭建个人网站？  建站之星后台管理：高效配置与模板优化提升用户体验  小建面朝正北，A点实际方位是否存在偏差？  如何选择适配移动端的WAP自助建站平台？  怎么将XML数据可视化 D3.js加载XML  如何确保FTP站点访问权限与数据传输安全？  如何在景安服务器上快速搭建个人网站？  淘宝制作网站有哪些,淘宝网官网主页？  ppt制作免费网站有哪些,ppt模板免费下载网站？  如何快速登录WAP自助建站平台？  建站之星各版本价格是多少？  网站图片在线制作软件,怎么在图片上做链接？  再谈Python中的字符串与字符编码（推荐）  小程序网站制作需要准备什么资料,如何制作小程序？