这篇文章主要介绍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双向连接”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注亿速云行业资讯频道！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
