经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » 程序设计 » PHP » 查看文章
Swoole 实现在线聊天
来源:cnblogs  作者:我爱读活法  时间:2019/10/21 14:35:38  对本文有异议

Swoole 跟 thinkphp5 结合开发 WebSocket 在线聊天通讯系统

ThinkPHP 使用 Swoole 需要安装 think-swoole Composer 包,前提系统已经安装
好了 Swoole PECL 拓展
tp5 的项目根目录下执行 composer 命令安装 think-swoole:
  1. 1 composer require topthink/think-swoole

 

话不多说,直接上代码:
新建 WebSocket.php 控制器:
(监听端口要确认服务器放行,宝塔环境还需要添加安全组规则)
  1. <?php
  2. namespace app\home\controller;use think\swoole\Server;class WebSocket e
  3. xtends Server{
  4. protected $host = '0.0.0.0'; //监听所有地址protected $port = 9501; //监听 9501 端口
  5. protected $serverType = 'socket';
  6. protected $option = [
  7. 'worker_num'=> 4, //设置启动的 Worker 进程数
  8. 'daemonize' => false, //守护进程化(上线改为 true)
  9. 'backlog' => 128, //Listen 队列长度
  10. 'dispatch_mode' => 2, //固定模式,保证同一个连接发来的数据只会被同一个
  11. worker 处理
  12. //心跳检测:每 60 秒遍历所有连接,强制关闭 10 分钟内没有向服务器发送任何
  13. 数据的连接
  14. 'heartbeat_check_interval' => 60,
  15. 'heartbeat_idle_time' => 600
  16. ];
  17. //建立连接时回调函数
  18. public function onOpen($server,$req)
  19. {
  20. $fd = $req->fd;//客户端标识
  21. $uid = $req->get['uid'];//客户端传递的用户 id
  22. $token = $req->get['token'];//客户端传递的用户登录 token
  23. //省略 token 验证逻辑......if (!$token) {
  24. $arr = array('status'=>2,'message'=>'token 已过期');
  25. $server->push($fd, json_encode($arr));
  26. $server->close($fd);
  27. return;
  28. }
  29. //省略给用户绑定 fd 逻辑......
  30. echo "用户{$uid}建立了连接,标识为{$fd}\n";
  31. }
  32. //接收数据时回调函数
  33. public function onMessage($server,$frame)
  34. {
  35. $fd = $frame->fd;
  36. $message = $frame->data;
  37. //省略通过 fd 查询用户 uid 逻辑......
  38. $uid = 666;
  39. $data['uid'] = $uid;
  40. $data['message'] = '用户'.$uid.'发送了:'.$message;
  41. $data['post_time'] = date("m/d H:i",time());
  42. $arr = array('status'=>1,'message'=>'success','data'=>$data);//仅推送给当前连接用户
  43. //$server->push($fd, json_encode($arr));
  44. //推送给全部连接用户
  45. foreach($server->connections as $fd) {
  46. $server->push($fd, json_encode($arr));
  47. }
  48. }
  49. //连接关闭时回调函数
  50. public function onClose($server,$fd)
  51. {
  52. echo "标识{$fd}关闭了连接\n";
  53. }
  54. }

 

