Swoole和Workerman的消息广播与订阅在PHP与MySQL中的实时通知功能

<?php
$server = new SwooleWebSocketServer("0.0.0.0", 9501);

$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "new connection open: {$request->fd}
";
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    $message = $frame->data;
    // 实现消息广播
    foreach($server->connections as $fd) {
        $server->push($fd, $message);
    }
});

$server->on('close', function ($ser, $fd) {
    echo "connection close: {$fd}
";
});

$server->start();

<?php
require_once './Workerman/Autoloader.php';

use WorkermanLibTimer;
use WorkermanWorker;

$worker = new Worker("websocket://0.0.0.0:2345");

$worker->onWorkerStart = function () {
    Timer::add(1, function () {
        // 实现消息广播
        foreach (Worker::$worker[0]->connections as $connection) {
            $connection->send('Hello');
        }
    });
};

$worker->onConnect = function ($connection) {
    echo "New connection
";
};

$worker->onMessage = function ($connection, $data) {
    echo "Receiving message: {$data}
";
};

$worker->onClose = function ($connection) {
    echo "Connection closed
";
};

Worker::runAll();

CREATE TABLE `messages` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `content` varchar(255) NOT NULL,
  PRIMARY KEY (`id`)
);

CREATE TRIGGER `new_message` AFTER INSERT ON `messages` FOR EACH ROW
BEGIN
  DECLARE message VARCHAR(255);
  SET message = CONCAT('New message: ', NEW.content);
  -- 发送实时通知
  INSERT INTO `notifications` (`message`) VALUES (message);
END;