【发布时间】:2018-12-09 17:02:39
【问题描述】:
我正在使用 node.js、ejs、express、mysql 和 socket.io。 我的服务器看起来像这样(index.js):
module.exports = function(io) {
var express = require('express');
var router = express.Router();
var mysql = require('mysql');
var pool = mysql.createPool({
connectionLimit: 10,
host: 'localhost',
user: 'root',
password: '',
database: 'chat'
});
router.get('/chat/:channel_name', (req, res, next) => {
var channel_name = req.params.channel_name;
// get the countries from the database so we make sure the users are connecting to the correct channel to chat, else redirect to /chat
pool.getConnection((err, connection) => {
if(err) return console.log(err);
connection.query('SELECT * FROM channel WHERE channel_name = ?', channel_name, (err, rows) => {
if(err) return console.log(err)
if(!rows.length){
return res.redirect('/chat')
}
res.render('channel', {channel_name: rows[0].channel_name})
var channel = io.of(`/chat/${rows[0].channel_name}`);
channel.on('connection', function(socket){
socket.join(rows[0].channel_name)
channel.to(rows[0].channel_name).emit('say hi', 'Hi from ' + rows[0].channel_name + '!');
});
});
});
});
router.get('/chat', function(req, res, next) {
res.render('chat');
});
return router;
}
客户:
<!DOCTYPE html>
<html>
<head>
<title><%= channel_name %></title>
</head>
<body>
<div id="message"></div>
</body>
</html>
<script src="/js/lib/jquery/jquery-3.2.1.min.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/2.1.1/socket.io.js"></script>
<script>
var socket = io(`/chat/<%= channel_name %>`);
socket.on('say hi', function(data){
$('#message').append(`<div>${data}</div>`)
})
</script>
基本上,当我重新启动服务器并尝试,例如:/chat/uk,它会显示在 html 页面上:Hi from uk!
但是,重新启动页面 10 次后,(第 11 次)浏览器一直在加载,并且在命令提示符下显示 GET /chat/uk - - ms - -,为什么会出现这种情况?
另外,这是使用命名空间的正确方法吗?我想创建用户将连接的多个频道(命名空间),然后私下一对一聊天(房间)
【问题讨论】:
标签: mysql node.js express socket.io ejs