ワーカーマン開発：チャットルーム機能の実装方法-Workerman-php.cn

ワーカーマン開発：チャットルーム機能の実装方法

WBOY

リリース： 2023-11-07 11:27:47

オリジナル

961 人が閲覧しました

ワーカーマン開発：チャットルーム機能の実装方法

ワーカーマン開発: チャットルーム機能の実装方法

はじめに:
インスタントメッセージングテクノロジの発展により、チャットルームは多くの人の共通の機能になりました。ウェブサイトとアプリケーション。この記事では、PHPフレームワークWorkermanを使った簡単なチャットルームの開発方法と具体的なコード例を紹介します。

1. Workerman の紹介:
Workerman は、Node.js の機能に似た、PHP をベースとした高性能の非同期マルチプロセスネットワークフレームワークです。 PHP マルチプロセスと非同期 I/O の機能を使用しており、従来の PHP アプリケーションと比較してパフォーマンスと同時処理能力を大幅に向上させることができます。

2. チャットルーム機能の実装:
以下は簡単なチャットルーム機能の実装例です:

新しい Workerman アプリケーションを作成します:
まず、新しい Workerman アプリケーションを作成する必要がある場合は、ターミナルで次のコマンドを使用します。

composer require workerman/workerman

ログイン後にコピー

次に、プロジェクトのルートディレクトリに新しい PHP ファイル (例: chatroom.php) を作成します。ファイルに次のコードを追加します。

require_once './vendor/autoload.php';

use WorkermanWorker;

$worker = new Worker("websocket://0.0.0.0:8000");

$worker->onConnect = function($connection) {
 // 新用户连接时触发的回调函数
};

$worker->onMessage = function($connection, $data) {
 // 收到客户端消息时触发的回调函数
};

$worker->onClose = function($connection) {
 // 用户断开连接时触发的回调函数
};

Worker::runAll();

ログイン後にコピー

新しいユーザーが接続するときのロジックを実装します。
$worker->onConnect コールバック関数では、接続情報をグローバル変数に保存したり、接続されているすべてのクライアントに新しいユーザーの追加をブロードキャストしたりするなど、新しいユーザーが接続するときにロジックを実装できます。コード例は次のとおりです。
```
$worker->onConnect = function($connection) {
 global $worker;
 $worker->connections[$connection->id] = $connection;
 
 foreach($worker->connections as $conn) {
     $conn->send('New user joined the chatroom.');
 }
};
```
ログイン後にコピー
クライアントメッセージを受信するときにロジックを実装します。
$worker->onMessage コールバック関数では、次のようにします。受信したクライアントメッセージを処理するための特定のビジネスロジックを指定できます。たとえば、接続されているすべてのクライアントにメッセージをブロードキャストします。コード例は次のとおりです。
```
$worker->onMessage = function($connection, $data) {
 global $worker;
  
 foreach($worker->connections as $conn) {
     $conn->send('User ' . $connection->id . ' says: ' . $data);
 }
};
```
ログイン後にコピー
ユーザーが切断するときのロジックを実装します。
$worker->onClose コールバック関数では、次のことができます。グローバル変数から切断されたユーザーを削除したり、接続されている他のクライアントにユーザーの離脱メッセージをブロードキャストしたりするなど、切断時にユーザーロジックを実装します。コード例は次のとおりです:
```
$worker->onClose = function($connection) {
 global $worker;
 unset($worker->connections[$connection->id]);
 
 foreach($worker->connections as $conn) {
     $conn->send('User ' . $connection->id . ' left the chatroom.');
 }
};
```
ログイン後にコピー
チャットルームサーバーを開始します:
ターミナルで次のコマンドを実行して、チャットルームサーバーを開始します:
```
php chatroom.php start
```
ログイン後にコピー