walkor / web-msg-sender

Web message pusher written in PHP based on workerman.

web-msg-sender

Web消息实时推送，支持在线用户数实时统计。基于PHPSocket.IO开发，使用websocket推送数据，当浏览器不支持websocket时自动切换comet推送数据。

效果截图

线上demo

接收消息页面：http://www.workerman.net:2123/
后端推送接口url：http://www.workerman.net:2121/?type=publish&to=&content=msgcontent
to为接收消息的uid，如果不传递则向所有人推送消息
content 为消息内容

注：可以通过php或者其它语言的curl功能实现后台推送

下载安装

1、git clone https://github.com/walkor/web-msg-sender

2、composer install

后端服务启动停止

Linux系统

启动服务

php start.php start -d

停止服务

php start.php stop

服务状态

php start.php status

windows系统

双击start_for_win.bat

如果启动不成功请参考 Workerman手册 配置环境

前端代码类似：

// 引入前端文件
<script src='//cdn.bootcss.com/socket.io/1.3.7/socket.io.js'></script>
<script>
// 初始化io对象
var socket = io('http://'+document.domain+':2120');
// uid 可以为网站用户的uid，作为例子这里用session_id代替
var uid = '<?php echo session_id();?>';
// 当socket连接后发送登录请求
socket.on('connect', function(){socket.emit('login', uid);});
// 当服务端推送来消息时触发，这里简单的aler出来，用户可做成自己的展示效果
socket.on('new_msg', function(msg){alert(msg);});
</script>

后端调用api向任意用户推送数据

<?php
// 指明给谁推送，为空表示向所有在线用户推送
$to_uid = '';
// 推送的url地址，上线时改成自己的服务器地址
$push_api_url = "http://workerman.net:2121/";
$post_data = array(
   'type' => 'publish',
   'content' => '这个是推送的测试数据',
   'to' => $to_uid, 
);
$ch = curl_init ();
curl_setopt ( $ch, CURLOPT_URL, $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, $post_data );
curl_setopt ( $ch, CURLOPT_HTTPHEADER, array("Expect:"));
$return = curl_exec ( $ch );
curl_close ( $ch );
var_export($return);

常见问题：

如果通信不成功检查防火墙
/sbin/iptables -I INPUT -p tcp --dport 2120 -j ACCEPT
/sbin/iptables -I INPUT -p tcp --dport 2121 -j ACCEPT
/sbin/iptables -I INPUT -p tcp --dport 2123 -j ACCEPT

workerman相关参见 www.workerman.net

workerman更多有趣的应用：

小蝌蚪聊天室

多人在线flappy birds

其它

web-msg-sender's Issues

workerman运行一段时间后会自动关闭，cron定时重启无效

我的workerman是单独运行的，但是机器上同时有nginx的php服务，
不知是否是干扰问题，每运行十几个小时候会自动关闭。
我在cron里加了定时重启，但是后台定时重启无效，每次我手动去重启才恢复正常

以上是cron的log，难道这样加错了吗？还是这样根本无效

请问有没有post数据的验证措施?比如只能在运行服务的服务器上发送数据

我在我的服务器运行了服务之后,并且跑通了demo,
然后把测试的post代码放到我的本地windows php cli运行一下,一样可以发送消息,
也就是只要有域名,端口默认,知道用户id或者随便乱输用户Id的话, 任何人都可以用php脚本post数据的

js向服务器传输json字符串中包含中文出错

请问如何解决呢？

posix_setsid 错误

Fatal error: Call to undefined function Workerman\posix_setsid() in /d/fawpi/app/web-msg-sender/vendor/workerman/workerman/Worker.php on line 695

性能问题

1，这个性能怎么样
2，怎么做压力测试

只允许指定用户连接？

HI，如果说需要只允许指定客户端连接服务端，框架有实现这个功能的吗？谢谢

请问支持 https 站点么？ socket 是否也支持 wss协议

请问支持 https 站点么？ socket 是否也支持 wss协议

window可以运行，linux不行

是用的window mount 到linux做的开发，window 按照 提示去执行 bat 文件可以执行。而linux 上运行 php start.php start -d 报了一堆的错。。是不是两个操作系统 用的 文件是不一样的。

请问web-msg-sender怎么使用自定义的array?

// 全局数组保存uid在线数据
$uidConnectionMap = array();
$live_agent_arr=array(); //自定义了个函数,在 $socket->on( 'login', function ( $uid )use( $socket ) 引用是null的,不解

