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