下面由workerman教學欄位介紹給大家介紹使用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>
<h1 id="target"></h1>
</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進行訊息推送的詳細內容。更多資訊請關注PHP中文網其他相關文章！
Workerman內置WebSocket客戶端的關鍵功能是什麼？Mar 18, 2025 pm 04:20 PMWorkerman的Websocket客戶端可以通過異步通信，高性能，可伸縮性和安全性等功能增強實時通信，並可以輕鬆地與現有系統集成。
如何使用工作人員來構建實時協作工具？Mar 18, 2025 pm 04:15 PM本文討論了使用高性能PHP服務器Workerman來構建實時協作工具。它涵蓋安裝，服務器設置，實時功能實現以及與現有系統集成，強調Workerman的密鑰F
為低延遲應用優化工作人員的最佳方法是什麼？Mar 18, 2025 pm 04:14 PM本文討論了針對低延遲應用程序的優化工作人員，重點介紹異步編程，網絡配置，資源管理，數據傳輸最小化，負載平衡和常規更新。
如何與Workerman和MySQL實施實時數據同步？Mar 18, 2025 pm 04:13 PM本文討論了使用Workerman和MySQL實施實時數據同步的，重點是設置，最佳實踐，確保數據一致性以及解決共同挑戰。
在無服務器體系結構中使用Workerman的主要考慮因素是什麼？Mar 18, 2025 pm 04:12 PM本文討論了將工作人員集成到無服務器體系結構中，專注於可擴展性，無狀態，冷啟動，資源管理和集成複雜性。 Workerman通過高並發，降低冷STA來提高性能
如何使用Workerman建立高性能的電子商務平台？Mar 18, 2025 pm 04:11 PM文章討論了使用Workerman建立高性能的電子商務平台，重點關注其功能，例如Websocket支持和可擴展性，以提高實時交互和效率。
Workerman的Websocket服務器的高級功能是什麼？Mar 18, 2025 pm 04:08 PMWorkerman的Websocket服務器可以通過可擴展性，低延遲和針對常見威脅的安全措施等功能增強實時通信。
如何使用工作人員來構建實時分析儀表板？Mar 18, 2025 pm 04:07 PM本文討論了使用高性能PHP服務器Workerman來構建實時分析儀表板。它涵蓋了與React，vue.js和Angular等框架的安裝，服務器設置，數據處理以及前端集成。關鍵功能
熱AI工具
Undresser.AI Undress
人工智慧驅動的應用程序，用於創建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Undress AI Tool
免費脫衣圖片
Clothoff.io
AI脫衣器
AI Hentai Generator
免費產生 AI 無盡。
熱門文章
熱工具
SublimeText3 Linux新版
SublimeText3 Linux最新版
EditPlus 中文破解版
體積小，語法高亮，不支援程式碼提示功能
PhpStorm Mac 版本
最新（2018.2.1 ）專業的PHP整合開發工具
SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)
記事本++7.3.1
好用且免費的程式碼編輯器
