自定义进程
class Pusher
{
public function onWorkerStart()
{
//$GLOBALS['con'];
global $con;
$con = new AsyncTcpConnection('tcp://127.0.0.1:8282');
$con->onConnect = function(AsyncTcpConnection $con) {
$con->send('hello');
};
$con->onMessage = function(AsyncTcpConnection $con, $data) {
echo $data;
$con->send($data);
};
$con->connect();
}
}
APP/CONTROLLER
如何调用上面的 $con->send()函数
进程间变量不共享, 第一,里面可以开个text协议监听,监听其它进程发送过来的数据,然后进行处理
.第二,可以每个进程都开一个连接维护
建议看下: Channel分布式通讯组件, 进程间通信组件