Я новичок в websocket.В настоящее время я слушаю websocket в моем приложении промежуточного программного обеспечения node.js.Получив сообщение, я должен сохранить это сообщение в базе данных.
const ws = new WebSocket("ws://localhost:3000");
ws.on("message", (event) => {
console.log("connected to DB");
testConnection();
});
При получении нового сообщения должна запускаться функция testConnection
.
async function testConnection() {
await sequelize.authenticate().then(() => {
console.log("Connected to DB");
})
.catch((err) => {
console.log(err);
});
};
Я пытаюсьпроверить соединение.
Но при получении нового сообщения функция testConnection
не вызывается.
Я хотел бы знать, как вызывать функцию при получении нового сообщения.