PHP API接口开发（Yaf）

• Lib库的抽离
• SDK的统一管理
• Composer管理第三方类库

class Common_Request{
    public static function request($key, $default=null,$type=null){
 if( $type == 'get'){
     $result = isset($_GET[$key])?trim($_GET[$key]):null;
 } elseif ($type == 'post'){
     $result = isset($_POST[$key])?trim($_POST[$key]):null;
 } else {
     $result = isset($_REQUEST[$key])?trim($_REQUEST[$key]):null;
 }

 if($default != null && $result==null){
     $result = $default;
 }
 return $result;
    }

    public static function getRequest($key, $default=null){
 return self::request($key,$default,'get');
    }

    public static function postRequest($key, $default=null){
 return self::request($key, $default, 'post');
    }

    public static function response($errno=0,$data=null){
 $resp = Err_Map::get($errno);

 if($data != null){
     $resp['data'] = $data;
 }
 return json_encode($resp);
    }
}

class Db_base{
    public static $errno  = 0;
    public static $errmsg = null;
    public static $db     = null;

    public static function getDb(){
 if(self::$db == null){
     self::$db = new PDO("mysql:host=localhost;dbname=imooc_yaf;","root","root");
     //防止pdo在拼接sql的时候将int转string
     self::$db->setAttribute(PDO::ATTR_EMULATE_PREPARES,false);
 }
 return self::$db;
    }

    public function errno(){
 return self::$errno;
    }

    public function errmsg(){
 return self::$errmsg;
    }
}

class Db_User extends Db_base {
    public function find($uname){
 $query = self::getDb()->prepare("select `pwd`, `id` from `user` where `name` = ? ");
 $query->execute(array($uname));
 $ret   = $query->fetchAll();
 if( !$ret || count($ret)!=1 ) {
     list(self::$errno,self::$errmsg) = Err_Map::get(1003);
     return false;
 }
 return $ret[0];
    }

    public function checkExists($uname){
 $query = self::getDb()->prepare("select count(*) as c from `user` where `name` = ?");
 $query->execute(array($uname));
 $count   = $query->fetchAll();
 if( $count[0]['c'] !=0 ) {
     list(self::$errno, self::$errmsg) = Err_Map::get(1005);
     return false;
 }
 return true;
    }


    public function addUser($uname,$password,$datetime){
 $query = self::getDb()->prepare("insert into `user` (`id`,`name`,`pwd`,`reg_time`) VALUES (null,?,?,?)");
 $ret = $query->execute(array($uname, $password,$datetime));
 if( !$ret ) {
     list(self::$errno,self::$errmsg) = Err_Map::get(1007);
     return false;
 }
 return true;
    }
}

• 统一的API接口返回
  • 错误信息字典
• 统一的API异常处理
  • 容错与降级

class Err_Map{
    const ERRMAP = array(
 0     => '',

 
 1001  => '请通过正常渠道提交',
 1002  => '用户名或密码不能为空',
 1003  => '用户查找失败',
 1004  => '密码错误',
 1005  => '用户名已存在',
 1006  => '密码太短，请输入最低8位的密码',
 1007  => '注册失败，写入数据库失败',

 
 2000  => '需要管理员权限',
 2001  => '请通过正常渠道提交',
 2002  => '没填写完整',
 2003  => '缺少必要的参数',
 2004  => '找不到文章,请确认是否有该文章',
 2005  => '找不到分类信息-',
 2006  => '操作文章数据表失败,errinfo:',
 2007  => '缺少必要的ID参数',
 2008  => '更新文章状态失败',
 2009  => '查询失败',
 2010  => '获取分类信息失败',
 2011  => '获取文章列表失败, errinfo',
 2012  => '删除数据失败',

 
 3001  => '请通过正常渠道提交',
 3002  => '用户id，邮件title，邮件内容不能为空',
 3003  => '邮箱信息查找失败',
 3004  => '邮箱不合法',

 
 4001  => '请通过正常渠道提交',
 4002  => '用户Id，短信内容不能为空',
 4003  => '用户手机号信息查找失败',
 4004  => '手机号不符合规定',
 4005  => '发送失败',
 4006  => '消息发送成功，数据插入失败',

 
 5001  => 'IP地址不正确',

 
 6001  => '请传递正确的商品ID',
 6002  => '请先登录后操作',
 6003  => '',
 6004  => '找不到这件商品',
 6005  => '商品过期',
 6006  => '商品没有库存',
 6007  => '创建订单失败',
 6008  => '更新库存失败',
 6009  => '请传递正确的订单ID',
 6010  => '',
 6011  => '找不到订单信息',
 6012  => '找不到商品信息',
    );

    public static function get($code){
 if(isset(self::ERRMAP[$code])){
     return array('errno'=>(0-$code), 'errmsg'=>self::ERRMAP[$code]);
 }
 return array('errno'=>(0-$code), 'errmsg'=>"没有定义该类错误码");

    }
}

• PHPdocument
  • -d -p
• swigger

• API时间开销定位与分析：
  • 时间开销情况分析
  • 剥洋葱定位方法
• API上下游性能优化：
  • MySQL时间开销优化
  • 后端服务调优
  • API返回调优
• 稳定性
  • 服务监控
    • supervisord
  • API负载均衡
  • 服务报警
  • API测试用例