过去对即时通讯应用一直望而生畏，印象中可以通过xmpp实现，自己很早以前在学习linux C编程中TCP协议的时候尝试自己写过一个非常简单的聊天功能,但是只是测试tcp协议的功能而已，http://blog.csdn.net/a158337/article/details/39059827，要用到项目中还是不行的，app里面的有直播课程，为了让用户之前看直播的时候聊天，我们需要建立一个聊天室，我首先了解到可以客户端服务器双向通信的websocket协议，后来我发现了一个神奇
workerman.
workerman
Workerman是一款纯PHP开发的开源高性能的PHP socket 服务器框架。被广泛的用于手机app、移动通讯，微信小程序，手游服务端、网络游戏、PHP聊天室、硬件通讯、智能家居、车联网、物联网等领域的开发。 支持TCP长连接，支持Websocket、HTTP等协议，支持自定义协议。拥有异步Mysql、异步Redis、异步Http、异步消息队列等众多高性能组件。
workerman的官方文档对其应用介绍非常详尽，因为做的时客户端之间通信，建立的时长连接，所以使用了GatewayWorker，这是一个对workerman封装的框架，更适用于长连接和客户端通信。
如何开发聊天室还是每太多头绪，参考(workerman-chat)[https://github.com/walkor/workerman-chat],这是一个开源的基于GatewayWorker的网页聊天室，非常容易部署到服务器，代码实现了网页端聊天，我要做的就是把代码部署到阿里云服务器，并且在客户端模仿网页实现websocket协议，然后在自己设定一些规范对聊天室成员进行管理就可以了。
需求
-
后台每次建立一个直播视频，都应该有一个聊天室和其一一对应，一个用户一次只能加入一个聊天室，在同一个聊天室的用户发言其他人都能看到（直播视频和用户的状态无关始终可以观看，直播视频是付费内容，不应该禁止）。
-
后台可以实时对用户和聊天室进行控制
- 聊天室状态
- 自由发言
- 全体禁言
- 用户状态：
- 正常：可以自由的发言，同时能看到其他人发言
- 禁言：在某个聊天室不能发言，但是可以看到其他人发言。
- 踢出：用户在某个聊天室内不能说话，并且不能看到其他人说话
- 黑名单：用户不能在任何聊天室说话，并且不能看到其他人说话
功能设计思路
后面提到的服务器只是按照功能划分，现实并不是不同的服务器。
聊天服务器：客户端用来建立websocket连接的服务。
后台服务器：指的是后台对客户端聊天室进行管理的服务。
app服务器：app平时请求数据的服务。
客户端：安卓或者iOS App。
项目部署
后台的代码采用了thinkphp框架，workerman-chat和后台代码独立部署，参考了项目部署,然后运行开启workerman-chat,通讯使用websocket协议，启动之前可能需要根据文档提示安装php扩展，如果正常启动可以看到正在监听的websocket端口号，然后客户端就可以通过指定的端口号和服务器建立websocket连接，如果连接失败可以参考手册的失败原因,如果没有找到，要查看服务器的防火墙是不是没有允许相应的端口连接。
php start.php start
建立聊天室
对于Gateway来说是不存在建立聊天室的概念的，只要调用
void Gateway::joinGroup(string $client_id, mixed $group);
就可以把用户加入到聊天室，如果group没有用户时，聊天室就不存在了，所以这里为了实现功能需要建立数据表存储自己建立的聊天室信息，在客户端请求直播地址的时候把对于的group号发送过去，客户端在用户观看直播的时候只能加入对应的group，如果group为空则表示聊天室没有建立，应该提示错误。
聊天室信息界面.png
客户端加入聊天室流程
1.请求视频相关信息，包含直播地址，group_id，聊天室的状态，用户对当前聊天室的状态信息，
2.客户端通过websocket协议和聊天服务器建立连接，此时聊天服务器通过websocket协议返回给用户类型为init的消息，包含了为用户本次连接分配的client_id。
3.客户端调用app服务器指定接口，上传user_id和client_id，app服务器会先删除以前数据库中该user_id和client_id的信息，然后将本次user_id和client_id关联保存起来，以后后台服务器并不知道client_id和user_id的关系，所以这里要做保存。
3.在绑定user_id和client_id成功后，app向聊天服务器发送类型为join_group的消息，加入group_id的聊天室，加入之后聊天服务器会把结果返回客户端，同时会把当前client_id和group_id关联写入数据库。
4.如果加入成功应该根据用户的权限和房间权限设置客户端的功能，决定用户是否能聊天和看到其他人聊天。
5.如果用户能够自由聊天
- app每次把用户输入的内容发送给聊天服务器，类型为 chat,聊天服务器收到后，会把收到的消息发送给所在group的所有人。
- app每次收到聊天服务器的信息应该在UI上进行展示。
6.断开连接
- 聊天服务器和客户端之间有心跳检测，如果因为网络问题导致连接断开，服务器的onclose方法会被回调，包含了断开用户的client_id，此时聊天服务器在这里将对于的client_id和group_id关联删除。客户端有尝试连接操作，请求权限，重新加入聊天室操作，
- 主动断开，用户离开聊天室，客户端向聊天服务器发送类型为leave的消息，收到后调用
void Gateway::leaveGroup(string $client_id, mixed $group);
方法让用户离开聊天室，并且删除client_id和group的对于关系。
注意事项
客户端每次向聊天服务器发送消息应带些固定信息如下
room_status:当前房间的状态，加入聊天室之前app服务器会从数据库查找并返回。
user_status:用户在当前聊天室的状态，加入聊天室之前app服务器会从数据库查找并返回。
nick_name:用户的昵称
user_id：用户的唯一标示符。
room_status和user_status在后面后台服务器对用户进行控制会用到，nick_name用来在聊天服务器收到消息后将本次消息转发群内的人时候客户端显示消息来源，user_id用来区分消息应不应该显示出来，因为用户自己发的消息，聊天服务器会发给群内所有人包含了用户自己，如果不处理消息会显示两次，所以聊天服务器在转发消息的时候会把user_id带上，如果客户端发现user_id和自己的一样就不应该展示消息。
后台对聊天室的控制
后台信息获取
后台服务器对聊天室的管理信息有时候有两种方式获取，一个是查数据库，另一个是调用Gateway类所提供的函数。至于选择哪一个应该根据实际速度来判断，当然Gateway类调用更准确。
比如聊天室列表是通过数据库查询出来的，先有成员可以查询数据库也调用
int Gateway::getClientCountByGroup(mixed $group);
聊天室列表.png
在聊天室信息界面，用户列表也可查询数据库获得，也可以通过调用
array Gateway::getClientSessionsByGroup(mixed $group);
返回值为client_id为key，client_id对应的$_SESSION为值的数组。
array(
'7f00000108fc00000008' => array(...),
'7f00000108fc00000009' => array(...),
)
这里$_SESSION对每一个用户都是唯一的，客户端向聊天服务器发送的数据都可以存在这里，包括上面提到的room_status等等,这样就不用去查询数据库获得。
管理用户和房间
- 在后台网页选择用户后编辑权限会向后台服务器发送ajax请求包含group_id，client_id，user_status。后台服务器收到后更新用户的权限，并写入数据库，并且通过
void Gateway::sendToClient(string $client_id, string $send_data);
给指定用户发送类型为update_user的消息,包含group_id和user_status。
2.客户端收到消息后检查当前的group_id更新user_status状态，然后向聊天服务器发送类型为update_user_success的消息，聊天服务器会更新对应用户的$_SESSION信息。
3.后台网页收到ajax回复后应该主动刷新当前网页，就看到用户的信息变了。
其实实际不一定按照这样的顺序，有可能2比较慢导致3先执行，甚至用户断开连接2根本不执行。所以第一步先将对用户的控制信息写入数据库可以保证下次客户端重新连接前请求控制信息的时候依然能够得到准确的信息,控制房间信息和控制用户信息原理基本类似，只是发送消息的对象不再是个别用户而是group的所有人。
void Gateway::sendToGroup(mixed $group, string $message [, array $exclude_client_id = null [, bool $raw = false]]);
总结
基本上实现流程就是这样，客户端和聊天服务器建立的时双向连接，后台管理功能可以调用Gateway类根据client_id向客户端发送数据，但是客户端不能向后台服务器发送数据。客户端直接请求app服务器获取通用的数。集合实际需求并参考了http://doc2.workerman.net/326107使用了这样的设计。
网友评论