欧美一区二区三区老妇人-欧美做爰猛烈大尺度电-99久久夜色精品国产亚洲a-亚洲福利视频一区二区

workerman中后端消息實(shí)時(shí)推送至前端的方法

workerman中后端消息實(shí)時(shí)推送至前端的方法，針對(duì)這個(gè)問題，這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答，希望可以幫助更多想解決這個(gè)問題的小伙伴找到更簡(jiǎn)單易行的方法。

平湖網(wǎng)站建設(shè)公司創(chuàng)新互聯(lián)建站,平湖網(wǎng)站設(shè)計(jì)制作，有大型網(wǎng)站制作公司豐富經(jīng)驗(yàn)。已為平湖上1000+提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\外貿(mào)網(wǎng)站建設(shè)要多少錢，請(qǐng)找那個(gè)售后服務(wù)好的平湖做網(wǎng)站的公司定做！

在開發(fā)過程中，我們經(jīng)常會(huì)遇到如下這種情況。前端列表展示后臺(tái)數(shù)據(jù)庫(kù)中的數(shù)據(jù)，但是在后臺(tái)的某一個(gè)接口中向數(shù)據(jù)庫(kù)插入一條數(shù)據(jù)，此時(shí)數(shù)據(jù)庫(kù)已更新，但是前端展示數(shù)據(jù)并沒有更新，需要手動(dòng)刷新才可以。但是每次都自己手動(dòng)更新，太麻煩了，這時(shí)候就可以用到workerman來(lái)解決問題了。

Workerman框架是一款純PHP開發(fā)的開源高性能的PHP socket 服務(wù)器框架。被廣泛的用于手機(jī)app、移動(dòng)通訊，微信小程序，手游服務(wù)端、網(wǎng)絡(luò)游戲、PHP聊天室、硬件通訊、智能家居、車聯(lián)網(wǎng)、物聯(lián)網(wǎng)等領(lǐng)域的開發(fā)。 支持TCP長(zhǎng)連接，支持Websocket、HTTP等協(xié)議，支持自定義協(xié)議。擁有異步MySQL、異步redis、異步Http、異步消息隊(duì)列等眾多高性能組件。

那我們應(yīng)該如何能使用才能解決上述問題呢？

1.前后端建立websocket的長(zhǎng)連接，用于互相的消息推送

2.后端內(nèi)部在建立一個(gè)監(jiān)聽進(jìn)程（協(xié)議不限）

3.在接口往數(shù)據(jù)庫(kù)中插入數(shù)據(jù)成功后，想內(nèi)部監(jiān)聽端口推送數(shù)據(jù)

4.在收到內(nèi)部監(jiān)聽端口的推送消息之后，后端在向前端通過websocket推送消息，實(shí)現(xiàn)刷新

在下載好workerman框架源碼后，我們來(lái)實(shí)現(xiàn)上述過程。

實(shí)現(xiàn)代碼：

server.php

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

運(yùn)行流程：

打開cmd，運(yùn)行server.php

打開前端頁(yè)面和console

在打開一個(gè)cmd，運(yùn)行push.php

此時(shí)在看前端頁(yè)面，console就收收到消息。

關(guān)于workerman中后端消息實(shí)時(shí)推送至前端的方法問題的解答就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識(shí)。

名稱欄目：workerman中后端消息實(shí)時(shí)推送至前端的方法
網(wǎng)頁(yè)路徑：http://chinadenli.net/article16/ipsdgg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供定制網(wǎng)站、關(guān)鍵詞優(yōu)化、云服務(wù)器、用戶體驗(yàn)、靜態(tài)網(wǎng)站、網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)

成都定制網(wǎng)站網(wǎng)頁(yè)設(shè)計(jì)