Проблемы с синхронизацией беспроводных дисплеев - PullRequest
Новая
       29

Проблемы с синхронизацией беспроводных дисплеев

0 голосов
/ 13 мая 2019

Я пытаюсь синхронизировать три дисплея, которые будут воспроизводить одно и то же видео, используя omxplayer. В настоящее время все три устройства подключены к главному серверу WS , и как только все три устройства подключены, сервер отправляет обратно объект даты на все три дисплея, который представляет собой текущее время плюс 15 дополнительных секунд. Затем, используя node-schedule , я ставлю все три устройства в очередь, чтобы начать воспроизведение видео в это конкретное время, но они работают примерно на 2-4 секунды друг от друга. Все они синхронизируются в одно и то же время (так как каждое устройство отвечало своим текущим временем и они идентичны второму), и все они на идентичном оборудовании, поэтому любые задержки из-за оборудования должны быть идентичны , Все они хранят видео локально, поэтому не должно быть проблем со скоростью интернета / загрузкой видеоклипа. Я не уверен, что пропускаю что-нибудь, и любые указатели были бы чрезвычайно полезны.

Особенности: Это Raspberry Pi Zero W, работающие на Balena Cloud с использованием базового образа Debian.

Код клиента 

const uuid = process.env.BALENA_DEVICE_UUID;
const WebSocket = require('ws');
const { exec } = require('child_process');
var schedule = require('node-schedule');

const ws = new WebSocket('ws://xxx.xxx.xxx.xxx:xxx');

ws.on('open', function open() {
  ws.send('CONNECT '+uuid);
});

ws.on('message', function incoming(data) {
  if (data.split("---")[0] == "START") {
    ws.send('['+uuid+'] My current time is '+ new Date());
    var j = schedule.scheduleJob(data.split("---")[1], function(){
      exec('omxplayer --loop /usr/src/app/video.mp4', (err, stdout, stderr) => {
      if (err) {
        console.log(`OMXPLAYER ERROR: ${stdout}`);
        return;
      }
      console.log(`OMXPLAYER: ${stdout}`);
      console.log(`OMXPLAYER: ${stderr}`);
      });
    });
  }
  console.log(data);
});

Код сервера 

const WebSocket = require('ws');

const wss = new WebSocket.Server({ port: xxxx });
var current = [];

wss.on('connection', function connection(ws) {
  ws.on('message', function incoming(message) {
    console.log('Received: %s', message);
    if (message.split(" ")[0] == "CONNECT") {
      ws.send("HELLO "+message.split(" ")[1]);
      current.push(message.split(" ")[1]);
      if (current.indexOf("xxx") >= 0 && current.indexOf("xxx") >= 0 && current.indexOf("xxx") >= 0) {
        var t = new Date();
        t.setSeconds(t.getSeconds() + 30);
        // Sends to the current client
        ws.send("START---" + t);
        // Sends to all remaining clients outside of the current client
        wss.clients.forEach(function each(client) {
        if (client !== ws && client.readyState === WebSocket.OPEN) {
          client.send("START---" + t);
          console.log("Sending start command...");
        }
      });
      }
    }
  });
});
...