Category: 服务器运维

什么是PHP高并发？

高并发问题在开发和部署应用程序时经常会遇到，当随着流量变大，会遇到各种各样的技术问题，比如接口响应超时、CPU load升高、GC频繁、死锁、大数据量存储等。例如：淘宝的双11，每秒几十万请求的秒杀系统、每天千万级的订单系统、每天亿级日活的信息流系统等。

高并发处理流程：

• 性能测试
• 服务器扩展
• 监控系统
• 异常处理

一、性能测试

了解测试系统在高负载下的性能表现，发现潜在的瓶颈和问题，可以采用压力测试和性能测试的方法。下面是一些步骤和工具，用以模拟大量并发用户的访问，进行系统性能评估：

1.定义测试目标和指标

• 性能指标：确定你想要测量的性能指标，如响应时间、吞吐量（请求/秒）、并发用户数、资源使用率（CPU、内存、磁盘、网络）等。
• 测试场景：定义具体的用户行为和交互模式，确保覆盖所有关键功能。

2. 选择合适的压力测试工具

• JMeter：Apache JMeter 可用于测试静态和动态资源、Web 动态应用程序的性能。它可用于模拟服务器、服务器组、网络或对象上的重负载，以测试其强度或分析不同负载类型下的整体性能。
• Gatling：Gatling 是另一种高性能的负载测试工具，它提供详细的报告和易于编写的脚本。
• LoadRunner：LoadRunner 是商业软件，适用于更复杂的测试需求，提供广泛的监控和分析功能。
• Locust：Locust 是一个轻量级的负载测试工具，使用Python编写，易于扩展和自定义。

3. 构建测试脚本和场景

• 根据定义的用户行为模式编写测试脚本。这些脚本应该模拟真实用户的各种操作，如登录、浏览页面、提交表单等。
• 配置并发用户数和请求频率，以模拟高并发环境。

以Locust为例：

from locust import HttpUser, between, task


class WebsiteUser(HttpUser):
    wait_time = between(5, 15)
    
    def on_start(self):
        self.client.post("/login", {
            "username": "test_user",
            "password": ""
        })
    
    @task
    def index(self):
        self.client.get("/")
        self.client.get("/static/assets.js")
        
    @task
    def about(self):
        self.client.get("/about/")

4. 执行测试并监控系统表现

• 在测试环境中执行压力测试。确保测试环境与生产环境尽可能相似，以获得准确的结果。
• 实时监控应用和服务器的性能指标，包括CPU、内存、网络IO等。

5. 分析测试结果

• 详细分析测试过程中收集的数据，识别性能瓶颈或失败点。
• 查看响应时间、错误率和系统资源使用情况，确定系统在哪些方面表现不佳。

6. 优化和调整

• 根据测试结果对应用和基础设施进行优化。可能的优化措施包括代码优化、数据库优化、增加服务器资源等。
• 重复测试以验证优化效果，确保所做的改动实际上提高了系统性能。

7. 文档化和持续测试

• 记录测试结果和优化措施，建立性能基准。
• 将性能测试纳入持续集成/持续部署（CI/CD）流程，确保系统随着时间的推移和功能的增加仍能保持良好的性能表现。

通过这样的方法，你可以有效地模拟高并发条件下的用户访问，检测并优化你的系统，确保它能够在实际运行环境中表现良好。

二、服务器拓展

如果性能测试发现服务器无法处理高并发请求，可以考虑扩展服务器。可以增加服务器的硬件配置，如增加CPU、内存等资源。也可以通过添加更多的服务器来实现负载均衡，提高性能。

三、监控系统

部署应用程序后，需要设置监控系统来实时监测服务器的性能。监控系统可以提供关于服务器负载、响应时间、错误率等指标的实时数据，帮助开发者及时发现和解决性能问题。

四、异常处理

在高并发的环境中，各种异常情况可能会频繁发生。开发者需要编写代码，及时处理异常。对于无法立即解决的异常，可以使用容错机制，如降级处理、熔断等方式来保证系统的稳定性。以下是一些处理高并发问题的方法参考：

