Comment utiliser le framework Hyperf pour le push de messages-Swoole-php.cn

Comment utiliser le framework Hyperf pour le push de messages

PHPz

Libérer： 2023-10-20 17:59:00

original

1145 Les gens l'ont consulté

Comment utiliser le framework Hyperf pour le push de messages

Avec le développement d'Internet, le push de messages en temps réel est devenu de plus en plus important dans de nombreux scénarios d'application. En tant que framework de microservices PHP hautes performances, le framework Hyperf présente les caractéristiques de légèreté, de faible latence et de concurrence élevée, et est très adapté au push de messages en temps réel. Cet article présentera comment implémenter le push de messages dans le framework Hyperf et fournira des exemples de code spécifiques.

1. Installez le framework Hyperf

Tout d'abord, nous devons installer le framework Hyperf. Il peut être installé via la commande composer :

composer create-project hyperf/hyperf-skeleton

Copier après la connexion

2. Installez l'extension Swoole

La couche sous-jacente du framework Hyperf utilise l'extension Swoole, nous devons donc d'abord installer l'extension Swoole. Il peut être installé via la commande suivante :

pecl install swoole

Copier après la connexion

3. Créez un serveur WebSocket

Dans le framework Hyperf, vous pouvez utiliser le serveur WebSocket pour réaliser un push de messages en temps réel. Nous devons créer un contrôleur WebSocket pour gérer les connexions client et les messages.

Tout d'abord, créez un fichier AppControllerWebSocketController et écrivez le code suivant : 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)
    {
        // 当客户端断开连接时触发
    }
}

Copier après la connexion

然后，修改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'],
            ],
        ],
    ],
];

Copier après la connexion

四、编写前端页面

接下来，我们需要编写一个前端页面来测试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>

Copier après la connexion

五、启动WebSocket服务器

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

php bin/hyperf.php start

Copier après la connexion

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

Ensuite, modifiez le fichier config/autoload/server.php et ajoutez la configuration du WebSocket serveur :

rrreee

4. Écrivez une page front-end

Ensuite, nous devons écrire une page front-end pour tester le serveur WebSocket. Créez un fichier index.html dans le répertoire public et écrivez le code suivant :

rrreee

5. Démarrez le serveur WebSocket 🎜🎜Enfin, nous devons démarrer le serveur WebSocket et laissez-le écouter les connexions et les messages des clients. Exécutez la commande suivante dans le terminal : 🎜rrreee🎜À ce stade, nous avons complété une simple fonction push de message implémentée à l'aide du framework Hyperf. Lorsque nous visitons la page http://localhost/index.html, une connexion au serveur WebSocket sera établie. Ensuite, nous saisissons le message et cliquons sur le bouton d'envoi, et nous pouvons voir le message reçu. dans la console. 🎜🎜Il convient de noter que cet article ne fournit qu'un exemple simple pour démontrer comment utiliser WebSocket dans le framework Hyperf pour le push de messages en temps réel. Il peut y avoir des exigences plus complexes dans les applications réelles, qui nécessitent une expansion et une optimisation correspondantes selon des scénarios spécifiques. 🎜🎜Résumé🎜🎜Cet article explique comment utiliser WebSocket dans le framework Hyperf pour implémenter le push de messages en temps réel et fournit des exemples de code correspondants. En étudiant cet article, je pense que vous avez déjà une certaine compréhension de la façon de transmettre des messages dans le framework Hyperf. J'espère que cet article vous sera utile, merci d'avoir lu ! 🎜

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!