如何使用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
Atas ialah kandungan terperinci 如何使用workerman进行消息推送. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!
Alat AI Hot
Undresser.AI Undress
Apl berkuasa AI untuk mencipta foto bogel yang realistik
AI Clothes Remover
Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.
Undress AI Tool
Gambar buka pakaian secara percuma
Clothoff.io
Penyingkiran pakaian AI
AI Hentai Generator
Menjana ai hentai secara percuma.
Artikel Panas
Alat panas
Notepad++7.3.1
Editor kod yang mudah digunakan dan percuma
SublimeText3 versi Cina
Versi Cina, sangat mudah digunakan
Hantar Studio 13.0.1
Persekitaran pembangunan bersepadu PHP yang berkuasa
Dreamweaver CS6
Alat pembangunan web visual
SublimeText3 versi Mac
Perisian penyuntingan kod peringkat Tuhan (SublimeText3)
Topik panas
1377
52
Laksanakan muat naik dan muat turun fail dalam dokumen Workerman
Nov 08, 2023 pm 06:02 PM
Untuk melaksanakan muat naik dan muat turun fail dalam dokumen Workerman, contoh kod khusus diperlukan. Pengenalan: Workerman ialah rangka kerja komunikasi rangkaian tak segerak PHP berprestasi tinggi yang ringkas, cekap dan mudah digunakan. Dalam pembangunan sebenar, muat naik dan muat turun fail adalah keperluan fungsi biasa Artikel ini akan memperkenalkan cara menggunakan rangka kerja Workerman untuk melaksanakan muat naik dan muat turun fail, dan memberikan contoh kod khusus. 1. Muat naik fail: Muat naik fail merujuk kepada operasi memindahkan fail pada komputer tempatan ke pelayan. Yang berikut digunakan
Mana satu lebih baik, swool atau pekerja?
Apr 09, 2024 pm 07:00 PM
Swoole dan Workerman kedua-duanya adalah rangka kerja pelayan PHP berprestasi tinggi. Terkenal dengan pemprosesan tak segerak, prestasi cemerlang dan kebolehskalaannya, Swoole sesuai untuk projek yang perlu mengendalikan sejumlah besar permintaan serentak dan daya pemprosesan yang tinggi. Workerman menawarkan fleksibiliti mod tak segerak dan segerak, dengan API intuitif yang lebih sesuai untuk kemudahan penggunaan dan projek yang mengendalikan volum serentak yang lebih rendah.
Bagaimana untuk melaksanakan penggunaan asas dokumen Workerman
Nov 08, 2023 am 11:46 AM
Pengenalan kepada cara melaksanakan penggunaan asas dokumen Workerman: Workerman ialah rangka kerja pembangunan PHP berprestasi tinggi yang boleh membantu pembangun membina aplikasi rangkaian konkurensi tinggi dengan mudah. Artikel ini akan memperkenalkan penggunaan asas Workerman, termasuk pemasangan dan konfigurasi, mencipta perkhidmatan dan port mendengar, mengendalikan permintaan pelanggan, dsb. Dan berikan contoh kod yang sepadan. 1. Pasang dan konfigurasikan Workerman Masukkan arahan berikut pada baris arahan untuk memasang Workerman: c
Pembangunan pekerja: Cara melaksanakan panggilan video masa nyata berdasarkan protokol UDP
Nov 08, 2023 am 08:03 AM
Pembangunan pekerja: panggilan video masa nyata berdasarkan protokol UDP Ringkasan: Artikel ini akan memperkenalkan cara menggunakan rangka kerja Workerman untuk melaksanakan fungsi panggilan video masa nyata berdasarkan protokol UDP. Kami akan mempunyai pemahaman yang mendalam tentang ciri-ciri protokol UDP dan menunjukkan cara membina aplikasi panggilan video masa nyata yang ringkas tetapi lengkap melalui contoh kod. Pengenalan: Dalam komunikasi rangkaian, panggilan video masa nyata adalah fungsi yang sangat penting. Protokol TCP tradisional mungkin mempunyai masalah seperti kelewatan penghantaran apabila melaksanakan panggilan video masa nyata tinggi. Dan UDP
Cara melaksanakan fungsi proksi terbalik dalam dokumen Workerman
Nov 08, 2023 pm 03:46 PM
Cara melaksanakan fungsi proksi terbalik dalam dokumen Workerman memerlukan contoh kod khusus Pengenalan: Workerman ialah rangka kerja komunikasi rangkaian berbilang proses PHP berprestasi tinggi yang menyediakan fungsi yang kaya dan prestasi berkuasa dan digunakan secara meluas dalam komunikasi masa nyata Web dan panjang. sambungan. Antaranya, Workerman juga menyokong fungsi proksi terbalik, yang boleh merealisasikan pengimbangan beban dan caching sumber statik apabila pelayan menyediakan perkhidmatan luaran. Artikel ini akan memperkenalkan cara menggunakan Workerman untuk melaksanakan fungsi proksi terbalik.
Cara menggunakan Workerman untuk membina sistem pengimbangan beban dengan ketersediaan tinggi
Nov 07, 2023 pm 01:16 PM
Cara menggunakan Workerman untuk membina sistem pengimbangan beban dengan ketersediaan tinggi memerlukan contoh kod khusus Dalam bidang teknologi moden, dengan perkembangan pesat Internet, semakin banyak laman web dan aplikasi perlu mengendalikan sejumlah besar permintaan serentak. Untuk mencapai ketersediaan tinggi dan prestasi tinggi, sistem pengimbangan beban telah menjadi salah satu komponen penting. Artikel ini akan memperkenalkan cara menggunakan rangka kerja sumber terbuka PHP Workerman untuk membina sistem pengimbangan beban dengan ketersediaan tinggi dan menyediakan contoh kod khusus. 1. Pengenalan kepada Workerman Worke
Bagaimana untuk melaksanakan fungsi pemasa dalam dokumen Workerman
Nov 08, 2023 pm 05:06 PM
Cara melaksanakan fungsi pemasa dalam dokumen Workerman Workerman ialah rangka kerja komunikasi rangkaian tak segerak PHP yang berkuasa yang menyediakan pelbagai fungsi, termasuk fungsi pemasa. Gunakan pemasa untuk melaksanakan kod dalam selang masa yang ditentukan, yang sangat sesuai untuk senario aplikasi seperti tugas yang dijadualkan dan tinjauan pendapat. Seterusnya, saya akan memperkenalkan secara terperinci cara melaksanakan fungsi pemasa dalam Workerman dan memberikan contoh kod khusus. Langkah 1: Pasang Workerman Mula-mula, kita perlu memasang Worker
Cara melaksanakan komunikasi TCP/UDP dalam dokumentasi Workerman
Nov 08, 2023 am 09:17 AM
Cara melaksanakan komunikasi TCP/UDP dalam dokumen Workerman memerlukan contoh kod khusus ialah rangka kerja tak segerak PHP berprestasi tinggi yang digunakan secara meluas untuk melaksanakan komunikasi TCP dan UDP. Artikel ini akan memperkenalkan cara menggunakan Workerman untuk melaksanakan komunikasi berasaskan TCP dan UDP serta memberikan contoh kod yang sepadan. 1. Komunikasi TCP Mencipta Pelayan TCP Menggunakan Workerman untuk mencipta pelayan TCP adalah sangat mudah Anda hanya perlu menulis kod berikut: <?ph
