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');
// 웹소켓 핸드 셰이크 성공시
$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 프로토콜로 연결
$ws_connection = new AsyncTcpConnection("ws://127.0.0.1:1234");
// 55초마다 opcode가 0x9인 웹소켓 허트비트를 서버로 전송
$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-way 핸드쉐이크 완료시
$ws_connection->onConnect = function($connection){
echo "tcp connected\n";
};
// 웹소켓 핸드쉐이크 완료시
$ws_connection->onWebSocketConnect = function(AsyncTcpConnection $con, $response) {
echo $response;
$con->send('hello');
};
// 원격 웹소켓 서버가 메시지를 보낼 때
$ws_connection->onMessage = function($connection, $data){
echo "recv: $data\n";
};
// 연결 중 오류가 발생할 때, 일반적으로 원격 웹소켓 서버 연결 실패 오류가 발생합니다.
$ws_connection->onError = function($connection, $code, $msg){
echo "error: $msg\n";
};
// 원격 웹소켓 서버와의 연결이 끊겼을 때
$ws_connection->onClose = function($connection){
echo "connection closed and try to reconnect\n";
// 연결이 끊기면 1초 후 재연결
$connection->reConnect(1);
};
// 위의 각종 콜백을 설정한 후 연결 작업을 실행합니다.
$ws_connection->connect();
};
Worker::runAll();