亚洲国产日韩欧美一区二区三区,精品亚洲国产成人av在线,国产99视频精品免视看7,99国产精品久久久久久久成人热,欧美日韩亚洲国产综合乱

首頁 php框架 Workerman 如何使用workerman進(jìn)行訊息推送

如何使用workerman進(jìn)行訊息推送

Jan 17, 2020 pm 04:08 PM
workerman

下面由workerman教學(xué)欄位介紹給大家介紹使用workerman進(jìn)行訊息推送的方法,希望對需要的朋友有幫助!

如何使用workerman進(jìn)行訊息推送

Workerman是一款純PHP開發(fā)的開源高效能的PHP socket 伺服器框架。廣泛的用於手機(jī)app、行動通訊,微信小程序,手遊服務(wù)端、網(wǎng)路遊戲、PHP聊天室、硬體通訊、智慧家庭、車聯(lián)網(wǎng)、物聯(lián)網(wǎng)等領(lǐng)域的開發(fā)。?

支援TCP長連接,支援Websocket、HTTP等協(xié)議,支援自訂協(xié)定。擁有非同步Mysql、非同步Redis、非同步Http、非同步訊息佇列等眾多高效能元件。與之類似的還有swoole,MeepoPS。

首先下載workerman的Web訊息推送系統(tǒng) web-msg-sender。

# wget http://www.workerman.net/download/senderzip
# unzip senderzip
#cd web-msg-sender 
#vim start.php
use Workerman\Worker;
// composer 的 autoload 文件
include __DIR__ . '/vendor/autoload.php';
if(strpos(strtolower(PHP_OS), 'win') === 0)
{
    exit("start.php not support windows, please use start_for_win.bat\n");
}
// 標(biāo)記是全局啟動
define('GLOBAL_START', 1);
// 加載IO 和 Web
require_once __DIR__ . '/start_io.php';
可以注釋掉 webServer 服務(wù) 沒什么用  省點(diǎn)資源
// require_once __DIR__ . '/start_web.php';
// 運(yùn)行所有服務(wù)
Worker::runAll();

儲存

#vim start_io.php
找到 將端口改成你要監(jiān)聽的端口 我是2120 記住要在安全組里入方向添加白名單
// PHPSocketIO服務(wù) 
$sender_io = new SocketIO(2120);
服務(wù)端設(shè)置完畢后
#php start.php start -d //開啟服務(wù) 并保持進(jìn)程

推送類別我使用的tp5

<?php
namespace app\index\moudel; 
/**
 * 推送事件
 * 典型調(diào)用方式:
 * $push = new WebSocket();
 * $push->setUser($user_id)->setContent($string)->push();//連貫操作
 *
 * Class WebSocket
 * @package app\index\moudel; 
 */
