PHP+swoole实现简单多人在线聊天群发,swoole在线聊天
PHP+swoole实现简单多人在线聊天群发,swoole在线聊天
由于本文的能力有限,有好多聊天逻辑的细节没有实现,只实现了群发,具体代码如下所示:
php代码:
$serv = new swoole_websocket_server("127.0.0.1",3999); //服务的基本设置 $serv->set(array( 'worker_num' => 2, 'reactor_num'=>8, 'task_worker_num'=>1, 'dispatch_mode' => 2, 'debug_mode'=> 1, 'daemonize' => true, 'log_file' => __DIR__.'/log/webs_swoole.log', 'heartbeat_check_interval' => 60, 'heartbeat_idle_time' => 600, )); $serv->on('connect', function ($serv,$fd){ // echo "client:$fd Connect.".PHP_EOL; }); //测试receive $serv->on("receive",function(swoole_server $serv,$fd,$from_id,$data){ // echo "receive#{$from_id}: receive $data ".PHP_EOL; }); $serv->on('open', function($server, $req) { // echo "server#{$server->worker_pid}: handshake success with fd#{$req->fd}".PHP_EOL;; // echo PHP_EOL; }); $serv->on('message',function($server,$frame) { // echo "message: ".$frame->data.PHP_EOL; $msg=json_decode($frame->data,true); switch ($msg['type']){ case 'login': $server->push($frame->fd,"欢迎欢迎~"); break; default: break; } $msg['fd']=$frame->fd; $server->task($msg); }); $serv->on("workerstart",function($server,$workerid){ // echo "workerstart: ".$workerid.PHP_EOL; // echo PHP_EOL; }); $serv->on("task","on_task"); $serv->on("finish",function($serv,$task_id,$data){ return ; }); $serv->on('close', function($server,$fd,$from_id) { // echo "connection close: ".$fd.PHP_EOL; // echo PHP_EOL; }); $serv->start(); function on_task($serv,$task_id,$from_id,$data) { switch ($data['type']){ case 'login': $send_msg="说:我来了~"; break; default: $send_msg="说:{$data['msg']['speak']}"; break; } foreach ($serv->connections as $conn){ if ($conn!=$data['fd']){ if (strpos($data['msg']['name'],"游客")===0){ $name=$data['msg']['name']."_".$data['fd']; }else{ $name=$data['msg']['name']; } }else{ $name="我"; } $serv->push($conn,$name.$send_msg); } return; } function on_finish($serv,$task_id,$data){ return true; }
前端代码:
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> <html> <head> <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> <title>WebSocket测试</title> <script language="javascript"type="text/javascript" src="jquery-1.12.0.min.js"> </script> </head> <body> <h2 id="WebSocket-Test">WebSocket Test</h2> 昵称:<input type="text" id="name" size="5" value="游客"/> <input type="text" id="content"> <button onclick="speak_to_all()">发送</button> <br/><br/> <textarea id="message" style="overflow-x:hidden" rows="10" cols="50"></textarea> <div id="output"></div> </body> <script language="javascript"type="text/javascript"> var wsUri ="ws://127.0.0.1:3999/"; var output; function init() { output = document.getElementById("output"); testWebSocket(); } function testWebSocket() { websocket = new WebSocket(wsUri); websocket.onopen = function(evt) { onOpen(evt) }; websocket.onclose = function(evt) { onClose(evt) }; websocket.onmessage = function(evt) { onMessage(evt) }; websocket.onerror = function(evt) { onError(evt) }; } function get_speak_msg(){ var name=document.getElementById("name").value; var speak=document.getElementById("content").value; var json_msg='{"name":"'+name+'","speak":\"'+speak+'"}'; return json_msg; } function pack_msg(type,msg){ return '{"type":"'+type+'","msg":'+msg+'}'; } function onOpen(evt) { append_speak("已经联通服务器........."); speak_msg=get_speak_msg(); send_msg=pack_msg("login",speak_msg); doSend(send_msg); } function onClose(evt) { append_speak("俺老孙去也!"); } function onMessage(evt) { append_speak(evt.data); } function onError(evt) { alert(evt.data); } function doSend(message) { websocket.send(message); } function append_speak(new_msg){ document.getElementById("message").value=document.getElementById("message").value+new_msg+"\n"; document.getElementById('message').scrollTop = document.getElementById('message').scrollHeight; } function speak_to_all(){ send_msg=pack_msg("speak",get_speak_msg()); if(document.getElementById("content").value==""){ return; } doSend(send_msg); document.getElementById("content").value=""; } init(); </script> </html>
推荐文章:php安装swoole扩展的方法 使用swoole扩展php websocket示例
以上代码给大家分享了PHP+swoole实现简单多人在线聊天群发的相关代码,希望本文所述对大家有所帮助。
您可能感兴趣的文章:
- 使用swoole扩展php websocket示例
- PHP框架Swoole定时器Timer特性分析
- php异步多线程swoole用法实例
- php安装swoole扩展的方法
- Swoole-1.7.22 版本已发布,修复PHP7相关问题
- 使用php+swoole对client数据实时更新(一)

