FEAT: 数据库切换，部署脚本更新

deploy.sh

@@ -1,12 +1,22 @@
 #!/bin/bash
 
-# 设置远程服务器信息
-REMOTE_USER="root"  # 远程服务器用户名，根据你的实际情况修改
-REMOTE_HOST="175.178.171.148" # 远程服务器地址
-REMOTE_BASE_DIR="/home/software"  # 远程服务器上的部署目录，根据你的目录结构修改
+# 各服务对应的远程服务器配置
+declare -A SERVER_CONFIG=(
+    # 服务名:IP地址
+    ["fs-admin"]="162.14.71.71"
+    ["fs-company"]="162.14.71.71"
+    ["fs-user-app"]="129.28.111.46"
+    ["fs-api"]="139.155.112.25"
+    ["fs-live-socket"]="118.24.135.139"
+    ["fs-sync"]="139.155.112.25"
+)
 
-# 本地 JAR 包路径  -- 根据你提供的目录结构修改
-LOCAL_FS_ADMIN_JAR="./fs-admin/target/fs-admin.jar" # 假设target目录和你提供的 tree 命令显示的目录同级
+# 通用配置（所有服务器相同）
+REMOTE_USER="root"
+REMOTE_BASE_DIR="/home/software"
+
+# 本地 JAR 包路径
+LOCAL_FS_ADMIN_JAR="./fs-admin/target/fs-admin.jar"
 LOCAL_FS_COMPANY_JAR="./fs-company/target/fs-company.jar"
 LOCAL_FS_USER_APP_JAR="./fs-user-app/target/fs-user-app.jar"
 LOCAL_FS_API_APP_JAR="./fs-api/target/fs-api.jar"
@@ -15,57 +25,135 @@ LOCAL_FS_SYNC_APP_JAR="./fs-sync/target/fs-sync-0.0.1-SNAPSHOT.jar"
 
 # 函数：检查本地文件是否存在
 check_local_file() {
-  if [ ! -f "$1" ]; then
-    echo "Error: Local file $1 not found."
-    exit 1
-  fi
+    if [ ! -f "$1" ]; then
+        echo "错误: 本地文件 $1 不存在。"
+        exit 1
+    fi
 }
 
-# 检查本地 JAR 文件是否存在
-check_local_file "$LOCAL_FS_ADMIN_JAR"
-check_local_file "$LOCAL_FS_COMPANY_JAR"
-check_local_file "$LOCAL_FS_USER_APP_JAR"
-check_local_file "$LOCAL_FS_LIVE_SOCKET_JAR"
-check_local_file "$LOCAL_FS_API_APP_JAR"
-# 停止远程服务器上可能正在运行的旧版本（假设进程名与 JAR 包名相同）
+# 停止远程服务器上可能正在运行的旧版本
 stop_remote_app() {
-  local app_name=$1
-  ssh "$REMOTE_USER@$REMOTE_HOST" "pkill -f $app_name || true"
+    local remote_user=$1
+    local remote_host=$2
+    local app_name=$3
+
+    echo "正在停止 $remote_host 上的 $app_name 服务..."
+    ssh "$remote_user@$remote_host" "pkill -f $app_name || echo '没有找到运行中的进程'"
+}
+
+# 检查服务器连通性
+check_server_connectivity() {
+    local remote_user=$1
+    local remote_host=$2
+
+    if ! ssh -o ConnectTimeout=5 "$remote_user@$remote_host" "echo '连接成功'" &>/dev/null; then
+        echo "错误: 无法连接到服务器 $remote_host"
+        return 1
+    fi
+    return 0
 }
 
