workerman實現tcp和http雙向連接的方法介紹

下面給大家介紹一下workerman實現tcp和http雙向連接的方法介紹。有一定的參考價值,有需要的朋友可以參考一下,希望對大家有所幫助。

workerman實現tcp和http雙向連接的方法介紹

相關推薦:《workerman

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  socketn");  $connection = socket_connect($socket, $host, $port) or die("Could not connet servern"); $mac = array("mac"=>'123456','ip'=>'1.2.3.4');  socket_write($socket, json_encode($mac)) or die("Write failedn"); 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”代表換行

workerman實現tcp和http雙向連接的方法介紹
我們在試一下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雙向連接的方法介紹
這個簡單的例子應該都懂。接下來就差業務代碼了,就看自己發揮了。

更多編程相關知識,請訪問:workerman!!

以上就是

? 版權聲明
THE END
喜歡就支持一下吧
點贊10 分享