Workerman实现Navicat Premium转发代理

2024-05-30码农

概述

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

「

项目仓库：https://gitee.com/windthesky/forward_proxy.git

配置

全部在 start.php 文件中

<?php /** @noinspection PhpUnused */ /** @noinspection PhpUndefinedFieldInspection */ /** @noinspection PhpObjectFieldsAreOnlyWrittenInspection */ ini_set('memory_limit', '512M'); useWorkerman\Connection\AsyncTcpConnection; useWorkerman\Worker; useWorkerman\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 */ functionapp_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 */ functionapp_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 */ functionapp_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 */ functionhandle_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 */ functionhandle_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 */ functionhandle_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 */ functionhandle_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();