文档章节

基于web-msg-sender进行消息推送

inuxor
 inuxor
发布于 2016/08/25 16:49
字数 716
阅读 1970
收藏 7

简介

web-msg-sender是一款web长连接推送框架,采用PHPSocket.IO开发,基于WebSocket长连接通讯,如果浏览器不支持WebSocket则自动转用comet推送。 通过后台推送消息,消息可以即时推送到客户端,非轮询,实时性非常好,性能很高。

特点:

多浏览器支持
支持针对单个用户推送消息
支持向所有用户推送消息
长连接推送(websocket或者comet),消息即时到达
支持在线用户数实时统计展示
支持在线页面数实时统计展示
支持跨域推送

场景

我司客服部门需要订单产生变化时方便的收到提醒,同时会员也需要站内信此类功能

环境

  • php7
  • thinkphp 5
  • ubuntu 16.04, Deepin 15.2, CentOS 7

安装

基本上下载下来就好了https://github.com/walkor/web-msg-sender

服务跑起来

cd  web-msg-sender
php start.php start -d

然后就会看见如下输出


Workerman[start.php] start in DAEMON mode

----------------------- WORKERMAN -----------------------------
Workerman version:3.2.8          PHP version:7.0.8-2
------------------------ WORKERS -------------------------------
user          worker        listen                   processes status
sinux         PHPSocketIO   socketIO://0.0.0.0:2120   1         [OK] 
sinux         WebServer     http://0.0.0.0:2123       1         [OK] 
----------------------------------------------------------------
Input "php start.php stop" to quit. Start success.

这就是跑起来了,OK

demo

服务端推

/application/lib/event/PushEvent.php


namespace app\lib\event;

/**
 * 推送事件
 * 典型调用方式:
 * $push = new PushEvent();
 * $push->setUser($user_id)->setContent($string)->push();
 *
 * Class PushEvent
 * @package app\lib\event
 */
class PushEvent
{
    /**
     * @var string 目标用户id
     */
    protected $to_user = '';

    /**
     * @var string 推送服务地址
     */
    protected $push_api_url = 'http://127.0.0.1:2121/';

    /**
     * @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,
        ];
        $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);

    }
}

客户端(浏览器)收

/application/demo/view/PushDemo/targetPage.html


<!DOCTYPE html>
<html lang="en">
<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://127.0.0.1:2120'); //这里当然填写真实的地址了
        // uid可以是自己网站的用户id,以便针对uid推送以及统计在线人数
        uid = 123;
        // 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>

写个用例,试一下

/application/demo/controller/PushDemo.php


namespace app\demo\controller;


use app\lib\event\PushEvent;

/**
 * 推送demo
 *
 * Class PushDemo
 * @package app\demo\controller
 */
class PushDemo
{
    /**
     * 推送一个字符串
     */
    public function pushAString()
    {
        $string = 'Man Always Remember Love Because Of Romance Only';
        $string = input('msg') ? : $string;
        $push = new PushEvent();
        $push->setUser()->setContent($string)->push();


    }

    /**
     * 推送目标页
     *
     * @return \think\response\View
     */
    public function targetPage()
    {
        return view();
    }
}

© 著作权归作者所有

inuxor

inuxor

粉丝 33
博文 25
码字总数 14592
作品 0
技术主管
私信 提问
加载中

评论(7)

j
jimmycan
你好,这个支持https的访问吗?
Grace_
Grace_
👍
inuxor
inuxor 博主

引用来自“luishou”的评论

这就整合了一下官方demo。。。
是啊,本来就是啊
luishou
luishou
这就整合了一下官方demo。。。
luishou
luishou
这就整合了一下官方demo。。。
w
wahahachuang4
GoEasy推送兼顾了websocket和polling两种连接方式,支持多版本浏览器包括低版本IE浏览器,值得一试;官网: https://goeasy.io/
lovnie
lovnie
79不错 很给力
利用php websocket实现小程序消息推送或即时通信功能 wss的实现

小程序没有消息推送功能,要想实现可以通过php的websocket来实现 一.配置服务器. 1.上传web-msg-sender目录到服务器 (官方地址https://www.workerman.net/web-sender 下载地址:https://www.wo...

xiaogg
04/09
288
0
PHP--web-msg-sender入门

考虑到浏览器对WebSocket的兼容性,在Workerman官网得知web-msg-sender在浏览器不支持WebSocket的情况下会采用http长连接的方式进行消息推送。根据官网https://github.com/walkor/web-msg-s...

btwangzhi
2018/05/04
0
0
Lua Web快速开发指南(10) - 利用MQ实现异步任务、订阅/发布、消息队列

Lua Web快速开发指南(10) - 利用MQ实现异步任务、订阅/发布、消息队列 本章节我们将学习如何使用库. MQ库简介 库实现了各类消息代理中间件(Message Broker)的连接协议, 目前支持:、、协议. 库...

水果糖的小铺子
06/25
25
0
深入了解 Dojo 的服务器推送技术

本文首发于IBM Developeworks:http://www.ibm.com/developerworks/cn/web/1202zhouxiangdojocometd/,感谢JayZ的投稿。 简介: 服务器推送技术已经出来一段时间了,业界上也有不少基于这种技...

bigYuan
2012/04/13
387
1
使用Akka Http,ActiveMQ搭建一个邮件发送服务器

代码地址:https://github.com/yangbajing/scala-applications/tree/master/email-server 应用功能是实现一个基于队列的邮件发送服务,每个邮件发送者(使用smtp协议)作为一个。多个可以在同...

羊八井
2015/08/13
2.8K
4

没有更多内容

加载失败,请刷新页面

加载更多

Mybatis Plus删除

/** @author beth @data 2019-10-17 00:30 */ @RunWith(SpringRunner.class) @SpringBootTest public class DeleteTest { @Autowired private UserInfoMapper userInfoMapper; /** 根据id删除......

一个yuanbeth
今天
4
0
总结

一、设计模式 简单工厂:一个简单而且比较杂的工厂,可以创建任何对象给你 复杂工厂:先创建一种基础类型的工厂接口,然后各自集成实现这个接口,但是每个工厂都是这个基础类的扩展分类,spr...

BobwithB
今天
5
0
java内存模型

前言 Java作为一种面向对象的,跨平台语言,其对象、内存等一直是比较难的知识点。而且很多概念的名称看起来又那么相似,很多人会傻傻分不清楚。比如本文我们要讨论的JVM内存结构、Java内存模...

ls_cherish
今天
4
0
友元函数强制转换

友元函数强制转换 p522

天王盖地虎626
昨天
5
0
js中实现页面跳转(返回前一页、后一页)

本文转载于:专业的前端网站➸js中实现页面跳转(返回前一页、后一页) 一:JS 重载页面,本地刷新,返回上一页 复制代码代码如下: <a href="javascript:history.go(-1)">返回上一页</a> <a h...

前端老手
昨天
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部