目前有带 laravel 广播的 IO 套接字和 redis 完美运行。直到我在域上设置 SSL 证书。

我在端口 3001 上运行了 redis-server。

然后有个socket.js设置监听3000

我在页面上的 JS 我通过 io('//{{ $listen }}:3000').

任何有关如何通过 https 实现此功能的指导都将非常有用。我可以只使用 443 作为端口吗？

谢谢。

我的 socket.js

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var Redis = require('ioredis');
var redis = new Redis();
redis.subscribe('notifications', function(err, count) {
});
redis.on('message', function(channel, message) {
    console.log('Message Recieved: ' + message);
    message = JSON.parse(message);
    io.emit(channel + ':' + message.event, message.data);
});
http.listen(3000, function(){
    console.log('Listening on Port 3000');
});

最佳答案

首先，设置您的 serverOptions 对象:

var serverOptions = {
    port: 3000,
    host: 127.0.0.1, //address to your site
    key: '/etc/nginx/ssl/your_site/server.key', //Or whatever the path to your SSL is
    cert: '/etc/nginx/ssl/your_site/server.crt',
    NPNProtocols: ['http/2.0', 'spdy', 'http/1.1', 'http/1.0']
}

对于 NPNProtocols，您可能并不关心所有这些，但提供它们以供引用。

现在只需创建服务器:

var app = require('https').createServer(serverOptions),
    io = require('socket.io')(app);

在他看来，这应该是即插即用的源代码。\

作为旁注，您的内容是完全开放的，任何人都可以在您的网络套接字上收听，因此不应通过此处发送任何私有(private)内容。如果您需要将您的数据保密，那么您将需要以下两件事中的一件；

1. 类似于JWT-Auth Token
2. 与 Redis 队列接口(interface)的自定义内容:

这是后者的一个例子:

var SECRET_KEY = '<YOUR_LARAVEL_SECRET_KEY>';
var laravel_session_parser = {
    ord: function (string) {
        return string.charCodeAt(0);
    },
    decryptSession: function (cookie, secret) {
        if (cookie) {
            var session_cookie = JSON.parse(new Buffer(cookie, 'base64'));
            var iv = new Buffer(session_cookie.iv, 'base64');
            var value = new Buffer(session_cookie.value, 'base64');
            var rijCbc = new mcrypt.MCrypt('rijndael-128', 'cbc');
            rijCbc.open(secret, iv);
            var decrypted = rijCbc.decrypt(value).toString();
            var len = decrypted.length - 1;
            var pad = laravel_session_parser.ord(decrypted.charAt(len));
            return phpunserialize.unserialize(decrypted.substr(0, decrypted.length - pad));
        }
        return null;
    },
    getUidFromObj: function (obj, pattern) {
        var regexp = /login_web_([a-zA-Z0-9]+)/gi;
        if (pattern) {
            regexp = pattern;
        }
        var u_id = null;
        for (var key in obj) {
            var matches_array = key.match(regexp);
            if (matches_array && matches_array.length > 0) {
                u_id = obj[matches_array[0]];
                return u_id;
            }
        }
        return u_id;
    },
    getRedisSession: function (s_id, cb) {
        var _sessionId = 'laravel:' + s_id;
        client.get(_sessionId, function (err, session) {
            if (err) {
                cb && cb(err);
                return;
            }
            cb && cb(null, session);
        });
    },
    getSessionId: function (session, _callback) {
        var u_id = null,
            err = null;
        try {
            var laravelSession = phpunserialize.unserialize(phpunserialize.unserialize(session));
            u_id = laravel_session_parser.getUidFromObj(laravelSession);
        } catch (err) {
            _callback(err, null);
        }
        _callback(err, u_id);
    },
    ready: function (socket, _callback) {
        if (typeof socket.handshake.headers.cookie === 'string') {
            var cookies = cookie.parse(socket.handshake.headers.cookie);
            var laravel_session = cookies.laravel_session;
            var session_id = laravel_session_parser.decryptSession(laravel_session, SECRET_KEY);

            laravel_session_parser.getRedisSession(session_id, function (err, session) {
                if (!err && session) {
                    laravel_session_parser.getSessionId(session, function (err, user_id) {
                        if (user_id) {
                            _callback(null, session_id, user_id, laravel_session)
                        } else {
                            _callback(new Error('Authentication error'), null);
                        }
                    });
                } else {
                    _callback(new Error('Authentication error'), null);
                }
            });
        }
    }
};

现在您可以让 IO 在个人 session 建立到 socket.io 的连接时获取他们的实例

io.on('connection', function (socket) {
    laravel_session_parser.ready(socket, function(err, session_id, user_id, laravel_session) {
        //log out the variables above to see what they provide
    });
});

注意，我更喜欢在 NodeJS 中使用 dotenv 来在 Laravel 和 Node 之间共享环境变量。

然后你可以执行 process.env.APP_KEY 并且你不需要担心共享变量。

另外请注意，上面的脚本并不完整，也不是生产就绪的，它只是用作示例。

关于通过 SSL https 连接的 Laravel IO Socket 和 redis，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/38832031/