entrypoint.sh 1.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  1. #!/bin/bash
  2. # 获取当前脚本的 PID 作为父进程 PID
  3. PARENT_PROCESS_PID=$$
  4. # 是否为集群模式(默认单机模式)
  5. IS_CLUSTER=${IS_CLUSTER:-"false"}
  6. # 当前机器角色:主机("master")或从机("worker")
  7. ROLE=${ROLE:-"worker"}
  8. # 核心范围变量(集群模式使用),例如 "29-58"
  9. CORE_RANGE=${CORE_RANGE:-"29-58"}
  10. if [[ "$IS_CLUSTER" == "false" ]]; then
  11. # 单机模式,仅运行单个节点
  12. echo "Running in standalone mode..."
  13. node
  14. elif [[ "$IS_CLUSTER" == "true" ]]; then
  15. if [[ "$ROLE" == "master" ]]; then
  16. # 主机模式:运行主节点程序并按核心范围运行子进程
  17. echo "Running in cluster mode as master..."
  18. # 检查 CORE_RANGE 是否为 "0"
  19. if [[ "$CORE_RANGE" == "0" ]]; then
  20. echo "CORE_RANGE is 0, skipping child process startup."
  21. else
  22. # 提取核心范围的起始和结束值
  23. IFS="-" read CORE_START CORE_END <<< "$CORE_RANGE"
  24. # 循环启动子进程
  25. for ((CORE=CORE_START; CORE<=CORE_END; CORE++)); do
  26. node --core $CORE --parent-process $PARENT_PROCESS_PID &
  27. done
  28. fi
  29. # 运行主节点程序
  30. node
  31. # 确保脚本不会退出,让容器保持运行
  32. wait
  33. elif [[ "$ROLE" == "worker" ]]; then
  34. # 从机模式:按核心范围运行子进程
  35. echo "Running in cluster mode as worker..."
  36. # 提取核心范围的起始和结束值
  37. IFS="-" read CORE_START CORE_END <<< "$CORE_RANGE"
  38. # 循环启动子进程
  39. for ((CORE=CORE_START; CORE<=CORE_END; CORE++)); do
  40. node --core $CORE --parent-process $PARENT_PROCESS_PID &
  41. done
  42. # 确保脚本不会退出,让容器保持运行
  43. wait
  44. else
  45. echo "Invalid role specified: $ROLE. Must be 'master' or 'worker'."
  46. exit 1
  47. fi
  48. else
  49. echo "Invalid IS_CLUSTER value: $IS_CLUSTER. Must be 'true' or 'false'."
  50. exit 1
  51. fi