suchen
HeimPHP-FrameworkWorkermanSo verwenden Sie Workerman für den Nachrichten-Push

In der folgenden Spalte des Workerman-Tutorials erfahren Sie, wie Sie Workerman zum Versenden von Nachrichten verwenden können. Ich hoffe, dass es Freunden in Not hilfreich sein wird!

So verwenden Sie Workerman für den Nachrichten-Push

Workerman ist ein Open-Source-Hochleistungs-PHP-Socket-Server-Framework, das rein in PHP entwickelt wurde. Es wird häufig in der Entwicklung mobiler Apps, mobiler Kommunikation, WeChat-Applets, mobiler Spieleserver, Online-Spiele, PHP-Chatrooms, Hardware-Kommunikation, Smart Homes, Internet der Fahrzeuge, Internet der Dinge und anderen Bereichen eingesetzt.

Unterstützt lange TCP-Verbindungen, unterstützt Websocket, HTTP und andere Protokolle sowie benutzerdefinierte Protokolle. Es verfügt über viele leistungsstarke Komponenten wie asynchrones MySQL, asynchrones Redis, asynchrones HTTP, asynchrone Nachrichtenwarteschlange usw. Ähnliche sind Swoole und MeepoPS.

Laden Sie zunächst das Web-Nachrichten-Push-System web-msg-sender von workerman herunter.

# wget http://www.workerman.net/download/senderzip
# unzip senderzip
#cd web-msg-sender 
#vim start.php
rrree

Speichern

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();

Die Push-Klasse, die ich verwende, ist tp5

#vim start_io.php
找到 将端口改成你要监听的端口 我是2120 记住要在安全组里入方向添加白名单
// PHPSocketIO服务 
$sender_io = new SocketIO(2120);
服务端设置完毕后
#php start.php start -d //开启服务 并保持进程

Operation Controller

