Ratchet实现PHP WebSocket多人聊天功能的展示

芒果芒果丶

2024-04-10 帮助1人

composer 安装ratchet
```
composer require cboden/ratchet
```
使用PDO连接数据库，创建mysql命令如下
1. CREATE TABLE messages (
2. id INT AUTO_INCREMENT PRIMARY KEY,
3. message TEXT NOT NULL,
4. created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
5. );
使用Redis存储消息列表

这个示例代码中，PHP代码使用Ratchet来创建WebSocket服务器，并实现了简单的聊天功能。HTML代码使用JavaScript来建立WebSocket连接，并处理消息传输和用户输入。要运行此代码，请确保已安装Ratchet并在终端中运行PHP文件。然后，通过打开浏览器并访问HTML代码所在的地址，就可以开始聊天了。

在onMessage方法中，我们首先将接收到的消息存入Redis列表中。然后，如果Redis中的消息数量超过1000，则将所有消息取出并依次存入MySQL中。请注意，在MySQL中执行多个INSERT语句时，最好使用事务（即BEGIN、COMMIT语句）来确保数据的完整性。

WebSocket服务端代码：

<?php
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
require_once __DIR__ . '/vendor/autoload.php';
class Chat implements MessageComponentInterface
{
protected $clients;
protected $pdo;
protected $redis;
public function __construct()
{
$this->clients = new \SplObjectStorage;
// 连接到数据库
$dsn = 'mysql:host=localhost;dbname=chat';
$username = 'root';
$password = '';
$options = [
\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION,
\PDO::ATTR_DEFAULT_FETCH_MODE => \PDO::FETCH_ASSOC
];
$this->pdo = new \PDO($dsn, $username, $password, $options);
// 连接到 Redis
$this->redis = new \Redis();
$this->redis->connect('localhost', 6379);
}
public function onOpen(ConnectionInterface $conn)
{
$this->clients->attach($conn);
echo "New connection! ({$conn->resourceId})\n";
}
public function onMessage(ConnectionInterface $from, $msg)
{
foreach ($this->clients as $client) {
if ($from !== $client) {
$client->send($msg);
}
}
// 将消息存入 Redis
$this->redis->rpush('messages', $msg);
// 如果 Redis 中的消息数量超过 1000，则将消息存入数据库
if ($this->redis->llen('messages') > 1000) {
$messages = $this->redis->lrange('messages', 0, -1);
// 开始事务
$this->pdo->beginTransaction();
foreach ($messages as $message) {
// 将消息存入数据库
$stmt = $this->pdo->prepare('INSERT INTO messages (message) VALUES (?)');
$stmt->execute([$message]);
// 从 Redis 中删除已经存入数据库的消息
$this->redis->lpop('messages');
}
// 提交事务
$this->pdo->commit();
}
}
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();
}
}
$webSocketServer = new \Ratchet\WebSocket\WsServer(new Chat());
$server = \Ratchet\Server\IoServer::factory(
new \Ratchet\Http\HttpServer($webSocketServer),
8080
);
$server->run();

开启socket服务命令，假设php文件名为socket.php

php ./socket.php

HTML代码：

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>WebSocket Chat</title>
</head>
<body>
<div id="messages"></div>
<form>
<input type="text" id="message" placeholder="Enter message">
<button type="submit">Send</button>
</form>
<script>
var conn;
var connect = function() {
conn = new WebSocket('ws://localhost:8080');
conn.onopen = function(e) {
console.log("Connection established!");
};
conn.onmessage = function(e) {
var messages = document.getElementById("messages");
var message = document.createElement("div");
message.innerHTML = e.data;
messages.appendChild(message);
};
conn.onclose = function(e) {
console.log("Connection closed, attempting to reconnect...");
setTimeout(connect, 1000);
};
};
connect();
var form = document.querySelector("form");
var input = document.querySelector("#message");
form.addEventListener("submit", function(e) {
e.preventDefault();
conn.send(input.value);
input.value = "";
});
</script>
</body>
</html>

保证WebSocket服务一直开启，可以使用一个常驻进程管理工具supervisor，使用supervisor的示例配置链接。

这篇好文章是转载于：学新通技术网

Ratchet实现PHP WebSocket多人聊天功能的展示

photoshop保存的图片太大微信发不了怎么办

Android 11 保存文件到外部存储，并分享文件

word里面弄一个表格后上面的标题会跑到下面怎么办

《学习通》视频自动暂停处理方法

photoshop扩展功能面板显示灰色怎么办

微信公众号没有声音提示怎么办

怎样阻止微信小程序自动打开

excel下划线不显示怎么办

excel打印预览压线压字怎么办

photoshop蒙版画笔没反应怎么办