基于workman的带有权限控制的聊天室实现

过去对即时通讯应用一直望而生畏,印象中可以通过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协议,然后在自己设定一些规范对聊天室成员进行管理就可以了。

需求

  1. 后台每次建立一个直播视频,都应该有一个聊天室和其一一对应,一个用户一次只能加入一个聊天室,在同一个聊天室的用户发言其他人都能看到(直播视频和用户的状态无关始终可以观看,直播视频是付费内容,不应该禁止)。

  2. 后台可以实时对用户和聊天室进行控制

  • 聊天室状态
    • 自由发言
    • 全体禁言
  • 用户状态:
    • 正常:可以自由的发言,同时能看到其他人发言
    • 禁言:在某个聊天室不能发言,但是可以看到其他人发言。
    • 踢出:用户在某个聊天室内不能说话,并且不能看到其他人说话
    • 黑名单:用户不能在任何聊天室说话,并且不能看到其他人说话

功能设计思路

后面提到的服务器只是按照功能划分,现实并不是不同的服务器。

聊天服务器:客户端用来建立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等等,这样就不用去查询数据库获得。

管理用户和房间

  1. 在后台网页选择用户后编辑权限会向后台服务器发送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使用了这样的设计。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 215,723评论 6 498
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,003评论 3 391
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 161,512评论 0 351
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,825评论 1 290
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,874评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,841评论 1 295
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,812评论 3 416
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,582评论 0 271
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,033评论 1 308
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,309评论 2 331
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,450评论 1 345
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,158评论 5 341
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,789评论 3 325
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,409评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,609评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,440评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,357评论 2 352

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,649评论 18 139
  • 点击查看原文 Web SDK 开发手册 SDK 概述 网易云信 SDK 为 Web 应用提供一个完善的 IM 系统...
    layjoy阅读 13,754评论 0 15
  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 31,621评论 18 399
  • 今天是11月6日易效能早睡早起早锻炼90天计划践行第一天,我的90天目标是每天晚上10:30之前上床睡觉,每天早上...
    苏珊许阅读 529评论 0 0
  • 播种好种子的时间到啦。我的目标是实现财富自由,月收入达到6000元(用于日常开销和参加空性智慧的课程)。我怀着全然...
    极致践行燕燕阅读 107评论 0 0