会说话的狗

import time
import json
import socket
import traceback
import threading
import SocketServer
 
class Too:
    def __init__(self):
        print 'Welcome!'
 
    def test(self, args):
        return 'xxx:%s' % args;
 
    def error(self, args):
        return 'not function!'
 
class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler):
 
    def handle(self):
        while True:
            try:
                data = self.request.recv(1024)
                if not data:
                    print 'end'
                    break
                data = json.read(data)
                res =  getattr(self._object, data['func'], 'error')(data['args'])
                if not res:
                    res = ''
                res = str(len(res)).rjust(8, '0')+str(res)
                self.request.send(res)
            except:
                print 'error in ThreadedTCPRequestHandler :%s, res:%s' % (traceback.format_exc(), data)
 
class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
    pass
 
class Server:
    def __init__(self, host, port):
        self.host = host
        self.port = port
        ThreadedTCPServer.allow_reuse_address = True
 
    def open(self, object):
        ThreadedTCPRequestHandler._object = object
        server = ThreadedTCPServer((self.host, self.port), ThreadedTCPRequestHandler)
        server.serve_forever()
 
if __name__ == '__main__':
    Server('0.0.0.0', 12580).open(Too())

class server{
 
    private $_host;
    private $_port;
    private $_error;
    private $_socket;
    private $_class;
 
    function __construct($host, $port){
        $this->_host = $host;
        $this->_port = $port;
        $this->_class = '';
        $this->_connect();
    }
 
    private function _connect(){
        $sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        if($sock===false){
            $this->_error('error socket_create'.socket_strerror(socket_last_error()));
        }
 
        $ret = socket_connect($sock, $this->_host, $this->_port);
        if($ret===false){
            $this->_error('error socket_connect'.socket_strerror(socket_last_error()));
        }
 
        $this->_socket = $sock;
    }
 
    public function object($class){
        $this->_class = $class;
        return $this;
    }
 
    public function __call($func, $args){
        $data = array('class' => $this->_class, 'func' => $func, 'args' => $args);
        $data = json_encode($data);
        $socket = $this->_socket;
 
        $res = socket_write($socket, $data, strlen($data));
        if($res===false){
            $this->_error('error socket_write'.socket_strerror(socket_last_error()));
        }
 
        $res = socket_read($socket, 1024, PHP_BINARY_READ);
        $result = substr($res, 8);
        $len = intval(substr($res, 0, 8));
 
        while(true){
            if($len != strlen($result)){
                $result .= socket_read($socket, 1024, PHP_BINARY_READ);
            }else{
                break;
            }
        }
 
        return $result;
    }
 
    private function _error($errMsg = ''){
        $this->_error = $errMsg;
        echo $errMsg;
        exit();
    }
 
    public function __destruct(){
        $socket = $this->_socket;
        socket_write($socket, '', 0); //结束
        socket_close($socket);
    }
}
 
function microtime_float(){
   list($usec, $sec) = explode(" ", microtime());
   return ((float)$usec + (float)$sec);
}
 
$start = microtime_float();
 
$s = new server('192.168.0.254', 12580);
$res1 = $s->object('Too')->test('a', 'b');
$res2 = $s->object('Too')->test('a', 'b');
 
$end = microtime_float();
 
echo $res1.$res2.'<br />';
 
echo 'cost:'.($end-$start);//速度在0.002秒左右