Я хотел бы установить связь между главным и рабочим узлами через соединение WebSocket в режиме роя Docker.
Главный узел должен был быть получен с рабочего узла.Сбой соединения.
Кроме того, я хотел бы подключиться через http к главному узлу с моего хост-компьютера.Также не удается установить соединение.
Вот мой docker-compose.yml
version: '3'
services:
master:
image: master
build:
context: .
dockerfile: ./docker/master/Dockerfile
env_file:
- ./config.env
command: ['node', './src/master/']
ports:
- 8080:8080
networks:
- webnet
deploy:
replicas: 1
resources:
limits:
cpus: "0.2"
memory: 200M
restart_policy:
condition: none
worker:
image: worker
build:
context: .
dockerfile: ./docker/worker/Dockerfile
env_file:
- ./config.env
command: ['node', './src/worker/']
deploy:
replicas: 10
resources:
limits:
cpus: "0.1"
memory: 100M
restart_policy:
condition: none
networks:
- webnet
depends_on:
- master
networks:
webnet:
Я создаю рой с помощью:
docker swarm init
docker-compose build --no-cache
docker stack deploy -c docker-compose.yml ${stack_name}
Я пытаюсь связаться с главным узлом с помощью:
curl http://localhost:8080/result
и получить
curl: (7) Failed to connect to localhost port 8080: Connection refused
Еще несколько подробностей о
master узле:
Env:
MASTER_PORT=3000
MASTER_HOST=localhost
MASTER_HTTP_PORT=8080
Код запуска сервера websocket:
const wss = new WebSocket.Server({ host: config.masterHost, port: config.masterPort }, (err) => {
if (err != null) {
throw err
}
console.log(`Web Socket server started on address ws://${config.masterHost}:${config.masterPort}`)
});
Код запуска http сервера:
server.listen(config.masterHttpPort, config.masterHost, (err) => {
if (err != null) {
throw err
}
console.log(`Http server started on address http://${config.masterHost}:${config.masterHttpPort}`);
});
Некоторые подробности о
работник узел:
Env
MASTER_SERVICE_HOST=master
MASTER_PORT=3000
Код подключения клиента websocket к главному узлу:
const masterUri = `ws://${config.masterServiceHost}:${config.masterPort}`;
console.log(`Connecting to ${masterUri}`);
const ws = new WebSocket(masterUri, {perMessageDeflate: false});
Я действительно сбит с толку, потому что, когда я запускаю приложение с docker-compose (не в режиме роя), все работает отлично.
Но в режиме роя я тоже не смог достичь
мастер-узел с хост-машины через http
и при этом я не могу достичь
мастер-узел с рабочего узла через соединение через веб-сокет
Я подозреваю, что я настраиваю докерсеть неправильно.
Журналы от master узла:
Process started with config: {
"grouperFile": "./src/operations/group.js",
"initialDelay": 10,
"mapperFile": "./src/operations/map.js",
"masterHost": "localhost",
"masterHttpPort": 8080,
"masterPort": 3000,
"masterServiceHost": "master",
"slaveReplicationFactor": 1
}
Web Socket server started on address ws://localhost:3000
Http server started on address http://localhost:8080
Также, некоторые журналы от worker узла:
Process started with config: {
"grouperFile": "./src/operations/group.js",
"initialDelay": 10,
"mapperFile": "./src/operations/map.js",
"masterHost": "master",
"masterHttpPort": 8080,
"masterPort": 3000,
"slaveReplicationFactor": 1
}
Connecting to ws://master:3000
events.js:174
throw er; // Unhandled 'error' event
^
Error: getaddrinfo EAI_AGAIN master master:3000
at GetAddrInfoReqWrap.onlookup [as oncomplete] (dns.js:57:26)
Emitted 'error' event at:
at ClientRequest.req.on (/app/node_modules/ws/lib/websocket.js:554:10)
at ClientRequest.emit (events.js:189:13)
at Socket.socketErrorListener (_http_client.js:392:9)
at Socket.emit (events.js:189:13)
at emitErrorNT (internal/streams/destroy.js:82:8)
at emitErrorAndCloseNT (internal/streams/destroy.js:50:3)
at process._tickCallback (internal/process/next_tick.js:63:19)