-# 部署单个 JAR 包
+# 部署单个 JAR 包到指定服务器
 deploy_jar() {
-  local local_jar=$1
-  local remote_dir=$2
-  local app_name=$(basename "$local_jar" .jar)
+    local local_jar=$1
+    local service_name=$2  # 服务名，用于确定目标服务器
+    local remote_dir=$3     # 远程目录名
+
+    # 获取服务对应的服务器IP
+    local remote_host="${SERVER_CONFIG[$service_name]}"
+    if [ -z "$remote_host" ]; then
+        echo "错误: 未找到服务 $service_name 的服务器配置"
+        return 1
+    fi
+
+    local app_name=$(basename "$local_jar" .jar)
+
+    echo "========================================"
+    echo "开始部署 $service_name 到服务器 $remote_host"
+    echo "本地文件: $local_jar"
+    echo "远程目录: $REMOTE_BASE_DIR/$remote_dir"
+    echo "========================================"
 
-   # 创建远程目录（如果不存在）
-  ssh "$REMOTE_USER@$REMOTE_HOST" "mkdir -p $REMOTE_BASE_DIR/$remote_dir"
-  # 停止旧版本
-  stop_remote_app $app_name
+    # 检查本地文件
+    check_local_file "$local_jar"
 
-  # 上传 JAR 包
-  scp "$local_jar" "$REMOTE_USER@$REMOTE_HOST:$REMOTE_BASE_DIR/$remote_dir/"
+    # 检查服务器连通性
+    if ! check_server_connectivity "$REMOTE_USER" "$remote_host"; then
+        return 1
+    fi
 
-  # 在后台启动 JAR 包, 并将输出重定向到 /dev/null
-  ssh "$REMOTE_USER@$REMOTE_HOST" "nohup java -jar -Dfile.encoding=UTF-8 $REMOTE_BASE_DIR/$remote_dir/$app_name.jar >> $REMOTE_BASE_DIR/$remote_dir/$app_name.log 2>&1 &"
+    # 创建远程目录（如果不存在）
+    echo "创建远程目录..."
+    ssh "$REMOTE_USER@$remote_host" "mkdir -p $REMOTE_BASE_DIR/$remote_dir"
 
-  echo "Deployed $app_name to $REMOTE_HOST:$REMOTE_BASE_DIR/$remote_dir"
+    # 停止旧版本
+    stop_remote_app "$REMOTE_USER" "$remote_host" "$app_name"
+
+    # 上传 JAR 包
+    echo "上传 JAR 包..."
+    scp "$local_jar" "$REMOTE_USER@$remote_host:$REMOTE_BASE_DIR/$remote_dir/"
+
+    # 在后台启动 JAR 包
+    echo "启动服务..."
+    ssh -f "$REMOTE_USER@$remote_host" \
+    "cd $REMOTE_BASE_DIR/$remote_dir && \
+     nohup java -jar -Dfile.encoding=UTF-8 $app_name.jar \
+     > $app_name.log 2>&1 &"
+
+    # 检查进程是否启动成功
+    if ssh "$REMOTE_USER@$remote_host" "pgrep -f $app_name" &>/dev/null; then
+        echo "✓ $service_name 部署成功到 $remote_host"
+    else
+        echo "✗ $service_name 启动失败，请检查日志: $REMOTE_BASE_DIR/$remote_dir/$app_name.log"
+        return 1
+    fi
+
+    echo ""
 }
+
 # 主要部署流程
+echo "开始多服务器分布式部署..."
+echo "部署配置:"
+for service in "${!SERVER_CONFIG[@]}"; do
+    echo "  $service -> ${SERVER_CONFIG[$service]}"
+done
+echo ""
 
 # 部署 fs-admin
-deploy_jar "$LOCAL_FS_ADMIN_JAR" "fs-admin"
+deploy_jar "$LOCAL_FS_ADMIN_JAR" "fs-admin" "fs-admin"
 
 # 部署 fs-company
-#deploy_jar "$LOCAL_FS_COMPANY_JAR" "fs-company"
+deploy_jar "$LOCAL_FS_COMPANY_JAR" "fs-company" "fs-company"
 
 # 部署 fs-user-app
-#deploy_jar "$LOCAL_FS_USER_APP_JAR" "fs-user-app"
-#deploy_jar "$LOCAL_FS_API_APP_JAR" "fs-api"
+deploy_jar "$LOCAL_FS_USER_APP_JAR" "fs-user-app" "fs-user-app"
+
+# 部署 fs-api
+deploy_jar "$LOCAL_FS_API_APP_JAR" "fs-api" "fs-api"
+
+# 部署 fs-live-socket
+deploy_jar "$LOCAL_FS_LIVE_SOCKET_JAR" "fs-live-socket" "fs-live-socket"
 
