Flask Docker 容器 SocketIO 问题
Flask Docker container SocketIO Issues
我有一个使用 SocketIO 从 Postgres 实时获取数据的 Flask 应用程序。
当我在本地 运行 时，应用程序工作正常。
当我使用 docker-compose 托管我的 Flask 应用程序时出现问题。我的 JS 客户端和 Flask 服务器托管在同一个容器中的单个应用程序中。
我在JS中的socketio是这样的：
var socket = io().connect(window.location.protocol + '//' + document.domain + ':' + location.port);
Docker 文件：
# Using python 3.7 in Alpine
FROM python:3.6.5-stretch
# Set the working directory to /app
WORKDIR /app
# Copy the current directory contents into the container at /app
ADD . /app
RUN apt-get update -y && apt-get upgrade -y
# Install the dependencies from requirements
RUN pip install -r requirements.txt
# Tell the port number the container should expose
EXPOSE 8083
# Run the command
ENTRYPOINT ["./entry.sh"]
entry.sh:
#!/bin/sh
gunicorn -k geventwebsocket.gunicorn.workers.GeventWebSocketWorker -b :8083 -w 5 run:app
我的 docker-compose 是这样的：
version: "3.8"
services:
fortweet:
container_name: fortweet
build: ./
env_file:
- secret.env
networks:
- plutusnet
ports:
- 8083:8083
restart: always
networks:
plutusnet:
name: plutus_network
driver: bridge
我也试过 var socket = io.connect('http://public_ip_of_website:8083') 但我的套接字连接仍然不起作用。
当我 运行 在本地单击某个按钮时，它应该如何正常工作，它在我的 JS 中执行此功能：
$("#tweets-live-start").click(function(){
if (is_streaming == true){
alert("A stream is already running")
}else{
$.ajax({
type: "POST",
url : "/admin/startstream",
data: {url : "print \"hello\""},
contentType: 'application/json;charset=UTF-8'
});
}
});
当我的服务器收到问候语时，它会启动推文流并通过套接字发送它们。然后我的套接字这样捕获它们：
// Listens for tweets
socket.on('stream-results', function(results){
// Insert tweets in divs
$('#live-tweet-container').prepend(`
<div class="row justify-content-md-center mt-3">
<div class="col-md-2">
<img width="56px" height="56px" src="${results.profile_pic !== "" ? results.profile_pic : "/static/icons/profile-pic.png"}" class="mx-auto d-block rounded" alt="">
</div>
<div class="col-md-8 my-auto">
<div><b>${results.author}</b></div>
<div>${results.message}</div>
</div>
</div>
`);
});
但是当我 运行 它在 docker 上时，没有任何反应。
当我检查我的浏览器 JS 控制台时，它似乎正在用一个错误的请求进行轮询，我不知道为什么：
index.js:83 GET http://th3pl4gu3.com:8083/socket.io/?EIO=3&transport=polling&t=NPYYrxr 400 (BAD REQUEST)
这是我的 docker ps 了解更多信息：
46446efeb472 mervin16/fortweet:dev "/bin/bash entry.sh" About a minute ago Up About a minute 0.0.0.0:8083->8083/tcp fortweet
12b2bff36af0 postgres "docker-entrypoint.s…" 2 hours ago Up 2 hours 0.0.0.0:5432->5432/tcp plutus
我不认为这是一个可访问性问题，因为我尝试了从每个容器到每个容器的几个 telnet 测试。
我检查了 docker 容器的日志，它给出了这个：
fortweet | [2020-12-26 15:18:55 +0000] [8] [INFO] Starting gunicorn 20.0.4
fortweet | [2020-12-26 15:18:55 +0000] [8] [INFO] Listening at: http://0.0.0.0:8083 (8)
fortweet | [2020-12-26 15:18:55 +0000] [8] [INFO] Using worker: geventwebsocket.gunicorn.workers.GeventWebSocketWorker
fortweet | [2020-12-26 15:18:55 +0000] [11] [INFO] Booting worker with pid: 11
fortweet | [2020-12-26 15:18:55 +0000] [12] [INFO] Booting worker with pid: 12
fortweet | [2020-12-26 15:18:55 +0000] [13] [INFO] Booting worker with pid: 13
fortweet | [2020-12-26 15:18:55 +0000] [14] [INFO] Booting worker with pid: 14
fortweet | [2020-12-26 15:18:55 +0000] [15] [INFO] Booting worker with pid: 15
fortweet | The client is using an unsupported version of the Socket.IO or Engine.IO protocols (further occurrences of this error will be logged with level INFO)
fortweet | The client is using an unsupported version of the Socket.IO or Engine.IO protocols (further occurrences of this error will be logged with level INFO)
fortweet | 172.16.0.1 - - [2020-12-26 15:19:57] "POST /admin/startstream HTTP/1.1" 204 170 0.023672
fortweet | The client is using an unsupported version of the Socket.IO or Engine.IO protocols (further occurrences of this error will be logged with level INFO)
fortweet | The client is using an unsupported version of the Socket.IO or Engine.IO protocols (further occurrences of this error will be logged with level INFO)
fortweet | 172.16.0.1 - - [2020-12-26 15:20:20] "GET /socket.io/?EIO=3&transport=polling&t=1608996021267-7 HTTP/1.1" 400 195 0.001418
fortweet | 172.16.0.1 - - [2020-12-26 15:20:20] "GET /socket.io/?EIO=3&transport=polling&t=1608996021267-7 HTTP/1.1" 400 195 0.001418
fortweet | 172.16.0.1 - - [2020-12-26 15:20:21] "GET /socket.io/?EIO=3&transport=polling&t=1608996021395-8 HTTP/1.1" 400 195 0.001625
fortweet | 172.16.0.1 - - [2020-12-26 15:20:21] "GET /socket.io/?EIO=3&transport=polling&t=1608996021395-8 HTTP/1.1" 400 195 0.001625
fortweet | 172.16.0.1 - - [2020-12-26 15:20:26] "GET /socket.io/?EIO=3&transport=polling&t=1608996026417-9 HTTP/1.1" 400 195 0.001367
fortweet | 172.16.0.1 - - [2020-12-26 15:20:26] "GET /socket.io/?EIO=3&transport=polling&t=1608996026417-9 HTTP/1.1" 400 195 0.001367
fortweet | 172.16.0.1 - - [2020-12-26 15:20:26] "GET /socket.io/?EIO=3&transport=polling&t=1608996027270-8 HTTP/1.1" 400 195 0.003811
fortweet | 172.16.0.1 - - [2020-12-26 15:20:26] "GET /socket.io/?EIO=3&transport=polling&t=1608996027270-8 HTTP/1.1" 400 195 0.003811
fortweet | 172.16.0.1 - - [2020-12-26 15:20:34] "POST /admin/startstream HTTP/1.1" 204 170 0.015831
fortweet | 172.16.0.1 - - [2020-12-26 15:20:36] "GET /socket.io/?EIO=3&transport=polling&t=1608996036486-11 HTTP/1.1" 400 195 0.001096
仅供参考，plutus 容器只是我的网络应用程序连接到的 Postgres 数据库。
谁能帮帮我？
400 (BAD REQUEST)表示Your Browser+JS和Flask app之间有通信。
我怀疑 Flask 应用程序和 Postgres 之间存在问题。
您的 Postgres 必须与您的应用程序服务器（您在 docker-compose 中称为“fortweet”的服务）在同一个网络中。另外，您已经给它一个主机名，以便应用程序服务器可以解析它在内部。
version: "3.8"
services:
postgres: # <=== same name here
image: postgres/postgres:11
networks:
- plutusnet # <== same network
fortweet:
container_name: fortweet
build: ./
env_file:
- secret.env
networks:
- plutusnet # <=== same network
links:
- db:postgres # <== than here
ports:
- 8083:8083
restart: always
networks:
plutusnet:
name: plutus_network
driver: bridge`
然后必须将应用配置为使用“postgres:5432”连接到数据库。
试一试告诉我们。
TL;DR - 您在客户端和服务器之间使用不兼容的 socketIO 版本。检查下面的 table 并确保您使用的是适当的 python 和 javascript 版本。
如容器日志所述，您在客户端和服务器之间使用了不兼容版本的 SocketIO。 SocketIO 和 EngineIO 协议已经过多次修订，它们 not all backward compatible，因此您必须确保在可以相互通信的客户端和服务器端使用适当的协议实现。
我怀疑当你 运行 你的应用程序在本地而不是在你的 Docker 容器中时它工作的原因是因为你的容器 requirements.txt 中的依赖项引用了旧的，不兼容的版本python 实施。根据您的描述，本地安装的 python socketIO 实现似乎是较新的版本，因此与客户端较新的 JS 版本兼容，并且连接没有问题（或者它可能是副-反之亦然....较旧的客户端，较新的服务器）。
如果您使用本机 javascript Socket.IO version 3.0+ on the client side (which implements the SocketIO Protocol v5 and EngineIO Protocol v4)，那么您需要确保在服务器端使用适当版本的 Python 实现。您没有指定，但我假设您使用的是 Flask-SocketIO，它本身是 python-socketio 的包装器，是 SocketIO 协议的实际 Python 实现。
检查您在 Javascript 中使用的 SocketIO 客户端版本。然后检查您的 requirements.txt 并确保 python-socketio 版本兼容，如下 table (source):
JS SocketIO Version
SocketIO Protocol
EngineIO Protocol
python-socketio
0.9.x
1, 2
1, 2
Not supported
1.x and 2.x
3, 4
3
4.x
3.x
5
4
5.x
您很可能在 python 端使用 JS 版本 3.x 和 4.x 版本（不兼容）。确保您使用的是 Flask-SocketIO v5.x、python-socketio v5.x 和 python-engineio v4.x，并且您的 JS 客户端是 3.x.那应该可以解决您的问题。
如果这在您的本地环境中工作正常，那么您可以 运行
pip freeze > requirements.txt 并将其用于您的 docker 构建。此 requirements.txt 文件将具有正确的依赖关系，因为当您在本地 运行 时它显然可以正常工作。
或者，如果您想确保拥有最新版本的所有内容，您可以 运行 pip install --upgrade flask-socketio。这将安装最新版本的 Flask-SocketIO 和最新的依赖项（包括 python-socketio 和 python-engineio）。然后重新生成您的 requirements.txt 文件并在您的 docker 构建中使用它。
我有一个使用 SocketIO 从 Postgres 实时获取数据的 Flask 应用程序。
当我在本地 运行 时，应用程序工作正常。
当我使用 docker-compose 托管我的 Flask 应用程序时出现问题。我的 JS 客户端和 Flask 服务器托管在同一个容器中的单个应用程序中。
我在JS中的socketio是这样的：
var socket = io().connect(window.location.protocol + '//' + document.domain + ':' + location.port);
Docker 文件：
# Using python 3.7 in Alpine
FROM python:3.6.5-stretch
# Set the working directory to /app
WORKDIR /app
# Copy the current directory contents into the container at /app
ADD . /app
RUN apt-get update -y && apt-get upgrade -y
# Install the dependencies from requirements
RUN pip install -r requirements.txt
# Tell the port number the container should expose
EXPOSE 8083
# Run the command
ENTRYPOINT ["./entry.sh"]
entry.sh:
#!/bin/sh
gunicorn -k geventwebsocket.gunicorn.workers.GeventWebSocketWorker -b :8083 -w 5 run:app
我的 docker-compose 是这样的：
version: "3.8"
services:
fortweet:
container_name: fortweet
build: ./
env_file:
- secret.env
networks:
- plutusnet
ports:
- 8083:8083
restart: always
networks:
plutusnet:
name: plutus_network
driver: bridge
我也试过 var socket = io.connect('http://public_ip_of_website:8083') 但我的套接字连接仍然不起作用。
当我 运行 在本地单击某个按钮时，它应该如何正常工作，它在我的 JS 中执行此功能：
$("#tweets-live-start").click(function(){
if (is_streaming == true){
alert("A stream is already running")
}else{
$.ajax({
type: "POST",
url : "/admin/startstream",
data: {url : "print \"hello\""},
contentType: 'application/json;charset=UTF-8'
});
}
});
当我的服务器收到问候语时，它会启动推文流并通过套接字发送它们。然后我的套接字这样捕获它们：
// Listens for tweets
socket.on('stream-results', function(results){
// Insert tweets in divs
$('#live-tweet-container').prepend(`
<div class="row justify-content-md-center mt-3">
<div class="col-md-2">
<img width="56px" height="56px" src="${results.profile_pic !== "" ? results.profile_pic : "/static/icons/profile-pic.png"}" class="mx-auto d-block rounded" alt="">
</div>
<div class="col-md-8 my-auto">
<div><b>${results.author}</b></div>
<div>${results.message}</div>
</div>
</div>
`);
});
但是当我 运行 它在 docker 上时，没有任何反应。
当我检查我的浏览器 JS 控制台时，它似乎正在用一个错误的请求进行轮询，我不知道为什么：
index.js:83 GET http://th3pl4gu3.com:8083/socket.io/?EIO=3&transport=polling&t=NPYYrxr 400 (BAD REQUEST)
这是我的 docker ps 了解更多信息：
46446efeb472 mervin16/fortweet:dev "/bin/bash entry.sh" About a minute ago Up About a minute 0.0.0.0:8083->8083/tcp fortweet
12b2bff36af0 postgres "docker-entrypoint.s…" 2 hours ago Up 2 hours 0.0.0.0:5432->5432/tcp plutus
我不认为这是一个可访问性问题，因为我尝试了从每个容器到每个容器的几个 telnet 测试。
我检查了 docker 容器的日志，它给出了这个：
fortweet | [2020-12-26 15:18:55 +0000] [8] [INFO] Starting gunicorn 20.0.4
fortweet | [2020-12-26 15:18:55 +0000] [8] [INFO] Listening at: http://0.0.0.0:8083 (8)
fortweet | [2020-12-26 15:18:55 +0000] [8] [INFO] Using worker: geventwebsocket.gunicorn.workers.GeventWebSocketWorker
fortweet | [2020-12-26 15:18:55 +0000] [11] [INFO] Booting worker with pid: 11
fortweet | [2020-12-26 15:18:55 +0000] [12] [INFO] Booting worker with pid: 12
fortweet | [2020-12-26 15:18:55 +0000] [13] [INFO] Booting worker with pid: 13
fortweet | [2020-12-26 15:18:55 +0000] [14] [INFO] Booting worker with pid: 14
fortweet | [2020-12-26 15:18:55 +0000] [15] [INFO] Booting worker with pid: 15
fortweet | The client is using an unsupported version of the Socket.IO or Engine.IO protocols (further occurrences of this error will be logged with level INFO)
fortweet | The client is using an unsupported version of the Socket.IO or Engine.IO protocols (further occurrences of this error will be logged with level INFO)
fortweet | 172.16.0.1 - - [2020-12-26 15:19:57] "POST /admin/startstream HTTP/1.1" 204 170 0.023672
fortweet | The client is using an unsupported version of the Socket.IO or Engine.IO protocols (further occurrences of this error will be logged with level INFO)
fortweet | The client is using an unsupported version of the Socket.IO or Engine.IO protocols (further occurrences of this error will be logged with level INFO)
fortweet | 172.16.0.1 - - [2020-12-26 15:20:20] "GET /socket.io/?EIO=3&transport=polling&t=1608996021267-7 HTTP/1.1" 400 195 0.001418
fortweet | 172.16.0.1 - - [2020-12-26 15:20:20] "GET /socket.io/?EIO=3&transport=polling&t=1608996021267-7 HTTP/1.1" 400 195 0.001418
fortweet | 172.16.0.1 - - [2020-12-26 15:20:21] "GET /socket.io/?EIO=3&transport=polling&t=1608996021395-8 HTTP/1.1" 400 195 0.001625
fortweet | 172.16.0.1 - - [2020-12-26 15:20:21] "GET /socket.io/?EIO=3&transport=polling&t=1608996021395-8 HTTP/1.1" 400 195 0.001625
fortweet | 172.16.0.1 - - [2020-12-26 15:20:26] "GET /socket.io/?EIO=3&transport=polling&t=1608996026417-9 HTTP/1.1" 400 195 0.001367
fortweet | 172.16.0.1 - - [2020-12-26 15:20:26] "GET /socket.io/?EIO=3&transport=polling&t=1608996026417-9 HTTP/1.1" 400 195 0.001367
fortweet | 172.16.0.1 - - [2020-12-26 15:20:26] "GET /socket.io/?EIO=3&transport=polling&t=1608996027270-8 HTTP/1.1" 400 195 0.003811
fortweet | 172.16.0.1 - - [2020-12-26 15:20:26] "GET /socket.io/?EIO=3&transport=polling&t=1608996027270-8 HTTP/1.1" 400 195 0.003811
fortweet | 172.16.0.1 - - [2020-12-26 15:20:34] "POST /admin/startstream HTTP/1.1" 204 170 0.015831
fortweet | 172.16.0.1 - - [2020-12-26 15:20:36] "GET /socket.io/?EIO=3&transport=polling&t=1608996036486-11 HTTP/1.1" 400 195 0.001096
仅供参考，plutus 容器只是我的网络应用程序连接到的 Postgres 数据库。
谁能帮帮我？
400 (BAD REQUEST)表示Your Browser+JS和Flask app之间有通信。
我怀疑 Flask 应用程序和 Postgres 之间存在问题。
您的 Postgres 必须与您的应用程序服务器（您在 docker-compose 中称为“fortweet”的服务）在同一个网络中。另外，您已经给它一个主机名，以便应用程序服务器可以解析它在内部。
version: "3.8"
services:
postgres: # <=== same name here
image: postgres/postgres:11
networks:
- plutusnet # <== same network
fortweet:
container_name: fortweet
build: ./
env_file:
- secret.env
networks:
- plutusnet # <=== same network
links:
- db:postgres # <== than here
ports:
- 8083:8083
restart: always
networks:
plutusnet:
name: plutus_network
driver: bridge`
然后必须将应用配置为使用“postgres:5432”连接到数据库。
试一试告诉我们。
TL;DR - 您在客户端和服务器之间使用不兼容的 socketIO 版本。检查下面的 table 并确保您使用的是适当的 python 和 javascript 版本。
如容器日志所述，您在客户端和服务器之间使用了不兼容版本的 SocketIO。 SocketIO 和 EngineIO 协议已经过多次修订，它们 not all backward compatible，因此您必须确保在可以相互通信的客户端和服务器端使用适当的协议实现。
我怀疑当你 运行 你的应用程序在本地而不是在你的 Docker 容器中时它工作的原因是因为你的容器 requirements.txt 中的依赖项引用了旧的，不兼容的版本python 实施。根据您的描述，本地安装的 python socketIO 实现似乎是较新的版本，因此与客户端较新的 JS 版本兼容，并且连接没有问题（或者它可能是副-反之亦然....较旧的客户端，较新的服务器）。
如果您使用本机 javascript Socket.IO version 3.0+ on the client side (which implements the SocketIO Protocol v5 and EngineIO Protocol v4)，那么您需要确保在服务器端使用适当版本的 Python 实现。您没有指定，但我假设您使用的是 Flask-SocketIO，它本身是 python-socketio 的包装器，是 SocketIO 协议的实际 Python 实现。
检查您在 Javascript 中使用的 SocketIO 客户端版本。然后检查您的 requirements.txt 并确保 python-socketio 版本兼容，如下 table (source):
| JS SocketIO Version | SocketIO Protocol | EngineIO Protocol | python-socketio |
|---|---|---|---|
| 0.9.x | 1, 2 | 1, 2 | Not supported |
| 1.x and 2.x | 3, 4 | 3 | 4.x |
| 3.x | 5 | 4 | 5.x |
您很可能在 python 端使用 JS 版本 3.x 和 4.x 版本（不兼容）。确保您使用的是 Flask-SocketIO v5.x、python-socketio v5.x 和 python-engineio v4.x，并且您的 JS 客户端是 3.x.那应该可以解决您的问题。
如果这在您的本地环境中工作正常，那么您可以 运行
pip freeze > requirements.txt 并将其用于您的 docker 构建。此 requirements.txt 文件将具有正确的依赖关系，因为当您在本地 运行 时它显然可以正常工作。
或者，如果您想确保拥有最新版本的所有内容，您可以 运行 pip install --upgrade flask-socketio。这将安装最新版本的 Flask-SocketIO 和最新的依赖项（包括 python-socketio 和 python-engineio）。然后重新生成您的 requirements.txt 文件并在您的 docker 构建中使用它。