如何使用workerman進行訊息推送
下面由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中文網其他相關文章！
熱AI工具
Undresser.AI Undress
人工智慧驅動的應用程序，用於創建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Undress AI Tool
免費脫衣圖片
Clothoff.io
AI脫衣器
AI Hentai Generator
免費產生 AI 無盡。
熱門文章
熱工具
記事本++7.3.1
好用且免費的程式碼編輯器
SublimeText3漢化版
中文版，非常好用
禪工作室 13.0.1
強大的PHP整合開發環境
Dreamweaver CS6
視覺化網頁開發工具
SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)
熱門話題
實作Workerman文件中的文件上傳與下載
Nov 08, 2023 pm 06:02 PM
實現Workerman文件中的文件上傳與下載，需要具體程式碼範例引言：Workerman是一款高效能的PHP非同步網路通訊框架，具備簡潔、高效、易用等特點。在實際開發中，文件上傳和下載是常見的功能需求，本文將介紹如何使用Workerman框架實現文件的上傳和下載，並給出具體的程式碼範例。一、檔案上傳：檔案上傳是指將本機上的檔案傳輸至伺服器端的操作。下面是使用
swoole和workerman哪個好
Apr 09, 2024 pm 07:00 PM
Swoole 和 Workerman 都是高效能 PHP 伺服器框架。 Swoole 以其非同步處理、出色的效能和可擴展性而聞名，適用於需要處理大量並發請求和高吞吐量的專案。 Workerman 提供了非同步和同步模式的靈活性，具有直覺的 API，更適合易用性和處理較低並發量的專案。
如何實作Workerman文件的基本使用方法
Nov 08, 2023 am 11:46 AM
如何實現Workerman文件的基本使用方法簡介：Workerman是一個高效能的PHP開發框架，它可以幫助開發者輕鬆建立高並發的網路應用程式。本文將介紹Workerman的基本使用方法，包括安裝和設定、建立服務和監聽連接埠、處理客戶端請求等。並給出相應的程式碼範例。一、安裝並設定Workerman在命令列中輸入以下命令來安裝Workerman：c
Workerman開發：如何實現基於UDP協定的即時視訊通話
Nov 08, 2023 am 08:03 AM
Workerman開發：基於UDP協議的即時視訊通話摘要：本文將介紹如何使用Workerman框架實現基於UDP協議的即時視訊通話功能。我們將深入了解UDP協議的特點，並透過程式碼範例展示如何建立一個簡單但完整的即時視訊通話應用程式。引言：在網路通訊中，即時視訊通話是一項非常重要的功能。傳統的TCP協定在實現即時性較高的視訊通話時，可能會有傳輸延遲等問題。而UDP
如何實現Workerman文件中的反向代理功能
Nov 08, 2023 pm 03:46 PM
如何實現Workerman文件中的反向代理功能，需要具體程式碼範例簡介：Workerman是一款高效能的PHP多進程網路通訊框架，提供了豐富的功能和強大的效能，廣泛應用於Web即時通訊、長連接服務等場景。其中，Workerman也支援反向代理功能，可實現伺服器對外提供服務時的負載平衡和靜態資源快取等功能。本篇文章將介紹如何使用Workerman實現反向代理功
如何實作Workerman文件中的定時器功能
Nov 08, 2023 pm 05:06 PM
如何實現Workerman文件中的定時器功能Workerman是一款強大的PHP非同步網路通訊框架，它提供了豐富的功能，其中就包括定時器功能。使用定時器可以在指定的時間間隔內執行程式碼，非常適合定時任務、輪詢等應用程式場景。接下來，我將詳細介紹如何在Workerman中實現定時器功能，並提供具體的程式碼範例。第一步：安裝Workerman首先，我們需要安裝Worker
如何使用Workerman建構高可用性負載平衡系統
Nov 07, 2023 pm 01:16 PM
如何使用Workerman建立高可用性負載平衡系統，需要具體程式碼範例在現代技術領域中，隨著網路的快速發展，越來越多的網站和應用程式需要處理大量的並發請求。為了實現高可用性和高效能，負載平衡系統成為了必不可少的組件之一。本文將介紹如何使用PHP開源框架Workerman建構一個高可用性的負載平衡系統，並提供具體的程式碼範例。一、Workerman簡介Worke
如何實現Workerman文件中的TCP/UDP通信
Nov 08, 2023 am 09:17 AM
如何實現Workerman文件中的TCP/UDP通信，需要具體程式碼範例Workerman是一款高效能的PHP非同步事件驅動框架，廣泛用於實現TCP和UDP通訊。本文將介紹如何使用Workerman實現基於TCP和UDP的通信，並提供相應的程式碼範例。一、TCP通訊創建TCP伺服器使用Workerman建立TCP伺服器十分簡單，只需寫如下程式碼：<?ph