-#deploy_jar "$LOCAL_FS_SYNC_APP_JAR" "fs-sync"
-#deploy_jar "$LOCAL_FS_LIVE_SOCKET_JAR" "fs-live-socket"
+# 部署 fs-sync (注意：这里使用了不同的JAR命名方式)
+deploy_jar "$LOCAL_FS_SYNC_APP_JAR" "fs-sync" "fs-sync"
 
-echo "Deployment completed."
+echo "========================================"
+echo "分布式部署完成!"
+echo "各服务部署状态:"
+for service in "${!SERVER_CONFIG[@]}"; do
+    remote_host="${SERVER_CONFIG[$service]}"
+    echo "  $service -> $remote_host"
+done
+echo "========================================"
 
+# 可选：显示各服务进程状态
+echo "服务进程状态检查:"
+for service in "${!SERVER_CONFIG[@]}"; do
+    remote_host="${SERVER_CONFIG[$service]}"
+    app_name="$service"  # 简化处理，实际可能需要根据JAR文件名调整
+    if ssh "$REMOTE_USER@$remote_host" "pgrep -f $app_name" &>/dev/null; then
+        echo "  ✓ $service 在 $remote_host 上运行正常"
+    else
+        echo "  ✗ $service 在 $remote_host 上未运行"
+    fi
+done

fs-admin/src/main/resources/application-dev.yml

@@ -5,11 +5,11 @@ spring:
     # redis 配置
     redis:
         # 地址
-        host: 127.0.0.1
+        host: 10.0.0.8
         # 端口，默认为6379
         port: 6379
         # 密码
-        password:
+        password: Ylrz_1q2w3e4r5t6y
         # 连接超时时间
         timeout: 10s
         lettuce:
@@ -22,23 +22,22 @@ spring:
                 max-active: 8
                 # #连接池最大阻塞等待时间（使用负值表示没有限制）
                 max-wait: -1ms
-        database: 0
+        database: 1
     datasource:
         type: com.alibaba.druid.pool.DruidDataSource
         driverClassName: com.mysql.cj.jdbc.Driver
         druid:
             # 主库数据源
             master:
-                url: jdbc:mysql://172.16.0.31:3306/fs_ffhx_hospital?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+                url: jdbc:mysql://10.0.0.6:3306/fs_ffhx_shop?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
                 username: root
                 password: Ylrz_1q2w3e4r5t6y
             # 从库数据源
             slave:
                 # 从数据源开关/默认关闭
-                enabled: false
-                url:
-                username:
-                password:
+                url: jdbc:mysql://10.0.0.3:3306/fs_ffhx_shop?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+                username: root
+                password: Ylrz_1q2w3e4r5t6y
             # 初始连接数
             initialSize: 5
             # 最小连接池数量

fs-api/src/main/resources/application-dev.yml

@@ -1,13 +1,15 @@
 # 数据源配置
 spring:
+    jackson:
+        time-zone: GMT+8 #如果有时区问题,设置时区
     # redis 配置
     redis:
         # 地址
-        host: 127.0.0.1
+        host: 10.0.0.8
         # 端口，默认为6379
         port: 6379
         # 密码
-        password:
+        password: Ylrz_1q2w3e4r5t6y
         # 连接超时时间
         timeout: 10s
         lettuce:
@@ -20,23 +22,22 @@ spring:
                 max-active: 8
                 # #连接池最大阻塞等待时间（使用负值表示没有限制）
                 max-wait: -1ms
-        database: 3
+        database: 1
     datasource:
         type: com.alibaba.druid.pool.DruidDataSource
         driverClassName: com.mysql.cj.jdbc.Driver
         druid:
             # 主库数据源
             master:
-                url: jdbc:mysql://172.16.0.31:3306/fs_ffhx_hospital?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+                url: jdbc:mysql://10.0.0.6:3306/fs_ffhx_shop?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
                 username: root
                 password: Ylrz_1q2w3e4r5t6y
             # 从库数据源
             slave:
                 # 从数据源开关/默认关闭
