百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

php如何实现秒杀功能?php+redis模拟简单抢购场景,快来看看吧

wptr33 2025-01-12 19:06 10 浏览

序言:php+redis实现秒杀功能,可缓解瞬时并发对mysql的压力,也是面试过程以及工作中常用到的知识点,如果对你有帮助的话赶紧点赞收藏吧。

本文用到的知识点需要提前安装redis,php如何安装redis请看之前的文章。

windows下给php安装redis扩展,并把redis单独注册为服务

场景:在某个时间点对商品goods_id=2的商品进行抢购,商品库存为10

建立商品goods_id=2的库存抢购列表

首先创建待抢购商品的list列表,如果有人抢购成功就移除一个,直到列表为空则表示抢购完成。

//1、连接redis数据库
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis_name = 'goods_id_2';//比如商品id=2的商品参与秒杀
//2、模拟抢购,库存为10,将库存放到redis中
$num = 10;
for($i=0;$i<$num;$i++){
	$redis->lPush($redis_name,1);//这里用某个商品的ID作为标识
}
echo "执行成功";

客户端进行模拟抢购

//1、连接redis数据库
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis_name = 'goods_id_2';//比如商品id=2的商品参与秒杀


//3、模拟用户请求,随机获取10名用户表示抢购成功
for($i=0;$i<100;$i++){
	$user_id = rand(100,999);
	$len = $redis->lLen($redis_name);
	$str = "";
	if(!$len || $len<=0){
		$str .= $user_id."抢购已结束";
		break;
	}else{
		$redis_user_name = "goods_id_2_user_id";
		//判断抢购列表中是否已存在该用户,获取列表中所有的数据
		$skill_list = $redis->lrange($redis_user_name, 0, -1);
		if(in_array($user_id, $skill_list)){
			$str .= $user_id."请勿重复提交";
		}else{
			$redis->rPop($redis_name);
			$redis->lPush($redis_user_name,$user_id."_".ceil(microtime(true)*1000));
			$str .= $user_id."已抢到";
		}
	}
	file_put_contents("D:/wwwroot/test/skill/cron.txt", $str."\r\n",FILE_APPEND);
}

echo '执行完成';

服务端执行队列处理,将redis中已抢购的用户保存到数据库中

<?php
$mysql_server_name = 'localhost'; //改成自己的mysql数据库服务器
$mysql_username = 'root'; //改成自己的mysql数据库用户名
$mysql_password = '123456'; //改成自己的mysql数据库密码
$mysql_database = 'test'; //改成自己的mysql数据库名
$conn=mysqli_connect($mysql_server_name,$mysql_username,$mysql_password,$mysql_database); //连接数据库
//连接数据库错误提示
if (mysqli_connect_errno($conn)) {
	die("连接 MySQL 失败: " . mysqli_connect_error());
}
mysqli_query($conn,"set names utf8"); //数据库编码格式
//1、连接redis数据库
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis_name = 'goods_id_2';//比如商品id=2的商品参与秒杀
//2、将list队列中的数据读取出来然后执行入库
$redis_user_name = "goods_id_2_user_id";
while(true){
	//判断抢购列表中是否已存在该用户,获取列表中所有的数据
	$result = $redis->rpop($redis_user_name);
	if($result){
		$skill_arr = array_filter(explode("_", $result));
		$sql = "insert into skill (user_id,timestamp) values({$skill_arr[0]},{$skill_arr[1]})";
		mysqli_query($conn,$sql); 
	}
}
echo "执行成功";

以上就是简单实现秒杀的场景,具体的代码还要根据实际的逻辑进行调整。

你学会了吗,赶紧点赞收藏试一试吧。

我是小程序软件开发,每天分享开发过程中遇到的知识点,如果对你有帮助的话,帮忙点个赞再走呗,非常感谢。

往期文章分享:

windows下安装php+apache的运行环境,并把apache单独注册为服务

telnet命令你了解多少?除了可以验证端口,还可以模拟邮件发送

相关推荐

每天一个AI姬,AMD核显用户有福了,AI绘画打破 NVIDIA 显卡垄断

使用StableDiffusion进行AI绘画,并不一定只能使用NVIDIA英伟达显卡,甚至,也不一定只能使用独立显卡。今天我们使用AMD6800H核显,并安装了StableDif...

NETworkManager:功能强大的网络管理与问题排除工具

关于NETworkManagerNETworkManager是一款功能强大的网络管理与问题排除工具,该工具完全开源,可以帮助广大研究人员轻松管理目标网络系统并排除网络疑难问题。该工具使用远程桌面、Po...

AMD也能深度学习+免费AI绘画:StableDiffusion+ROCm部署教程!

某国政客扇扇嘴皮子,CN玩硬件和深度学习的圈子里就掀起了一场风暴,这就是著名的嘴皮子效应(误)。没了高性能计算的A100H100倒也能理解,但是美利坚这波把RTX4090禁售了就让人无语了,所以不少做...

windows 下编译 python_rtmpstream

最近在研究数字人,看了大咖的项目(https://github.com/lipku/metahuman-stream),尝试编译此项目的依赖项目python_rtmpstream(https://gi...

如何使用 Python 操作 Git 代码?GitPython 入门介绍

花下猫语:今天,我在查阅如何用Python操作Gitlab的时候,看到这篇文章,觉得还不错,特分享给大家。文中还提到了其它几种操作Git的方法,后续有机会的话,再陆续分享之~~作者:匿蟒...

网上看了不少,终于把ZlmediaKit流媒体框架搭建起来啦

你都站在2023年代了,视频通话、视频直播、视频会议、视频监控就是风口浪尖上的猪师兄,只要你学那么一丁点,拿个高薪的工作不过分吧!我也是半瓶子晃荡的,所以路人呀,共学习,同进步!本篇开始,只讲在Lin...

MacDown:一款 macOS 的强大 Markdown 编辑器

大家好,很高兴又见面了,我是"...

ZLMediaKit安装配置和推拉流

一、ZLMediaKit库简介ZLMediaKit是一个基于...

大神赞过的:学习 WebAssembly 汇编语言程序设计

文/阿里淘系F(x)Team-旭伦随着前端页面变得越来越复杂,javascript的性能问题一再被诟病。而Javascript设计时就不是为了性能优化设计的,这使得浏览器上可以运行的本地语言一...

【Docker】部署WVP视频监控平台

回来Docker系列,今天将会跟大家分享一则关于开源WVP视频监控平台的搭建。先说结论吧,一开始按照网上说的一步一步搭建没有搭建成功,不知道是版本太旧还是我这边机器有问题,尝试了好几个不同方式的搭建都...

MongoDB+GridFS存储文件方案

GridFS是MongoDB的一个内置功能,它提供一组文件操作的API以利用MongoDB存储文件,GridFS的基本原理是将文件保存在两个Collection中,一个保存文件索引,一个保存文...

【开源】强大、创新且直观的 EDA套件

今天分享的LibrePCB是...

Ollama如何制作自己的大模型?

背景Llama3发布了,这次用了...

Ollama使用指南【超全版】

一、Ollama快速入门Ollama是一个用于在本地运行大型语言模型的工具,下面将介绍如何在不同操作系统上安装和使用Ollama。官网:https://ollama.comGithub:http...

基于区块链的价值共享互联网即时通讯应用平台源码免费分享

——————关注转发之后私信回复【源码】即可免费获取到本项目所有源码基于区块链的价值共享互联网即时通讯应用平台,是一个去中心化的任何人都可以使用的通讯网络,是一款基于区块链的价值共享互联网即时通讯AP...