• 使用缓存：缓存是提高性能的重要工具之一。可以使用内存缓存、数据库缓存或分布式缓存等不同类型的缓存来存储常用的数据或页面。通过减少对数据库的访问，可以大大减轻服务器的负担，提高响应速度。
• 应用服务器和数据库的扩展：通过增加更多的服务器和使用负载均衡（如使用 HAProxy 或 AWS ELB）分散请求，可以显著提高应用处理高并发的能力。优化数据库查询，使用更有效的索引，或者考虑使用更适合读多写少操作的数据库架构，如主从复制。在某些情况下，分库分表也是提高数据库处理能力的有效策略。
• 异步处理：如果应用程序有一些耗时的操作，可以考虑使用异步处理来提高并发能力。将耗时的操作放入消息队列或后台任务中进行处理，然后返回快速响应给用户。

还有利用文件排他锁方式：

• 阻塞模式下，如果进程在获取文件排他锁时，其它进程正在占用锁的话，此进程会挂起等待其它进程释放锁后，并自己获取到锁后，再往下执行。示例如下:

<?php
$http = new swoole_http_server("0.0.0.0", 9510);
$http->set(array(
 'reactor_num' => 2,  //reactor thread num
 'worker_num' => 4    //worker process num
));
$http->on('request', function (swoole_http_request $request, swoole_http_response $response) {
 $uniqid = uniqid('uid-', TRUE);
 $redis = new Redis();
 $redis->connect('127.0.0.1', 6379);
 $fp = fopen("lock.txt", "w+");
 // 阻塞(等待)模式， 要取得独占锁定（写入的程序）
 if (flock($fp,LOCK_EX)) {  //锁定当前指针
 // 成功取得锁后，放心处理订单
 $rest_count = intval($redis->get("rest_count"));
 $value = "{$rest_count}-{$uniqid}";
 if ($rest_count > 0) {
 // do something ...
 $rand = rand(100, 1000000);
 $sum = 0;
 for ($i = 0; $i < $rand; $i++) {$sum += $i;}
 $redis->lPush('uniqids', $value);
 $redis->decr('rest_count');
 }
 // 订单处理完成后，再释放锁
 flock($fp, LOCK_UN);
 }
 fclose($fp);
});
$http->start();

使用 ab 测试：

$ ab -t 20 -c 10 http://192.168.1.104:9510/

• 非阻塞模式下，如果进程在获取文件排他锁时，其它进程正在占用锁的话，此进程会马上判断获取锁失败，并且继续往下执行。示例代码：

<?php
$http = new swoole_http_server("0.0.0.0", 9511);
$http->set(array(
 'reactor_num' => 2,  //reactor thread num
 'worker_num' => 4    //worker process num
));
$http->on('request', function (swoole_http_request $request, swoole_http_response $response) {
 $uniqid = uniqid('uid-', TRUE);
 $redis = new Redis();
 $redis->connect('127.0.0.1', 6379);
 $fp = fopen("lock.txt", "w+");
 // 非阻塞模式， 如果不希望 flock() 在锁定时堵塞，则给 lock 加上 LOCK_NB
 if(flock($fp,LOCK_EX | LOCK_NB))   //锁定当前指针
 {
 // 成功取得锁后，放心处理订单
 $rest_count = intval($redis->get("rest_count"));
 $value = "{$rest_count}-{$uniqid}";
 if($rest_count > 0){
 // do something ...
 $rand = rand(100, 1000000);
 $sum=0;
 for ($i=0;$i<$rand;$i++){ $sum+=$i; }
 $redis->lPush('uniqids', $value);
 $redis->decr('rest_count');
 }
 // 订单处理完成后，再释放锁
 flock($fp,LOCK_UN);
 } else {
 // 如果获取锁失败，马上进入这里执行
 echo "{$uniqid} - 系统繁忙，请稍后再试".PHP_EOL;
 }
 fclose($fp);
});
$http->start();

总结

在应对高并发问题时，开发者需要综合考虑多个因素，通过合理使用缓存、负载均衡、异步处理和数据库优化等方法，可以提高系统的并发能力和性能；通过性能测试、服务器扩展、监控系统和异常处理等操作流程，可以确保系统能够在高并发情况下运行稳定。