實現(xiàn) WebSocket 的一對一消息通信涉及客戶端和服務(wù)器端兩個部分的編碼。我將為你提供一個基本的示例，展示如何使用 PHP（通過 Ratchet 庫）實現(xiàn)后端 WebSocket 服務(wù)器，以及如何在客戶端設(shè)置發(fā)送者和接收者信息。
客戶端（前端）部分
在客戶端，通常使用 JavaScript 來實現(xiàn) WebSocket 連接和消息發(fā)送。以下是一個簡單的示例代碼：
javascript代碼：
// 客戶端 WebSocket 連接
var socket = new WebSocket('ws://yourserveraddress:8080');
// 當連接打開時
socket.onopen = function() {
console.log('WebSocket connected.');
// 準備發(fā)送的消息
var message = {
sender: 'sender_id', // 發(fā)送者的標識，可以是用戶 ID 或其他標識符
receiver: 'recipient_id', // 接收者的標識
content: 'Hello!' // 消息內(nèi)容
};
// 發(fā)送消息給服務(wù)器
socket.send(JSON.stringify(message));
};
// 監(jiān)聽來自服務(wù)器的消息
socket.onmessage = function(event) {
var receivedMessage = JSON.parse(event.data);
console.log('Message received from server:', receivedMessage);
// 在這里處理接收到的消息
};
// 錯誤處理
socket.onerror = function(error) {
console.error('WebSocket error:', error);
};
// 連接關(guān)閉時的處理
socket.onclose = function(event) {
if (event.wasClean) {
console.log('WebSocket closed cleanly');
} else {
console.error('WebSocket connection closed unexpectedly');
}
};
服務(wù)器端（PHP）部分
在服務(wù)器端，我們使用 PHP 和 Ratchet 庫來實現(xiàn) WebSocket 服務(wù)器，并處理客戶端發(fā)送過來的消息。以下是一個簡單的例子 server.php：
php代碼：
<?php
require __DIR__ . '/vendor/autoload.php';
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
class Chat implements MessageComponentInterface {
protected $clients;
public function __construct() {
$this->clients = new \SplObjectStorage;
}
public function onOpen(ConnectionInterface $conn) {
// 存儲連接對象
$this->clients->attach($conn);
echo "New connection! ({$conn->resourceId})\n";
}
public function onMessage(ConnectionInterface $from, $msg) {
$message = json_decode($msg);
// 找到接收者并發(fā)送消息
foreach ($this->clients as $client) {
if ($client !== $from && $message->receiver == $client->resourceId) {
$client->send(json_encode([
'sender' => $message->sender,
'content' => $message->content
]));
break;
}
}
}
public function onClose(ConnectionInterface $conn) {
// 移除斷開的連接
$this->clients->detach($conn);
echo "Connection {$conn->resourceId} has disconnected\n";
}
public function onError(ConnectionInterface $conn, \Exception $e) {
echo "An error has occurred: {$e->getMessage()}\n";
$conn->close();
}
}
// 啟動 WebSocket 服務(wù)器
$server = IoServer::factory(
new HttpServer(
new WsServer(
new Chat()
)
),
8080 // WebSocket 服務(wù)器端口
);
echo "WebSocket server running...\n";
$server->run();
解釋
客戶端部分：在客戶端，通過 WebSocket 連接發(fā)送一個 JSON 格式的消息，包含發(fā)送者和接收者的標識以及消息內(nèi)容。
服務(wù)器端部分：在 PHP 中，使用 Ratchet 庫實現(xiàn)一個 WebSocket 服務(wù)器。在 onMessage 方法中，服務(wù)器接收到消息后解析 JSON 數(shù)據(jù)，查找與接收者匹配的客戶端連接，并將消息發(fā)送給該客戶端。
注意事項
安全性：這個示例中沒有包括身份驗證或安全性檢查，實際應(yīng)用中需要根據(jù)需求加強安全性措施。
異常處理：適當處理連接關(guān)閉、錯誤等異常情況，以確保服務(wù)器的穩(wěn)定性和可靠性。
擴展性：此示例是基于一對一通信，如果需要支持多對多或其他復(fù)雜的通信模式，需要相應(yīng)調(diào)整和擴展。
通過這些代碼示例，你可以實現(xiàn)基本的 WebSocket 一對一消息通信功能，在實際應(yīng)用中可根據(jù)具體需求進行擴展和優(yōu)化。