feat(worker): start.sh 支持多 worker 实例(bash start.sh worker <id>,端口 9090+id,独立 pid)
This commit is contained in:
parent
2cb864940c
commit
d1374bda82
13
start.sh
13
start.sh
@ -7,12 +7,17 @@ cd "$WORKDIR"
|
||||
[ -f .smssend ] && source .smssend
|
||||
|
||||
# 运行模式:all(默认,HTTP+poller) / web(仅HTTP,无poller) / worker(仅poller,分布式worker节点)
|
||||
# 多 worker 本机/跨机测试:bash start.sh worker <id>(id=1,2,3...,端口 9090+id,pid 独立)
|
||||
MODE="${1:-all}"
|
||||
case "$MODE" in
|
||||
web) PORT=9090; PIDFILE="pipeline-web.pid"; PIPELINE_MODE=web ;;
|
||||
worker) PORT=9091; PIDFILE="pipeline-worker.pid"; PIPELINE_MODE=worker ;;
|
||||
all) PORT=9090; PIDFILE="pipeline.pid"; PIPELINE_MODE=all ;;
|
||||
*) echo "用法: $0 [web|worker|all]"; exit 1 ;;
|
||||
web) PORT=9090; PIDFILE="pipeline-web.pid"; PIPELINE_MODE=web ;;
|
||||
worker)
|
||||
WID="${2:-1}"
|
||||
PORT=$((9090 + WID))
|
||||
PIDFILE="pipeline-worker-${WID}.pid"
|
||||
PIPELINE_MODE=worker ;;
|
||||
all) PORT=9090; PIDFILE="pipeline.pid"; PIPELINE_MODE=all ;;
|
||||
*) echo "用法: $0 [web|worker <id>|all]"; exit 1 ;;
|
||||
esac
|
||||
export PIPELINE_MODE
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user