workerman TCP客户端

2022-02-02
// 继承TcpConnection

use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;

require_once __DIR__ . '/vendor/autoload.php';

$task = new Worker();

$task->onWorkerStart = function($task)
{
    $connection = new AsyncTcpConnection('tcp://127.0.0.1:80');
    $connection->onConnect = function(AsyncTcpConnection $connection)
    {
        echo "connect success\n";
    };

    $connection->onMessage = function(AsyncTcpConnection $connection, $buffer)
    {
        echo $buffer;
    };

    $connection->onClose = function(AsyncTcpConnection $connection)
    {
        echo "connection closed\n";
    };

    $connection->onError = function(AsyncTcpConnection $connection, $code, $msg)
    {
        echo "Error code:$code msg:$msg\n";
    };
    $connection->connect();
};

// 运行worker
Worker::runAll();

 

{/if}