<?php
use \Workerman\Worker;
use \Workerman\Connection\AsyncTcpConnection;
require_once './Workerman/Autoloader.php';

//遠程CCS地址
$REAL_CCS_ADDRESS = 'tcp://xx.xx.xx.xx:80';

// 監(jiān)聽本地4237端口
$proxy = new Worker('http://0.0.0.0:4237');

$proxy->onConnect = function($connection)
{
    global $REAL_CCS_ADDRESS;
    // 異步建立一個到實際ccs服務(wù)器的連接
    $connection_to_css = new AsyncTcpConnection($REAL_CCS_ADDRESS);
    // ccs連接發(fā)來數(shù)據(jù)時，轉(zhuǎn)發(fā)給對應(yīng)客戶端的連接
    $connection_to_css->onMessage = function($connection_to_css, $buffer)use($connection)
    {
        var_dump($buffer);
        $connection->send($buffer);
    };
    // ccs連接關(guān)閉時，關(guān)閉對應(yīng)的代理到客戶端的連接
    $connection_to_css->onClose = function($connection_to_css)use($connection)
    {
        $connection->close();
    };
    // ccs連接上發(fā)生錯誤時，關(guān)閉對應(yīng)的代理到客戶端的連接
    $connection_to_css->onError = function($connection_to_css)use($connection)
    {
        $connection->close();
    };

    // 執(zhí)行異步連接
    $connection_to_css->connect();

    // 客戶端發(fā)來數(shù)據(jù)時，轉(zhuǎn)發(fā)給對應(yīng)的ccs連接
    $connection->onMessage = function($connection, $buffer)use($connection_to_css)
    {
        $buffer = $_POST;
        var_dump($connection_to_css->send($buffer));
    };
    // 客戶端連接斷開時，斷開對應(yīng)的ccs連接
    $connection->onClose = function($connection)use($connection_to_css)
    {
        $connection_to_css->close();
    };
    // 客戶端連接發(fā)生錯誤時，斷開對應(yīng)的ccs連接
    $connection->onError = function($connection)use($connection_to_css)
    {
        $connection_to_css->close();
    };

};
// 運行worker
Worker::runAll();