ThinkPHP6에서 실시간 통신을 위해 WebSocket을 사용하는 방법은 무엇입니까?-ThinkPHP-php.cn

집

PHP 프레임워크

ThinkPHP

ThinkPHP6에서 실시간 통신을 위해 WebSocket을 사용하는 방법은 무엇입니까?

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Jun 12, 2023 am 10:40 AM

thinkphpwebsocket실시간 의사소통

WebSocket은 실시간 통신을 달성하기 위해 서버와 클라이언트 간에 실시간 연결을 설정할 수 있는 전이중 통신 프로토콜입니다. 웹 개발에서 일반적으로 사용되는 PHP 프레임워크는 ThinkPHP입니다. 그러면 ThinkPHP6에서 실시간 통신을 위해 WebSocket을 어떻게 사용할 수 있을까요?

Swoole 확장 설치

먼저 서버에 swoole 확장을 설치해야 합니다.

composer require swoole/swoole

참고: swoole 확장을 사용하려면 PHP 버전 >= 7.0이 필요합니다.

WebSocket 서비스 생성

ThinkPHP6에서는 사용자 정의 명령을 통해 WebSocket 서비스를 생성할 수 있습니다. 명령줄 도구를 열고 프로젝트 루트 디렉터리에 들어가서 다음 명령을 실행합니다.

php think make:command WebSocket

명령을 실행하면 app/command 디렉터리에 WebSocket.php 파일이 생성됩니다. 이 파일에 다음 코드를 추가합니다.

<?php
namespace appcommand;

use swoole_websocket_server;
use swoole_http_request;
use thinkconsoleCommand;
use thinkconsoleInput;
use thinkconsoleOutput;

class WebSocket extends Command
{
    protected function configure()
    {
        // 给命令起一个名字
        $this->setName('swoole:websocket')
            ->setDescription('Start websocket server');
    }

    protected function execute(Input $input, Output $output)
    {
        $server = new swoole_websocket_server("0.0.0.0", 9501);

        // 监听WebSocket连接打开事件
        $server->on('open', function (swoole_websocket_server $server, swoole_http_request $request) {
            echo "connection open: {$request->fd}
";
        });

        // 监听WebSocket消息事件
        $server->on('message', function (swoole_websocket_server $server, $frame) {
            echo "received message: {$frame->data}
";

            // 广播消息给所有连接的客户端
            $server->push($frame->fd, "this is server");
        });

        // 监听WebSocket连接关闭事件
        $server->on('close', function ($ser, $fd) {
            echo "connection close: {$fd}
";
        });

        $server->start();
    }
}

다음 명령을 실행하여 WebSocket 서비스를 시작합니다.

php think swoole:websocket

Use WebSocket in the view

뷰에서 JavaScript의 WebSocket API를 사용하여 서버와 통신할 수 있습니다. 실시간 . 예:

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>WebSocket</title>
</head>
<body>
    <script>
        var ws = new WebSocket('ws://localhost:9501');

        ws.onopen = function(){
            console.log('WebSocket open');
        };

        ws.onmessage = function(ev){
            console.log('WebSocket message: ' + ev.data);
        };

        ws.onclose = function(){
            console.log('WebSocket close');
        };
    </script>
</body>
</html>

위 코드는 WebSocket 인스턴스를 생성하고 로컬 WebSocket 서비스에 연결합니다. 서버가 메시지를 보내면 처리를 위해 onmessage 함수가 호출됩니다. 인스턴스의 send 함수를 호출하여 서버에 메시지를 보낼 수 있습니다.

이제 WebSocket 서비스가 성공적으로 생성되어 프런트 엔드와 실시간 통신 연결이 구축되었습니다.

요약

ThinkPHP6에서는 swoole 확장 기능을 이용하여 WebSocket 실시간 통신 기능을 쉽게 구현할 수 있습니다. 사용자 정의 명령을 통해 WebSocket 서비스를 활성화하고 이를 JavaScript WebSocket API와 결합하면 웹 애플리케이션에서 실시간 통신을 달성하여 다양한 비즈니스 요구 사항을 충족할 수 있습니다.

위 내용은 ThinkPHP6에서 실시간 통신을 위해 WebSocket을 사용하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명

본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.

핫 AI 도구

Video Face Swap

완전히 무료인 AI 얼굴 교환 도구를 사용하여 모든 비디오의 얼굴을 쉽게 바꾸세요!

뜨거운 도구

DVWA(Damn Vulnerable Web App)는 매우 취약한 PHP/MySQL 웹 애플리케이션입니다. 주요 목표는 보안 전문가가 법적 환경에서 자신의 기술과 도구를 테스트하고, 웹 개발자가 웹 응용 프로그램 보안 프로세스를 더 잘 이해할 수 있도록 돕고, 교사/학생이 교실 환경 웹 응용 프로그램에서 가르치고 배울 수 있도록 돕는 것입니다. 보안. DVWA의 목표는 다양한 난이도의 간단하고 간단한 인터페이스를 통해 가장 일반적인 웹 취약점 중 일부를 연습하는 것입니다. 이 소프트웨어는