PHP 用 workman 即时通讯，做个简版QQ

1. workman是什么，一般应用在那些地方

workerman是一个高性能的PHP socket 服务器框架，workerman基于PHP多进程以及libevent事件轮询库，PHP开发者只要实现一两个接口，便可以开发出自己的网络应用，例如Rpc服务、聊天室服务器、手机游戏服务器等。

workerman的目标是让PHP开发者更容易的开发出基于socket的高性能的应用服务，而不用去了解PHP socket以及PHP多进程细节。 workerman本身是一个PHP多进程服务器框架，具有PHP进程管理以及socket通信的模块，所以不依赖php-fpm、nginx或者apache等这些容器便可以独立运行。

2. workman都可以使用那些协议通讯

WorkerMan提供了HTTP协议、WebSocket协议以及非常简单的Text文本协议、可用于二进制传输的frame协议。开发者可以直接使用这些协议，不必再二次开发。如果这些协议都不满足需要，开发者可以参照定制协议章节实现自己的协议。

开发者也可以直接基于tcp或者udp协议。协议使用示例：

// http协议
$worker1 = new Worker('http://0.0.0.0:1221');
// websocket协议
$worker2 = new Worker('websocket://0.0.0.0:1222');
// text文本协议（telnet协议）
$worker3 = new Worker('text://0.0.0.0:1223');
// frame文本协议（可用于二进制数传输）
$worker3 = new Worker('frame://0.0.0.0:1223');
// 直接基于tcp传输
$worker4 = new Worker('tcp://0.0.0.0:1224');
// 直接基于udp传输
$worker5 = new Worker('udp://0.0.0.0:1225');

3.workman的简单例子

3.1 客户端例子 (浏览器 javascript)

<html>
<body>    
<div style="margin: 0 auto;width: 800px"><h2>聊天室</h2><textarea type="text" style="border: 1px solid black;width: 800px;height: 200px;" id="his"></textarea><input type="text" style="width:740px" id="sendMsg">&nbsp;<button id="send">发送</button>
</div>
</body>
</html>
<script src="./jquery.min.js"></script>
<script>$(function () {var ws = new WebSocket("ws://192.168.1.115:2347");var storage = window.localStorage;if(!storage.getItem('name')){var name=prompt("请输入您的名字","");storage.setItem('name',name);}$('#send').click(function () {msg = $('#sendMsg').val();$('#sendMsg').val('');ws.send(storage.getItem('name')+':'+msg);});ws.onopen = function() {$('#his').append("服务器连接成功.....");$('#his').append("\n");};ws.onmessage = function(e) {$('#his').append(e.data);$('#his').append("\n");console.log(e.data);};});
</script>

WebSocket.onopen：连接成功后调用
WebSocket.onmessage：当接收到服务器消息时调用
WebSocket.onclose：连接关闭后调用

3.2 服务端例子 (php)

<?php 
use Workerman\Worker;
require_once __DIR__ . '/vendor/workerman/workerman/Autoloader.php';// 当客户端连上来时分配uid，并保存连接，并通知所有客户端
function handle_connection($connection)
{}// 当客户端发送消息过来时，转发给所有人
function handle_message($connection, $data)
{global $text_worker;foreach($text_worker->connections as $conn){$conn->send($data);}
}// 当客户端断开时，广播给所有客户端
function handle_close($connection)
{}// 创建一个文本协议的Worker监听2347接口
$text_worker = new Worker("websocket://0.0.0.0:2347");
// 只启动1个进程，这样方便客户端之间传输数据
$text_worker->count = 1;$text_worker->onConnect = 'handle_connection';
$text_worker->onMessage = 'handle_message';
$text_worker->onClose = 'handle_close';Worker::runAll();

3.3 测试

这里开了2个浏览器测试