基于workerman的聊天室

作者:nango 阅读:1052次来源:http://blog.csdn.net/free_ant/article/details/52701212 时间:2016-09-29 14:28

<div class="markdown_views">
Workerman是一款纯PHP开发的开源高性能的PHP socket 服务器框架。用它可以开发出许多高性能的socket应用。 
这里我用它简单的做了个实时聊天室，支持私聊，非轮询，并发性也不错。

先上demo <a href="http://www.5none.com/index/index/chat">http://www.5none.com/index/index/chat</a>

首先，看一下核心代码：

<pre class="prettyprint"><code class=" hljs php">// 创建一个Worker监听2345端口，使用websocket协议通讯
$ws = new Worker("websocket://0.0.0.0:2345");
//已连接客户端 ，便于统计在线用户
$ws-&gt;hasConnections = array();
//监听客户端发来消息
$ws-&gt;onMessage = function ($connection, $message) use ($ws) {
//握手成功
//解码客户端连接发来的消息
$data = json_decode($message,true);
//将已连接客户端存入变量中
$ws-&gt;hasConnections[$connection-&gt;id] = array('name' =&gt; $data['name'], 'id' =&gt; $connection-&gt;id);
$content = '欢迎 &lt;i&gt;'.$data['name'].'&lt;/i&gt; 加入聊天室！ ';
//拼装返回的数据结构
$back_data = array(
 'content' =&gt; $content, 
 'nick' =&gt; '&lt;b style="color:red"&gt;系统：&lt;/b&gt;', 
 'client_id' =&gt; $connection-&gt;id, 
 'client_name' =&gt; $data['name'], 
 'type' =&gt; 'login', 
 'clients' =&gt; $ws-&gt;hasConnections, 
 'time' =&gt; date('Y-m-d H:i')
 );
//向所有在线用户广播消息
sendMessageToAll($back_data);

};</code></pre>

这里主要用到worker类的onMessage回调属性，当有客户端的连接上有数据发来时就会触发，所以我们可已定义个匿名函数进行一些列操作，接下来看一下<code>sendMessageToAll</code>函数

<pre class="prettyprint"><code class=" hljs php">//向所有在线用户推送消息
//$ws = new Worker("websocket://0.0.0.0:2345");
function sendMessageToAll($message){
 global $ws;
 foreach ($ws-&gt;connections as $connection)
 {
 $connection-&gt;send(json_encode($message));

}
}</code></pre>

该函数主要向用户推送消息，<code>connections</code>此属性中存储了当前进程的所有的客户端连接，所以我们可以遍历他进行广播。 
源码：<a href="https://git.oschina.net/hotnone/workmanchat.git">https://git.oschina.net/hotnone/workmanchat.git</a>
</div>
 <script type="text/javascript">
 $(function () {
 $('pre.prettyprint code').each(function () {
 var lines = $(this).text().split('\n').length;
 var $numbering = $('<ul/>').addClass('pre-numbering').hide();
 $(this).addClass('has-numbering').parent().append($numbering);
 for (i = 1; i <= lines; i++) {
 $numbering.append($('<li/>').text(i));
 };
 $numbering.fadeIn(1700);
 });
 });
 </script>

基于workerman的聊天室

NANGO

文章分类

最新文章

文章归档