-                enabled: false
-                url:
-                username:
-                password:
+                url: jdbc:mysql://10.0.0.3:3306/fs_ffhx_shop?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+                username: root
+                password: Ylrz_1q2w3e4r5t6y
             # 初始连接数
             initialSize: 5
             # 最小连接池数量

fs-company/src/main/resources/application-dev.yml

@@ -1,17 +1,17 @@
 # 数据源配置
 spring:
+    jackson:
+        time-zone: GMT+8 #如果有时区问题,设置时区
     # redis 配置
     redis:
         # 地址
-        host: 127.0.0.1
+        host: 10.0.0.8
         # 端口，默认为6379
         port: 6379
-        # 数据库索引
-        database: 0
         # 密码
-        password:
+        password: Ylrz_1q2w3e4r5t6y
         # 连接超时时间
-        timeout: 20s
+        timeout: 10s
         lettuce:
             pool:
                 # 连接池中的最小空闲连接
@@ -22,34 +22,22 @@ spring:
                 max-active: 8
                 # #连接池最大阻塞等待时间（使用负值表示没有限制）
                 max-wait: -1ms
+        database: 1
     datasource:
-#        clickhouse:
-#            type: com.alibaba.druid.pool.DruidDataSource
-##            driverClassName: ru.yandex.clickhouse.ClickHouseDriver
-#            driverClassName: com.clickhouse.jdbc.ClickHouseDriver
-#            url: jdbc:clickhouse://139.186.211.165:8123/sop_show?compress=0&use_server_time_zone=true&use_client_time_zone=false&timezone=Asia/Shanghai
-#            username: default
-#            password: rt2024
-##            initialSize: 10
-#            maxActive: 100
-#            minIdle: 10
-#            maxWait: 6000
-        mysql:
-            type: com.alibaba.druid.pool.DruidDataSource
-            driverClassName: com.mysql.cj.jdbc.Driver
+        type: com.alibaba.druid.pool.DruidDataSource
+        driverClassName: com.mysql.cj.jdbc.Driver
         druid:
             # 主库数据源
             master:
-                url: jdbc:mysql://172.16.0.31:3306/fs_ffhx_hospital?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+                url: jdbc:mysql://10.0.0.6:3306/fs_ffhx_shop?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
                 username: root
                 password: Ylrz_1q2w3e4r5t6y
             # 从库数据源
             slave:
                 # 从数据源开关/默认关闭
-                enabled: false
-                url:
-                username:
-                password:
+                url: jdbc:mysql://10.0.0.3:3306/fs_ffhx_shop?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+                username: root
+                password: Ylrz_1q2w3e4r5t6y
             # 初始连接数
             initialSize: 5
             # 最小连接池数量

fs-live-socket/src/main/resources/application-dev.yml

@@ -1,13 +1,15 @@
 # 数据源配置
 spring:
+    jackson:
+        time-zone: GMT+8 #如果有时区问题,设置时区
     # redis 配置
     redis:
         # 地址
-        host: 127.0.0.1
+        host: 10.0.0.8
         # 端口，默认为6379
         port: 6379
         # 密码
-        password:
+        password: Ylrz_1q2w3e4r5t6y
         # 连接超时时间
         timeout: 10s
         lettuce:
@@ -20,24 +22,22 @@ spring:
                 max-active: 8
                 # #连接池最大阻塞等待时间（使用负值表示没有限制）
                 max-wait: -1ms
-        database: 0
+        database: 1
     datasource:
         type: com.alibaba.druid.pool.DruidDataSource
         driverClassName: com.mysql.cj.jdbc.Driver
         druid:
             # 主库数据源
             master:
-                url: jdbc:mysql://172.16.0.31:3306/fs_ffhx_hospital?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
-#                url: jdbc:mysql://127.0.0.1:3307/fs_ffhx_hospital?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+                url: jdbc:mysql://10.0.0.6:3306/fs_ffhx_shop?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
                 username: root
                 password: Ylrz_1q2w3e4r5t6y
             # 从库数据源
             slave:
                 # 从数据源开关/默认关闭
