phpDAS 特性
1、php7 (开发环境是在php7 , php5.6)
建议使用php7 , 经测试运行速度是php5.6, 8倍左右
2、Swoole （C语言写的网络通信框架 ）
使用Swoole 实现异步多线程服务器 , 异步任务 , 异步IO
3、thrift（多语言RPC服务接口定义）
基于thrift 编写RPC服务 , 实现多语言调用服务,如:java , php , .net 等等
4、consul（分布式服务发现与管理）
使用consul 实现分布式中的服务管理, 服务健康检测,服务监控等
5、Phalcon（C语言写的php mvc框架）
使用Phalcon 实现mvc框架 , 它是C语言写的php扩展, 服务注入方式
6、composer(php 依赖管理)
框架使用到的类都提交到composer了 , 可以按需要安装依赖, 由我们来维护代码, 你可以更专注于业务代码
7、阿里云的日志服务logger
提供日志采集和强大日志接口、日志自定义索引搜索 , 还有日志上下文查询锁定问题更简单,更有报警等功能
8、阿里云的MQ消息服务
简直就是一万能的变压器,支持上亿消息产生 , 然后我们只在平滑消费消息就可以了,不会因为高并发而把服务挂掉! 好评!
9 、 分布式redis
架构里必须安装redis , 服务发现是在redis里找服务的 , 这样支持高并发 , consul 会监听服务是健康而更新redis里的服务
10、多线程调用
使用Swoole实现多线程调用 ,
$content = $this->getDi()->getAsyncClient()->setClassName("\app\services\HiService")->callBack(function ($params) { var_dump($params); })
->errorCallback(function($error) { // var_dump($this->say3("error")); })
->say3('wen');
安装composer
安装php扩展 Swoole
安装php扩展 Phalcon
http://phalcon.ipanta.com/1.3/tutorial.html#checking-your-installation
phpDAS手册
开始使用phpDAS
一、 下载代码 ： git clone https://github.com/wenzouquan/phpDAS.git phpDAS
二、 运行php写的服务端 ：
1、cd phpDAS/phpDAS_service
2、安装依赖 composer install
3、启动运行微服务： php server.php
三、php客户调用示例代码
1、 cd phpDAS/client_php
2、安装依赖 composer install
3、php client.php
四、java 客户端调用示例代码
1、将 client_java 里的 thrift-client-demo ，thrift-client-demo-api maven项目导入到编辑器中，其中thrift-client-demo是依赖thrift-client-demo-api的
2、分别对 thrift-client-demo ，thrift-client-demo-api ， maven update project 下载依赖 ， 然后 maven install
3、然后运行 thrift-client-demo的HelloClientDemo.java 示例代码
说明,java示例中没有加服务发现代码 , 代码参考以下,从redis中取一个服务名字,java中实现就不再写了
$services=$this->redis->sMembers($serviceName);
$key = array_rand($services, 1); //随机找到一个服务
$service = explode("@",$services[$key]);
其它语言调用服务,请参与thrift客户端代码(官网下载的安装包里有各种语言代码),注意客户端传输协议需要与服务端一致。改下代码希望有助于理解
transport = new TSocket(SERVER_IP, SERVER_PORT, TIMEOUT);
TProtocol protocol = new TBinaryProtocol(new TFramedTransport(transport));
//Services\Demo\HiService 为服务名称 TMultiplexedProtocol tMultiplexedProtocol = new TMultiplexedProtocol(protocol, "Services\Demo\HiService");
transport.open();
HiService.Client client = new HiService.Client(tMultiplexedProtocol);
String result = client.say(userName);
thrift 使用
首先需要安装thrift ： http://thrift.apache.org/
安装好之后，就可以使用thrift命令生成接口代码了
这里我们写了一个示例，可进入phpDAS test.thrift 这是接口定义文件
在phpDAS目录下，执行 thrift -gen java test.thrift 就会生成java服务接口代码
因为我们使用php来实现服务接口 所以要加上:server 就可以生成php服务接口代码了 thrift -gen php:server test.thrift
consul服务安装搭建与管理
https://www.consul.io/ 进入官网 下载安装 consul
通常我们在本地测试使用: consul agent -dev -config-dir=/Volumes/UNTITLED/www/phpDAS/consul/config
线上consul配置参考:
http://tonybai.com/2015/07/06/implement-distributed-services-registery-and-discovery-by-consul/
在这里架构里服务发现是存在redis里,所以使用前请先配置redis
线上需要修改这里代码 redis配置 :phpDAS_service/bin/AddServerToRedis.php
这样consul监听到服务添加或减少都会调用phpDAS_service/bin/AddServerToRedis.php 这个脚本 ,从而达到服务同步到redis
微服务开发与调式方法
上面我们提到用php server.php 来启动微服务，这种方式使用基于Swoole启动的tpc协议服务，代码运行一次之后就常驻内存了，所以我们的改了代码，需要重启或热替换。这样对我们开发调试有点不方便。
因此我们提供了一个传统的http web服务来调试 ， 我们可以使用apache 或其它运行这个项目
将所有请求重写到dev.php文件， 使用apache的朋友 可以这样配置 .htaccess
Options +FollowSymlinks RewriteEngine OnRewriteCond %{REQUEST_FILENAME} !-d RewriteCond %{REQUEST_FILENAME} !-f RewriteRule ^(.*)$ dev.php/$1 [QSA,PT,L]
配置好web服务器试，我们就可以使用调式普通网站一样了
路由：http://pdas.com/HiService/say/?name=12 ， 这样就调用 HiService 服务的say方法。 参数name
我们这样就可以使用postman来测试服务了
也可以在编辑器上打断点了，debug 配置相关文档如下：http://www.cnblogs.com/derrck/p/5195946.html
swoole服务器进程守护
打开phpDAS_service/Swoole/check_server.sh 文件 , 修改把端口(8091)改成自己服务的端口,目录也改成server.php的目录
count=ps -fe |lsof -i :8091| wc -l
echo $count
if [ $count -lt 1 ]; then
ps -eaf |grep "server.php" | grep -v "grep"| awk '{print $2}'|xargs kill -9
sleep 2
ulimit -c unlimited
php /Volumes/UNTITLED/www/phpDAS/phpDAS_service/server.php
echo "restart";
echo $(date +%Y-%m-%d_%H:%M:%S) >/Volumes/UNTITLED/www/phpDAS/phpDAS_service/log/restart.log
fi
使用 crontab 监控 check_server.sh 文件 ,一分钟检查一次服务
crontab -e //添加任务
*/1 * * * * /Volumes/UNTITLED/www/phpDAS/phpDAS_service/bin/check_server.sh
crontab -l //查看任务列表
性能测试
php client.php
1、调用100次发现服务并使用tcp协议执行服务
[发现服务100次，页面执行时间：0.092694044113159 秒]
2、调用100次发现,并curl使用http协议执行服务
[发现服务100次，页面执行时间：3.4024829864502 秒]
//定义服务接口 $servicesApi = array( 'Services\Demo' => dirname(dirname(FILE)) . '/phpDAS_api/gen-php', //Services的目录 ); //实例化redis
$redis = new \Redis();
$redis->connect("127.0.0.1", "6379");
//实例化客户端
$client = new \phpkit\thriftrpc\Client($servicesApi);
$client->setRedis($redis);//注入redis 对象
$client->setHttpDedug(1);//使用http调试
//$client->setXdebugSession(14462);//调试XdebugSession
//实例化服务
$stime = microtime(true);
$count =100;
for($i=0;$i<$count;$i++){
//发现服务
$hiService = $client->getRPCService("Services\\Demo\\HiService");
//服务调用
$hiService->say("wen");
}
$etime = microtime(true);
$total = $etime - $stime;
echo "
[发现服务{$count}次，页面执行时间：{$total} ]秒";