前端演示页面:
(省略控制器判断登录状态、分配数据逻辑......)
  1. <!DOCTYPE html><html lang="en"><head><meta charset="UTF-8" /><meta http-
  2. equiv="X-UA-Compatible" content="IE=edge,chrome=1" /><meta name="viewpor
  3. t" content="width=device-width,initial-scale=1,minimum-scale=1,maximum-s
  4. cale=1,user-scalable=no" /><title>Chat</title><link rel="stylesheet" typ
  5. e="text/css" href="/static/liaotian/chat.css" /><script src="/static/liaotian/js/jquery.min.js"></script><script src="/static/liaotian/js/flexib
  6. le.js"></script></head><body>
  7. <header class="header">
  8. <a class="back" href="javascript:history.back()"></a>
  9. <h5 class="tit">在线聊天</h5>
  10. <a href=""><div class="right">退出</div></a>
  11. </header>
  12. <!-- 聊天内容 start-->
  13. <div class="message"> </div>
  14. <!-- 聊天内容 end-->
  15. <!-- 底部 start-->
  16. <div class="footer">
  17. <img id="setbtn" src="/static/liaotian/images/hua.png" alt="" />
  18. <img src="/static/liaotian/images/xiaolian.png" alt="" />
  19. <input type="text" id="msg" value="" maxlength="300">
  20. <p style="background: rgb(17, 79, 142);" id="sendBtn">发送</p>
  21. </div>
  22. <!-- 底部 end--></body></html><script src="http://apps.bdimg.com/lib
  23. s/jquery/2.1.4/jquery.min.js"></script><script src="https://cdn.bootcss.
  24. com/layer/3.1.0/layer.js"></script><script type="text/javascript">
  25. $(function () {
  26. var uid = 666;//当前用户 idvar token = 'abcdefg';//用户 token
  27. //判断浏览器是否支持 WebSocket
  28. var supportsWebSockets = 'WebSocket' in window || 'MozWebSocket' in w
  29. indow;
  30. if (supportsWebSockets) {
  31. //建立 WebSocket 连接(ip 地址换成自己主机 ip)
  32. var ws = new WebSocket("ws://127.0.0.1:9501?uid="+uid+"&token="+t
  33. oken);
  34. ws.onopen = function () {
  35. layer.msg('服务器连接成功',{shade:0.1,icon:1,time:600});
  36. };
  37. ws.onerror = function () {
  38. layer.msg('服务器连接失败',{shade:0.1,icon:2,time:600});
  39. };
  40. ws.onmessage = function (evt) {
  41. var data = $.parseJSON(evt.data);
  42. //错误提示
  43. if(data.status != 1){
  44. layer.alert(data.message,{icon:2});
  45. return;
  46. }
  47. //消息返回if (data.status==1 && data.data.message!='') {
  48. var html = "";
  49. if (data.data.uid == uid) {
  50. html += "<div style='word-break:break-all' class=\"sho
  51. w\"><div class=\"time\">"+data.data.post_time+"</div><div class=\"msg\">
  52. <img src=\""+data.data.head_img+"\" alt=\"\" /><p><i clas=\"msg_input\">
  53. </i>"+data.data.message+"</p></div></div>";
  54. }else{
  55. html += "<div style='word-break:break-all' class=\"sen
  56. d\"><div class=\"time\">"+data.data.post_time+"</div><div class=\"msg\">
  57. <img src=\""+data.data.head_img+"\" alt=\"\" /><p><i clas=\"msg_input\">
  58. </i>"+data.data.message+"</p></div></div>";
  59. }
  60. }
  61. $(".message").append(html);
  62. setTimeout(function () {
  63. ($('.message').children("div:last-child")[0]).scrollIntoV
  64. iew();//向上滚动
  65. },100);
  66. };
  67. ws.onclose = function (res) {
  68. };
  69. //按钮发送
  70. $("#sendBtn").click(function () {
  71. var contents = $("#msg").val().trim();if(contents == null || contents == ""){
  72. layer.msg('内容为空',{shade:0.1,icon:2,time:600});
  73. return false;
  74. }else{
  75. ws.send(contents);
  76. $("#msg").val("");
  77. }
  78. });
  79. //回车发送
  80. $("#msg").keydown(function (evel) {
  81. var that = $(this);
  82. if (evel.keyCode == 13) {
  83. evel.cancelBubble = true;
  84. evel.preventDefault();
  85. evel.stopPropagation();
  86. var contents = that.val().trim();
  87. if(contents == null || contents == ""){
  88. layer.msg('内容为空',{shade:0.1,icon:2,time:600});
  89. return false;
  90. }else{
  91. ws.send(contents);that.val("");
  92. }
  93. }
  94. });
  95. }else{
  96. layer.alert("您的浏览器不支持 WebSocket!");
  97. }
  98. });</script>

 

服务器移到项目根目录开启服务:
php public/index.php Websocket/start
这里的路径,是因为我绑定了 home 模块为默认模块,tp5 默认情况是:php
public/index.php index/Websocket/start)
开启成功,查看端口已经被监听:
lsof -i:9501

原文链接:http://www.cnblogs.com/wadhf/p/11712765.html

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号