Socket.io почему подключается дважды?

Евгений Запунный, Распределение нагрузки)
Это я так в доках увидел:

const socket = io("https://example.com"); // the main namespace
const productSocket = io("https://example.com/product", { forceNew: true }); // the "product" namespace
const orderSocket = io("https://example.com/order", { forceNew: true }); // the "order" namespace

Socket.io почему подключается дважды?

А что если в рамках микросервиса разворачивать свой сервер WebSocket? (Это так отдельно от темы).
Например Микросервис заказы, на нём развернуть Websocket сервер чисто под заказы

Socket.io почему подключается дважды?

Ни в какую, вообще не реагирует никак. Хотя VUEJS фронт отлично подключается, одно подключения, все события отправляются.

Socket.io почему подключается дважды?

Евгений Запунный, 1. спасибо, убрал
2. Error: "connect" is a reserved event name
Вызвал так: socket.emit('connect')

Socket.io почему подключается дважды?

Евгений Запунный, У меня 1 сервер WebSocket:

io.sockets.on('connection', function (socket) {
    console.log('hello: ' + socket.id) // ЭТО ВЫВОДИТСЯ ДВАЖДЫ
})

И микросервис, который пытаюсь подключить через socket.io к нему:

const io = require('socket.io-client')
const socket = io("http://localhost:1900", {
    transports: ["websocket"]
})
socket.on("connect", (socket) => {
    console.log('CONNECT SOCKET', socket) // ЭТО В КОНСОЛЬ НЕ ВЫВОДИТСЯ
});

Socket.io почему подключается дважды?

socket.on("connect", (socket) => {
    console.log('CONNECT SOCKET', socket) // Это в консоль не выводится
});

Проблема ещё что connect не срабатывает

Socket.io почему подключается дважды?

Нет, это NodeJS.
Микросервис на NodeJS я его хочу подключить к серверу websocket, чтобы он рассылал уведомления.

GRAPHQL подписки, как правильно реализовать?

Понял, спасибо

Единый микросервис для сбора/хранения всех логов, правильно ли это?

есть готовые инструменты

Можете посоветовать хорошие? Микросервисов более 20 шт.

Единый микросервис для сбора/хранения всех логов, правильно ли это?

Roman Kitaev,
А понял, что неправильно

Как правильно повторно выполнять неудачные задачи?

А вариант хранить задачу где-то в базе, и если она не выполнилась, скрипт проверяет наличие таких и пытается снова выполнять, при определенном количестве ''не успеха", метит задачу как провальную и отправляет уведомление. Как такой вариант?
Ну то есть вынести это на логику, а не на Rabbit(именно про повторы, а не всё)

Корректно ли пишу код NodeJS?

Спасибо. Примерно так уже реализовал)

Как исключить создание дубликатов при запросе RabbitMQ?

А если два одновременно придут в Rabbit?

Как исключить создание дубликатов при запросе RabbitMQ?

И так сделал поле UNIQUE, но мне кажется это должно работать и без этого. Создаётся ощущение что в других случаях, к примеру без поля UNIQUE (где нет уникальных полей, где они не нужны), будут дубликаты, я об этом.

Корректно ли пишу код NodeJS?

WbICHA, Я просто ещё не дошёл до тех мест, где написано console.log(err). Понято что их нужно обработать. Вы об этом?

Корректно ли пишу код NodeJS?

WbICHA, Но тем не менее, это вроде как работает. Принцип написания checkUniqueEmail нашёл на просторах интернета

Корректно ли пишу код NodeJS?

WbICHA, Это снова Я, Если уже надоел, можете не отвечать)
Пришлось поменять код исходя из pool.connect рекомендаций и прежний код не вязался.

app.post('/register', async (req, res) => {
    try {
        const { body } = req
        await checkUniqueEmail(body.email, function (isUniqueEmail) {
            if (!isUniqueEmail) {
                res.json({
                    status: 'error',
                    title: 'E-Mail адрес занят',
                    text: 'Используйте другой',
                })
                return
            }
            res.json({
                status: 'success',
            })
        })
    } catch (err) {
        console.error(err)
    }
});

function checkUniqueEmail (email, callback) {
    pool.connect((err, client, done) => {
        if (err) throw err
        client.query('SELECT * FROM users WHERE email = $1', [email], (err, res) => {
            done()
            if (err) {
                console.log(err)
            } else {
                return callback(res.rowCount === 0)
            }
        })
    })
}

В правильном направлении?

Корректно ли пишу код NodeJS?

WbICHA, Огромное спасибо за помощь :)

Корректно ли пишу код NodeJS?

WbICHA, Прошу прощение за доставучесть, может этот вариант вернее?)

app.post('/register', async (req, res) => {
    let body = req.body
    let response = {status:'', title:'', text:''}
    if (await checkUniqueEmail(body.email)) {
        response.status = 'success'
    } else {
        response.status = 'error'
        response.title = 'E-Mail адрес занят'
        response.text = 'Используйте другой'
    }
    res.json(response)
});
function checkUniqueEmail (email) {
    return pool.query(`SELECT * FROM users WHERE 'email' = $1`, [email]).then(res => {
        if (res.rowCount !== 0) {
            return Promise.resolve(false)
        } else {
            return Promise.resolve(true)
        }
    }).catch(err => Promise.reject(err))
}

Корректно ли пишу код NodeJS?

WbICHA, Спасибо.

app.post('/register', async (req, res) => {
    let body = req.body
    let response = {status:'', title:'', text:''}
    checkUniqueEmail(body.email, function (err, result) {
        if (result.rowCount === 0) {
            response.status = 'success'
        } else {
            response.status = 'error'
            response.title = 'E-Mail адрес занят'
            response.text = 'Используйте другой'
        }
        res.json(response)
    })
});
function checkUniqueEmail (email, callback) {
    pool.query(`SELECT * FROM users WHERE 'email' = $1`, [email], (err, result) => {
        callback(err, result)
    })
}

Переписал, так лучше?