ホットAIツール

Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。

Undress AI Tool
脱衣画像を無料で

Clothoff.io
AI衣類リムーバー

AI Hentai Generator
AIヘンタイを無料で生成します。

人気の記事

ホットツール

メモ帳++7.3.1
使いやすく無料のコードエディター

SublimeText3 中国語版
中国語版、とても使いやすい

ゼンドスタジオ 13.0.1
強力な PHP 統合開発環境

ドリームウィーバー CS6
ビジュアル Web 開発ツール

SublimeText3 Mac版
神レベルのコード編集ソフト(SublimeText3)

ホットトピック









PHP 8.4 では、いくつかの新機能、セキュリティの改善、パフォーマンスの改善が行われ、かなりの量の機能の非推奨と削除が行われています。 このガイドでは、Ubuntu、Debian、またはその派生版に PHP 8.4 をインストールする方法、または PHP 8.4 にアップグレードする方法について説明します。

Visual Studio Code (VS Code とも呼ばれる) は、すべての主要なオペレーティング システムで利用できる無料のソース コード エディター (統合開発環境 (IDE)) です。 多くのプログラミング言語の拡張機能の大規模なコレクションを備えた VS Code は、

あなたが経験豊富な PHP 開発者であれば、すでにそこにいて、すでにそれを行っていると感じているかもしれません。あなたは、運用を達成するために、かなりの数のアプリケーションを開発し、数百万行のコードをデバッグし、大量のスクリプトを微調整してきました。

このチュートリアルでは、PHPを使用してXMLドキュメントを効率的に処理する方法を示しています。 XML(拡張可能なマークアップ言語)は、人間の読みやすさとマシン解析の両方に合わせて設計された多用途のテキストベースのマークアップ言語です。一般的にデータストレージに使用されます

JWTは、JSONに基づくオープン標準であり、主にアイデンティティ認証と情報交換のために、当事者間で情報を安全に送信するために使用されます。 1。JWTは、ヘッダー、ペイロード、署名の3つの部分で構成されています。 2。JWTの実用的な原則には、JWTの生成、JWTの検証、ペイロードの解析という3つのステップが含まれます。 3. PHPでの認証にJWTを使用する場合、JWTを生成および検証でき、ユーザーの役割と許可情報を高度な使用に含めることができます。 4.一般的なエラーには、署名検証障害、トークンの有効期限、およびペイロードが大きくなります。デバッグスキルには、デバッグツールの使用とロギングが含まれます。 5.パフォーマンスの最適化とベストプラクティスには、適切な署名アルゴリズムの使用、有効期間を合理的に設定することが含まれます。

文字列は、文字、数字、シンボルを含む一連の文字です。このチュートリアルでは、さまざまな方法を使用してPHPの特定の文字列内の母音の数を計算する方法を学びます。英語の母音は、a、e、i、o、u、そしてそれらは大文字または小文字である可能性があります。 母音とは何ですか? 母音は、特定の発音を表すアルファベットのある文字です。大文字と小文字など、英語には5つの母音があります。 a、e、i、o、u 例1 入力:string = "tutorialspoint" 出力:6 説明する 文字列「TutorialSpoint」の母音は、u、o、i、a、o、iです。合計で6元があります

静的結合(静的::) PHPで後期静的結合(LSB)を実装し、クラスを定義するのではなく、静的コンテキストで呼び出しクラスを参照できるようにします。 1)解析プロセスは実行時に実行されます。2)継承関係のコールクラスを検索します。3)パフォーマンスオーバーヘッドをもたらす可能性があります。

PHPの魔法の方法は何ですか? PHPの魔法の方法には次のものが含まれます。1。\ _ \ _コンストラクト、オブジェクトの初期化に使用されます。 2。\ _ \ _リソースのクリーンアップに使用される破壊。 3。\ _ \ _呼び出し、存在しないメソッド呼び出しを処理します。 4。\ _ \ _ get、dynamic属性アクセスを実装します。 5。\ _ \ _セット、動的属性設定を実装します。これらの方法は、特定の状況で自動的に呼び出され、コードの柔軟性と効率を向上させます。
