PHP Websocket 開発チュートリアル、リアルタイムのアンケート機能の構築、特定のコード例が必要
Websocket テクノロジは、Web アプリケーションに組み込むことができる新しいネットワーク プロトコルです。 -時間通信機能。従来の HTTP プロトコルとは異なり、Websocket プロトコルは双方向通信を実現でき、中断することなくデータを送受信できます。この記事では、PHPとWebsocket技術を利用したリアルタイムアンケート機能の構築方法と具体的なコード例を紹介します。
- サーバーへの Ratchet のインストール
Ratchet は、Websocket アプリケーションを開発するための PHP ライブラリです。始める前に、サーバーに Ratchet をインストールする必要があります。次のコマンドを使用します。
composer require cboden/ratchet
- Websocket サーバー コードの書き込み
まず、Ratchet WebSocket サーバーを作成する必要があります。この例では、すべてのコードを PHP ファイルに配置します。このファイルでは、RatchetWebSocketWsServer クラスを拡張するクラスを作成します。コンストラクターでは、接続されたクライアントを格納するインスタンス変数 $clients を初期化します。
次はサーバー コードです:
<?php
require __DIR__ . '/vendor/autoload.php'; // 引入 ratchet
use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetWebSocketWsServer;
class PollServer implements MessageComponentInterface {
protected $clients;
public function __construct() {
$this->clients = new SplObjectStorage;
}
public function onOpen(ConnectionInterface $conn) {
$this->clients->attach($conn);
echo 'Client ' . $conn->resourceId . ' connected
';
}
public function onClose(ConnectionInterface $conn) {
$this->clients->detach($conn);
echo 'Client ' . $conn->resourceId . ' disconnected
';
}
public function onMessage(ConnectionInterface $from, $msg) {
echo 'Received message ' . $msg . ' from client ' . $from->resourceId . "
";
// 在这里处理逻辑...
}
public function onError(ConnectionInterface $conn, Exception $e) {
echo "An error has occurred: {$e->getMessage()}
";
$conn->close();
}
}
$server = new RatchetApp('localhost', 8080); // 创建一个新的 WebSocket 服务器
$server->route('/poll', new WsServer(new PollServer())); // 定义路由
$server->run(); // 启动服务器上記のコードは、RatchetMessageComponentInterface インターフェイスを実装する PollServer という名前のクラスを定義します。 MessageComponentInterface インターフェイスは非常にシンプルで、メソッドは onOpen、onClose、onMessage、onError## の 4 つだけです。 # 。これらのメソッドは、クライアントがサーバーに接続するとき、サーバーから切断するとき、新しいメッセージを受信するとき、およびエラーが発生するときに呼び出されます。上記のコードではログを出力するだけですが、実際のロジックを扱う際に必要に応じて変更してください。
PollServer クラスを RatchetWebSocketWsServer クラスのコンストラクターに渡す必要があります。これにより、WebSocket プロトコルを使用してクライアントと通信する新しい WebSocket サーバーが作成されます。
/poll という名前のルートを定義します。運用環境では、WebSocket サーバーの実際のドメイン名とポートを使用する必要があります。
- クライアント側コードの作成
<!DOCTYPE html>
<html>
<head>
<title>Real-time Poll</title>
</head>
<body>
<h1 id="Real-time-Poll">Real-time Poll</h1>
<script>
const connection = new WebSocket('ws://localhost:8080/poll'); // 替换为真实的域名和端口
connection.addEventListener('open', () => {
console.log('Connected');
});
connection.addEventListener('message', event => {
const message = JSON.parse(event.data);
console.log('Received', message);
});
connection.addEventListener('close', () => {
console.log('Disconnected');
});
connection.addEventListener('error', error => {
console.error(error);
});
</script>
</body>
</html>上記のコードは、connection という名前の新しい WebSocket オブジェクトを作成し、ws:/ /localhost を使用します。サーバー URL として 8080/poll を指定します。運用環境では、この URL を実際のサーバーのドメイン名とポートに置き換える必要があります。
JSON.parse を使用してメッセージを JavaScript オブジェクトに解析し、コンソールに記録します。
- リアルタイムアンケート機能の実装
public function onMessage(ConnectionInterface $from, $msg) {
echo 'Received message ' . $msg . ' from client ' . $from->resourceId . "
";
$data = json_decode($msg, true);
switch ($data['action']) {
case 'vote':
$vote = $data['vote'];
$this->broadcast([
'action' => 'update',
'votes' => [
'yes' => $this->getVoteCount('yes'),
'no' => $this->getVoteCount('no')
]
]);
break;
}
}
private function broadcast($message) {
foreach ($this->clients as $client) {
$client->send(json_encode($message));
}
}
private function getVoteCount($option) {
// 在这里查询投票选项的数量...
} 上記のコードでは、クライアントから送信されたメッセージを onMessage メソッドで処理します。このメソッドはメッセージをデコードし、switch ステートメントを使用して action フィールドをチェックします。 action が vote と等しい場合、投票数を更新し、broadcast メソッドを使用してすべてのクライアントに更新を送信します。
broadcast メソッドでは、ループを使用してすべてのクライアントをループし、メッセージを各クライアントに送信します。このメソッドは、JSON エンコードされたメッセージをクライアントに送信します。このメッセージは、connection.addEventListener('message', ...) イベント ハンドラーに登録されたイベント ハンドラーで使用されます。
- 完全なコード例
<?php
require __DIR__ . '/vendor/autoload.php';
use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetWebSocketWsServer;
class PollServer implements MessageComponentInterface {
protected $clients;
public function __construct() {
$this->clients = new SplObjectStorage;
}
public function onOpen(ConnectionInterface $conn) {
$this->clients->attach($conn);
echo 'Client ' . $conn->resourceId . ' connected
';
}
public function onClose(ConnectionInterface $conn) {
$this->clients->detach($conn);
echo 'Client ' . $conn->resourceId . ' disconnected
';
}
public function onMessage(ConnectionInterface $from, $msg) {
echo 'Received message ' . $msg . ' from client ' . $from->resourceId . "
";
$data = json_decode($msg, true);
switch ($data['action']) {
case 'vote':
$vote = $data['vote'];
$this->broadcast([
'action' => 'update',
'votes' => [
'yes' => $this->getVoteCount('yes'),
'no' => $this->getVoteCount('no')
]
]);
break;
}
}
public function onError(ConnectionInterface $conn, Exception $e) {
echo "An error has occurred: {$e->getMessage()}
";
$conn->close();
}
private function broadcast($message) {
foreach ($this->clients as $client) {
$client->send(json_encode($message));
}
}
private function getVoteCount($option) {
// 在这里查询投票选项的数量...
}
}
$server = new RatchetApp('localhost', 8080);
$server->route('/poll', new WsServer(new PollServer()));
$server->run();index .html: <!DOCTYPE html>
<html>
<head>
<title>Real-time Poll</title>
</head>
<body>
<h1 id="Real-time-Poll">Real-time Poll</h1>
<form>
<label><input type="radio" name="vote" value="yes"> Yes</label>
<label><input type="radio" name="vote" value="no"> No</label>
<button type="submit">Vote</button>
</form>
<ul>
<li>Yes: <span id="yes-votes">0</span></li>
<li>No: <span id="no-votes">0</span></li>
</ul>
<script>
const connection = new WebSocket('ws://localhost:8080/poll');
connection.addEventListener('open', () => {
console.log('Connected');
});
connection.addEventListener('message', event => {
const message = JSON.parse(event.data);
if (message.action === 'update') {
document.getElementById('yes-votes').textContent = message.votes.yes;
document.getElementById('no-votes').textContent = message.votes.no;
}
});
connection.addEventListener('close', () => {
console.log('Disconnected');
});
connection.addEventListener('error', error => {
console.error(error);
});
document.querySelector('form').addEventListener('submit', event => {
event.preventDefault();
const vote = document.querySelector('input[name="vote"]:checked').value;
connection.send(JSON.stringify({
action: 'vote',
vote: vote
}));
});
</script>
</body>
</html> 上記のコード例では、投票結果をサーバーに送信するための単純な HTML フォームを提供しています。ユーザーがフォームを送信すると、投票結果が JSON オブジェクトとしてサーバー上の WebSocket 接続に送信されます。 クライアントが更新メッセージを受信すると、HTML 内の投票結果を更新します。
- 概要
以上がPHP Websocket開発チュートリアル、リアルタイムアンケート機能の構築の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
アクション中のPHP：実際の例とアプリケーションApr 14, 2025 am 12:19 AMPHPは、電子商取引、コンテンツ管理システム、API開発で広く使用されています。 1）eコマース：ショッピングカート機能と支払い処理に使用。 2）コンテンツ管理システム：動的コンテンツの生成とユーザー管理に使用されます。 3）API開発：RESTFUL API開発とAPIセキュリティに使用されます。パフォーマンスの最適化とベストプラクティスを通じて、PHPアプリケーションの効率と保守性が向上します。
PHP：インタラクティブなWebコンテンツを簡単に作成しますApr 14, 2025 am 12:15 AMPHPにより、インタラクティブなWebコンテンツを簡単に作成できます。 1）HTMLを埋め込んでコンテンツを動的に生成し、ユーザー入力またはデータベースデータに基づいてリアルタイムで表示します。 2）プロセスフォームの提出と動的出力を生成して、XSSを防ぐためにHTMLSPECIALCHARSを使用していることを確認します。 3）MySQLを使用してユーザー登録システムを作成し、Password_HashおよびPreprocessingステートメントを使用してセキュリティを強化します。これらの手法を習得すると、Web開発の効率が向上します。
PHPとPython：2つの一般的なプログラミング言語を比較しますApr 14, 2025 am 12:13 AMPHPとPythonにはそれぞれ独自の利点があり、プロジェクトの要件に従って選択します。 1.PHPは、特にWebサイトの迅速な開発とメンテナンスに適しています。 2。Pythonは、データサイエンス、機械学習、人工知能に適しており、簡潔な構文を備えており、初心者に適しています。
PHPの永続的な関連性：それはまだ生きていますか？Apr 14, 2025 am 12:12 AMPHPは依然として動的であり、現代のプログラミングの分野で重要な位置を占めています。 1）PHPのシンプルさと強力なコミュニティサポートにより、Web開発で広く使用されています。 2）その柔軟性と安定性により、Webフォーム、データベース操作、ファイル処理の処理において顕著になります。 3）PHPは、初心者や経験豊富な開発者に適した、常に進化し、最適化しています。
PHPの現在のステータス：Web開発動向を見てくださいApr 13, 2025 am 12:20 AMPHPは、現代のWeb開発、特にコンテンツ管理とeコマースプラットフォームで依然として重要です。 1）PHPには、LaravelやSymfonyなどの豊富なエコシステムと強力なフレームワークサポートがあります。 2）パフォーマンスの最適化は、Opcacheとnginxを通じて達成できます。 3）PHP8.0は、パフォーマンスを改善するためにJITコンパイラを導入します。 4）クラウドネイティブアプリケーションは、DockerおよびKubernetesを介して展開され、柔軟性とスケーラビリティを向上させます。
PHP対その他の言語：比較Apr 13, 2025 am 12:19 AMPHPは、特に迅速な開発や動的なコンテンツの処理に適していますが、データサイエンスとエンタープライズレベルのアプリケーションには良くありません。 Pythonと比較して、PHPはWeb開発においてより多くの利点がありますが、データサイエンスの分野ではPythonほど良くありません。 Javaと比較して、PHPはエンタープライズレベルのアプリケーションでより悪化しますが、Web開発により柔軟性があります。 JavaScriptと比較して、PHPはバックエンド開発により簡潔ですが、フロントエンド開発のJavaScriptほど良くありません。
PHP対Python：コア機能と機能Apr 13, 2025 am 12:16 AMPHPとPythonにはそれぞれ独自の利点があり、さまざまなシナリオに適しています。 1.PHPはWeb開発に適しており、組み込みのWebサーバーとRich Functionライブラリを提供します。 2。Pythonは、簡潔な構文と強力な標準ライブラリを備えたデータサイエンスと機械学習に適しています。選択するときは、プロジェクトの要件に基づいて決定する必要があります。
PHP：Web開発の重要な言語Apr 13, 2025 am 12:08 AMPHPは、サーバー側で広く使用されているスクリプト言語で、特にWeb開発に適しています。 1.PHPは、HTMLを埋め込み、HTTP要求と応答を処理し、さまざまなデータベースをサポートできます。 2.PHPは、ダイナミックWebコンテンツ、プロセスフォームデータ、アクセスデータベースなどを生成するために使用され、強力なコミュニティサポートとオープンソースリソースを備えています。 3。PHPは解釈された言語であり、実行プロセスには語彙分析、文法分析、編集、実行が含まれます。 4.PHPは、ユーザー登録システムなどの高度なアプリケーションについてMySQLと組み合わせることができます。 5。PHPをデバッグするときは、error_reporting（）やvar_dump（）などの関数を使用できます。 6. PHPコードを最適化して、キャッシュメカニズムを使用し、データベースクエリを最適化し、組み込み関数を使用します。 7
ホットAIツール
Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ
AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。
Undress AI Tool
脱衣画像を無料で
Clothoff.io
AI衣類リムーバー
AI Hentai Generator
AIヘンタイを無料で生成します。
人気の記事
ホットツール
SublimeText3 中国語版
中国語版、とても使いやすい
SublimeText3 Mac版
神レベルのコード編集ソフト（SublimeText3）
SAP NetWeaver Server Adapter for Eclipse
Eclipse を SAP NetWeaver アプリケーション サーバーと統合します。
EditPlus 中国語クラック版
サイズが小さく、構文の強調表示、コード プロンプト機能はサポートされていません
DVWA
Damn Vulnerable Web App (DVWA) は、非常に脆弱な PHP/MySQL Web アプリケーションです。その主な目的は、セキュリティ専門家が法的環境でスキルとツールをテストするのに役立ち、Web 開発者が Web アプリケーションを保護するプロセスをより深く理解できるようにし、教師/生徒が教室環境で Web アプリケーションを教え/学習できるようにすることです。安全。 DVWA の目標は、シンプルでわかりやすいインターフェイスを通じて、さまざまな難易度で最も一般的な Web 脆弱性のいくつかを実践することです。このソフトウェアは、
