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', 10009).open(Too())
 

  <?php
  

  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('127.0.0.1', 10009);
  

  $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);
  

  ?>