메시지 푸시에 Hyperf 프레임워크를 사용하는 방법-Swoole-php.cn

메시지 푸시에 Hyperf 프레임워크를 사용하는 방법

PHPz

풀어 주다： 2023-10-20 17:59:00

원래의

1112명이 탐색했습니다.

메시지 푸시에 Hyperf 프레임워크를 사용하는 방법

인터넷이 발전함에 따라 실시간 메시지 푸시는 많은 애플리케이션 시나리오에서 점점 더 중요해졌습니다. 고성능 PHP 마이크로서비스 프레임워크인 Hyperf 프레임워크는 경량, 낮은 대기 시간, 높은 동시성이라는 특성을 가지며 실시간 메시지 푸시에 매우 적합합니다. 이 문서에서는 Hyperf 프레임워크에서 메시지 푸시를 구현하는 방법을 소개하고 특정 코드 예제를 제공합니다.

1. Hyperf 프레임워크 설치

먼저 Hyperf 프레임워크를 설치해야 합니다. 작곡가 명령을 통해 설치할 수 있습니다:

composer create-project hyperf/hyperf-skeleton

로그인 후 복사

2. Swoole 확장 설치

Hyperf 프레임워크의 기본 계층은 Swoole 확장을 사용하므로 먼저 Swoole 확장을 설치해야 합니다. 다음 명령을 통해 설치할 수 있습니다.

pecl install swoole

로그인 후 복사

3. WebSocket 서버 생성

Hyperf 프레임워크에서는 WebSocket 서버를 사용하여 실시간 메시지 푸시를 구현할 수 있습니다. 클라이언트 연결과 메시지를 처리하려면 WebSocket 컨트롤러를 만들어야 합니다.

먼저 AppControllerWebSocketController 파일을 생성하고 다음 코드를 작성합니다. AppControllerWebSocketController文件，编写如下代码：

<?php

declare(strict_types=1);

namespace AppController;

use HyperfWebSocketServerContext;
use HyperfWebSocketServerSender;

class WebSocketController
{
    public function onConnect($fd)
    {
        // 当客户端连接时触发
    }

    public function onMessage($fd, $data)
    {
        // 当接收到客户端消息时触发
        $sender = make(Sender::class);
        $sender->push($fd, 'Hello, ' . $data);
    }

    public function onClose($fd)
    {
        // 当客户端断开连接时触发
    }
}

로그인 후 복사

然后，修改config/autoload/server.php文件，添加WebSocket服务器的配置：

<?php

declare(strict_types=1);

return [
    'servers' => [
        [
            'name' => 'websocket',
            'type' => Server::TYPE_WEB_SOCKET,
            'host' => '0.0.0.0',
            'port' => 9502,
            'sock_type' => SWOOLE_SOCK_TCP,
            'callbacks' => [
                Event::ON_HAND_SHAKE => [HyperfWebSocketServerListenerHandShakeListener::class, 'onHandShake'],
                Event::ON_MESSAGE => [AppControllerWebSocketController::class, 'onMessage'],
                Event::ON_CLOSE => [AppControllerWebSocketController::class, 'onClose'],
            ],
        ],
    ],
];

로그인 후 복사

四、编写前端页面

接下来，我们需要编写一个前端页面来测试WebSocket服务器。在public目录下创建一个index.html文件，编写如下代码：

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>WebSocket Demo</title>
</head>
<body>
    <input type="text" id="message" placeholder="请输入消息">
    <button onclick="sendMessage()">发送</button>

    <script>
        var ws = new WebSocket("ws://localhost:9502");

        ws.onopen = function() {
            console.log("连接成功");
        };

        ws.onmessage = function(evt) {
            console.log("收到消息：" + evt.data);
        };

        function sendMessage() {
            var message = document.getElementById("message").value;
            ws.send(message);
        };
    </script>
</body>
</html>

로그인 후 복사

五、启动WebSocket服务器

最后，我们需要启动WebSocket服务器，让它监听客户端的连接和消息。在终端执行以下命令：

php bin/hyperf.php start

로그인 후 복사

至此，我们已经完成了一个使用Hyperf框架实现的简单消息推送功能。当我们访问http://localhost/index.htmlrrreee

그런 다음 config/autoload/server.php 파일을 수정하고 WebSocket 구성을 추가합니다. server:

rrreee

4. 프런트 엔드 페이지 작성

다음으로 WebSocket 서버를 테스트하기 위한 프런트 엔드 페이지를 작성해야 합니다. public 디렉토리에 index.html 파일을 생성하고 다음 코드를 작성합니다:

rrreee

5. WebSocket 서버 시작 🎜🎜마지막으로 WebSocket 서버를 시작해야 합니다. 클라이언트 연결과 메시지를 수신하도록 합니다. 터미널에서 다음 명령을 실행합니다. 🎜rrreee🎜이제 Hyperf 프레임워크를 사용하여 구현된 간단한 메시지 푸시 기능이 완성되었습니다. http://localhost/index.html 페이지에 접속하면 WebSocket 서버에 연결이 됩니다. 그러면 메시지를 입력하고 보내기 버튼을 누르면 수신된 메시지를 볼 수 있습니다. 콘솔에서. 🎜🎜이 문서에서는 실시간 메시지 푸시를 위해 Hyperf 프레임워크에서 WebSocket을 사용하는 방법을 보여주는 간단한 예만 제공한다는 점에 유의해야 합니다. 실제 애플리케이션에는 특정 시나리오에 따라 해당 확장 및 최적화가 필요한 더 복잡한 요구 사항이 있을 수 있습니다. 🎜🎜요약🎜🎜이 글에서는 Hyperf 프레임워크에서 WebSocket을 사용하여 실시간 메시지 푸시를 구현하는 방법을 소개하고 해당 코드 예제를 제공합니다. 이 기사를 연구함으로써 귀하는 이미 Hyperf 프레임워크에서 메시지를 푸시하는 방법을 어느 정도 이해하고 있다고 믿습니다. 이 글이 도움이 되셨으면 좋겠습니다. 읽어주셔서 감사합니다! 🎜

위 내용은 메시지 푸시에 Hyperf 프레임워크를 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!