Server : Apache/2.4.6 (CentOS) OpenSSL/1.0.2k-fips PHP/7.4.20 System : Linux st2.domain.com 3.10.0-1127.10.1.el7.x86_64 #1 SMP Wed Jun 3 14:28:03 UTC 2020 x86_64 User : apache ( 48) PHP Version : 7.4.20 Disable Function : NONE Directory : /var/www/html/trader/vendor/workerman/globaldata/src/ |
<?php
namespace GlobalData;
use Workerman\Worker;
/**
* Global data server.
*/
class Server
{
/**
* Worker instance.
* @var worker
*/
protected $_worker = null;
/**
* All data.
* @var array
*/
protected $_dataArray = array();
/**
* Construct.
* @param string $ip
* @param int $port
*/
public function __construct($ip = '0.0.0.0', $port = 2207)
{
$worker = new Worker("frame://$ip:$port");
$worker->count = 1;
$worker->name = 'globalDataServer';
$worker->onMessage = array($this, 'onMessage');
$worker->reloadable = false;
$this->_worker = $worker;
}
/**
* onMessage.
* @param TcpConnection $connection
* @param string $buffer
*/
public function onMessage($connection, $buffer)
{
if($buffer === 'ping')
{
return;
}
$data = unserialize($buffer);
if(!$buffer || !isset($data['cmd']) || !isset($data['key']))
{
return $connection->close(serialize('bad request'));
}
$cmd = $data['cmd'];
$key = $data['key'];
switch($cmd)
{
case 'get':
if(!isset($this->_dataArray[$key]))
{
return $connection->send('N;');
}
return $connection->send(serialize($this->_dataArray[$key]));
break;
case 'set':
$this->_dataArray[$key] = $data['value'];
$connection->send('b:1;');
break;
case 'add':
if(isset($this->_dataArray[$key]))
{
return $connection->send('b:0;');
}
$this->_dataArray[$key] = $data['value'];
return $connection->send('b:1;');
break;
case 'increment':
if(!isset($this->_dataArray[$key]))
{
return $connection->send('b:0;');
}
if(!is_numeric($this->_dataArray[$key]))
{
$this->_dataArray[$key] = 0;
}
$this->_dataArray[$key] = $this->_dataArray[$key]+$data['step'];
return $connection->send(serialize($this->_dataArray[$key]));
break;
case 'cas':
$old_value = !isset($this->_dataArray[$key]) ? null : $this->_dataArray[$key];
if(md5(serialize($old_value)) === $data['md5'])
{
$this->_dataArray[$key] = $data['value'];
return $connection->send('b:1;');
}
$connection->send('b:0;');
break;
case 'delete':
unset($this->_dataArray[$key]);
$connection->send('b:1;');
break;
default:
$connection->close(serialize('bad cmd '. $cmd));
}
}
}