node.js - 如何在 Node 中的 Mongoose 上触发套接字事件?
问题描述
这是我的模型。
const mongoose = require('mongoose');
var timestamps = require('mongoose-timestamp');
var CategorySchema = new mongoose.Schema({
name: String
});
CategorySchema.plugin(timestamps);
CategorySchema.post('save', function () {
console.log(this.name);
});
var Category = mongoose.model('Category', CategorySchema);
module.exports = Category;
这是我的 index.js
const express = require('express');
const bodyParser = require('body-parser');
const cors = require('cors');
const { mongoose } = require('./config/db.js');
var routes = require('./routes/routes');
var j = require('./utility/mailer');
var app = express();
//app.use(bodyParser.json());
app.use(bodyParser.json({ limit: '50mb' }));
app.use(bodyParser.urlencoded({ extended: true, limit: '50mb' }));
app.use(cors({ origin: 'http://localhost:4200' }));
app.use(express.static('uploads'));
//app.listen(3000, () => console.log('server started'));
app.use(function (req, res, next) {
res.setTimeout(10000, function () {
console.log('timeout call');
res.status(408).send({ 'res': 'timed out' });
//res.end(408);
return;
});
next();
});
app.use('/', routes);
app.set("port", (process.env.PORT || 3000));
/*
app.listen(app.get("port"), function () {
console.log("Server started: http://localhost:" + app.get("port") + "/");
}) */
var server = app.listen(app.get('port'), function () {
console.log('Express server listening on port ' + server.address().port);
});
var io = require("socket.io").listen(server, {
handlePreflightRequest: (req, res) => {
const headers = {
"Access-Control-Allow-Headers": "Content-Type, Authorization",
"Access-Control-Allow-Origin": req.headers.origin,
"Access-Control-Allow-Credentials": true
};
res.writeHead(200, headers);
res.end();
}
});
let timerId = null,
sockets = new Set();
io.on('connection', socket => {
console.log('connected');
sockets.add(socket);
console.log(`Socket ${socket.id} added`);
if (!timerId) {
startTimer();
}
socket.emit('new data', { data: 'new data'});
socket.on('clientdata', data => {
});
socket.on('disconnect', () => {
});
});
function startTimer() {
timerId = setInterval(() => {
if (!sockets.size) {
clearInterval(timerId);
timerId = null;;
}
for (const s of sockets) {
s.emit('data', { data: 'some data' });
}
}, 2000);
}
var gulp = require('gulp');
var sonarqubeScanner = require('sonarqube-scanner');
gulp.task('default', function (callback) {
sonarqubeScanner({
serverUrl: "https://localhost:8081",
}, callback);
});
io.listen(8000);
我想为类别模型文件中的猫鼬保存挂钩内的套接字触发一个事件。你能建议一种方法吗?钩子正在工作。但是我想不出一种可能从 socket.on 触发事件的方法,因为它在 index.js 中。
如果你不把计时器放在那里也没关系。这只是为了在间隔内发出事件,因为我正在学习教程。
解决方案
您可以将 IO 设为全局变量,以便您可以在应用程序的任何位置访问它。
global.io = require("socket.io").listen(server, {
handlePreflightRequest: (req, res) => {
const headers = {
"Access-Control-Allow-Headers": "Content-Type, Authorization",
"Access-Control-Allow-Origin": req.headers.origin,
"Access-Control-Allow-Credentials": true
};
res.writeHead(200, headers);
res.end();
}});
然后在你的保存钩子中
io.emit("event-name",payload);
推荐阅读
- php - 使用 PDO 将数据插入数据库 php
- google-sheets - GSHEET 中是否有任何功能可以制作下拉列表,其中在一个单元格中选择特定值将返回不同单元格中的预定值
- typescript - 如何通过中间 TS 文件导入枚举?
- php - 使用 PDO SQL INSERT INTO 的 PHPunit 测试函数未定义数组键错误
- flutter - Flutter - 应该只有一项具有 [DropdownButton] 的值
- mysql - 如何使用表引用获取 mysql 查询?
- javascript - 如何使图像根据文本移动?
- python - 如何在单击子窗口打开时禁用菜单按钮,直到子窗口在 tkinter 中关闭
- flutter - 在 Android Studio 的项目面板中隐藏不必要的文件夹和文件
- cookies - 嵌入 youtube 视频时的 cookie 问题