【公共环境】WebChat 中间件集合服务Docker部署方案

# 基础服务
$mkdir -p mysql/data
$mkdir -p redis7.4-alpine/data redis7.4-alpine/conf
$mkdir -p nacos2.5.1/logs nacos2.5.1/data
$mkdir -p sentinel/sentinel-1.8.9
$mkdir -p rocketmq5.3.2/conf
$mkdir -p minio/latest/data
$mkdir -p mongodb/latest/data
$mkdir -p n8n/data

# Elasticsearch
$mkdir -p elasticsearch8.14.3/config elasticsearch8.14.3/data elasticsearch8.14.3/logs elasticsearch8.14.3/plugins

# Milvus + Etcd
$mkdir -p milvus/data milvus/etcd

# XXL-Job
$mkdir -p xxl-job/logs

$cd /path/to/project
$docker compose up -d

# 第一批：基础服务
$docker compose up -d mysql redis rmqnamesrv mongodb minio elasticsearch

# 第二批：等基础服务健康后
$docker compose up -d nacos rmqbroker etcd

# 第三批：等 Nacos / Broker / Etcd 就绪后
$docker compose up -d sentinel rocketmq-dashboard milvus xxl-job-admin n8n

$docker compose ps                    # 查看所有服务状态
$docker compose logs -f <服务名>       # 实时查看日志
$docker compose restart <服务名>       # 重启单个服务
$docker compose down                  # 停止并移除所有容器
$docker compose down -v               # 停止并移除容器+网络

# 命令行连接
$mysql -h 43.138.184.148 -P 33306 -u root -pqg-yyds-chat4j

# 客户端工具
$Host: 43.138.184.148
$Port: 33306
$Username: root
$Password: qg-yyds-chat4j

# application.yml 配置示例
spring:
  datasource:
    url: jdbc:mysql://43.138.184.148:33306/your_database?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
    username: root
    password: qg-yyds-chat4j
    driver-class-name: com.mysql.cj.jdbc.Driver

# 命令行连接（认证已关闭，无需密码）
$redis-cli -h 43.138.184.148 -p 36379

# application.yml 配置示例
spring:
  data:
    redis:
      host: 43.138.184.148
      port: 36379
      # 认证已关闭，无需配置 password
      database: 0
      timeout: 3000ms
      lettuce:
        pool:
          max-active: 8
          max-idle: 8
          min-idle: 0

# application.yml 配置示例
spring:
  cloud:
    nacos:
      discovery:
        server-addr: 43.138.184.148:38848
        namespace: 2cdfb8e3-f127-4020-93df-2d4c3dc805b5
        # username: nacos
        # password: nacos
      config:
        server-addr: 43.138.184.148:38848
        namespace: 2cdfb8e3-f127-4020-93df-2d4c3dc805b5
        # username: nacos
        # password: nacos
        file-extension: yml
        shared-configs:
          - data-id: common.yml
            refresh: true

# application.yml 配置示例
spring:
  cloud:
    sentinel:
      transport:
        dashboard: 43.138.184.148:38081
        port: 8719
      # Nacos 规则持久化
      datasource:
        flow:
          nacos:
            server-addr: 43.138.184.148:38848
            namespace: 2cdfb8e3-f127-4020-93df-2d4c3dc805b5
            data-id: ${spring.application.name}-flow-rules
            rule-type: flow
        degrade:
          nacos:
            server-addr: 43.138.184.148:38848
            namespace: 2cdfb8e3-f127-4020-93df-2d4c3dc805b5
            data-id: ${spring.application.name}-degrade-rules
            rule-type: degrade

# application.yml 配置示例
rocketmq:
  name-server: 43.138.184.148:39876
  # 认证已关闭，无需配置 access-key / secret-key
  producer:
    group: webchat-producer-group
    send-message-timeout: 3000
    retry-times-when-send-failed: 2
  consumer:
    group: webchat-consumer-group

# application.yml 配置示例
minio:
  endpoint: http://43.138.184.148:39000
  access-key: chat4j
  secret-key: qg-yyds-chat4j
  bucket-name: webchat
  secure: false

# 命令行连接
$mongosh "mongodb://admin:qg-yyds-chat4j@43.138.184.148:27017"

# 连接字符串
$mongodb://admin:qg-yyds-chat4j@43.138.184.148:27017/webchat?authSource=admin

# application.yml 配置示例
spring:
  data:
    mongodb:
      uri: mongodb://admin:qg-yyds-chat4j@43.138.184.148:27017/webchat?authSource=admin
      auto-index-creation: true

# 健康检查（安全认证已关闭，无需密码）
$curl http://43.138.184.148:39200/_cluster/health?pretty

