接收消息页面:http://demos.workerman.net/web-sender/
推送接口url:http://demos.workerman.net:2121/?type=publish&to=uid&content=content
, b1 ~& L& i! r: D/ O7 l8 b其中to为接收消息的uid,如果传空则向所有人推送消息 content 为消息内容
% M; k4 M, R, q0 }9 V( i Z效果2:
- {5 b; n# _: M: u见本页面页脚在线统计部分,支持实时的在线人数和在线页面统计
" a! r- g: Y$ ]1 _% i# y, T3 E3 @- x
安装启动首先:参考手册检查/安装workerman环境
1、下载:(下载web-msg-sender,并解压缩到任意目录
2、启动:linux系统cd到到框架目录里运行php start.php start -d。windows系统进入到框架目录里双击start_for_win.bat文件启动。
3、测试:浏览器访问端口http://ip:2123或者http://域名:2123,例如 http://workerman.net:2123如图:(如果无法访问请检查服务器防火墙,如果是云服务器还要设置安全组)
3 d# l3 x% t% R
# g9 _5 @; k! d( w
( t# M) U! K2 r7 e前端测试:- <script src='http://cdn.bootcss.com/socket.io/1.3.7/socket.io.js'></script>
- x" C# Q$ I: {& A. U; e4 S - <script>
0 Y, q) ?) _6 c( T - // 连接服务端,workerman.net:2120换成实际部署web-msg-sender服务的域名或者ip9 x" I- i5 G' I# Z7 g
- var socket = io('http://workerman.net:2120');
|$ A% g' U# o& X$ }; q - // uid可以是自己网站的用户id,以便针对uid推送以及统计在线人数
- W9 s+ @5 g" Y( N+ K7 m - uid = 123;
5 o' s' o/ ^# Y) U) l0 f) _ - // socket连接后以uid登录
9 B- ^$ J' e% o' u - socket.on('connect', function(){% D! Z& U8 G v- p* w
- socket.emit('login', uid);5 q% E0 y0 |! c1 C* o
- });0 {! x: Q1 q* x; D1 [( u- {2 n7 |
- // 后端推送来消息时+ ~ I/ j, j) T: X8 R! ?- c
- socket.on('new_msg', function(msg){$ ?9 m# W% T' w# r4 w" c/ N
- console.log("收到消息:"+msg);* i# @4 f# D4 `+ `! r
- });0 A( p/ u) S' _( Y( N
- // 后端推送来在线数据时) \1 m/ L3 B. i- b
- socket.on('update_online_count', function(online_stat){
8 k: `% l- u6 J- e2 ~8 V - console.log(online_stat);
9 ~) G/ p1 t1 \7 M0 H/ r0 g1 X9 g) w - });2 i" \! c% i( f" j7 Y# V; Y
- </script>
复制代码 后端调用api向任意用户推送:- <?php
& L' ?" l# c- ]4 o5 b2 o/ `4 g - // 指明给谁推送,为空表示向所有在线用户推送
$ J I) s6 D) ~+ S* o4 G, f* p - $to_uid = "";
5 l4 W3 p8 u; h# \5 Y. a+ H9 e - // 推送的url地址,使用自己的服务器地址
& ~- {5 C. C; c8 v; T - $push_api_url = "http://workerman.net:2121/";
1 \" O _6 }7 p4 \' J - $post_data = array(; R# W9 {* a! R9 c
- "type" => "publish",0 c" O: p+ R' g: B0 i7 A4 o
- "content" => "这个是推送的测试数据", B0 Q* p" G* B% @ \& U6 @
- "to" => $to_uid,
, b' X8 @& V4 r7 m& ^ - );
. j: O+ U0 V' U6 S4 b% i - $ch = curl_init ();
. x$ T! x5 A: E( h - curl_setopt ( $ch, CURLOPT_URL, $push_api_url );1 ?" y6 y: N; Y" C! g; s' [& j9 c
- curl_setopt ( $ch, CURLOPT_POST, 1 );
' i) D0 c9 h1 f# L - curl_setopt ( $ch, CURLOPT_HEADER, 0 );3 z% _6 X9 D9 \) y' Y, o
- curl_setopt ( $ch, CURLOPT_RETURNTRANSFER, 1 );
$ {: x4 {- `3 W; ^* x; |( e7 e6 Q9 ?! O - curl_setopt ( $ch, CURLOPT_POSTFIELDS, $post_data );
9 w7 V0 S5 u j6 ~5 u. D - curl_setopt ($ch, CURLOPT_HTTPHEADER, array("Expect:"));( }$ R' n8 s) p: T1 r" O0 f
- $return = curl_exec ( $ch );0 P' w' ], Q. j: }3 o) t+ N
- curl_close ( $ch );& X& ? [1 O$ s( H! e) f: s& S
- var_export($return);
复制代码 $ Q$ v2 X) x% ~2 f( g
; k! G" Y" ^5 a0 n( B! ?
. ?# D1 T& H5 I
' C1 a/ L4 i( c# h# E! _. u
% s( [( Z" V$ P本文摘自 https://www.workerman.net/web-sender# S8 ?1 ^% L& \( `5 f
+ s7 Y1 \+ V, V0 w1 j; N
$ C" z" Z5 T3 d9 ~5 O- A) A4 o& R7 B; S3 O" U
5 A% ^8 j' h) a+ ^" M7 \4 Z% f0 H. @4 Z4 B8 K0 F* \
- F# b+ W4 ?! A' y# P# L& d1 [