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

//遠(yuǎn)程CCS地址
$REAL_CCS_ADDRESS = 'tcp://xx.xx.xx.xx:80';

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

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

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

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

};
// 運(yùn)行worker
Worker::runAll();