<?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 = &#39;&#39;;
    /**
     * @var string 推送服务地址 
     */
    protected $push_api_url = &#39;http://127.0.0.1:2000&#39;;
    /**
     * @var string 推送内容
     */
    protected $content = &#39;&#39;;
    /**
     * 设置推送用户,若参数留空则推送到所有在线用户
     *
     * @param string $user
     * @return $this
     */
    public function setUser($user = &#39;&#39;)
    {
        $this->to_user = $user ? : &#39;&#39;;
        return $this;
    }
    /**
     * 设置推送内容
     *
     * @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);
    }
}

Die Front-End-Anzeige des Push-Ziels

<?php
namespace app\index\controller;
use think\Controller;
use app\index\moudel\WebSocket;
class Index extends Controller
{
 /**
     * 推送一个字符串
     */
    public function push_msg(){
        $uid = input(&#39;uid&#39;,&#39;&#39;);//uid为空的时候推送给所有用户
        $string = &#39;这是一个推送的测试&#39;;
        $string = input(&#39;msg&#39;) ? : $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=&#39;http://cdn.bootcss.com/socket.io/1.3.7/socket.io.js&#39;></script>
<script>
    jQuery(function ($) {
        // 连接服务端
        var socket = io(&#39;http://39.106.132.216:2000/&#39;); //这里当然填写真实的地址了
        // uid可以是自己网站的用户id,以便针对uid推送以及统计在线人数,但一定是唯一标识
        uid = 321;
        // socket连接后以uid登录
        socket.on(&#39;connect&#39;, function () {
            socket.emit(&#39;login&#39;, uid);
        });
        // 后端推送来消息时
        socket.on(&#39;new_msg&#39;, function (msg) {
            console.log("收到消息:" + msg);
            $(&#39;#target&#39;).append(msg).append(&#39;<br>&#39;);
        });
        // 后端推送来在线数据时
        socket.on(&#39;update_online_count&#39;, function (online_stat) {
            console.log(online_stat);
            $(&#39;#count&#39;).html(online_stat);
        });
    })
</script>

Das Frontend zeigt erfolgreich 321 als meine benutzerdefinierte UID an

So verwenden Sie Workerman für den Nachrichten-Push

Das obige ist der detaillierte Inhalt vonSo verwenden Sie Workerman für den Nachrichten-Push. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme
Dieser Artikel ist reproduziert unter:csdn. Bei Verstößen wenden Sie sich bitte an admin@php.cn löschen
Was sind die wichtigsten Funktionen des integrierten WebSocket-Kunden von Workerman?Was sind die wichtigsten Funktionen des integrierten WebSocket-Kunden von Workerman?Mar 18, 2025 pm 04:20 PM

Der WebSocket-Client von Workerman verbessert die Echtzeitkommunikation mit Funktionen wie asynchroner Kommunikation, hoher Leistung, Skalierbarkeit und Sicherheit und integrieren Sie leicht in vorhandene Systeme.

Wie benutzt ich Workerman zum Aufbau von Tools für die Zusammenarbeit in Echtzeit?Wie benutzt ich Workerman zum Aufbau von Tools für die Zusammenarbeit in Echtzeit?Mar 18, 2025 pm 04:15 PM

In dem Artikel werden mit Workerman, einem Hochleistungs-PHP-Server, mit dem Erstellen von Echtzeit-Kollaborations-Tools erörtert. Es deckt Installation, Server-Setup, Echtzeit-Feature-Implementierung und Integration in vorhandene Systeme ab und betont den Schlüssel von Workerman F f.

Was sind die besten Möglichkeiten, Woro Workerman für Anwendungen mit geringer Latenz zu optimieren?Was sind die besten Möglichkeiten, Woro Workerman für Anwendungen mit geringer Latenz zu optimieren?Mar 18, 2025 pm 04:14 PM

Der Artikel erläutert die Optimierung von Workerman für Anwendungen mit niedriger Latenz und konzentriert sich auf asynchrone Programmierungen, Netzwerkkonfiguration, Ressourcenverwaltung, Minimierung von Datenübertragung, Lastausgleich und regelmäßige Aktualisierungen.

Wie kann ich Echtzeitdatensynchronisation mit Workerman und MySQL implementieren?Wie kann ich Echtzeitdatensynchronisation mit Workerman und MySQL implementieren?Mar 18, 2025 pm 04:13 PM

In dem Artikel wird die Implementierung der Echtzeitdatensynchronisation mithilfe von Workerman und MySQL erläutert, sich auf Setup, Best Practices, die Gewährleistung der Datenkonsistenz und die Bewältigung häufiger Herausforderungen konzentrieren.

Was sind die wichtigsten Überlegungen für die Verwendung von Workerman in einer serverlosen Architektur?Was sind die wichtigsten Überlegungen für die Verwendung von Workerman in einer serverlosen Architektur?Mar 18, 2025 pm 04:12 PM

In dem Artikel wird die Integration von Workerman in serverlose Architekturen erläutert und sich auf Skalierbarkeit, Staatenlosigkeit, Kaltstarts, Ressourcenmanagement und Komplexität der Integration konzentrieren. Workerman verbessert die Leistung durch hohe Parallelität, reduzierte Kälte -STA

Wie baue ich eine Hochleistungs-E-Commerce-Plattform mit Workerman auf?Wie baue ich eine Hochleistungs-E-Commerce-Plattform mit Workerman auf?Mar 18, 2025 pm 04:11 PM

In dem Artikel wird mit Workerman errichtet, die eine Hochleistungs-E-Commerce-Plattform erstellen und sich auf ihre Funktionen wie WebSocket-Support und Skalierbarkeit konzentrieren, um Echtzeit-Interaktionen und Effizienz zu verbessern.

Was sind die erweiterten Funktionen des WebSocket -Servers von Workerman?Was sind die erweiterten Funktionen des WebSocket -Servers von Workerman?Mar 18, 2025 pm 04:08 PM

Der WebSocket-Server von Workerman verbessert die Echtzeitkommunikation mit Funktionen wie Skalierbarkeit, geringer Latenz und Sicherheitsmaßnahmen gegen häufige Bedrohungen.

Wie benutze ich Workerman zum Aufbau von Echtzeit-Dashboards?Wie benutze ich Workerman zum Aufbau von Echtzeit-Dashboards?Mar 18, 2025 pm 04:07 PM

In dem Artikel wird mit Workerman, einem Hochleistungs-PHP-Server, mit dem Erstellen von Echtzeit-Analyse-Dashboards erläutert. Es deckt Installation, Server -Setup, Datenverarbeitung und Frontend -Integration mit Frameworks wie React, Vue.js und Angular ab. Schlüsselfunktion

See all articles

Heiße KI -Werkzeuge

Undresser.AI Undress

Undresser.AI Undress

KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover

AI Clothes Remover

Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Undress AI Tool

Undress AI Tool

Ausziehbilder kostenlos

Clothoff.io

Clothoff.io

KI-Kleiderentferner

AI Hentai Generator

AI Hentai Generator

Erstellen Sie kostenlos Ai Hentai.

Heißer Artikel

R.E.P.O. Energiekristalle erklärten und was sie tun (gelber Kristall)
3 Wochen vorBy尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. Beste grafische Einstellungen
3 Wochen vorBy尊渡假赌尊渡假赌尊渡假赌
R.E.P.O. So reparieren Sie Audio, wenn Sie niemanden hören können
3 Wochen vorBy尊渡假赌尊渡假赌尊渡假赌
WWE 2K25: Wie man alles in Myrise freischaltet
4 Wochen vorBy尊渡假赌尊渡假赌尊渡假赌

Heiße Werkzeuge

Dreamweaver CS6

Dreamweaver CS6

Visuelle Webentwicklungstools

Sicherer Prüfungsbrowser

Sicherer Prüfungsbrowser

Safe Exam Browser ist eine sichere Browserumgebung für die sichere Teilnahme an Online-Prüfungen. Diese Software verwandelt jeden Computer in einen sicheren Arbeitsplatz. Es kontrolliert den Zugriff auf alle Dienstprogramme und verhindert, dass Schüler nicht autorisierte Ressourcen nutzen.

EditPlus chinesische Crack-Version

EditPlus chinesische Crack-Version

Geringe Größe, Syntaxhervorhebung, unterstützt keine Code-Eingabeaufforderungsfunktion

Senden Sie Studio 13.0.1

Senden Sie Studio 13.0.1

Leistungsstarke integrierte PHP-Entwicklungsumgebung

WebStorm-Mac-Version

WebStorm-Mac-Version

Nützliche JavaScript-Entwicklungstools