Cara Swoole melaksanakan pengimbangan beban perkhidmatan proksi TCP

Swoole ialah rangka kerja komunikasi rangkaian berprestasi tinggi yang dibangunkan berdasarkan sambungan bahasa PHP Ia meningkatkan prestasi dan keupayaan penyelarasan aplikasi PHP melalui ciri tak segerak, coroutine dan lain-lain. Dalam projek sebenar, kami selalunya perlu menggunakan perkhidmatan proksi TCP pada berbilang pelayan untuk mencapai pengimbangan beban perkhidmatan. Artikel ini akan memperkenalkan cara Swoole melaksanakan pengimbangan beban perkhidmatan proksi TCP.

Pertama sekali, seni bina perkhidmatan proksi TCP perlu dijelaskan. Biasanya, perkhidmatan proksi TCP terdiri daripada dua bahagian: klien dan pelayan. Pelanggan menghantar permintaan kepada perkhidmatan proksi TCP, pelayan memajukan permintaan ke pelayan akhir belakang, dan mengembalikan hasil respons kepada klien. Apabila menggunakan perkhidmatan proksi TCP pada berbilang pelayan, kami perlu melaksanakan strategi pengimbangan beban untuk mengagihkan permintaan secara sama rata kepada setiap pelayan untuk meningkatkan ketersediaan dan pemprosesan sistem.

Dalam Swoole, pengimbangan beban perkhidmatan proksi TCP boleh dicapai dalam pelbagai cara. Berikut adalah dua cara biasa.

1. Komponen proksi TCP berasaskan Swoole

Swoole menyediakan komponen proksi TCP yang boleh digunakan sebagai perisian tengah perkhidmatan proksi TCP untuk mencapai pemajuan trafik dan pengimbangan beban. Mula-mula, mulakan komponen perkhidmatan proksi TCP Swoole pada pelayan:

$proxy = new SwooleProxyServer('0.0.0.0', 8080, SWOOLE_PROCESS);
$proxy->set(
    array(
        'timeout' => 3, //超时时间
        'heartbeat_check_interval' => 60, //心跳检测间隔
        'heartbeat_idle_time' => 600, //连接空闲时间
        'load_balance' => SWOOLE_PROXY_ROUNDROBIN, //负载均衡策略
        'server_list' => array(
            array('host' => '192.168.1.1', 'port' => 8080),
            array('host' => '192.168.1.2', 'port' => 8080),
            array('host' => '192.168.1.3', 'port' => 8080),
        ),
    )
);
$proxy->run();

Dalam kod di atas, kami menyediakan perkhidmatan proksi TCP dengan memanggil kelas SwooleProxyServer, mendengar port 8080 dan menetapkan parameter yang berkaitan. Antaranya, parameter load_balance menentukan strategi pengimbangan beban, yang boleh dipilih daripada kaedah pengundian, rawak dan berasaskan berat. Parameter server_list menentukan senarai alamat perkhidmatan bahagian belakang.

Kemudian, dalam klien, hantarkan permintaan kepada perkhidmatan proksi TCP melalui komponen klien TCP Swoole:

