Ответ 1
Мне удалось заставить WebSockets работать с новым балансировщиком нагрузки приложений (ALB).
Сначала создайте новую целевую группу для вас ALB. Эта целевая группа должна использовать тот же порт, что и ваше приложение, и должна быть настроена проверка работоспособности. Однако основное различие заключается в том, что вы должны включить Stickiness.
Затем добавьте новое правило прослушивателя в ваш ALB. Это правило должно иметь путь для маршрутизации настройки WebSocket -/socket.io. Кроме того, задайте имя целевой группы только что созданной целевой группе.
Я использую Node/Hapi/Socket.io для моего сервера (работает на экземпляре, полученном из Amazon Linux AMI). Базовая настройка:
const hapi = require('hapi');
const websocket = require('./WebSocket');
var server = new hapi.Server();
server.connection(config.Application);
websocket.Initialize(server.listener);
где WebSocket.js
var io = null;
module.exports = {
Initialize: function (http) {
io = require('socket.io')(http);
io.on('connection', function (socket) {
console.log('Websocket ' + socket.id + ' connected.');
socket.on('disconnect', function () {
console.log('Websocket ' + socket.id + ' disconnected.');
});
});
}
};
Я использую Angular 1.5x для моего клиента, с socket.io-client. Важно настроить параметры клиента WebSocket следующим образом, или вы не сможете подключиться.
(function () {
'use strict';
angular
.module('XXXXX', [])
.run(runHandler);
runHandler.$inject = ['WebSocketService'];
function runHandler(WebSocketService) {
WebSocketService.Initialize();
}
})();
Служба WebSocket:
(function () {
'use strict';
angular
.module('XXXXX')
.factory('WebSocketService', WebSocketService);
WebSocketService.$inject = [];
function WebSocketService() {
var socket = null;
function initialize() {
var url = 'http://' + ALB_URL + ':5800';
socket = io(url, {transports: ['websocket'], upgrade: false});
socket.on('connect', function () {
console.log('Socket connected');
});
socket.on('disconnect', function () {
console.log('Socket disconnected');
});
}
return {
Initialize: initialize
};
}
})();