During the development process, we often encounter the following situation. The front-end list displays the data in the back-end database, but when a piece of data is inserted into the database in a certain interface in the back-end, the database has been updated, but the front-end display data has not been updated and needs to be refreshed manually. But it is too troublesome to update manually every time. At this time, Workerman can be used to solve the problem.

Workerman Framework is an open source high-performance PHP socket server framework developed purely in PHP. It is widely used in the development of mobile apps, mobile communications, WeChat applets, mobile game servers, online games, PHP chat rooms, hardware communications, smart homes, Internet of Vehicles, Internet of Things and other fields. Supports TCP long connections, supports Websocket, HTTP and other protocols, and supports custom protocols. It has many high-performance components such as asynchronous Mysql, asynchronous Redis, asynchronous Http, asynchronous message queue, etc.

So how should we use it to solve the above problems?

1. The front and back ends establish long websocket connections for pushing messages to each other

2. The back end establishes a listening process (no protocol restrictions)

3. After the interface successfully inserts data into the database, the data will be pushed to the internal listening port

4. After receiving the push message from the internal listening port, the backend will push the data to the frontend Push messages through websocket to achieve refresh

After downloading the source code of the workerman framework, let's implement the above process.

Implementation code:

server.php

<?php
use Workerman\Worker;
 
require_once __DIR__ . &#39;/../../vendor/autoload.php&#39;;
 
 
// 初始化一個worker容器，監(jiān)聽1234端口
$worker = new Worker(&#39;websocket://0.0.0.0:1234&#39;);//
 
/*
 * 注意這里進(jìn)程數(shù)必須設(shè)置為1，否則會報端口占用錯誤
 * (php 7可以設(shè)置進(jìn)程數(shù)大于1，前提是$inner_text_worker->reusePort=true)
 */
$worker->count = 1;
// worker進(jìn)程啟動后創(chuàng)建一個text Worker以便打開一個內(nèi)部通訊端口
$worker->onWorkerStart = function($worker)
{
    // 開啟一個內(nèi)部端口，方便內(nèi)部系統(tǒng)推送數(shù)據(jù)，Text協(xié)議格式 文本+換行符
    $inner_text_worker = new Worker(&#39;text://0.0.0.0:5678&#39;);
    $inner_text_worker->onMessage = function($connection, $buffer)
    {
        // $data數(shù)組格式，里面有uid，表示向那個uid的頁面推送數(shù)據(jù)
        $data = json_decode($buffer, true);
        $uid = $data[&#39;uid&#39;];
        // 通過workerman，向uid的頁面推送數(shù)據(jù)
        $ret = sendMessageByUid($uid, $buffer);
        // 返回推送結(jié)果
        $connection->send($ret ? &#39;ok&#39; : &#39;fail&#39;);
    };
    // ## 執(zhí)行監(jiān)聽 ##
    $inner_text_worker->listen();
};
// 新增加一個屬性，用來保存uid到connection的映射
$worker->uidConnections = array();
// 當(dāng)有客戶端發(fā)來消息時執(zhí)行的回調(diào)函數(shù)
$worker->onMessage = function($connection, $data)
{
    global $worker;
    // 判斷當(dāng)前客戶端是否已經(jīng)驗證,既是否設(shè)置了uid
    if(!isset($connection->uid))
    {
        // 沒驗證的話把第一個包當(dāng)做uid（這里為了方便演示，沒做真正的驗證）
        $connection->uid = $data;
        /* 保存uid到connection的映射，這樣可以方便的通過uid查找connection，
         * 實現(xiàn)針對特定uid推送數(shù)據(jù)
         */
        $worker->uidConnections[$connection->uid] = $connection;
        return;
    }
};
 
// 當(dāng)有客戶端連接斷開時
$worker->onClose = function($connection)
{
    global $worker;
    if(isset($connection->uid))
    {
        // 連接斷開時刪除映射
        unset($worker->uidConnections[$connection->uid]);
    }
};
 
// 向所有驗證的用戶推送數(shù)據(jù)
function broadcast($message)
{
    global $worker;
    foreach($worker->uidConnections as $connection)
    {
        $connection->send($message);
    }
}
 
// 針對uid推送數(shù)據(jù)
function sendMessageByUid($uid, $message)
{
    global $worker;
    if(isset($worker->uidConnections[$uid]))
    {
        $connection = $worker->uidConnections[$uid];
        $connection->send($message);
        return true;
    }
    return false;
}
 
// 運(yùn)行所有的worker
Worker::runAll();

push.php

<?php
//插入數(shù)據(jù)庫操作
 
// 建立socket連接到內(nèi)部推送端口
$client = stream_socket_client(&#39;tcp://127.0.0.1:5678&#39;, $errno, $errmsg, 1);
// 推送的數(shù)據(jù)，包含uid字段，表示是給這個uid推送
$data = array(&#39;uid&#39;=>&#39;uid1&#39;, &#39;percent&#39;=>&#39;88%&#39;);
// 發(fā)送數(shù)據(jù)，注意5678端口是Text協(xié)議的端口，Text協(xié)議需要在數(shù)據(jù)末尾加上換行符
fwrite($client, json_encode($data)."\n");
// 讀取推送結(jié)果
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>

Running process:

Open cmd and run server.php

Open the front-end page and console

Open a cmd and run push.php

At this time, while viewing the front-end page, the console received the message.

For more workerman knowledge, please pay attention to the workerman tutorial column on the PHP Chinese website.

The above is the detailed content of How to push back-end messages to the front-end in workerman in real time. For more information, please follow other related articles on the PHP Chinese website!