Пример минимального Websocket Nodejs Tail - PullRequest
Новая
       7

Пример минимального Websocket Nodejs Tail

12 голосов
/ 17 августа 2010

Я пытаюсь создать поток данных в браузере, используя websocket.Данные являются выводом файла журнала.(tail -f filename) Используя узел js, мне удалось войти в stdout, но я не смог создать сервер и создать клиентский (js / html) код для создания веб-сокета и получения всех выходных данныхэто дочерний процесс.Кто-нибудь может мне помочь?

СЕРВЕР NODE.JS ВЫХОДИТ ХВОСТ НА ВЫХОД (как видно из http://snippets.dzone.com/posts/show/12067)

var sys = require('sys')
var spawn = require('child_process').spawn;
var filename = process.ARGV[2];

if (!filename)
  return sys.puts("Usage: node <server.js> <filename>");

var tail = spawn("tail", ["-f", filename]);
sys.puts("start tailing");

tail.stdout.on("data", function (data) {
  sys.puts(data);
});

Моя цель - создать самый простой поток.хорошо принят за это. Спасибо.

Ответы [ 3 ]

16 голосов
/ 05 сентября 2010

Это просто? 

var sys = require('sys')
var spawn = require('child_process').spawn;
var filename = process.ARGV[2];
if (!filename)
  return sys.puts("Usage: node <server.js> <filename>");

var tail = spawn("tail", ["-f", filename]);

http = require('http');
http.createServer(function (req, res) {
  sys.puts("new connection..");
  res.writeHead(200, {'Content-Type': "text/plain;charset=UTF-8"});
  tail.stdout.on("data", function (data) {
    res.write(data);
  }); 
}).listen(3000);

Подключитесь к серверу, и вы получите свой хвост. Вам придется следить за временем ожидания на стороне клиента, в зависимости от вашего браузера, если хвост не работает.

Если вы хотите получить доступ к этим данным из javascript в браузере, рассмотрите возможность использования socket.io , так как это будет использовать лучший метод, доступный браузеру для доступа к потоку (websocket, long poll, flash и т. Д. .). Если вам нужен пример клиентского JavaScript, я тоже могу опубликовать его.

7 голосов
/ 13 марта 2011

Это похоже на старый вопрос и, возможно, проблема уже решена, но в случае, если это не здесь, суть https://gist.github.com/867575.

он использует socket.io и вместо порождения процессов tail -f (которые занимают больше памяти) используется fs.watchFile.

5 голосов
/ 18 декабря 2015

Вот простой пример, который я в основном взял из этой сути

Сначала переключитесь в пустой каталог 

mkdir socket-tail-app; cd socket-tail-app;

Затем установите то, что нужно 

npm install socket.io

Запустите его так: 

node server.js /path/to/file/to/tail

После запуска откройте браузер на 

http://localhost:8000

Вот файлы, которые вам нужны:

server.js 

var http    = require('http'),
    io      = require('socket.io'),
    fs      = require('fs');

var spawn = require('child_process').spawn;

var filename = process.argv[2];
if (!filename) 
{
  console.log("Usage: node server.js filename_to_tail");
  return;
}


// -- Node.js Server ----------------------------------------------------------

server = http.createServer(function(req, res){
  res.writeHead(200, {'Content-Type': 'text/html'})
  fs.readFile(__dirname + '/index.html', function(err, data){
    res.write(data, 'utf8');
    res.end();
  });
})
server.listen(8000, '0.0.0.0');

// -- Setup Socket.IO ---------------------------------------------------------

var io = io.listen(server);

io.on('connection', function(client){
  console.log('Client connected');
  var tail = spawn("tail", ["-f", filename]);
  client.send( { filename : filename } );

  tail.stdout.on("data", function (data) {
    console.log(data.toString('utf-8'))
    client.send( { tail : data.toString('utf-8') } )
  }); 

});

console.log('Server running at http://0.0.0.0:8000/, connect with a browser to see tail output');

index.html 

<code><!DOCTYPE html>
<html>
<head>
  <title>tail.js</title>
  <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
  <script src="//code.jquery.com/jquery-2.1.4.min.js"></script>
  <script src="//cdn.socket.io/socket.io-1.3.7.js"></script>

  <style>
    body
      { color: #1a2c37;
        font-family: 'Helvetica', sans-serif; font-size: 86%;
        padding: 2em; }
    #info
      { font-size: 120%;
        font-weight: bold; }
    #tail
      { border: 1px solid #ccc;
        height: 300px;
        padding: 0.5em;
        overflow: hidden;
        position: relative;
        overflow-y: scroll; }
  </style>

</head>
<body>
  <pre id="info">
var Application = function () {var socket = io.connect ('http://127.0.0.1:8000/');socket.on ('connect', function () {console.log ('Подключен к:', socket.host);});socket.on ('message', function (message) {console.log («Полученное сообщение:», сообщение);if (message.filename) {$ ('# info'). html ('$ tail -f' + message.filename);};if (message.tail) {$ ('# tail'). html ($ ('# tail'). html () + message.tail);bottom = $ ("# tail") [0] .scrollHeight - $ ("# tail"). height ()$ ( '# Хвост') scrollTop (внизу).}});вернуть {гнездо: гнездо};};$ (function () {var app = Application ();});
...