下面要跟大家介紹一下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連線要求。
'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雙向連線的方法介紹的詳細內容。更多資訊請關注PHP中文網其他相關文章！
