Workerman实现转发代理

主要用于代理MySQL连接，用Navicat Premium直接连接数据库，用不了一会在卡住，用了这个代理就可以流畅使用，也可以用于访问内部数据库或者服务等等。

gitee

https://gitee.com/windthesky/forward_proxy.git

配置

全部在start.php文件中

<?php
/** @noinspection PhpUnused */
/** @noinspection PhpUndefinedFieldInspection */
/** @noinspection PhpObjectFieldsAreOnlyWrittenInspection */
ini_set('memory_limit', '512M');

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

// 自动加载类
require_once __DIR__ . '/vendor/autoload.php';
require_once __DIR__ . '/common.php';

// 是否写入日记
const LOG_WRITE = true;
// 是否显示日记
const SHOW_LOG = true;
// 是否超时关闭
const TIMEOUT_CLOSE = true;
// 超过300秒后发送消息会先断开
const TIME = 300;

//接收缓冲区大小，默认2M，根据网速和传输数据大小填写，影响最终转发的网速
TcpConnection::$defaultMaxSendBufferSize = 2*1024*1024;
AsyncTcpConnection::$defaultMaxSendBufferSize = 2*1024*1024;

$proxy_list = [
    [
        'type' => 'tcp',
        'host' => '127.0.0.1',
        'port' => 3306,
        'local_port' => 33060,
    ],
];

$app_list = [];
$connect_list = [];
$client_list = [];

/**
 * app收到
 * @param AsyncTcpConnection $app_connection
 * @param $data
 * @return void
 */
function app_message(AsyncTcpConnection $app_connection,$data): void
{
    try {
        write_log('app收到：开始');
        $client_id=$app_connection->client_id;

        global $connect_list;
        write_log(['app收到：',$data]);
        write_log(['app收到-client_id：',$client_id]);
        $connect_list[$client_id]->send($data);
        write_log('app收到-处理完：');
    } catch (Throwable $e) {
        write_log(['app收到：异常==》',$e->getMessage()]);
        $app_connection->close();
    }
}

/**
 * app错误
 * @param AsyncTcpConnection $app_connection
 * @return void
 */
function app_error(AsyncTcpConnection $app_connection): void
{
    try {
        write_log('app错误：');
        $client_id=$app_connection->client_id;
        global $connect_list;
        $connect_list[$client_id]->close();
        write_log('app错误：执行完');
    } catch (Throwable $e) {
        write_log(['app错误：异常==》',$e->getMessage()]);
    }
}

/**
 * app关闭
 * @param AsyncTcpConnection $app_connection
 * @return void
 */
function app_close(AsyncTcpConnection $app_connection): void
{
    try {
        write_log('app关闭：');
        $client_id=$app_connection->client_id;
        global $connect_list,$app_list;
        $connect_list[$client_id]->close();
        unset($app_list[$client_id]);
        write_log('app关闭：执行完');
    } catch (Throwable $e) {
        write_log(['app关闭：异常==》',$e->getMessage()]);
    }
}

//Todo 客户端连接处理
/**
 * 客户端连接处理
 * @param TcpConnection $connection
 * @return void
 */
function handle_connection(TcpConnection $connection): void
{
    try {
        write_log('客户端连接：');
        $connection->lastMessageTime = time();
        global $app_list,$connect_list;
        $client_id = 'client-'.session_create_id();

        $connection->client_id = $client_id;

        $connect_list[$client_id]=$connection;
        $proxy_url=$connection->worker->proxy_url;

        write_log(['客户端连接：开始==》',$connection->client_id]);

        $app_list[$client_id] = new AsyncTcpConnection($proxy_url);
        $app_list[$client_id]->client_id = $client_id;
        $app_list[$client_id]->onMessage = 'app_message';
        $app_list[$client_id]->onError = 'app_error';
        $app_list[$client_id]->onClose = 'app_close';
        $app_list[$client_id]->connect();

        write_log(['客户端连接：完成==》',$connection->client_id]);
    } catch (Throwable $e) {
        write_log(['客户端连接：异常==》',$connection->client_id,$e->getMessage()]);
    }
}

/**
 * 收到消息处理
 * @param TcpConnection $connection
 * @param $data
 * @return void
 */
function handle_message(TcpConnection $connection,$data): void
{
    try {
        write_log(['收到消息：',$data]);
        global $app_list;
        if(TIMEOUT_CLOSE && time()-$connection->lastMessageTime>TIME){
            write_log(['收到消息：超时关闭']);
            $connection->close();
            return;
        }
        $app_list[$connection->client_id]->send($data);
        $connection->lastMessageTime = time();
        write_log(['收到消息：完']);
    } catch (Throwable $e) {
        write_log(['收到消息：异常==》',$connection->client_id,$e->getMessage()]);
    }
}

/**
 * 处理错误
 * @param TcpConnection $connection
 * @return void
 */
function handle_error(TcpConnection $connection): void
{
    try {
        write_log(['处理错误：开始==》',$connection->client_id]);
        $client_id=$connection->client_id;

        global $app_list;
        if (empty($app_list[$client_id])) return;
        $app_list[$client_id]->close();
        write_log(['处理错误：完成==》',$client_id]);
    } catch (Throwable $e) {
        write_log(['处理错误：异常==》',$e->getMessage()]);
    }
}

/**
 * 处理关闭
 * @param TcpConnection $connection
 * @return void
 */
function handle_close(TcpConnection $connection): void
{
    try {
        write_log(['处理关闭：开始==》',$connection->client_id]);
        $client_id=$connection->client_id;

        global $app_list,$connect_list;
        if (empty($app_list[$client_id])) return;
        $app_list[$client_id]->close();
        unset($connect_list[$client_id]);
        write_log(['处理关闭：完成==》',$client_id]);
    } catch (Throwable $e) {
        write_log(['处理关闭：异常==》',$e->getMessage()]);
    }
}

$worker = new Worker();

$worker->onWorkerStart = function() {
    global $client_list,$proxy_list;
    foreach($proxy_list as $k=>$v)
    {
        $url=$v['type'].'://0.0.0.0:'.$v['local_port'];
        $proxy_url=$v['type'].'://'.$v['host'].':'.$v['port'];
        echo '监听地址：'.$url.PHP_EOL;
        echo '代理地址：'.$proxy_url.PHP_EOL;
        $client_list[$k] = new Worker($url);
        $client_list[$k]->proxy_key = $k;
        $client_list[$k]->proxy_info = $v;
        $client_list[$k]->proxy_url = $proxy_url;
        $client_list[$k]->onConnect = 'handle_connection';
        $client_list[$k]->onMessage = 'handle_message';
        $client_list[$k]->onError = 'handle_error';
        $client_list[$k]->onClose = 'handle_close';
        $client_list[$k]->listen();
    }
};

Worker::runAll();

启动

以debug（调试）方式启动

php start.php start

以daemon（守护进程）方式启动

php start.php start -d

停止

php start.php stop

重启

php start.php restart

平滑重启

php start.php reload

查看状态

php start.php status

Windows 启动

双击start_for_win.bat