$client = new SwooleClient(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
$client->set(
    array(
        'open_length_check' => true,
        'package_length_type' => 'N',
        'package_length_offset' => 0,
        'package_body_offset' => 4,
        'package_max_length' => 2000000, //最大数据长度
    )
);
$client->on('connect', function ($cli) {
    $cli->send("hello,world
");
});
$client->on('receive', function ($cli, $data) {
    echo "Receive: $data";
});
$client->on('error', function ($cli) {
    echo "Connect failed
";
});
$client->on('close', function ($cli) {
    echo "Connection close
";
});
$client->connect('127.0.0.1', 8080, 0.5);

Dengan memanggil komponen klien TCP Swoole, nyatakan klien TCP, tetapkan parameter yang berkaitan dan hantar Permintaan kepada perkhidmatan proksi TCP. Perkhidmatan proksi TCP akan memajukan permintaan ke pelayan bahagian belakang mengikut dasar pengimbangan beban dan mengembalikan hasil respons kepada pelanggan.

2. Pelayan proksi terbalik berasaskan Swoole

Swoole juga menyediakan pelayan proksi terbalik yang boleh digunakan terus pada pelayan hadapan untuk mencapai pengimbangan beban dan proksi terbalik. Mula-mula, dalam pelayan proksi terbalik, mulakan komponen perkhidmatan proksi terbalik Swoole:

$proxy = new SwooleServer('0.0.0.0', 80, SWOOLE_PROCESS);
$proxy->set(
    array(
        'worker_num' => 2, //工作进程数
        'daemonize' => true, //守护进程模式
        'max_conn' => 10000, //最大连接数
        'open_http2_protocol' => true, //启用HTTP2协议
        'ssl_cert_file' => '/path/to/server.crt', //SSL证书文件
        'ssl_key_file' => '/path/to/server.key', //SSL证书私钥
        'ssl_verify_peer' => false, //SSL客户端验证
        'ssl_allow_self_signed' => false, //允许使用自签名证书
        'ssl_client_cert_file' => '/path/to/client.crt', //SSL客户端证书文件
    )
);
$proxy->on('request', function ($request, $response) {
    $filePath = '/path/to/static/files' . $request->server['request_uri'];
    $contentType = getMimeType($filePath);
    if (is_file($filePath)) {
        $response->header('Content-Type', $contentType);
        $response->sendFile($filePath);
    } else {
        $proxy = new SwooleHttpClient('www.example.com', 80);
        $proxy->set(
            array(
                'timeout' => 3,
                'keep_alive' => false,
            )
        );
        $proxy->on('error', function ($cli) use ($response) {
            $response->statusCode(503);
            $response->end();
        });
        $proxy->on('close', function ($cli) use ($response) {
            $response->end();
        });
        $proxy->on('receive', function ($cli, $data) use ($response) {
            $response->header('Content-Type', 'text/html');
            $response->end($data);
        });
        $headers = array();
        foreach ($request as $key => $value) {
            if (strpos($key, 'HTTP_') === 0) {
                $headers[strtolower(str_replace('_', '-', substr($key, 5)))] = $value;
            }
        }
        $proxy->setHeaders($headers);
        $proxy->execute($request->server['request_method'], $request->server['request_uri']);
    }
});
$proxy->start();

Dalam kod di atas, kami membuat instantiate pelayan proksi terbalik dengan memanggil kelas SwooleServer, mendengar port 80 dan menetapkan parameter yang berkaitan. Dalam fungsi panggil balik on('request'), ia dinilai sama ada fail yang diminta wujud Jika ia wujud, kandungan fail dihantar terus jika ia tidak wujud, permintaan dimajukan ke pelayan belakang dan respons keputusan dikembalikan. Apabila memajukan permintaan, kami melaksanakannya melalui komponen klien HTTP Swoole, menghantar permintaan ke pelayan bahagian belakang dan mengembalikan hasil respons kepada klien.

Kemudian, gunakan pelayan proksi terbalik pada berbilang pelayan dan gunakan perisian pengimbangan beban seperti Nginx atau LVS untuk mencapai pengedaran permintaan yang seimbang. Memandangkan pelayan proksi terbalik Swoole menyokong protokol HTTP2, ia boleh meningkatkan prestasi dan keupayaan serentak dengan berkesan Ia juga menyokong penyulitan SSL dan pengesahan pelanggan, yang meningkatkan keselamatan sistem.

Ringkasnya, Swoole menyediakan pelbagai cara untuk melaksanakan pengimbangan beban perkhidmatan proksi TCP, dan anda boleh memilih penyelesaian yang sesuai berdasarkan keperluan dan senario sebenar. Dengan mengkonfigurasi parameter dengan sewajarnya dan memilih strategi pengimbangan beban yang sesuai, ketersediaan dan daya pemprosesan sistem boleh dipertingkatkan dengan berkesan.

Atas ialah kandungan terperinci Cara Swoole melaksanakan pengimbangan beban perkhidmatan proksi TCP. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!