溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章給大家分享的是有關使用workerman進行消息推送的方法的內容。小編覺得挺實用的，因此分享給大家做個參考。一起跟隨小編過來看看吧。
Workerman是一款純PHP開發的開源高性能的PHP socket 服務器框架。被廣泛的用于手機app、移動通訊，微信小程序，手游服務端、網絡游戲、PHP聊天室、硬件通訊、智能家居、車聯網、物聯網等領域的開發。
支持TCP長連接，支持Websocket、HTTP等協議，支持自定義協議。擁有異步Mysql、異步Redis、異步Http、異步消息隊列等眾多高性能組件。與之類似的還有swoole，MeepoPS。
首先下載workerman的Web消息推送系統 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");
}
// 標記是全局啟動
define('GLOBAL_START', 1);
// 加載IO 和 Web
require_once __DIR__ . '/start_io.php';
可以注釋掉 webServer 服務 沒什么用 省點資源
// require_once __DIR__ . '/start_web.php';
// 運行所有服務
Worker::runAll();保存
#vim start_io.php 找到 將端口改成你要監聽的端口 我是2120 記住要在安全組里入方向添加白名單 // PHPSocketIO服務 $sender_io = new SocketIO(2120); 服務端設置完畢后 #php start.php start -d //開啟服務 并保持進程
推送類 我用的tp5
<?php
namespace app\index\moudel;
/**
* 推送事件
* 典型調用方式：
* $push = new WebSocket();
* $push->setUser($user_id)->setContent($string)->push();//連貫操作
*
* Class WebSocket
* @package app\index\moudel;
*/
class WebSocket
{
/**
* @var string 目標用戶id
*/
protected $to_user = '';
/**
* @var string 推送服務地址
*/
protected $push_api_url = 'http://127.0.0.1:2000';
/**
* @var string 推送內容
*/
protected $content = '';
/**
* 設置推送用戶，若參數留空則推送到所有在線用戶
*
* @param string $user
* @return $this
*/
public function setUser($user = '')
{
$this->to_user = $user ? : '';
return $this;
}
/**
* 設置推送內容
*
* @param string $content
* @return $this
*/
public function setContent($content = '')
{
$this->content = $content;
return $this;
}
/**
* 推送
*/
public function push()
{
$data = [
'type' => 'publish',
'content' => $this->content,
'to' => $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('Expect:'));
$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
{
/**
* 推送一個字符串
*/
public function push_msg(){
$uid = input('uid','');//uid為空的時候推送給所有用戶
$string = '這是一個推送的測試';
$string = input('msg') ? : $string;
$push = new WebSocket();
$push->setUser($uid)->setContent($string)->push();
}
/**
* 推送目標頁
*
* @return \think\response\View
*/
public function targetPage(){
return view();
}
}推送目標的前端顯示
<!DOCTYPE html> <html> <head> <meta charset="UTF-8"> <title>Title</title> </head> <body> <strong id="count"></strong> <h2 id="target"></h2> </body> </html> <script src="http://cdn.bootcss.com/jquery/3.1.0/jquery.min.js"></script> <script src='http://cdn.bootcss.com/socket.io/1.3.7/socket.io.js'></script> <script> jQuery(function ($) { // 連接服務端 var socket = io('http://39.106.132.216:2000/'); //這里當然填寫真實的地址了 // uid可以是自己網站的用戶id，以便針對uid推送以及統計在線人數，但一定是唯一標識 uid = 321; // socket連接后以uid登錄 socket.on('connect', function () { socket.emit('login', uid); }); // 后端推送來消息時 socket.on('new_msg', function (msg) { console.log("收到消息：" + msg); $('#target').append(msg).append('<br>'); }); // 后端推送來在線數據時 socket.on('update_online_count', function (online_stat) { console.log(online_stat); $('#count').html(online_stat); }); }) </script>
http://我自己的域名/index/index/pushAString?uid=123 ok 為推送成功 offline 為未在線 fail 為失敗
前端成功展示 321為我自定義的uid
感謝各位的閱讀！關于使用workerman進行消息推送的方法就分享到這里了，希望以上內容可以對大家有一定的幫助，讓大家可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
