php--swoole simple timer use

_db = mysql_connect('192.168.2.130', 'root', '123456');//26上面数据库配置 } public static function getInstance() { if(! (self::$_instance instanceof self) ) { self::$_instance = new self(); } return self::$_instance; } //下列函数用于调整对象的克隆行为 private function __clone() {} public function insert_one(){ if(!mysql_select_db('sakila')){ return false; } $time = time(); $sql = "INSERT INTO sw_db (add_time) VALUES (".$time.")"; $result = mysql_query($sql,$this->_db); } }

_sw)){ $this->_sw = new swoole_server('192.168.2.130', 9501); } } public function run(){ $this->_sw->on('WorkerStart', array($this, 'onStart')); $this->_sw->on('Receive', array($this, 'onReceive')); $this->_sw->start(); } public function onStart(swoole_server $_sw){ $_sw->tick(1000, function ($id) { $this->upsert(); }); } private function upsert(){ $db_sw = Sw::getInstance(); $db_sw->insert_one(); } public function onReceive(swoole_server $_sw){ echo '1'; } } $timer = new Timer(); $timer->run();

#!/bin/sh pid=`ps -ef | grep '/ydy/swoole/Timer.php' | grep -v grep |awk '{print $2}'` if [ "${pid}" = "" ] then php /ydy/swoole/Timer.php & fi