{

protected $_server = null;

protected $_ip = "0.0.0.0";

protected $_port = 9569;

protected $_config;

//server report

final public function discovery(array $config)

{

$self = $this;

$this->_server->addProcess(new \swoole_process(function () use ($config, $self) {

swoole_set_process_name("dora: monitor service");

static $_redisObj = array();

while (true) {

//for result list

$serverListResult = array();

//get redis config

$redisConfig = $self->_config["redis"];

//connect all redis

foreach ($redisConfig as $redisItem) {

//validate redis ip and port

if (trim($redisItem["ip"]) && $redisItem["port"] > 0) {

$key = $redisItem["ip"] . "_" . $redisItem["port"];

try {

//connecte redis

if (!isset($_redisObj[$key])) {

//if not connect

$_redisObj[$key] = new \Redis();

$_redisObj[$key]->connect($redisItem["ip"], $redisItem["port"]);

}

//get register node server

$serverList = $_redisObj[$key]->smembers("dora.serverlist");

if ($serverList) {

foreach ($serverList as $sitem) {

$info = json_decode($sitem, true);

//decode success

if ($info) {

//get last report time

$lastTimeKey = "dora.servertime." . $info["node"]["ip"] . "." . $info["node"]["port"] . ".time";

$lastUpdatTime = $_redisObj[$key]->get($lastTimeKey);

//timeout ignore

if (time() - $lastUpdatTime > 20) {

continue;

}

if (is_array($info["group"])) {

foreach ($info["group"] as $groupname) {

$clientkey = $info["node"]["ip"] . "_" . $info["node"]["port"];

$serverListResult[$groupname][$clientkey] = array("ip" => $info["node"]["ip"], "port" => $info["node"]["port"]);

$serverListResult[$groupname][$clientkey]["updatetime"] = $lastUpdatTime;

}

}

//foreach group and record this info

}//decode info if

}// foreach

}//if got server list from redis

} catch (\Exception $ex) {

//var_dump($ex);

$_redisObj[$key] = null;

echo "get redis server error" . PHP_EOL;

}

}

}

if (count($serverListResult) > 0) {

$configString = var_export($serverListResult, true);

$ret = file_put_contents($this->_config["export_path"], "<?php" . PHP_EOL . "//This is generaled by client monitor" . PHP_EOL . "return " . $configString . ";");

if (!$ret) {

echo "Error save the config to file..." . PHP_EOL;

} else {

echo "General config file to:" . $this->_config["export_path"] . PHP_EOL;

}

} else {

echo "Error there is no Config get..." . PHP_EOL;

}

//sleep 10 sec

sleep(10);

}

}));

}

public function __construct($ip = "0.0.0.0", $port = 9569, $config = array())

{

//record ip:port

$this->_ip = $ip;

$this->_port = $port;

//create server object

$this->_server = new \swoole_server($ip, $port, \SWOOLE_PROCESS, \SWOOLE_SOCK_UDP);

//set config

$this->_server->set(array(

'open_length_check' => 1,

'dispatch_mode' => 3,

'package_length_type' => 'N',

'package_length_offset' => 0,

'package_body_offset' => 4,

'package_max_length' => 1024 * 1024 * 2,

'buffer_output_size' => 1024 * 1024 * 3,

'pipe_buffer_size' => 1024 * 1024 * 32,

'open_tcp_nodelay' => 1,

'heartbeat_check_interval' => 5,

'heartbeat_idle_time' => 10,

'reactor_num' => 1,

'worker_num' => 2,

'task_worker_num' => 0,

'max_request' => 0, //必须设置为0否则并发任务容易丢,don't change this number

'task_max_request' => 4000,

'backlog' => 2000,

'log_file' => '/tmp/sw_monitor.log',

'task_tmpdir' => '/tmp/swmonitor/',

'daemonize' => 0,//product env is 1

));

//register the event

$this->_server->on('Packet', array($this, 'onPacket'));

echo "Start Init Server udp://" . $ip . ":" . $port . PHP_EOL;

//store the list of redis

$this->_config["redis"] = $config["discovery"];

//store the avaliable node list to this config file

$this->_config["export_path"] = $config["config"];

//log monitor path

$this->_config["log_path"] = $config["log"];

$this->discovery($this->_config["redis"]);

}

public function start()

{

$this->_server->start();

}

public function onPacket(\swoole_server $server, $data, $client_info)

{

//$data = \DoraDRPC\Base\Packet::packDecode($data);

//$server->sendto($client_info['address'], $client_info['port'], \DoraDRPC\Base\Packet::packEncode(array()));

//var_dump($server, $data);

}