Workerman实现转发代理

windthesky

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

592 3 6
3个评论

Tinywan

支持

  • 暂无评论

厉害厉害!

  • 暂无评论
兔白白

Navicat Premium 连接服务器数据库 确实 一会儿不操作 就卡住了.. 要等好久才响应

  • 暂无评论

windthesky

320
积分
0
获赞数
0
粉丝数
2023-07-26 加入
×
🔝