如何使用workerman進行消息推送

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

use?WorkermanWorker; //?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.batn"); } //?標記是全局啟動 define('GLOBAL_START',?1); //?加載IO?和?Web require_once?__DIR__?.?'/start_io.php'; 可以注釋掉?webServer?服務(wù)?沒什么用??省點資源 //?require_once?__DIR__?.?'/start_web.php'; //?運行所有服務(wù) Worker::runAll();

#vim?start_io.php 找到?將端口改成你要監(jiān)聽的端口?我是2120?記住要在安全組里入方向添加白名單 //?PHPSocketIO服務(wù)? $sender_io?=?new?SocketIO(2120); 服務(wù)端設(shè)置完畢后 #php?start.php?start?-d?//開啟服務(wù)?并保持進程

<?php namespace appindexmoudel;  /**  * 推送事件  * 典型調(diào)用方式：  * $push = new WebSocket();  * $push->setUser($user_id)-&gt;setContent($string)-&gt;push();//連貫操作 ?* ?*?Class?WebSocket ?*?@package?appindexmoudel;? ?*/ class?WebSocket { ????/** ?????*?@var?string?目標用戶id ?????*/ ????protected?$to_user?=?''; ????/** ?????*?@var?string?推送服務(wù)地址? ?????*/ ????protected?$push_api_url?=?'http://127.0.0.1:2000'; ????/** ?????*?@var?string?推送內(nèi)容 ?????*/ ????protected?$content?=?''; ????/** ?????*?設(shè)置推送用戶，若參數(shù)留空則推送到所有在線用戶 ?????* ?????*?@param?string?$user ?????*?@return?$this ?????*/ ????public?function?setUser($user?=?'') ????{ ????????$this-&gt;to_user?=?$user???:?''; ????????return?$this; ????} ????/** ?????*?設(shè)置推送內(nèi)容 ?????* ?????*?@param?string?$content ?????*?@return?$this ?????*/ ????public?function?setContent($content?=?'') ????{ ????????$this-&gt;content?=?$content; ????????return?$this; ????} ????/** ?????*?推送 ?????*/ ????public?function?push() ????{ ????????$data?=?[ ????????????'type'?=&gt;?'publish', ????????????'content'?=&gt;?$this-&gt;content, ????????????'to'?=&gt;?$this-&gt;to_user, ????????]; ????????//?var_dump($data); ????????//?var_dump($this-&gt;push_api_url); ????????$ch?=?curl_init?(); ????????curl_setopt($ch,?CURLOPT_URL,?$this-&gt;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 appindexcontroller; use thinkController; use appindexmoudelWebSocket; 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)-&gt;setContent($string)-&gt;push(); ????} ????/** ?????*?推送目標頁 ?????* ?????*?@return?thinkresponseView ?????*/ ????public?function?targetPage(){ ????????return?view(); ????} }

nbsp;html&gt;   ????<meta> ????<title>Title</title><strong></strong> <h1></h1>   <script></script><script></script><script>     jQuery(function ($) {         // 連接服務(wù)端         var socket = io(&#39;http://39.106.132.216:2000/&#39;); //這里當(dāng)然填寫真實的地址了         // uid可以是自己網(wǎng)站的用戶id，以便針對uid推送以及統(tǒng)計在線人數(shù)，但一定是唯一標識         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;);         });         // 后端推送來在線數(shù)據(jù)時         socket.on(&#39;update_online_count&#39;, function (online_stat) {             console.log(online_stat);             $(&#39;#count&#39;).html(online_stat);         });     }) </script>

http://我自己的域名/index/index/pushAString?uid=123 ok?為推送成功 offline?為未在線 fail?為失敗