通过PHP的Wrapper无缝迁移原有项目到新服务的实现方法

varname = $url["host"];
$this- position = 0;
return true;
}

function stream_read($count)
{
$ret = substr($GLOBALS[$this- varname], $this- position, $count);
$this- position += strlen($ret);
return $ret;
}

function stream_write($data)
{
$left = substr($GLOBALS[$this- varname], 0, $this- position);
$right = substr($GLOBALS[$this- varname], $this- position + strlen($data));
$GLOBALS[$this- varname] = $left . $data . $right;
$this- position += strlen($data);
return strlen($data);
}

function stream_tell()
{
return $this- position;
}

function stream_eof()
{
return $this- position  = strlen($GLOBALS[$this- varname]);
}

function stream_seek($offset, $whence)

{

switch ($whence) {

case SEEK_SET:

if ($offset < strlen($GLOBALS[$this- varname]) && $offset  = 0) {

$this- position = $offset;

return true;

} else {

return false;

}

break;

case SEEK_CUR:

if ($offset  = 0) {

$this- position += $offset;

return true;

} else {

return false;

}

break;

case SEEK_END:

if (strlen($GLOBALS[$this- varname]) + $offset  = 0) {

$this- position = strlen($GLOBALS[$this- varname]) + $offset;

return true;

} else {

return false;

}

break;

default:

return false;

}

}

}

stream_wrapper_register("var", "VariableStream")

or die("Failed to register protocol");

$myvar = "";

$fp = fopen("var://myvar", "r+");

fwrite($fp, "line1\n");

fwrite($fp, "line2\n");

fwrite($fp, "line3\n");

rewind($fp);

while (!feof($fp)) {

echo fgets($fp);

}

fclose($fp);

var_dump($myvar);

? 

#!/usr/bin/env php
<?php
 
namespace wrapper;
 
error_reporting(E_ALL);
 
require_once '/usr/local/Cellar/thrift/0.9.1/Thrift/ClassLoader/ThriftClassLoader.php';
 
use Thrift\ClassLoader\ThriftClassLoader;
 
$GEN_DIR = realpath(dirname(__FILE__).'/..').'/gen-php';
 
$loader = new ThriftClassLoader();
$loader- registerNamespace('Thrift', '/usr/local/Cellar/thrift/0.9.1/');
$loader- registerDefinition('xiaoju', $GEN_DIR);
$loader- register();
 
use Thrift\Protocol\TBinaryProtocol;
use Thrift\Transport\TSocket;
use Thrift\Transport\THttpClient;
use Thrift\Transport\TBufferedTransport;
use Thrift\Exception\TException;
 
 
class RetryWrapper {
  public function __construct($classname, $hosts) {
    $this- clazz = new \ReflectionClass($classname);
    $this- hosts = $hosts;
  }
 
  public function __call($method, $args) {
    shuffle($this- hosts);
    foreach ($this- hosts as $key =  $host) {
      try {
        return $this- inner_call($host, $method, $args);
      } catch (TException $ex) {
        $msg = $ex- getMessage();
        if (!strstr($msg, 'TSocket')) {
          throw $ex;
        }
      }
    }
    throw new TException("all server down!");
  }
 
  public function inner_call($host, $method, $args) {
    $tmp = explode(":", $host);
    $socket = new TSocket($tmp[0], (int)$tmp[1]);
    $transport = new TBufferedTransport($socket, 1024, 1024);
    $protocol = new TBinaryProtocol($transport);
    $client = $this- clazz- newInstanceArgs(array($protocol));
 
    $transport- open();
    $result = call_user_func_array(array($client, $method), $args);
    $transport- close();
    return $result;
  }
}
 
$hosts = array('localhost:9090', 'localhost:9091');
$wrapper = new RetryWrapper("\xxx\xx\MessageServiceClient", $hosts, 3);
 
$data = array('businessId' =  300100001, 'phones' =  array('2','2','3'), 'message' =  'asdfqer') ;
$message = new \xxx\xx\Message($data);
 
print $wrapper- sendMessage($message);
print "\n";
 
?