总结
我尝试在 Digital Ocean 上构建应用程序。我选择了它的服务/产品“App”。我的应用程序由 3 个组件组成:
- 服务:Flask应用+ZMQ客户端(REQ socket)
- Worker:ZMQ 服务器(REP 套接字)
- Worker:ZMQ 客户端(REQ 套接字)
使用的语言是 Python。术语“服务”和“工人”在 Digital Ocean App Spec 的上下文中。
预期行为
我尝试将请求从客户端组件发送到服务器组件(在收到响应之后)。
我期望这种情况:
- 服务器已启动并等待请求
- 客户端已启动并发送请求
- 服务器接收请求
- 服务器发送响应
- 客户端接收响应
真实行为
它在第 3 步中断。这意味着服务器永远不会收到请求。客户端和服务器都启动了,没有任何异常(通过日志确认)
我试过的
以不同的顺序启动/重启组件
不同的端口号
重命名组件(删除有问题的字符)
将 ZMQ REQ 套接字连接到 localhost
按名称将 ZMQ REQ 套接字连接到 REP 组件(代码示例)
在 App Spec yaml 文件中定义内部端口。只有服务才有可能。
工人 ZMQ 客户
import time
import zmq
import logging
logging.basicConfig(level=logging.DEBUG)
try:
zmq_context = zmq.Context()
socket = zmq_context.socket(zmq.REQ)
socket.connect("tcp://ZMQServer:55555")
for i in range(5):
logging.debug(f"[CLIENT] Sending request {i}")
socket.send_string("test")
time.sleep(1)
logging.debug(f"[CLIENT] Waiting for a response {i}")
message = socket.recv_string()
logging.debug("[CLIENT] Response received")
except Exception as e:
logging.error(e)
工作 ZMQ 服务器
import time
import zmq
import logging
logging.basicConfig(level=logging.DEBUG)
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://*:55555")
logging.debug("[SERVER] Starting ZMQ SERVER")
while True:
logging.debug("[SERVER] Waiting for request")
message = socket.recv_string()
time.sleep(1)
logging.debug("[SERVER] Sending response")
socket.send_string("Perfect! It is working.")
应用规范
name: basic-app
region: fra
services:
- environment_slug: python
github:
branch: main
deploy_on_push: true
repo: ...
http_port: 8080
instance_count: 1
instance_size_slug: basic-xs
name: c-3
routes:
- path: /
run_command: gunicorn --worker-tmp-dir /dev/shm --config gunicorn_config.py app:app
source_dir: /
internal_ports:
- 55555
workers:
- environment_slug: python
github:
branch: main
deploy_on_push: true
repo: ...
instance_count: 1
instance_size_slug: basic-xs
name: ZMQServer
run_command: python zmq_server.py
source_dir: /
- environment_slug: python
github:
branch: main
deploy_on_push: true
repo: ...
instance_count: 1
instance_size_slug: basic-xs
name: ZMQClient
run_command: python client.py
source_dir: /
谢谢你的答案