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客户端