#zys高性能服务框架 ###核心特性 1.基于swoole提供同步异步数据库连接池服务 2.基于thrift提供rpc远程调用服务 3.基于HTML5提供在线网络直播平台服务 4.基于vmstat提供服务器硬件实时监控服务 5.基于yac、yaconf提供共享数据、配置服务 6.基于php_ext_zqf提供高并发计数器、红包、二维码服务 7.很好的支持网页版console的shell服务 8.基于swoole提供分布式服务器通讯服务 ###服务启动需要php以cli模式运行/server/server.php php server.php start php server.php stop ###swoole实现简单的视频直播（可以实时传音频、视频、聊天）需要php以cli模式运行/server/swoole/SwooleLiveServer.php 录制视频页面 http://localhost/index/swoolelivecamera 接受视频页面 http://localhost/index/swoolelive ###vmstat服务器监控需要php以cli模式运行/server/swoole/VmStatServer.php 本地访问http://localhost/vmstat/ 执行如下： ###thrift的rpc远程调用需要php以cli模式运行/server/rpc/RpcServer.php（守护进程）本地访问http://localhost/index/rpc （返回0表示成功） ###composer 安装 { "require": { "qieangel2013/zys": "0.1.0" } } ###数据库连接池使用方法服务文件在/server/mysql/DbServer.php 简单地封装文件在/application/library/mysql/dbclient.php 配置在conf/application.ini中 ;数据库连接池配置 DbServer.async=true //配置是同步执行还是异步执行，默认不配置代表异步执行，同步执行设置为false DbServer.multiprocess=false //配置是否启用多进程，默认不配置代表单进程阻塞模式，多进程模式要设置为true DbServer.pool_num=20 //配置连接池mysql的数量 DbServer.port=9501 DbServer.logfile="/server/log/DbServer.log" DbServer.localip="192.168.2.13" 使用方法： $dbclient=new mysql_dbclient; //print_r($data); for ($i=0; $i <100 ; $i++) { $dbclient->query("INSERT INTO user(name) VALUES('$i')"); //echo "INSERT INTO user(name) VALUES('$i')"; } $data=$dbclient->query("select * from user"); $dbclient->close(); print_r($data); exit; ###数据库连接池多进程执行如下： ###后台访问：http://localhost/admin/user/index

test.png',500,1);第一个参数是url，第二参数是保存路径，第三个参数是二维码长或者宽，第四个参数是决定是否透明，默认是不透明的

