Comment transmettre des messages back-end vers le front-end dans Workerman en temps réel

Au cours du processus de développement, nous rencontrons souvent la situation suivante. La liste frontale affiche les données dans la base de données principale, mais lorsqu'une donnée est insérée dans la base de données dans une certaine interface du back-end, la base de données a été mise à jour, mais les données d'affichage frontales ont n'a pas été mis à jour et doit être actualisé manuellement. Mais il est trop difficile de mettre à jour manuellement à chaque fois, vous pouvez utiliser Workerman pour résoudre le problème.

Workerman framework est un framework de serveur socket PHP open source hautes performances développé uniquement en PHP. Il est largement utilisé dans le développement d'applications mobiles, de communications mobiles, d'applets WeChat, de serveurs de jeux mobiles, de jeux en ligne, de salons de discussion PHP, de communications matérielles, de maisons intelligentes, de l'Internet des véhicules, de l'Internet des objets et d'autres domaines. Prend en charge les connexions longues TCP, prend en charge Websocket, HTTP et d'autres protocoles, ainsi que les protocoles personnalisés. Il possède de nombreux composants hautes performances tels que Mysql asynchrone, Redis asynchrone, Http asynchrone, file d'attente de messages asynchrone, etc.

Alors, comment devrions-nous l'utiliser pour résoudre les problèmes ci-dessus ?

1. Les extrémités avant et arrière établissent une longue connexion Websocket pour transmettre des messages les uns aux autres

2. Un processus d'écoute est établi à l'intérieur du back-end (aucune restriction de protocole) <.>

3. Une fois que l'interface a inséré avec succès les données dans la base de données, les données sont poussées vers le port d'écoute interne

4. , le backend envoie les données aux messages Push du frontend via websocket pour obtenir une actualisation

Après avoir téléchargé le code source du framework Workerman, nous mettrons en œuvre le processus ci-dessus.

Code d'implémentation :

server.php

<?php
use Workerman\Worker;
 
require_once __DIR__ . &#39;/../../vendor/autoload.php&#39;;
 
 
// 初始化一个worker容器，监听1234端口
$worker = new Worker(&#39;websocket://0.0.0.0:1234&#39;);//
 
/*
 * 注意这里进程数必须设置为1，否则会报端口占用错误
 * (php 7可以设置进程数大于1，前提是$inner_text_worker->reusePort=true)
 */
$worker->count = 1;
// worker进程启动后创建一个text Worker以便打开一个内部通讯端口
$worker->onWorkerStart = function($worker)
{
    // 开启一个内部端口，方便内部系统推送数据，Text协议格式 文本+换行符
    $inner_text_worker = new Worker(&#39;text://0.0.0.0:5678&#39;);
    $inner_text_worker->onMessage = function($connection, $buffer)
    {
        // $data数组格式，里面有uid，表示向那个uid的页面推送数据
        $data = json_decode($buffer, true);
        $uid = $data[&#39;uid&#39;];
        // 通过workerman，向uid的页面推送数据
        $ret = sendMessageByUid($uid, $buffer);
        // 返回推送结果
        $connection->send($ret ? &#39;ok&#39; : &#39;fail&#39;);
    };
    // ## 执行监听 ##
    $inner_text_worker->listen();
};
// 新增加一个属性，用来保存uid到connection的映射
$worker->uidConnections = array();
// 当有客户端发来消息时执行的回调函数
$worker->onMessage = function($connection, $data)
{
    global $worker;
    // 判断当前客户端是否已经验证,既是否设置了uid
    if(!isset($connection->uid))
    {
        // 没验证的话把第一个包当做uid（这里为了方便演示，没做真正的验证）
        $connection->uid = $data;
        /* 保存uid到connection的映射，这样可以方便的通过uid查找connection，
         * 实现针对特定uid推送数据
         */
        $worker->uidConnections[$connection->uid] = $connection;
        return;
    }
};
 
// 当有客户端连接断开时
$worker->onClose = function($connection)
{
    global $worker;
    if(isset($connection->uid))
    {
        // 连接断开时删除映射
        unset($worker->uidConnections[$connection->uid]);
    }
};
 
// 向所有验证的用户推送数据
function broadcast($message)
{
    global $worker;
    foreach($worker->uidConnections as $connection)
    {
        $connection->send($message);
    }
}
 
// 针对uid推送数据
function sendMessageByUid($uid, $message)
{
    global $worker;
    if(isset($worker->uidConnections[$uid]))
    {
        $connection = $worker->uidConnections[$uid];
        $connection->send($message);
        return true;
    }
    return false;
}
 
// 运行所有的worker
Worker::runAll();

push.php

<?php
//插入数据库操作
 
// 建立socket连接到内部推送端口
$client = stream_socket_client(&#39;tcp://127.0.0.1:5678&#39;, $errno, $errmsg, 1);
// 推送的数据，包含uid字段，表示是给这个uid推送
$data = array(&#39;uid&#39;=>&#39;uid1&#39;, &#39;percent&#39;=>&#39;88%&#39;);
// 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
fwrite($client, json_encode($data)."\n");
// 读取推送结果
echo fread($client, 8192);
 
 ?>

clien.html

<!DOCTYPE html>
<html>
<head>
	<title></title>
</head>
<body>
<script>
	var ws = new WebSocket(&#39;ws://127.0.0.1:1234&#39;);
	ws.onopen = function(){
		var uid = &#39;uid1&#39;;
		ws.send(uid);
	};
	ws.onmessage = function(e){
		//alert(e.data);
		console.log(e.data);
		//window.location.reload();
	};
</script>
</body>
</html>

Processus en cours d'exécution :

Ouvrez cmd, exécutez server.php

Ouvrez la page front-end et la console

Ouvrez un cmd, exécutez push.php

Lors de l'affichage de la page frontale, la console a reçu le message.

Pour plus de connaissances sur Workerman, veuillez faire attention à la colonne

Tutoriel Workerman sur le site Web PHP chinois.

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!