从一个 id 发出的 socket.io

Question

我用socket.io通过nodejs和angular4编写了代码。我使用过2种不同的浏览器，我检查了连接和socket.io给了2个不同的socket.id，但是当发出2个浏览器时，却是从1个id发出的！

应用程序中的代码.js

io.on('connection', function(socket){app.set('socket', socket);console.log('a user connected to :'+socket.id);socket.on('disconnect', function(){console.log('user disconnected');});});

代码发出

        let socket     = req.app.get('socket');
        console.log('emit from :' +socket.id )
        socket.emit('chatroom-'+chat.room, chat);

客户端的代码侦听

        this.socket.on('chatroom-'+this.roomData._id, (data)=>{
          console.log('socket push',data);             
        })

我所有的代码

初始化app.js

//construct
const express       = require('express');
const app           = express();
const server        = require('http').createServer(app);
const io            = require('socket.io').listen(server);
const port          = 3000;

//initialize
app.use(cors());
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: true}));
app.use(passport.initialize());
app.use(passport.session());
app.use(express.static(path.join(__dirname,'public')));
///passport strategy
require('./config/passport');

//routes
const chat    = require('./routes/chat');
app.use('/chat',chat);


io.on('connection', function (socket) {
    app.set('socket', socket);
    console.log('a user has connected as :'+socket.id);
    io.on('connection', function () {
        console.log('a user has disconnected ');
    });

});

//start server code
server.listen(port, ()=> {
    console.log('node serve has been started on port : '+port);
})

在chat.js路由添加新消息后发送聊天

///add new chat
router.post('/add', passport.authenticate('jwt',{session:false}), (req,res,next) => {
    //validation
    if(!req.user._id){ res.json({status:false, message:'something went wrong, please sign-in first and try again'}) }
    if(req.user._id != req.body.user){ res.json({status:false, message:'something went wrong, please sign-in first and try again'}) }
    if(!req.body.room){ res.json({status:false, message:'something went wrong, please refresh the page and try again'}) }
    if(!req.body.text){ res.json({status:false, message:'you have to fill a chat message to add it'}) }
    next();
}, (req, res) => {
    //create new one 
    let chatData = new Chat(req.body);

    //do create
    Chat.create(chatData, (err, chat)=>{
        //error 
        if(err){ res.josn({status:false, message:err.message})}
        else{
            //replace user id to user data
            chat.user = req.user;
            //define socketio
            let socket     = req.app.get('socket');
            //emit new message
            socket.broadcast.emit('chatroom-'+chat.room, chat);
            //return respone
            res.json({status:true, message:'the message has been sent', chat:chat})
        }
    })
});

Answer 1

如果您只是尝试从您的路由广播到一个房间，您可以更改此选项：

io.on('connection', function (socket) {
    app.set('socket', socket);
    console.log('a user has connected as :'+socket.id);
    io.on('connection', function () {
        console.log('a user has disconnected ');
    });
});

对此：

// make io available via app object
app.set('io', io);

io.on('connection', function (socket) {
    console.log('a user has connected as :'+socket.id);
    io.on('disconnect', function () {
        console.log('a user has disconnected ');
    });
});

然后，改变这一点：

        let socket     = req.app.get('socket');
        //emit new message
        socket.broadcast.emit('chatroom-'+chat.room, chat);

对此：

        let io  = req.app.get('io');
        //emit new message
        io.emit('chatroom-'+chat.room, chat);

这将始终如一地将聊天发送给房间中的所有用户。

如果您只想发送给房间中的其他用户，而不是发送给发出消息的用户，那么通过套接字发送消息会更容易。io，而不是通过表单帖子。然后，您可以使用：

 socket.broadcast.emit('chatroom-'+chat.room, chat);

其中socket是您在套接字上接收消息的套接字。io，你会很方便。