# application.yml 配置示例
spring:
  elasticsearch:
    uris: http://43.138.184.148:39200
    # 安全认证已关闭，无需配置 username / password
    connection-timeout: 5s
    socket-timeout: 30s

# Python SDK 连接示例
from pymilvus import connections
connections.connect(
    alias="default",
    host="43.138.184.148",
    port="19530"
)

# application.yml 配置示例（Spring Boot + Milvus Java SDK）
milvus:
  host: 43.138.184.148
  port: 19530
  # 认证已关闭，无需配置 token

$mysql -h 43.138.184.148 -P 33306 -u root -pqg-yyds-chat4j < ./sql/xxl-job/tables_xxl_job.sql

# application.yml 配置示例
xxl:
  job:
    admin:
      addresses: http://43.138.184.148:39092/xxl-job-admin
    accessToken: qg-yyds-chat4j
    executor:
      appname: webchat-executor
      address:
      ip:
      port: 9999
      logpath: /data/applogs/xxl-job/jobhandler
      logretentiondays: 30

prod_new/
├── docker-compose.yml                          # 主编排文件
├── WebChat中间件集合服务部署方案.md              # 本文档
│
├── mysql/
│   └── data/                                   # MySQL 数据目录
│
├── redis7.4-alpine/
│   ├── data/                                   # Redis 数据目录
│   └── conf/
│       └── redis.conf                          # Redis 配置（认证已关闭、AOF 持久化）
│
├── nacos2.5.1/
│   ├── logs/                                   # Nacos 日志
│   └── data/                                   # Nacos 数据
│
├── sentinel/
│   └── sentinel-1.8.9/
│       └── sentinel-dashboard-1.8.9.jar        # Sentinel JAR（需手动放置）
│
├── rocketmq5.3.2/
│   └── conf/
│       └── broker.conf                         # Broker 配置（认证已关闭）
│
├── minio/
│   └── latest/
│       └── data/                               # MinIO 数据目录
│
├── mongodb/
│   └── latest/
│       └── data/                               # MongoDB 数据目录
│
├── elasticsearch8.14.3/
│   ├── config/
│   │   └── elasticsearch.yml                   # ES 配置（安全认证已关闭）
│   ├── data/                                   # ES 数据
│   ├── logs/                                   # ES 日志
│   └── plugins/                                # ES 插件
│
├── n8n/
│   └── data/                                   # n8n 数据
│
├── milvus/
│   ├── data/                                   # Milvus 向量数据
│   └── etcd/                                   # Etcd 元数据
│
├── xxl-job/
│   └── logs/                                   # XXL-Job 日志
│
└── sql/
    ├── nacos2.5.1/
    │   └── mysql-schema.sql                    # Nacos 建表脚本
    └── xxl-job/
        └── tables_xxl_job.sql                  # XXL-Job 建表脚本

# 1. 检查所有容器运行状态
$docker compose ps

# 2. MySQL 连通性
$docker compose exec mysql mysqladmin ping -h localhost -u root -pqg-yyds-chat4j

# 3. Redis 连通性（认证已关闭）
$docker compose exec redis redis-cli ping

# 4. MongoDB 连通性
$docker compose exec mongodb mongosh --eval "db.adminCommand('ping')" -u admin -p 'qg-yyds-chat4j'

# 5. MinIO 健康检查
$curl -f http://43.138.184.148:39000/minio/health/live

# 6. Nacos 控制台
$curl http://43.138.184.148:38848/nacos/

# 7. Sentinel 控制台
$curl http://43.138.184.148:38081/

# 8. Elasticsearch 健康检查
$curl http://43.138.184.148:39200/_cluster/health?pretty

# 9. Milvus 健康检查
$curl http://43.138.184.148:39091/healthz

from pymilvus import MilvusClient
import time


def connect_to_milvus():
    max_retries = 10
    retry_delay = 5

    for attempt in range(max_retries):
        try:
            # 新版官方推荐写法
            client = MilvusClient(
                uri="http://43.138.184.148:19530",  # 直接拼接 host:port
                timeout=30
            )

            # 检查版本
            version = client.get_server_version()
            print(f"Milvus 连接成功！版本: {version}")
            return client

        except Exception as e:
            print(f"连接尝试 {attempt + 1} 失败: {e}")

            if "not ready" in str(e).lower():
                print(f"Milvus 启动中，{retry_delay}秒后重试...")
                time.sleep(retry_delay)
            else:
                break

    print("无法连接到 Milvus，请检查服务")
    return None


# 执行连接
client = connect_to_milvus()
if client:
    try:
        # 新版获取集合列表
        cols = client.list_collections()
        print(f"现有集合: {cols}")
        print("\nMilvus 正常可用！")
    except Exception as e:
        print(f"操作失败: {e}")