實(shí)現 WebSocket 的一對一消息通信涉及客戶(hù)端和服務(wù)器端兩個(gè)部分的編碼。我將為你提供一個(gè)基本的示例，展示如何使用 PHP（通過(guò) Ratchet 庫）實(shí)現后端 WebSocket 服務(wù)器，以及如何在客戶(hù)端設置發(fā)送者和接收者信息。
客戶(hù)端（前端）部分
在客戶(hù)端，通常使用 JavaScript 來(lái)實(shí)現 WebSocket 連接和消息發(fā)送。以下是一個(gè)簡(jiǎn)單的示例代碼：
javascript代碼：
// 客戶(hù)端 WebSocket 連接
var socket = new WebSocket('ws://yourserveraddress:8080');
// 當連接打開(kāi)時(shí)
socket.onopen = function() {
console.log('WebSocket connected.');
// 準備發(fā)送的消息
var message = {
sender: 'sender_id', // 發(fā)送者的標識，可以是用戶(hù) ID 或其他標識符
receiver: 'recipient_id', // 接收者的標識
content: 'Hello!' // 消息內容
};
// 發(fā)送消息給服務(wù)器
socket.send(JSON.stringify(message));
};
// 監聽(tīng)來(lái)自服務(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)閉時(shí)的處理
socket.onclose = function(event) {
if (event.wasClean) {
console.log('WebSocket closed cleanly');
} else {
console.error('WebSocket connection closed unexpectedly');
}
};
服務(wù)器端（PHP）部分
在服務(wù)器端，我們使用 PHP 和 Ratchet 庫來(lái)實(shí)現 WebSocket 服務(wù)器，并處理客戶(hù)端發(fā)送過(guò)來(lái)的消息。以下是一個(gè)簡(jiǎn)單的例子 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) {
// 移除斷開(kāi)的連接
$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();
}
}
// 啟動(dòng) WebSocket 服務(wù)器
$server = IoServer::factory(
new HttpServer(
new WsServer(
new Chat()
)
),
8080 // WebSocket 服務(wù)器端口
);
echo "WebSocket server running...\n";
$server->run();
解釋
客戶(hù)端部分：在客戶(hù)端，通過(guò) WebSocket 連接發(fā)送一個(gè) JSON 格式的消息，包含發(fā)送者和接收者的標識以及消息內容。
服務(wù)器端部分：在 PHP 中，使用 Ratchet 庫實(shí)現一個(gè) WebSocket 服務(wù)器。在 onMessage 方法中，服務(wù)器接收到消息后解析 JSON 數據，查找與接收者匹配的客戶(hù)端連接，并將消息發(fā)送給該客戶(hù)端。
注意事項
安全性：這個(gè)示例中沒(méi)有包括身份驗證或安全性檢查，實(shí)際應用中需要根據需求加強安全性措施。
異常處理：適當處理連接關(guān)閉、錯誤等異常情況，以確保服務(wù)器的穩定性和可靠性。
擴展性：此示例是基于一對一通信，如果需要支持多對多或其他復雜的通信模式，需要相應調整和擴展。
通過(guò)這些代碼示例，你可以實(shí)現基本的 WebSocket 一對一消息通信功能，在實(shí)際應用中可根據具體需求進(jìn)行擴展和優(yōu)化。