当前位置：首页 > PHP教程 > php高级应用 > 列表

PHP+swoole实现简单多人在线聊天群发

发布:smiling　来源: PHP粉丝网 　添加日期：2021-07-06 10:26:33　浏览: 评论：0　

这篇文章主要介绍了PHP+swoole实现简单多人在线聊天群发 的相关资料,需要的朋友可以参考下，由于本文的能力有限，有好多聊天逻辑的细节没有实现，只实现了群发，具体代码如下所示：

php代码：

  1. $serv = new swoole_websocket_server("127.0.0.1",3999); 
  2. //服务的基本设置 
  3. $serv->set(array( 
  4. 'worker_num' => 2, 
  5. 'reactor_num'=>8, 
  6. 'task_worker_num'=>1, 
  7. 'dispatch_mode' => 2, 
  8. 'debug_mode'=> 1, 
  9. 'daemonize' => true, 
  10. 'log_file' => __DIR__.'/log/webs_swoole.log', 
  11. 'heartbeat_check_interval' => 60, 
  12. 'heartbeat_idle_time' => 600, 
  13. )); 
  14. $serv->on('connect', function ($serv,$fd){ 
  15. // echo "client:$fd Connect.".PHP_EOL; 
  16. }); 
  17. //测试receive 
  18. $serv->on("receive",function(swoole_server $serv,$fd,$from_id,$data){ 
  19. // echo "receive#{$from_id}: receive $data ".PHP_EOL; 
  20. }); 
  21. $serv->on('open', function($server, $req) { 
  22. // echo "server#{$server->worker_pid}: handshake success with fd#{$req->fd}".PHP_EOL;; 
  23. // echo PHP_EOL; 
  24. }); 
  25. $serv->on('message',function($server,$frame) { 
  26. // echo "message: ".$frame->data.PHP_EOL; 
  27. $msg=json_decode($frame->data,true); 
  28. switch ($msg['type']){ 
  29. case 'login': 
  30. $server->push($frame->fd,"欢迎欢迎~"); 
  31. break; 
  32. default: 
  33. break; 
  34. } 
  35. $msg['fd']=$frame->fd; 
  36. $server->task($msg); 
  37. }); 
  38. $serv->on("workerstart",function($server,$workerid){ 
  39. // echo "workerstart: ".$workerid.PHP_EOL; 
  40. // echo PHP_EOL; 
  41. }); 
  42. $serv->on("task","on_task"); 
  43. $serv->on("finish",function($serv,$task_id,$data){ 
  44. return ; 
  45. }); 
  46. $serv->on('close', function($server,$fd,$from_id) { 
  47. // echo "connection close: ".$fd.PHP_EOL; 
  48. // echo PHP_EOL; 
  49. }); 
  50. $serv->start(); 
  51. function on_task($serv,$task_id,$from_id,$data) { 
  52. switch ($data['type']){ 
  53. case 'login': 
  54. $send_msg="说:我来了~"; 
  55. break; 
  56. default: 
  57. $send_msg="说:{$data['msg']['speak']}"; 
  58. break; 
  59. } 
  60. foreach ($serv->connections as $conn){ 
  61. if ($conn!=$data['fd']){ 
  62. if (strpos($data['msg']['name'],"游客")===0){ 
  63. $name=$data['msg']['name']."_".$data['fd']; 
  64. }else{ 
  65. $name=$data['msg']['name']; 
  66. } 
  67. }else{ 
  68. $name="我"; 
  69. } 
  70. $serv->push($conn,$name.$send_msg); 
  71. } 
  72. return; 
  73. } 
  74. function on_finish($serv,$task_id,$data){ 
  75. return true; 
  76. } 

前端代码：

  1. <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> 
  2. <html> 
  3. <head> 
  4. <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 
  5. <title>WebSocket测试</title>  
  6. <script language="javascript"type="text/javascript" src="jquery-1.12.0.min.js">  
  7. </script> 
  8. </head> 
  9. <body> 
  10. <h2>WebSocket Test</h2>  
  11. 昵称：<input type="text" id="name" size="5" value="游客"/> <input type="text" id="content">  
  12. <button onclick="speak_to_all()">发送</button> 
  13. <br/><br/> 
  14. <textarea id="message" style="overflow-x:hidden" rows="10" cols="50"></textarea>  
  15. <div id="output"></div> 
  16. </body>  
  17. <script language="javascript"type="text/javascript">  
  18. var wsUri ="ws://127.0.0.1:3999/";  
  19. var output;  
  20. function init() {  
  21. output = document.getElementById("output");  
  22. testWebSocket(); 
  23. } 
  24. function testWebSocket() {  
  25. websocket = new WebSocket(wsUri);  
  26. websocket.onopen = function(evt) {  
  27. onOpen(evt)  
  28. };  
  29. websocket.onclose = function(evt) {  
  30. onClose(evt)  
  31. };  
  32. websocket.onmessage = function(evt) {  
  33. onMessage(evt)  
  34. };  
  35. websocket.onerror = function(evt) {  
  36. onError(evt)  
  37. };  
  38. } 
  39. function get_speak_msg(){ 
  40. var name=document.getElementById("name").value; 
  41. var speak=document.getElementById("content").value; 
  42. var json_msg='{"name":"'+name+'","speak":\"'+speak+'"}'; 
  43. return json_msg; 
  44. } 
  45. function pack_msg(type,msg){ 
  46. return '{"type":"'+type+'","msg":'+msg+'}'; 
  47. } 
  48. function onOpen(evt) { 
  49. append_speak("已经联通服务器........."); 
  50. speak_msg=get_speak_msg(); 
  51. send_msg=pack_msg("login",speak_msg); 
  52. doSend(send_msg); 
  53. } 
  54. function onClose(evt) {  
  55. append_speak("俺老孙去也！"); 
  56. }  
  57. function onMessage(evt) { 
  58. append_speak(evt.data); 
  59. } 
  60. function onError(evt) { 
  61. alert(evt.data); 
  62. } 
  63. function doSend(message) {  
  64. websocket.send(message); 
  65. } 
  66. function append_speak(new_msg){ 
  67. document.getElementById("message").value=document.getElementById("message").value+new_msg+"\n"; 
  68. document.getElementById('message').scrollTop = document.getElementById('message').scrollHeight; 
  69. } 
  70. function speak_to_all(){ 
  71. send_msg=pack_msg("speak",get_speak_msg()); 
  72. if(document.getElementById("content").value==""){ 
  73. return; 
  74. } 
  75. doSend(send_msg); 
  76. document.getElementById("content").value=""; 
  77. } 
  78. init(); 
  79. </script> 
  80. </html>

Tags: PHP+swoole PHP多人在线聊天

分享到：

相关文章

推荐文章

热门文章

最新评论文章