发表新帖

刚完成的一个DOME,多SQL并发.

经常有一些慢查询需要做任务处理.为提高效率.用SWOOLE做了个DEMO,请大大给点建议.初步想法是把多条SQL分发后来并发处理.
client.php
{{{php
define('BR', PHP_SAPI==='cli' ? "\n" : "<br />");
$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_SYNC);
$client->connect('127.0.0.1', 9501);
$client->send('aaa' . "\r\n\r\n");
$rsdata='';
while(true){
	$rsdata.=$client->recv();
	if(substr($rsdata,-4)=="\r\n\r\n"){
		break;
	}
}
$client->close();
$rsdata=trim($rsdata);
echo strlen($rsdata).BR;
}}}

service.php
{{{php
define('BR', PHP_SAPI==='cli' ? "\n" : "<br />");
$serv = new swoole_server("127.0.0.1", 9501);
$serv->on('Connect', function($serv, $fd){
	//echo "Client:Connect $fd.\n";
});
$serv->on('close', function($serv, $fd) {
	echo "Client: Close {$fd}\n";
});
$serv->on('Receive', function($serv, $fd, $from_id, $data){
	$cmd=trim($data);
	if($cmd==='aaa')
	{
		$sqls=array(
			'SELECT * FROM ecm_goods WHERE goods_id>20850313 AND goods_id<20850413 ORDER BY goods_id DESC',
			'SELECT * FROM ecm_member WHERE user_id>10 AND user_id<200 ORDER BY user_id ASC',
			'SELECT * FROM ecm_store WHERE store_id>1783 AND store_id<2000 ORDER BY store_id DESC',
		);
		$rs_data=array();
		foreach($sqls as $sql){
			echo 'for '.$fd.': '.$sql.BR;
			$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_SYNC);
			$client->connect('127.0.0.1', 9501);
			$client->send($sql);
			$tmp='';
			while(true){
				$tmp.=$client->recv();
				if(substr($tmp,-4)=="\r\n\r\n"){
					break;
				}
			}
			$tmp=trim($tmp);
			echo strlen($tmp).BR;
			$rs_data[]=$tmp;
			unset($tmp);
			$client->close();
		}

$rstr=serialize($rs_data);
		echo strlen($rstr).BR;
		$serv->send($fd, $rstr."\r\n\r\n");
	}
	else
	{
		$res=sqlRsFor($cmd);
		$sql_rs_data=serialize($res);
		$sql_rs_len=strlen($sql_rs_data);
		unset($res);
		$serv->send($fd, $sql_rs_data."\r\n\r\n");
		echo 'cmd: '.$cmd.' -> END '. $sql_rs_len . BR;
	}
	if($fd > $max_fd)$max_fd=$fd;
//	echo 'Receive: '.$from_id.' '.$max_fd.' '.$fd.' '.$data.' '.BR;
});
}}}

各位大神给点建议.写的很蹩脚..................

发布于8年前 · 0 次浏览 · 来自提问

童

童年的我们无拘无束,@#现

各位大神给点建议.写的很蹩脚..................