echo "is_arraya-".is_array($live_agent_arr)." is_nulla-".is_null($live_agent_arr)." is_stringa-".is_string($live_agent_arr)."\n\n";

// PHPSocketIO服务
$sender_io = new SocketIO( 2120 );
// 客户端发起连接事件时，设置连接socket的各种事件回调
$sender_io->on( 'connection', function ( $socket ) {
// 当客户端发来登录事件时触发

$socket->on( 'login', function ( $uid )use( $socket ) {
    global $uidConnectionMap,$last_online_count,$last_online_page_count,$live_agent_arr;
    // 已经登录过了
    
    if ( isset( $socket->uid ) ) {
        return;
    }
    // 更新对应uid的在线数据
    $uid = ( string )$uid;
    if ( !isset( $uidConnectionMap[ $uid ] ) ) {
        $uidConnectionMap[ $uid ] = 0;
    }
    
    echo "is_arrayb-".is_array($uidConnectionMap)." is_nullb-".is_null($uidConnectionMap)." is_stringb-".is_string($uidConnectionMap)."\n\n"; //执行结果 is_array($uidConnectionMap) 可以 true
    echo "is_array-".is_array($live_agent_arr)." is_null-".is_null($live_agent_arr)." is_string-".is_string($live_agent_arr)."\n\n";  //执行结果 is_array($live_agent_arr) 是flase, is_null($live_agent_arr)=true

    // 这个uid有++$uidConnectionMap[$uid]个socket连接
    ++$uidConnectionMap[ $uid ];
   
    if(isset($live_agent_arr)){
        array_push( $live_agent_arr, array( "exten" => $uid, "channel" => "" ) );
    }
    // 将这个连接加入到uid分组，方便针对uid推送数据
    $socket->join( $uid );
    $socket->uid = $uid;

} );

} );

我十分不理解的是,为何 我自己定义的

$live_agent_arr 在 function ($uid) use($socket) 是 null, 而例子里自带的$uidConntionMap可以正常使用? 我该怎么样使用自己定义的array?

请各位大神不吝赐教,小白跪谢!!!

discuss

这个框架对于前端就是引入socket.io.js，两行代码就实现消息推送系统，另外浏览器兼容性如何？长连接推送（websocket或者comet这个主要是scoket.io做的兼容？

是否支持集群，目前SLB多台服务器，出现链接不上服务的问题

$sender_io = new SocketIO(2120);
域名访问是2120也是没用的

socket.io-clientpp无法完成链接

使用socket.io-clientpp开发的客户端，在与服务进行http链接后，等待ws链接时显示超时；
用js的client没问题。java，c++的都有问题。但连socket.io的服务器正常。

2121发送可以，2123查看不了，2120也接收不了

web-msg-sender，可以启动，2123页面打不开，尝试发送，可以成功发送，接收不了
mac下没问题，传到ubuntu就有问题
/sbin/iptables -I INPUT -p tcp --dport 2120 -j ACCEPT
/sbin/iptables -I INPUT -p tcp --dport 2121 -j ACCEPT
/sbin/iptables -I INPUT -p tcp --dport 2123 -j ACCEPT
防火墙这三个命令也输入进去了
help！

怎么增加进程？

6核8g服务器

并发2000时就挂掉了。。

请问如何增加进程数

composer install 报错

No composer.lock file present. Updating dependencies to latest instead of installing from lock file. See https://getcomposer.org/install for more information.
Loading composer repositories with package information
Updating dependencies
Your requirements could not be resolved to an installable set of packages.

Problem 1
- Root composer.json requires workerman/phpsocket.io, it could not be found in any version, there may be a typo in the package name.

Potential causes:

• A typo in the package name
• The package is not available in a stable-enough version according to your minimum-stability setting
  see https://getcomposer.org/doc/04-schema.md#minimum-stability for more details.
• It's a private package and you forgot to add a custom repository to find it

Read https://getcomposer.org/doc/articles/troubleshooting.md for further common problems. 怎么解决呢

Safari浏览器无法携带sid进而报错Bad handshake method

有办法解决吗？

js如何手动断开连接，不能刷新页面

js如何手动断开连接，不能刷新页面

小白刚接触这个,请问这个sender还需要自己定义心跳连接吗? 是否已经默认有了? 谢谢

如何向特定的多个用户同时发送消息？

比如特定的用户1和用户2，而不是全部用户。