workerman json mysql_GitHub - stamhe/workerman-JsonRpc: workerman作为进程管理器,json作为协议的远程服务调用的框架...

巫煌
2023-12-01

workerman

workerman 是一个高性能的PHP socket服务框架,开发者可以在这个框架下开发各种网络应用,例如Rpc服务、聊天室、游戏等。

workerman 具有以下特性

多进程

支持TCP/UDP

支持各种应用层协议

使用libevent事件轮询库,支持高并发

支持文件更新检测及自动加载

支持服务平滑重启

支持telnet远程控制及监控

支持异常监控及告警

支持长连接

支持以指定用户运行worker进程

所需环境

workerman需要PHP版本不低于5.3,只需要安装PHP的Cli即可,无需安装PHP-FPM、nginx、apache

workerman不能运行在Window平台

安装

以ubuntu为例

安装PHP Cli

sudo apt-get install php5-cli

强烈建议安装libevent扩展,以便支持更高的并发量

sudo pecl install libevent

建议安装proctitle扩展(php5.5及以上版本原生支持,无需安装),以便方便查看进程信息

sudo pecl install proctitle

启动停止

以ubuntu为例

启动

sudo ./bin/workermand start

重启启动

sudo ./bin/workermand restart

平滑重启/重新加载配置

sudo ./bin/workermand reload

查看服务状态

sudo ./bin/workermand status

停止

sudo ./bin/workermand stop

Rpc应用使用方法

###客户端同步调用:

include_once 'yourClientDir/RpcClient.php';

$address_array = array(

'tcp://127.0.0.1:2015',

'tcp://127.0.0.1:2015'

);

// 配置服务端列表

RpcClient::config($address_array);

$uid = 567;

// User对应applications/JsonRpc/Services/User.php 中的User类

$user_client = RpcClient::instance('User');

// getInfoByUid对应User类中的getInfoByUid方法

$ret_sync = $user_client->getInfoByUid($uid);

###客户端异步调用:

RpcClient支持异步远程调用

include_once 'yourClientDir/RpcClient.php';

// 服务端列表

$address_array = array(

'tcp://127.0.0.1:2015',

'tcp://127.0.0.1:2015'

);

// 配置服务端列表

RpcClient::config($address_array);

$uid = 567;

$user_client = RpcClient::instance('User');

// 异步调用User::getInfoByUid方法

$user_client->asend_getInfoByUid($uid);

// 异步调用User::getEmail方法

$user_client->asend_getEmail($uid);

这里是其它的业务代码

....................

....................

// 需要数据的时候异步接收数据

$ret_async1 = $user_client->arecv_getEmail($uid);

$ret_async2 = $user_client->arecv_getInfoByUid($uid);

这里是其他业务逻辑

###服务端:

服务端每个类提供一组服务,类文件默认放在workerman/applications/JsonRpc/Services目录下。

客户端实际上是远程调用这些类的静态方法。

例如:

RpcClient::instance('User')->getInfoByUid($uid);

调用的是workerman/applications/JsonRpc/Services/User.php 中 User类的getInfoByUid方法。

User.php文件类似这样

class User

{

public static function getInfoByUid($uid)

{

// ....

}

public static function getEmail($uid)

{

// ...

}

}

如果你想要增加一组服务,可以在这个目录下增加类文件即可。

配置

配置文件在applications/conf.d/JsonRpcWorker.conf

;Rpc网络服务应用配置

;所用的传输层协议及绑定的ip端口

listen = tcp://0.0.0.0:2015

;长连接还是短连接,Rpc服务这里设置成短连接,每次请求后服务器主动断开

persistent_connection = 0

;启动多少worker进程,这里建议设置成cpu核数的整数倍,例如 CPU数*3

start_workers=12

;接收多少请求后退出该进程,重新启动一个新进程,设置成0代表永不重启

max_requests=1000

;以哪个用户运行该worker进程,建议使用权限较低的用户运行worker进程,例如www-data

user=www-data

;socket有数据可读的时候预读长度,一般设置为应用层协议包头的长度,这里设置成尽可能读取更多的数据

preread_length=84000

rpc监控

 类似资料: