本文主要给大家介绍MySQL之特定SQL下的并发性能测试讲义，希望可以给大家补充和更新些知识，如有其它问题需要了解的可以持续在亿速云行业资讯里面关注我的更新文章的。
从全文检索或者缓存中获取ID，根据ID查询数据库获取基础信息，进行页面展示
SQL：select * from table where id in(id1,id2,id3...id40)
mysql的具体配置不在这里列举，即下面的性能报告只是特定场景下的性能分析，不代表mysql的“真实”性能。本文核心是提供一种测试方法，而不是单纯的提供一份数据报告 。
mysql_test.php
<?php
ini_set('memory_limit', '1280M'); //协程会耗费较多的内存
define('MAX_MYSQLPOOL_NUM', $argv['1']); //mysql最大连接数，即并发数
define('TESTCOUNT', $argv['2']); //一共的测试次数
$mysqlconf = [
'host' => '127.0.0.1',
'port' => 3307,
'user' => 'root',
'password' => '123456',
'database' => '',
'timeout' => 10
];
Swoole\Coroutine::create(function () use ($mysqlconf) {
$stime = microtime(true); //程序开始时间
$pool = new MysqlPool($mysqlconf);
$chan = new chan(MAX_MYSQLPOOL_NUM); //并发数，协程间使用channel通信
for($i = 1; $i< TESTCOUNT + MAX_MYSQLPOOL_NUM; $i++) {
$chan->push('x');
Swoole\Coroutine::create(function() use($pool, $chan, $i) {
//测试的业务逻辑开始
$conn = $pool->get();
if($conn) {
$sql = "select /* parallel */ * from table where id in (".implode(',', getRandpid()).')';
$time1 = microtime(true);
$conn->query($sql);
$time2 = microtime(true);
if($i % intval(TESTCOUNT / 10) == 0) { //输出执行的进度
echo "\n finish $i / ".TESTCOUNT;
}
$pool->put($conn, (($time2 - $time1) * 1000)); //每次查询耗时就不单独做实例，直接修改连接池类做简单统计
} else {
echo "\n connect mysql fail，跳过SQL";
}
//业务逻辑结束
$chan->pop();
});
}
$etime = microtime(true);
echo "\n ============执行结果=============";
echo "\n 并发数量： ".MAX_MYSQLPOOL_NUM;
echo "\n 查询次数： ".TESTCOUNT;
echo "\n 执行总耗时： ".intval($etime - $stime)."秒\n";
echo "\n QPS (查询次数/总耗时) :". intval((TESTCOUNT / ($etime - $stime)));
echo "\n 每次查询耗时平均值：".intval($pool->alltime / TESTCOUNT) ."ms";
echo "\n ============end=============\n";
die;
});
//数据库连接池，https://wiki.swoole.com/wiki/page/852.html
class MysqlPool
{
protected $pool;
private $mysqlconf;
public $alltime;
public function __construct($mysqlconf)
{
$this->pool = new SplQueue();
$this->mysqlconf = $mysqlconf;
$this->alltime = 0;
}
public function put($mysql, $time = 0)
{
$this->pool->push($mysql);
$this->alltime += $time;
}
public function get()
{
//有空闲连接
if (count($this->pool) > 0) {
return $this->pool->pop();
}
$mysql = new Swoole\Coroutine\Mysql();
$res = $mysql->connect($this->mysqlconf);
if ($res == false) {
echo "\n connect error info: ".$mysql->error."\n";
return false;
} else {
return $mysql;
}
}
}
//随机生成的数字
function getRandpid()
{
for ($i = 0; $i < 40; ++$i) {
$ret[] = rand(1, 185724600);
}
return $ret;
}测试代码：修改以上代码
2：“业务逻辑”部分中的SQL改为：
$sql = "select * from table_10 where id in (".implode(',', getRandpid()).')';
测试指令：
php mysql_test.php 1 1000 //并发为1，查询1000次
php mysql_test.php 10 1000 //并发为10，查询1000次
php mysql_test.php 50 10000 //并发为50，查询10000次
...
php mysql_test.php 500 100000 //并发为500，查询100000次
测试结果：
说明
查询oneproxy。因为查询id是随机的，每查一次oneproxy，对应查询的是40个mysql的表。
即，当oneproxy的并发数为1，mysql的对应并发数是40
测试代码：
以上提供的代码即为此种情况的代码，无须修改。
测试指令：
php mysql_test.php 1 1000 //并发为1，查询1000次
php mysql_test.php 10 1000 //并发为10，查询1000次
php mysql_test.php 50 10000 //并发为50，查询10000次
...
php mysql_test.php 100 10000 //并发为100，查询10000次
测试结果：
分到两台，测试结果：
最后，关注性能的同时，也要关注系统的稳定性、开发者的易用性、易维护性。
看了以上关于MySQL之特定SQL下的并发性能测试讲义，希望能给大家在实际运用中带来一定的帮助。本文由于篇幅有限，难免会有不足和需要补充的地方，如有需要更加专业的解答，可在官网联系我们的24小时售前售后，随时帮您解答问题的。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
