ws/wss 클라이언트로서의 Workerman

때때로 Workerman을 클라이언트로 사용하여 ws/wss 프로토콜을 통해 특정 서버에 연결하고 상호 작용을 해야 할 필요가 있습니다. 아래는 예제입니다.

Workerman을 ws 클라이언트로 사용하기

<?php
use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker();

$worker->onWorkerStart = function($worker){

    $con = new AsyncTcpConnection('ws://echo.websocket.org:80');

    // websocket 핸드쉐이크가 성공적으로 완료되면
    $con->onWebSocketConnect = function(AsyncTcpConnection $con, ) {
        $con->send('hello');
    };

    // 메시지를 수신할 때
    $con->onMessage = function(AsyncTcpConnection $con, $data) {
        echo $data;
    };

    $con->connect();
};

Worker::runAll();

Workerman을 wss(ws+ssl) 클라이언트로 사용하기

<?php
use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker();

$worker->onWorkerStart = function($worker){
    // ssl은 443 포트로 접근해야 합니다.
    $con = new AsyncTcpConnection('ws://echo.websocket.org:443');

    // ssl 암호화를 통해 접근하도록 설정하여 wss로 만듭니다.
    $con->transport = 'ssl';

    $con->onWebSocketConnect = function(AsyncTcpConnection $con) {
        $con->send('hello');
    };

    $con->onMessage = function(AsyncTcpConnection $con, $data) {
        echo $data;
    };

    $con->connect();
};

Worker::runAll();

Workerman을 wss(ws+ssl) 클라이언트로 사용하기 + 로컬 ssl 인증서

<?php
use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker();

$worker->onWorkerStart = function($worker){
    // 상대 호스트의 로컬 ip와 포트 및 ssl 인증서를 설정합니다.
    $context_option = array(
        // ssl 옵션, http://php.net/manual/zh/context.ssl.php를 참조하십시오.
        'ssl' => array(
            // 로컬 인증서 경로. PEM 형식이어야 하며 로컬 인증서와 개인 키가 포함되어야 합니다.
            'local_cert'        => '/your/path/to/pemfile',
            // local_cert 파일의 비밀번호.
            'passphrase'        => 'your_pem_passphrase',
            // 자가 서명 인증서를 허용할지 여부.
            'allow_self_signed' => true,
            // SSL 인증서를 검증할 필요가 있는지 여부.
            'verify_peer'       => false
        )
    );

    // ssl은 443 포트로 접근해야 합니다.
    $con = new AsyncTcpConnection('ws://echo.websocket.org:443', $context_option);

    // ssl 암호화를 통해 접근하도록 설정하여 wss로 만듭니다.
    $con->transport = 'ssl';

    $con->onWebSocketConnect = function(AsyncTcpConnection $con) {
        $con->send('hello');
    };

    $con->onMessage = function(AsyncTcpConnection $con, $data) {
        echo $data;
    };

    $con->connect();
};

Worker::runAll();

기타 설정

<?php
require_once __DIR__ . '/vendor/autoload.php';

use Workerman\Protocols\Ws;
use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;

$worker = new Worker();
// 프로세스가 시작될 때
$worker->onWorkerStart = function()
{
    // websocket 프로토콜로 원격 websocket 서버에 연결
    $ws_connection = new AsyncTcpConnection("ws://127.0.0.1:1234");
    // 55초마다 서버에 opcode가 0x9인 websocket 핑을 보냅니다.
    $ws_connection->websocketPingInterval = 55;
    // 사용자 정의 http 헤더
    $ws_connection->headers = ['token' => 'value'];
    // 데이터 유형 설정, 기본 BINARY_TYPE_BLOB은 텍스트
    $ws_connection->websocketType = Ws::BINARY_TYPE_BLOB; // BINARY_TYPE_BLOB은 텍스트, BINARY_TYPE_ARRAYBUFFER는 바이너리
    // TCP 연결이 3번의 핸드쉐이크를 마치면
    $ws_connection->onConnect = function($connection){
        echo "tcp connected\n";
    };
    // websocket 핸드쉐이크가 완료되면
    $ws_connection->onWebSocketConnect = function(AsyncTcpConnection $con, $response) {
        echo $response;
        $con->send('hello');
    };
    // 원격 websocket 서버에서 메시지를 수신할 때
    $ws_connection->onMessage = function($connection, $data){
        echo "recv: $data\n";
    };
    // 연결 중 오류 발생 시, 일반적으로 원격 websocket 서버 연결 실패 오류
    $ws_connection->onError = function($connection, $code, $msg){
        echo "error: $msg\n";
    };
    // 원격 websocket 서버의 연결이 끊어질 때
    $ws_connection->onClose = function($connection){
        echo "connection closed and try to reconnect\n";
        // 연결 끊어지면 1초 후 재연결
        $connection->reConnect(1);
    };
    // 위의 다양한 콜백을 설정한 후, 연결 작업을 실행
    $ws_connection->connect();
};
Worker::runAll();