php处理高并发框架 swoole是怎样解决高并发的

我爱编程网小编给大家带来了php处理高并发框架 swoole是怎样解决高并发的相关文章，一起来看一下吧。

用PHP编写支持高并发的网站，需要做什么处理？

PHP语言开发高并发的网站，需要加缓存，复杂逻辑走消息队列异步处理，mysql查询必须走索引，还搞不定就加机器分流，mysql配置升高并且一主多从，使用codis集群，增加消息队列的消费者，如果还搞不定就随机拒绝请求，当然这是最后的退路。

缓存

缓存是避免业务查询过多的请求mysql，导致业务不可用，根据场景来判断是否需要使用codis集群，如果并发量没有达到某个级别，16G的redis也可以，但是要避免redis在高并发下容易发生的缓存穿透，尽量做成高可用，并保证缓存实现的 命中率 。

消息队列

这也是高并发情境下的杀手锏，削峰填谷，将耗时的业务逻辑直接以队列的形式异步慢慢处理，防止请求过度积压，导致的服务器不可用。

mysql优化

有些场景下必须查询mysql的，也应该走索引，避免多表联合查询，甚至mysql的事务隔离级别都尽量的降低，或者直接去掉事务，采用最终一致性的补偿机制。升级mysql的配置，核心数和内存的提升对查询速度的优化是显而易见的，最好能一步到位的走一主多从，查询路由到从服务器上。

随机拒绝请求

这不是开玩笑，我们必须保证服务器可用，宁愿拒绝掉一些请求，也不能让服务器大量请求阻塞，最终导致大家都用不了。

swoole是怎样解决高并发的

1、swoole介绍
swoole是PHP的一个扩展。
简单理解：swoole=异步I/O+网络通信
PHPer可以基于swoole去实现过去PHP无法实现的功能。
2、swoole如何处理高并发
①Reactor模型介绍
IO复用异步非阻塞程序使用经典的Reactor模型，Reactor顾名思义就是反应堆的意思，它本身不处理任何数据收发。只是可以监视一个socket(也可以是管道、eventfd、信号)句柄的事件变化。Reactor只是一个事件发生器，实际对socket句柄的操作，如connect/accept、send/recv、close是在callback中完成的。
②swoole的架构
swoole采用 多线程Reactor+多进程Worker，因为reactor基于epoll，所以每个reactor可以处理无数个连接请求。 如此，swoole就轻松的处理了高并发。

我爱编程网

php怎样应对高并发

高并发下的数据安全
我们知道在多线程写入同一个文件的时候，会出现“线程安全”的问题（多个线程同时运行同一段代码，如果每次运行结果和单线程运行的结果是一样的，结果和预期相同，就是线程安全的）。
如果是MySQL数据库，可以使用它自带的锁机制很好的解决问题，但是在大规模并发的场景中，是不推荐使用MySQL的。秒杀和抢购的场景中，最关键的问题，就是“超发”，如果在这方面控制不慎，会导致实际产生的订单比预售商品还多的问题。
超发的原因：（推荐学习：PHP编程从入门到精通）
假设某个抢购场景中，我们一共只有100个商品，在最后一刻，我们已经消耗了99个商品，仅剩最后一个。这个时候，系统发来多个并发请求，这批请求读取到的商品余量都是1个，然后都通过了余量的判断，最终导致超发。
值得注意的是：记得将库存字段number字段设为unsigned，当库存为0时，因为unsigned字段不能为负数，将会返回false
优化方案
优化1：使用MySQL的事务，锁住操作的行 BEGIN ; SELECT ... FOR UPDATE ; COMMIT ; ROLLBACK
<?php
//优化方案1：使用MySQL的事务，锁住操作的行
include('./mysql.php');
function build_order_no(){
return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//记录日志
function insertLog($event,$type=0){
global $conn;
$sql="insert into ih_log(event,type)
values('$event','$type')";
mysqli_query($conn,$sql);
}

mysqli_query($conn,"BEGIN"); //开始事务
$sql="select number from ih_store where goods_id='$goods_id' and sku_id='$sku_id' FOR UPDATE";//此时这条记录被锁住,其它事务必须等待此次事务提交后才能执行
$rs=mysqli_query($conn,$sql);
$row=$rs->fetch_assoc();

if($row['number']>0){
//生成订单
$order_sn=build_order_no();
$sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price)
values('$order_sn','$user_id','$goods_id','$sku_id','$price')";
$order_rs=mysqli_query($conn,$sql);
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
$store_rs=mysqli_query($conn,$sql);
if($store_rs){
echo '库存减少成功';
insertLog('库存减少成功');
mysqli_query($conn,"COMMIT");//事务提交即解锁
}else{
echo '库存减少失败';
insertLog('库存减少失败');
}
}else{
echo '库存不够';
insertLog('库存不够');
mysqli_query($conn,"ROLLBACK");
}优化2：文件锁的思路
对于日访问量不高或者说并发数不是很大的应用，用一般的文件操作方法完全没有问题。但如果并发高，在我们对文件进行读写操作时，很有可能多个进程对进一文件进行操作，如果这时不对文件的访问进行相应的独占，就容易造成数据丢失。
<?php
//优化方案2：使用非阻塞的文件排他锁
include ('./mysql.php');
//生成唯一订单号
function build_order_no(){
return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}

//记录日志
function insertLog($event,$type=0){
global $conn;
$sql="insert into ih_log(event,type)
values('$event','$type')";
mysqli_query($conn,$sql);
}
$fp = fopen("lock.txt", "w+");
if(!flock($fp,LOCK_EX | LOCK_NB)){
echo "系统繁忙，请稍后再试";
return;
}

//下单
$sql="select number from ih_store where goods_id='$goods_id' and sku_id='$sku_id'";
$rs = mysqli_query($conn,$sql);
$row = $rs->fetch_assoc();
if($row['number']>0){//库存是否大于0
//模拟下单操作
$order_sn=build_order_no();
$sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price)
values('$order_sn','$user_id','$goods_id','$sku_id','$price')";
$order_rs = mysqli_query($conn,$sql);
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
$store_rs = mysqli_query($conn,$sql);
if($store_rs){
echo '库存减少成功';
insertLog('库存减少成功');
flock($fp,LOCK_UN);//释放锁
}else{
echo '库存减少失败';
insertLog('库存减少失败');
}
}else{
echo '库存不够';
insertLog('库存不够');
}

fclose($fp);

以上就是我爱编程网小编给大家带来的php处理高并发框架 swoole是怎样解决高并发的，希望能对大家有所帮助。