-                enabled: false
-                url:
-                username:
-                password:
+                url: jdbc:mysql://10.0.0.3:3306/fs_ffhx_shop?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+                username: root
+                password: Ylrz_1q2w3e4r5t6y
             # 初始连接数
             initialSize: 5
             # 最小连接池数量

fs-sync/src/main/resources/application-dev.yml

@@ -5,13 +5,13 @@ spring:
     # redis 配置
     redis:
         # 地址
-        host: 127.0.0.1
+        host: 10.0.0.8
         # 端口，默认为6379
         port: 6379
         # 密码
-        password:
+        password: Ylrz_1q2w3e4r5t6y
         # 连接超时时间
-        timeout: 30s
+        timeout: 10s
         lettuce:
             pool:
                 # 连接池中的最小空闲连接
@@ -22,4 +22,4 @@ spring:
                 max-active: 8
                 # #连接池最大阻塞等待时间（使用负值表示没有限制）
                 max-wait: -1ms
-        database: 0
+        database: 1

fs-sync/src/main/resources/application.yml

@@ -7,18 +7,18 @@ logging:
 flink:
   cdc:
     mysql:
-      hostname: 172.16.0.31
+      hostname: 10.0.0.6
       port: 3306
-      databaseList: fs_ffhx_hospital
+      databaseList: fs_ffhx_shop
       tableList:
-        - fs_ffhx_hospital.fs_user
-        - fs_ffhx_hospital.fs_store_product
-        - fs_ffhx_hospital.fs_store_product_attr_value
-        - fs_ffhx_hospital.fs_store_product_package
-        - fs_ffhx_hospital.fs_user_address
-        - fs_ffhx_hospital.fs_warehouses
-        - fs_ffhx_hospital.fs_store_product_attr
-        - fs_ffhx_hospital.fs_express
+        - fs_ffhx_shop.fs_user
+        - fs_ffhx_shop.fs_store_product
+        - fs_ffhx_shop.fs_store_product_attr_value
+        - fs_ffhx_shop.fs_store_product_package
+        - fs_ffhx_shop.fs_user_address
+        - fs_ffhx_shop.fs_warehouses
+        - fs_ffhx_shop.fs_store_product_attr
+        - fs_ffhx_shop.fs_express
       username: root
       password: Ylrz_1q2w3e4r5t6y
       serverTimeZone: Asia/Shanghai

fs-user-app/src/main/resources/application-dev.yml

@@ -1,13 +1,15 @@
 # 数据源配置
 spring:
+    jackson:
+        time-zone: GMT+8 #如果有时区问题,设置时区
     # redis 配置
     redis:
         # 地址
-        host: 127.0.0.1
+        host: 10.0.0.8
         # 端口，默认为6379
         port: 6379
         # 密码
-        password:
+        password: Ylrz_1q2w3e4r5t6y
         # 连接超时时间
         timeout: 10s
         lettuce:
@@ -20,23 +22,22 @@ spring:
                 max-active: 8
                 # #连接池最大阻塞等待时间（使用负值表示没有限制）
                 max-wait: -1ms
-        database: 0
+        database: 1
     datasource:
         type: com.alibaba.druid.pool.DruidDataSource
         driverClassName: com.mysql.cj.jdbc.Driver
         druid:
             # 主库数据源
             master:
-                url: jdbc:mysql://172.16.0.31:3306/fs_ffhx_hospital?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+                url: jdbc:mysql://10.0.0.6:3306/fs_ffhx_shop?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
                 username: root
                 password: Ylrz_1q2w3e4r5t6y
             # 从库数据源
             slave:
                 # 从数据源开关/默认关闭
-                enabled: false
-                url:
-                username:
-                password:
+                url: jdbc:mysql://10.0.0.3:3306/fs_ffhx_shop?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+                username: root
+                password: Ylrz_1q2w3e4r5t6y
             # 初始连接数
             initialSize: 5
             # 最小连接池数量