###自定义自动加载配置如下： ;可以任意加载多个目录类和目录函数用,隔开例如：application.autolibrary='job,common';application.autofunction='pro,function' 支持深度查找目录，如果不想开启可以不用配置 application.autolibrary='common' application.autofunction='function' ;如果不想开启可以不用配置 ###db操作类读写分离配置如下： ;数据库驱动类型 database.config.type='mysql' ;服务器地址 database.config.host='192.168.0.1,192.168.0.2' ;数据库名 database.config.name='root' ;用户名 database.config.user='user1,user2' ;密码 database.config.pwd='pwd1,pwd2' ;端口 database.config.port= '3306' ;启用字段缓存 database.config.fields_cache=false ;数据库编码默认采用utf8 database.config.charset='utf8' ;数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) database.config.deploy_type=1 ;数据库读写是否分离主从式有效 database.config.rw_separate=true ;读写分离后主服务器数量 database.config.master_num=1 ;指定从服务器序号 database.config.slave_no='' ###db操作类使用方法如下： $where=array('id' =>37936); $user=new HbModel('hb_users');//直接实例化给表名就行了，其他跟操作thinkphp一样 $result=$user->where($where)->select();//支持链式操作，支持pdo，mysqli，mongo echo $user->getlastsql(); print_r($result); exit; ###redis操作使用方法如下： $this->_redis=new phpredis();//需要安装redis扩展 $this->_redis->set('token',1); ###upload操作使用方法如下： $config=Yaf_Application::app()->getConfig()->upload->config->toArray(); $ftpconfig=Yaf_Application::app()->getConfig()->ftp->config->toArray(); $upload=new Upload($config, 'Ftp',$ftpconfig); $info=$upload->upload(); if (!$info) {// 上传错误提示错误信息 echo $upload->getError(); } else {// 上传成功 if (!empty($info["UpLoadFile"])) $pic=array("cate_pic" => $info["UpLoadFile"]['savepath'] . $info["UpLoadFile"]['savename']); print_r($pic); } ###微信分享操作使用方法如下： //微信分享 $jssdk=new wx_share_wxshare("你的appId", "你的appSecret"); $signPackage=$jssdk->GetSignPackage();; $data['appId']=$signPackage['appId']; $data['nonceStr']=$signPackage['nonceStr']; $data['timestamp']=$signPackage['timestamp']; $data['signature']=$signPackage['signature']; $this->getView()->assign("token", json_encode($data)); ###微信支付操作使用方法如下：（具体操作在weixin控制器里）
$jsApi = new wx_pay_JsApi(); $oid=123;//订单id $userid=456;//用户id $wx_openid='';//微信授权id if(empty($wx_openid)){ if (!isset($_GET['code'])) { $url = wx_pay_config::JS_API_CALL_URL; $url = str_replace('%oid%', $oid, $url); $url = str_replace('%uid%', $userid, $url); $url = $jsApi->createOauthUrlForCode($url); Header("Location: $url"); } else { $code = $_GET['code']; $jsApi->setCode($code); $openid = $jsApi->getOpenId(); }
}else{ $openid = $wx_openid; } $unifiedOrder = new wx_pay_UnifiedOrder(); $unifiedOrder->setParameter("body", "test"); //商品描述 $unifiedOrder->setParameter("out_trade_no", "1111111111"); //商户订单号 $unifiedOrder->setParameter("total_fee", "0101"); //总金额 $total $unifiedOrder->setParameter("notify_url", wx_pay_config::NOTIFY_URL); //通知地址 $unifiedOrder->setParameter("trade_type", "JSAPI"); //交易类型 $unifiedOrder->setParameter("openid", $openid); //用户标识 $prepay_id = $unifiedOrder->getPrepayId(); $jsApi->setPrepayId($prepay_id); $jsApiParameters = $jsApi->getParameters(); ###swoole作为http_server操作使用方法如下：根目录下有server集成了swoole服务端 (后台运行直接php执行) HttpServer.php （linux环境下直接执行php HttpServer.php） http_server实现原理是把swoole作为底层处理请求，然后通过php-cli把url交给 yaf来处理，yaf只是作为一个框架使用

swoole作为http_server的调用如下：

在浏览器里输入http://www.xxx.com:9501/index/swoolehttp,生产环境可以把监听端口改为80
    public function swoolehttpAction(){
     		 Yaf_Dispatcher::getInstance()->autoRender(FALSE);
    		$where=array('id' =>37936);
    		$user=new HbModel('hb_users');//直接实例化给表名就行了，其他跟操作thinkphp一样
    		$result = $user->where($where)->select();
    		//echo $user->getlastsql();
    		// echo json_encode( $result);
     		echo json_encode( $where);//通过swoole返回给浏览器结果{"id":37936｝
		}

###swoole作为websocket_server操作使用方法如下：根目录下有server集成了swoole服务端 (后台运行直接php执行) WebSocketServer.php （linux环境下直接执行php WebSocketServer.php） websocket_server实现原理是把swoole作为websocket服务器，然后通过php-cli把参数传给 yaf来处理，yaf来处理逻辑

swoole作为websocket_server的调用如下：

在浏览器里输入http://www.xxx.com/index/swoolesocket
    public function swoolesocketAction(){
     		Yaf_Dispatcher::getInstance()->autoRender(FALSE);
    		$this->getView()->display("index/swoolesocket.html");
		}

###html请求websocket <title></title> <script type="text/javascript" src="/public/js/jquery-1.8.0.min.js"></script> <style> #chatLog {width:440px; height:200px; border:1px solid #7F9DB9; overflow:auto;margin-bottom: 20px} </style> <script type="text/javascript"> var exampleSocket = new WebSocket("ws://192.168.1.46:9503");//设为相应的监听ｉｐ及端口号 exampleSocket.onopen = function (event) { exampleSocket.send("亲！我连上啦！"); }; exampleSocket.onmessage = function (event) { console.log(event.data); $('#chatLog').append('
'+event.data); } exampleSocket.onclose = function(event) { console.log('Client notified socket has closed',event); }; </script>

发送关闭

###如果你对我的辛勤劳动给予肯定，请给我捐赠，你的捐赠是我最大的动力

StandOpen/zys

swoole作为http_server的调用如下：

swoole作为websocket_server的调用如下：