PHP WebSocket开发秘籍：打造功能强大且高度可定制的聊天系统

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class WebSocketService implements MessageComponentInterface {

  public function onOpen(ConnectionInterface $conn) {
    // 连接建立时的逻辑处理
  }

  public function onMessage(ConnectionInterface $from, $msg) {
    // 收到消息时的逻辑处理
  }

  public function onClose(ConnectionInterface $conn) {
    // 连接关闭时的逻辑处理
  }

  public function onError(ConnectionInterface $conn, Exception $e) {
    // 出错时的逻辑处理
  }
}

require 'vendor/autoload.php';

$loop = ReactEventLoopFactory::create();
$webSocket = new RatchetWebSocketWsServer(new WebSocketService());
$server = new ReactSocketServer('0.0.0.0:8080', $loop);

$webSocket->setDecorator(function (ConnectionInterface $conn) {
  return new WebSocketConnectionDecorator($conn);
});

$server->listen($webSocket);

$loop->run();

<div id="chat-window"></div>

var socket = new WebSocket('ws://localhost:8080');

socket.onopen = function() {
  console.log('Connection established.');
};

socket.onmessage = function(event) {
  var data = JSON.parse(event.data);
  // 处理收到的消息
};

socket.onclose = function() {
  console.log('Connection closed.');
};

function sendMessage(message) {
  socket.send(JSON.stringify({ message: message }));
}

public function onMessage(ConnectionInterface $from, $msg) {
  // 消息存储逻辑
  $data = json_decode($msg, true);
  
  $content = $data['message'];
  $userId = $data['user_id'];
  
  // 将消息存储到数据库
  $pdo = new PDO('mysql:host=localhost;port=3306;dbname=chat', 'root', 'password');
  $stmt = $pdo->prepare('INSERT INTO messages (content, user_id, create_time) VALUES (?, ?, ?)');
  $stmt->execute([$content, $userId, date('Y-m-d H:i:s')]);
}