workerman如何實現tcp和http雙向連接

這篇文章主要介紹workerman如何實現tcp和http雙向連接，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

workerman實現tcp和http雙向連接

本來想采用GatewayWorker來完成的，最后還是想寫簡單一點。用workerman進行和智能設備的tcp長連接和http的短連接。
場景需求。小程序端傳給服務器開啟設備或調節溫度等操作。服務器和小程序http短連接，拿到信息后與設備進行tcp長連接。

1、建立tcp連接

protected $socket = 'tcp://0.0.0.0:2346';
protected $processes = 1;
protected $uidConnections = array();

2、在onWorkerStart建立http連接

global $ws_worker;
    // 監聽5678端口，協議websocket/http
    $ws_worker = new Work('http://0.0.0.0:5678');
    // 網頁ws發來數據的時候的處理，可根據需要做處理，這里省略
    $ws_worker->onMessage = function($ws_connection, $data){
    	$redis = new Redis();
        //獲取http發過來的http值
        $data = $data['get'];
        if(empty($data['type'])){
            $ws_connection->send("type為空");
        }elseif($data['type'] == 1){
            //開機
            //拿mac去redis驗證是否存在，然后拿拿到http進行訪問請求開機。做個定時器。到期自動請求設備關機
            $mac = $redis->hGet('facility',$data['mac']);
            if(!$mac){
                $ws_connection->send("mac地址錯誤");
            }
            $status = $this->sendMessageByUid($mac,'開機');//像指定用戶發送消息
            if($status == 1){//回調碼，判斷是否成功
                $ws_connection->send("開機成功");
            }else{
                $ws_connection->send("發生錯誤");
            }
        }elseif($data['type'] == 2){
            //關機
            //拿mac去redis驗證是否存在，然后拿拿到http進行訪問請求關機。
            $mac = $redis->hGet('facility',$data['mac']);
            if(!$mac){
                $ws_connection->send("mac地址錯誤");
            }
              $status = $this->sendMessageByUid($mac,'關機');//像指定用戶發送消息
            if($status == 1){//回調碼，判斷是否成功
                $ws_connection->send("關機成功");
            }else{
                $ws_connection->send("發生錯誤");
            }
        }
    };
    $ws_worker->listen();

}

上面代碼為demo案例。下面做點連接的測試，業務代碼自行參考

3、tcp連接與http連接

 /**
 * 當連接建立時觸發的回調函數
 * @param $connection
 */
public function onConnect($connection)
{
  $connection->send(“tcp連接\n");
    echo 'tcp連接';
    
}

我們做一個客戶端的tcp連接請求。

<?php
set_time_limit(0);

$host = "xxxxxxxx";//這里是你的服務器ip
$port = 2346;//這里是你的服務器端口
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)or die("Could not create  socket\n");

$connection = socket_connect($socket, $host, $port) or die("Could not connet server\n");
$mac = array("mac"=>'123456','ip'=>'1.2.3.4');

socket_write($socket, json_encode($mac)) or die("Write failed\n");
while ($buff = socket_read($socket, 1024, PHP_NORMAL_READ)) {
    echo '1';
    echo("Response was:" . $buff . "\n");
    echo("input what you want to say to the server:\n");
    $text = fgets(STDIN);
    socket_write($socket, $text);
}
socket_close($socket);

我們在終端運行這個php文件和server文件，當建立了連接時。服務端會輸出tcp連接（此時已是長連接）

注：當用tcp連接發送消息的時候，注意粘包問題。每個消息后加"\n"代表換行

我們在試一下http連接，http連接就簡單多了。url訪問就可以了

global $ws_worker;
$ws_worker = new Work('http://0.0.0.0:5678');
$ws_worker->onMessage = function($ws_connection, $data){
        echo "http連接";
}

這個簡單的例子應該都懂。接下來就差業務代碼了，就看自己發揮了。

以上是“workerman如何實現tcp和http雙向連接”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注億速云行業資訊頻道！