use \Workerman\Worker;
use \Workerman\Connection\AsyncTcpConnection;
require_once './Workerman/Autoloader.php';
$task = new Worker();
// 進(jìn)程啟動時異步建立一個到www.baidu.com連接對象,并發(fā)送數(shù)據(jù)獲取數(shù)據(jù)
$task->onWorkerStart = function($task)
{
$connection_to_baidu = new AsyncTcpConnection('tcp://****:80');
// 當(dāng)連接建立成功時,發(fā)送http請求數(shù)據(jù)
$connection_to_baidu->onConnect = function($connection_to_baidu)
{
echo "connect success\n";
};
$connection_to_baidu->onMessage = function($connection_to_baidu, $http_buffer)
{
echo $http_buffer;
};
$connection_to_baidu->onClose = function($connection_to_baidu)
{
echo "connection closed\n";
};
$connection_to_baidu->onError = function($connection_to_baidu, $code, $msg)
{
echo "Error code:$code msg:$msg\n";
};
$connection_to_baidu->connect();
};
// 運行worker
Worker::runAll();
這個實例 如果服務(wù)端斷開 ,這邊就自己onClose 了,我想讓他onClose的時候自動重連
$connection_to_baidu->onClose = function($connection_to_baidu)
{
$connection_to_baidu->connect();
};
然后輸入了 connect success 但是數(shù)據(jù)沒接收到 ($http_buffer沒數(shù)據(jù))