Как отдельным потоком постоянно отправлять сообщения в WebSocket клиенту?

Question

[Re7r0]

Есть код:

const WebSocket = require('ws')
 
const wsServer = new WebSocket.Server({port: 9000})
wsServer.on('connection', onConnect)

function some_function(){
    while(true){
        //some code
    }
}

function onConnect(wsClient) {
    console.log('Новый пользователь');

    wsClient.on('message', function(message) {

        wsClient.send('Данные получены...')

        some_function(); //как запустить эту функцию, чтобы она выполнялась параллельно

    })
    wsClient.on('close', function() {

        console.log('Пользователь отключился');
    })
 }

Как запустить функцию, отмеченную в коде через комментарии, параллельно

Answer 1

[Alex McArrow]

Вот такой вариант:

const WebSocket = require('ws')

const wsServer = new WebSocket.Server({ port: 9000 })
wsServer.on('connection', (wsClient) => {
    wsClient.on('error', console.error);
    console.log('Новый пользователь');
    wsClient.on('message', function (message) {
        console.log('Сообщение от пользователя:', message);
        wsClient.send('Данные получены...')
        wsClient._timer = setInterval(() => some_function(wsClient), 1000);

    })
    wsClient.on('close', function () {
        clearInterval(wsClient._timer);
        console.log('Пользователь отключился');
    })
})

function some_function(wsClient) {
    wsClient.send('Сообщение каждый вызов')
}

При каждом полученном сообщение - создается таймер который с заложенным интервалом (1000мс = 1 сек) выполняет функцию

Comments

[Re7r0]

разве таймер запустит some_function параллельно, чтобы не мешать основному потоку прослушивать сообщения клиента

[Alexandroppolus]

Re7r0, конечно! и отслеживание таймеров, и отправка данных происходят параллельно основному потому. В основном потоке только вызов wsClient.send - не сама отправка, а только лишь "просьба к системе отправить данные", но это копеечные расходы и они никого не блочат. Запихивать такое дело в отдельный поток - только зря тратить ресурсы.
Это, собственно, основа основ nodejs

[Re7r0]

Alex McArrow, Alexandroppolus, спасибо большое, очень помогли

[rPman]

Alexandroppolus, Alex McArrow
Эй, не вводите человека в заблуждение

node.js - асинхронный, это значит все выполняется в одном потоке, в т.ч. и функция, запускаемая с помощью setInterval, пока выполняется функция, все остальные ждут (под капотом различные сетевые методы, которые для физической их реализации, запускаются в отдельном потоке, доработают до вызова кода, написанного пользователя, и будут ждать)

При асинхронном программировании, методы, вызываемые на события (в т.ч. и в приведенном в примере коде), должны быть короткими

Для параллельных тяжелых вычислений нужно использовать воркеры или к примеру модуль child_process

[Alexandroppolus]

rPman, так я то же самое написал.
some_function будет отрабатывать в основном потоке, но в нем нет тяжёлых вычислений

Answer 2

[rPman]

Для параллельных тяжелых вычислений нужно использовать воркеры или к примеру модуль child_process