thinkphp 搭建Workerman聊天

要在 ThinkPHP 框架中搭建基于 Workerman 的聊天室应用，可以按照以下步骤进行。Workerman 是一个高性能的 PHP 网络通信框架，非常适合用于实现 WebSocket 服务器。以下是一个简单的实现步骤：

1. 环境准备

确保你的开发环境满足以下要求：

• PHP 版本 >= 7.0
• 安装了 Composer
• 安装了 ThinkPHP 框架

2. 安装 Workerman

首先，在你的 ThinkPHP 项目根目录下使用 Composer 安装 Workerman：

composer require workerman/workerman

3. 创建 WebSocket 服务

在 application 目录下创建一个新的目录，例如 workerman, 并在其中创建一个文件 Chat.php 来定义 WebSocket 服务：

<?php
namespace app\workerman;

use Workerman\Worker;
use Workerman\Connection\TcpConnection;

class Chat
{
    public function start()
    {
        // 创建一个支持 SSL 的 WebSocket 服务器
        $context = [
            // SSL 证书路径
            'ssl' => [
                'local_cert' => '/path/to/fullchain.pem', // 公钥证书
                'local_pk' => '/path/to/privkey.pem', // 私钥
                'verify_peer' => false, // 如果不需要验证客户端证书可以设置为 false
            ],
        ];

        // 创建一个 WebSocket 服务器，监听 443 端口（wss 默认端口）
        $ws_worker = new Worker("websocket://0.0.0.0:443", $context);
        $ws_worker->transport = 'ssl';

        // 设置 WebSocket 服务的事件回调
        $ws_worker->onConnect = function (TcpConnection $connection) {
            echo "New connection\n";
        };

        $ws_worker->onMessage = function (TcpConnection $connection, $data) {
            // 广播消息到所有客户端
            foreach ($ws_worker->connections as $client_connection) {
                $client_connection->send("User: " . $data);
            }
        };

        $ws_worker->onClose = function (TcpConnection $connection) {
            echo "Connection closed\n";
        };

        // 运行 Workerman
        Worker::runAll();
    }
}

4. 配置和启动服务

在 config 目录下的 database.php 或其他配置文件中添加 WebSocket 服务器的端口配置（可选）。

在 public 目录下创建一个入口文件，例如 ws_server.php，用于启动 WebSocket 服务：

<?php
// 定义应用目录
define('APP_PATH', __DIR__ . '/../application/');

// 加载框架引导文件
require __DIR__ . '/../thinkphp/start.php';

// 启动 Workerman 聊天服务
$chat = new \app\workerman\Chat();
$chat->start();

5. 运行 WebSocket 服务

在命令行中运行以下命令启动 WebSocket 服务器：

php public/ws_server.php

6. 前端连接 WebSocket 服务器

在你的前端代码中连接 WebSocket 服务器，可以使用以下 JavaScript 代码：

var ws = new WebSocket('wss://your-domain.com');

ws.onopen = function() {
    console.log('WebSocket connection opened');
};

ws.onmessage = function (event) {
    console.log('Received message: ' + event.data);
};

ws.onclose = function() {
    console.log('WebSocket connection closed');
};

// 发送消息
function sendMessage(message) {
    ws.send(message);
}

7. 集成到 ThinkPHP 项目

可以将 WebSocket 服务的启动与 ThinkPHP 的其他部分集成，例如在控制器中添加方法来启动或管理服务，具体取决于你的项目需求。

8. 安全性与优化

• 考虑使用 SSL/TLS 来加密 WebSocket 通信。
• 处理连接的认证和授权，以确保只有授权用户可以发送和接收消息。
• 在生产环境中使用进程守护工具（如 Supervisor）来管理 Workerman 进程。

通过以上步骤，你应该可以在 ThinkPHP 框架中搭建一个简单的基于 Workerman 的聊天室应用。根据项目需求，你可以进一步扩展功能和优化性能。