我构建了使用 socket.io 和 expressjs 的小应用程序
服务器端
var express = require('express'),
sio = require('socket.io');
var app = express.createServer();
app.configure('development', function(){
app.use(express.bodyParser());
app.use(express.cookieParser());
app.use(express.static(__dirname + '/'));
app.set('views', __dirname + '/views');
app.use(express.errorHandler({dumpExceptions: true, showStack: true}));
app.use(app.router);
});
app.listen(4000);
var io = sio.listen(app);
app.get('/', function (req, res) {
res.redirect('index.html');
});
io.sockets.on('connection', function (socket) {
app.post('/mysegment',function(req,res){
var userData = req.body;
socket.emit('sendUser', userData);
res.send("yes I got that segment");
});
socket.on('getUser',function(msg){
console.log("Yes Socket work Properly "+msg);
});
});
和索引.html
var socket = io.connect();
socket.on('connect', function () {
console.log("client connection done.....");
});
socket.on('sendUser', function (data) {
alert("On send user");
socket.emit('getUser',"Hello");
});
这个演示完美运行但是当我刷新页面时并将帖子请求发送到"/mysegment",我的时间套接字无法正常工作。我在控制台上没有收到消息"是的,套接字工作正常(和我的味精)"但我得到的回应是"是的,我得到了那个片段" 任何建议请...
io.sockets.on('connection', function (socket) {
app.post('/mysegment', ...
这里发生的事情是,每次任何客户端与websockets连接时,都会向所有/mysgment POST请求添加一个新的处理程序。然后,当有人向/mysegment 发送 POST 时,所有连接的客户端都将获得userData
......这可能不是你想要的。
为了简单起见,坚持使用套接字,而对其他事情使用普通HTTP。
否则,您必须共享会话和/或找到相应的套接字。
您可以在快速路由中访问套接字对象,如下所示(在 scoket.io v4 中):
var socket = io.sockets.on('connection', function (socket) {
socket.on('getUser',function(msg){
console.log("Yes Socket work Properly "+msg);
});
});
app.post('/mysegment',function(req,res){
var userData = req.body;
socket.emit('sendUser', userData);
res.send("yes I got that segment");
});