class WebSocket
{
    /**
     * @var string 目標(biāo)用戶id
     */
    protected $to_user = &#39;&#39;;
    /**
     * @var string 推送服務(wù)地址 
     */
    protected $push_api_url = &#39;http://127.0.0.1:2000&#39;;
    /**
     * @var string 推送內(nèi)容
     */
    protected $content = &#39;&#39;;
    /**
     * 設(shè)置推送用戶,若參數(shù)留空則推送到所有在線用戶
     *
     * @param string $user
     * @return $this
     */
    public function setUser($user = &#39;&#39;)
    {
        $this->to_user = $user ? : &#39;&#39;;
        return $this;
    }
    /**
     * 設(shè)置推送內(nèi)容
     *
     * @param string $content
     * @return $this
     */
    public function setContent($content = &#39;&#39;)
    {
        $this->content = $content;
        return $this;
    }
    /**
     * 推送
     */
    public function push()
    {
        $data = [
            &#39;type&#39; => &#39;publish&#39;,
            &#39;content&#39; => $this->content,
            &#39;to&#39; => $this->to_user,
        ];
        // var_dump($data);
        // var_dump($this->push_api_url);
        $ch = curl_init ();
        curl_setopt($ch, CURLOPT_URL, $this->push_api_url);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_HEADER, 0);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array(&#39;Expect:&#39;));
        $res = curl_exec($ch);
        curl_close($ch);
        dump($res);
    }
}

操作控制器

<?php
namespace app\index\controller;
use think\Controller;
use app\index\moudel\WebSocket;
class Index extends Controller
{
 /**
     * 推送一個(gè)字符串
     */
    public function push_msg(){
        $uid = input(&#39;uid&#39;,&#39;&#39;);//uid為空的時(shí)候推送給所有用戶
        $string = &#39;這是一個(gè)推送的測試&#39;;
        $string = input(&#39;msg&#39;) ? : $string;
        $push = new WebSocket();
        $push->setUser($uid)->setContent($string)->push();
    }
    /**
     * 推送目標(biāo)頁
     *
     * @return \think\response\View
     */
    public function targetPage(){
        return view();
    }
}

推送目標(biāo)的前端顯示

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<strong id="count"></strong>
<h1 id="target"></h1>
</body>
</html>
<script src="http://cdn.bootcss.com/jquery/3.1.0/jquery.min.js"></script>
<script src=&#39;http://cdn.bootcss.com/socket.io/1.3.7/socket.io.js&#39;></script>
<script>
    jQuery(function ($) {
        // 連接服務(wù)端
        var socket = io(&#39;http://39.106.132.216:2000/&#39;); //這里當(dāng)然填寫真實(shí)的地址了
        // uid可以是自己網(wǎng)站的用戶id,以便針對uid推送以及統(tǒng)計(jì)在線人數(shù),但一定是唯一標(biāo)識
        uid = 321;
        // socket連接后以uid登錄
        socket.on(&#39;connect&#39;, function () {
            socket.emit(&#39;login&#39;, uid);
        });
        // 后端推送來消息時(shí)
        socket.on(&#39;new_msg&#39;, function (msg) {
            console.log("收到消息:" + msg);
            $(&#39;#target&#39;).append(msg).append(&#39;<br>&#39;);
        });
        // 后端推送來在線數(shù)據(jù)時(shí)
        socket.on(&#39;update_online_count&#39;, function (online_stat) {
            console.log(online_stat);
            $(&#39;#count&#39;).html(online_stat);
        });
    })
</script>
http://我自己的域名/index/index/pushAString?uid=123
ok 為推送成功
offline 為未在線
fail 為失敗

前端成功展示321為我自訂的uid

如何使用workerman進(jìn)行訊息推送

以上是如何使用workerman進(jìn)行訊息推送的詳細(xì)內(nèi)容。更多資訊請關(guān)注PHP中文網(wǎng)其他相關(guān)文章!

本網(wǎng)站聲明
本文內(nèi)容由網(wǎng)友自願投稿,版權(quán)歸原作者所有。本站不承擔(dān)相應(yīng)的法律責(zé)任。如發(fā)現(xiàn)涉嫌抄襲或侵權(quán)的內(nèi)容,請聯(lián)絡(luò)admin@php.cn

熱AI工具

Undress AI Tool

Undress AI Tool

免費(fèi)脫衣圖片

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅(qū)動的應(yīng)用程序,用於創(chuàng)建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費(fèi)的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費(fèi)的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強(qiáng)大的PHP整合開發(fā)環(huán)境

Dreamweaver CS6

Dreamweaver CS6

視覺化網(wǎng)頁開發(fā)工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

熱門話題

Laravel 教程
1597
29
PHP教程
1488
72
實(shí)作Workerman文件中的文件上傳與下載 實(shí)作Workerman文件中的文件上傳與下載 Nov 08, 2023 pm 06:02 PM

實(shí)現(xiàn)Workerman文件中的文件上傳與下載,需要具體程式碼範(fàn)例引言:Workerman是一款高效能的PHP非同步網(wǎng)路通訊框架,具備簡潔、高效、易用等特點(diǎn)。在實(shí)際開發(fā)中,文件上傳和下載是常見的功能需求,本文將介紹如何使用Workerman框架實(shí)現(xiàn)文件的上傳和下載,並給出具體的程式碼範(fàn)例。一、檔案上傳:檔案上傳是指將本機(jī)上的檔案傳輸至伺服器端的操作。下面是使用

swoole和workerman哪個(gè)好 swoole和workerman哪個(gè)好 Apr 09, 2024 pm 07:00 PM

Swoole 和 Workerman 都是高效能 PHP 伺服器框架。 Swoole 以其非同步處理、出色的效能和可擴(kuò)展性而聞名,適用於需要處理大量並發(fā)請求和高吞吐量的專案。 Workerman 提供了非同步和同步模式的靈活性,具有直覺的 API,更適合易用性和處理較低並發(fā)量的專案。

如何實(shí)作Workerman文件的基本使用方法 如何實(shí)作Workerman文件的基本使用方法 Nov 08, 2023 am 11:46 AM

如何實(shí)現(xiàn)Workerman文件的基本使用方法簡介:Workerman是一個(gè)高效能的PHP開發(fā)框架,它可以幫助開發(fā)者輕鬆建立高並發(fā)的網(wǎng)路應(yīng)用程式。本文將介紹Workerman的基本使用方法,包括安裝和設(shè)定、建立服務(wù)和監(jiān)聽連接埠、處理客戶端請求等。並給出相應(yīng)的程式碼範(fàn)例。一、安裝並設(shè)定Workerman在命令列中輸入以下命令來安裝Workerman:c

如何實(shí)作Workerman文件中的定時(shí)器功能 如何實(shí)作Workerman文件中的定時(shí)器功能 Nov 08, 2023 pm 05:06 PM

如何實(shí)現(xiàn)Workerman文件中的定時(shí)器功能Workerman是一款強(qiáng)大的PHP非同步網(wǎng)路通訊框架,它提供了豐富的功能,其中就包括定時(shí)器功能。使用定時(shí)器可以在指定的時(shí)間間隔內(nèi)執(zhí)行程式碼,非常適合定時(shí)任務(wù)、輪詢等應(yīng)用程式場景。接下來,我將詳細(xì)介紹如何在Workerman中實(shí)現(xiàn)定時(shí)器功能,並提供具體的程式碼範(fàn)例。第一步:安裝Workerman首先,我們需要安裝Worker

Workerman開發(fā):如何實(shí)現(xiàn)基於UDP協(xié)定的即時(shí)視訊通話 Workerman開發(fā):如何實(shí)現(xiàn)基於UDP協(xié)定的即時(shí)視訊通話 Nov 08, 2023 am 08:03 AM

Workerman開發(fā):基於UDP協(xié)議的即時(shí)視訊通話摘要:本文將介紹如何使用Workerman框架實(shí)現(xiàn)基於UDP協(xié)議的即時(shí)視訊通話功能。我們將深入了解UDP協(xié)議的特點(diǎn),並透過程式碼範(fàn)例展示如何建立一個(gè)簡單但完整的即時(shí)視訊通話應(yīng)用程式。引言:在網(wǎng)路通訊中,即時(shí)視訊通話是一項(xiàng)非常重要的功能。傳統(tǒng)的TCP協(xié)定在實(shí)現(xiàn)即時(shí)性較高的視訊通話時(shí),可能會有傳輸延遲等問題。而UDP

如何實(shí)現(xiàn)Workerman文件中的反向代理功能 如何實(shí)現(xiàn)Workerman文件中的反向代理功能 Nov 08, 2023 pm 03:46 PM

如何實(shí)現(xiàn)Workerman文件中的反向代理功能,需要具體程式碼範(fàn)例簡介:Workerman是一款高效能的PHP多進(jìn)程網(wǎng)路通訊框架,提供了豐富的功能和強(qiáng)大的效能,廣泛應(yīng)用於Web即時(shí)通訊、長連接服務(wù)等場景。其中,Workerman也支援反向代理功能,可實(shí)現(xiàn)伺服器對外提供服務(wù)時(shí)的負(fù)載平衡和靜態(tài)資源快取等功能。本篇文章將介紹如何使用Workerman實(shí)現(xiàn)反向代理功

如何使用Workerman建構(gòu)高可用性負(fù)載平衡系統(tǒng) 如何使用Workerman建構(gòu)高可用性負(fù)載平衡系統(tǒng) Nov 07, 2023 pm 01:16 PM

如何使用Workerman建立高可用性負(fù)載平衡系統(tǒng),需要具體程式碼範(fàn)例在現(xiàn)代技術(shù)領(lǐng)域中,隨著網(wǎng)路的快速發(fā)展,越來越多的網(wǎng)站和應(yīng)用程式需要處理大量的並發(fā)請求。為了實(shí)現(xiàn)高可用性和高效能,負(fù)載平衡系統(tǒng)成為了必不可少的組件之一。本文將介紹如何使用PHP開源框架Workerman建構(gòu)一個(gè)高可用性的負(fù)載平衡系統(tǒng),並提供具體的程式碼範(fàn)例。一、Workerman簡介Worke

實(shí)現(xiàn)Workerman文件中的文件傳輸功能 實(shí)現(xiàn)Workerman文件中的文件傳輸功能 Nov 08, 2023 pm 03:39 PM

Workerman是基於PHP開發(fā)的高效能非同步事件驅(qū)動框架,它可以輕鬆實(shí)現(xiàn)TCP/UDP協(xié)定下的長連線開發(fā)。除此之外,Workerman也提供了實(shí)現(xiàn)檔案傳輸?shù)墓δ埽梢杂渺洞髾n案傳輸、資料備份等場景。本文將介紹如何在Workerman中實(shí)現(xiàn)檔案傳輸功能,並提供具體的程式碼範(fàn)例。一、文件上傳功能實(shí)現(xiàn)文件上傳功能需要客戶端將要上傳的文件傳送給服務(wù)端,服務(wù)端驗(yàn)證

See all articles