Как отдельным потоком постоянно отправлять сообщения в 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 параллельно, чтобы не мешать основному потоку прослушивать сообщения клиента