Если вы ищете способ отображения фактического содержимого файла в Интернете без необходимости перезагрузки страницы, вам необходимо установить сервер WebSocket.
Вы можете создать сервер WebSocket, используя рамки, такие как phpDaemon, ReactPHP, Ratchet, icicle или реализовать свой собственный сервер с помощью PHP расширений оберточных асинхронных библиотек: eventev, или аналогичных.
Я выбрал случайную структуру из приведенного выше списка: Ratchet. Ratchet основан на ReactPHP. ReactPHP выбирает бэкенд для цикла событий из следующего списка: - libevent
расширения, - libev
расширения, - event
расширения, - или внутренний класс на основе встроенного stream_select()
функции.
Как продюсер event
, я выбрал event
.
Я написал «быстрый» пример, чтобы дать вам представление о том, как он может быть реализован. Скорее всего, вам придется разработать свою собственную версию, возможно, используя разные инструменты. Но код должен дать вам импульс.
SRC/MyApp/Server.php
<?php
namespace MyApp;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
class Server implements MessageComponentInterface {
protected $clients;
public function __construct() {
$this->clients = new \SplObjectStorage;
}
public function onOpen(ConnectionInterface $conn) {
$this->clients->attach($conn);
echo "New connection! ({$conn->resourceId})\n";
}
public function onMessage(ConnectionInterface $from, $msg) {
$numRecv = count($this->clients) - 1;
printf("Connection %d sending '%s' to %d other connection%s\n",
$from->resourceId, $msg, $numRecv, $numRecv == 1 ? '' : 's');
foreach ($this->clients as $client) {
if ($from !== $client) {
$client->send($msg);
}
}
}
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();
}
public function broadcast($msg) {
foreach ($this->clients as $client) {
$client->send($msg);
}
}
}
server.php
<?php
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use MyApp\Server;
require __DIR__ . '/vendor/autoload.php';
$server = IoServer::factory(
new HttpServer(
new WsServer(
$my_app_server = new Server()
)
),
9989
);
$loop = $server->loop;
$filename = '/var/log/messages';
$loop->addPeriodicTimer(5, function()
use ($filename, $my_app_server)
{
static $stat_info;
if ($stat_info == null) {
clearstatcache(true, $filename);
$stat_info = stat($filename);
}
clearstatcache(true, $filename);
$st = stat($filename);
$size_diff = $st['size'] - $stat_info['size'];
echo "Diff = $size_diff bytes\n";
if ($size_diff > 0) {
$offset = $stat_info['size'];
$bytes = $size_diff;
} elseif ($size_diff < 0) {
// The file is likely truncated by `logrotate` or similar utility
$offset = 0;
$bytes = $st['size'];
} else {
$bytes = 0;
}
$stat_info = $st;
if ($bytes) {
if (! $fp = fopen($filename, 'r')) {
fprintf(STDERR, "Failed to open file $filename\n");
return;
}
if ($offset > 0) {
fseek($fp, $offset);
}
if ($msg = fread($fp, $bytes)) {
$my_app_server->broadcast($msg);
}
fclose($fp);
}
}
);
$server->run();
test.html
<html>
<head>
<meta http-equiv="content-type" content="text/html; charset=utf-8">
<title>Test</title>
</head>
<body>
<script>
var conn = new WebSocket('ws://localhost:9989');
conn.onopen = function(e) {
console.log("Connection established!");
};
conn.onmessage = function(e) {
console.log("Msg from server", e.data);
};
</script>
</body>
</html>
Я опущу шаги р equired для установки базовой тестовой среды с использованием Composer. Предполагая, что вы успешно настроили тестовую среду для файлов выше, вы будете иметь возможность запускать сервер с помощью следующей команды:
php server.php
Проверьте, если пользователь имеет право на чтение /var/log/messages
. В моей системе только root
может прочитать файл. Таким образом, вам может потребоваться выполнить указанную выше команду с помощью sudo
(корневые разрешения).
Теперь вы можете открыть test.html
в браузере и посмотреть на вывод консоли. Затем активируйте событие, которое обычно регистрируется в файле сообщений. Например, вы можете вызывать sudo
с неправильным паролем. Сервер должен обнаружить изменения в течение 5 секунд, а затем отправить их клиентам WebSocket.
Спасибо за быстрый ответ Сергей! Я закончил с решением, которое позволяет избежать символических ссылок. – iDigLiveMusic