tcp와 http 간의 양방향 연결을 구현하는 워커맨의 방법 소개

tcp와 http 양방향 연결을 구현하는 방법을 workerman 여러분께 소개하겠습니다. 도움이 필요한 친구들이 모두 참고할 수 있기를 바랍니다.

관련 추천: "workerman Tutorial"

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

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();

}

에서 http 연결 설정 위 코드는 데모 사례입니다. 몇 가지 연결 테스트를 해보겠습니다. 비즈니스 코드를 직접 참조하세요

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 파일과 서버 파일을 실행합니다. 서버는 tcp 연결을 출력합니다(현재는 긴 연결입니다)

참고: tcp 연결을 사용하여 메시지를 보낼 때 고정 패킷 문제에 주의하세요. 각 메시지 뒤에 "n"을 추가하면 줄 바꿈을 나타냅니다.

우리는 훨씬 더 간단한 http 연결을 시도하고 있습니다. url

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

에 접속하시면 이 간단한 예를 모두 이해하실 수 있을 것입니다. 다음으로 남은 것은 비즈니스 코드뿐이며, 이를 수행하는 것은 귀하의 몫입니다.

더 많은 프로그래밍 관련 지식을 보려면 프로그래밍 교육을 방문하세요! !

위 내용은 tcp와 http 간의 양방향 연결을 구현하는 워커맨의 방법 소개의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!