ws协议

বর্তমানে Workerman এর ws协议 সংস্করণ 13।

workerman ক্লায়েন্ট হিসাবে কাজ করতে পারে, ws协议 ব্যবহার করে websocket সংযোগ শুরু করতে পারে, দূরবর্তী websocket সার্ভারে সংযোগ স্থাপন করে, দ্বিদিকে যোগাযোগ বাস্তবায়ন করে।

注意
ws协议 শুধুমাত্র AsyncTcpConnection দ্বারা ক্লায়েন্ট হিসেবে ব্যবহার করা যাবে, websocket সার্ভার হিসেবে শোনা হবে না। অর্থাৎ নিচের লেখাটি ভুল।

$worker = new Worker('ws://0.0.0.0:8080');

যদি আপনি workerman কে websocket সার্ভার হিসেবে ব্যবহার করতে চান, তাহলে websocket协议 ব্যবহার করুন।

ws作为websocket客户端协议示例：

<?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 = [
        'Cookie' => 'PHPSID=82u98fjhakfusuanfnahfi; token=2hf9a929jhfihaf9i',
        'OtherKey' => 'values'
    ];
    // 设置数据类型(可选)
    $ws_connection->websocketType = Ws::BINARY_TYPE_BLOB; // BINARY_TYPE_BLOB为文本 BINARY_TYPE_ARRAYBUFFER为二进制
    // 当TCP完成三次握手后(可选)
    $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();

অতিরিক্ত তথ্যের জন্য 作为ws/wss客户端 দেখুন।