870027381/go-im-logic repository overview

⁠GO-IM Logic

GO-IM⁠ 的业务层：消费 Kafka 中的消息并批量写入 MySQL，同时通过 gRPC 为 Gateway 提供历史消息、用户查询等接口。

• 源码：https://github.com/chaishuanzhu/GO-IM⁠
• 客户端下载 / 项目介绍：https://go-im.dl.chaisz.com/⁠
• 配套镜像：870027381/go-im-gateway⁠（连接层）

Logic 只在全量部署中使用，不对外提供服务；最小化部署不需要它。

⁠标签

均为多架构镜像：linux/amd64、linux/arm64。

⁠单独运行

和 Gateway 共用同一份配置文件，读取其中的 logic 段（listen_addr、mysql、kafka、worker_id）。

docker run -d --name logic \
  -p 50051:50051 \
  -v $(pwd)/config.json:/etc/im/config.json:ro \
  870027381/go-im-logic:latest

⁠部署指南

三种方式都使用 Docker Hub 上的预构建镜像（870027381/go-im-gateway、870027381/go-im-logic，linux/amd64 + linux/arm64），无需拉源码编译。

最小化部署由 Gateway 直接写 MySQL，聊天、群聊、历史、搜索、文件全部可用；全量部署把写库交给 Logic 消费 Kafka，Gateway 热路径更轻。两者用户可见功能一致，数据库表结构相同。

消息持久化默认按 200 条或 10ms 聚合后批量写入，队列容量 8192、批量 writer 2 个、失败重试 3 次。可通过 gateway.persist_* 参数调优；MySQL 连接池通过 gateway.mysql.max_* / conn_max_* 配置。设计与容量估算见 单机持久化批量写入优化方案⁠。

服务端只提供 API 和长连接，没有网页端。部署完成后在桌面端 / 移动端客户端⁠中把服务器地址填为网关地址，用邮箱注册账号（需先配置 SMTP⁠）。

⁠Docker 最小化部署

需要 Docker 20.10+ 和 Docker Compose v2。

mkdir go-im && cd go-im
base=https://raw.githubusercontent.com/chaishuanzhu/GO-IM/main/deploy/docker
curl -fsSLO $base/docker-compose.minimal.yml
curl -fsSLO $base/config.minimal.json

# 必改：JWT 签名密钥
sed -i.bak "s|CHANGE_ME_run_openssl_rand_base64_48|$(openssl rand -base64 48 | tr -d '\n/+=')|" config.minimal.json

docker compose -f docker-compose.minimal.yml up -d
docker compose -f docker-compose.minimal.yml ps

curl http://<服务器IP>:8080/health 返回 "status":"ok" 即就绪，客户端服务器地址填 http://<服务器IP>:8080。

⁠Docker 全量部署

mkdir go-im && cd go-im
base=https://raw.githubusercontent.com/chaishuanzhu/GO-IM/main/deploy/docker
curl -fsSLO $base/docker-compose.yml
curl -fsSLO $base/config.json

sed -i.bak "s|CHANGE_ME_run_openssl_rand_base64_48|$(openssl rand -base64 48 | tr -d '\n/+=')|" config.json

docker compose up -d
docker compose ps

curl http://<服务器IP>:8080/health 返回 "status":"ok" 即就绪，客户端服务器地址填 http://<服务器IP>:8080。Kafka 首次启动约需 30 秒，Logic、Gateway 会等它健康后再启动。

⁠Docker 部署的常用操作

以下命令以全量为例，最小化部署加上 -f docker-compose.minimal.yml。

docker compose logs -f gateway                  # 查看日志
docker compose pull && docker compose up -d     # 升级到 latest
GOIM_TAG=1.7.0 docker compose up -d             # 固定 / 回滚到指定版本
docker compose down                             # 停止（保留数据卷）
docker compose down -v                          # 停止并删除所有数据

可写进同目录 .env 的变量：

数据库密码只在首次创建数据卷时生效，之后修改需进 MySQL 手动改。

⁠邮件验证码

注册、找回密码、绑定邮箱都通过邮件验证码完成，用户 ID 由服务端从 100000 起自动分配。未配置 SMTP 时这三个功能返回 503，已有账号仍可用 ID + 密码登录。

在配置文件的 gateway.mail 中填写 SMTP 服务器并设 enabled: true；密码不要写进配置文件，通过环境变量 GOIM_MAIL_PASSWORD 传入：

"mail": {
    "enabled": true,
    "host": "smtp.exmail.qq.com",
    "port": 465,
    "username": "[email protected]",
    "from": "GO-IM <[email protected]>"
}

• 端口 465 使用隐式 TLS，其他端口（如 587）使用 STARTTLS
• Docker：在 .env 中写 MAIL_PASSWORD=...，compose 会传给 gateway
• Kubernetes：填 kustomization.yaml 中 goim-infra 的 MAIL_PASSWORD
• 验证码 10 分钟有效，同一邮箱 60 秒内只发一次、每天最多 10 次；启用 Redis 时多个网关共享验证码

⁠Kubernetes 全量部署

需要 kubectl 1.27+（内置 kustomize）、默认 StorageClass 和一个 Ingress 控制器。清单在 deploy/k8s⁠，默认部署到命名空间 go-im。

git clone --depth 1 https://github.com/chaishuanzhu/GO-IM.git
cd GO-IM/deploy/k8s

# 1. 必改：JWT 签名密钥
sed -i.bak "s|CHANGE_ME_run_openssl_rand_base64_48|$(openssl rand -base64 48 | tr -d '\n/+=')|" config.json
# 2. ingress.yaml：把 im.example.com 换成你的域名，按需设置 ingressClassName / tls
# 3. kustomization.yaml：按需修改 goim-infra 中的密码（同步改 config.json）和镜像版本 newTag
# 4. 邮件验证码：config.json 的 gateway.mail 设 enabled: true，SMTP 密码填 goim-infra 的 MAIL_PASSWORD

kubectl apply -k .
kubectl -n go-im get pods -w

所有 Pod 就绪后 http://<你的域名>/health 返回 "status":"ok"，客户端服务器地址填 http://<你的域名>（配了 TLS 则为 https://）。

常用操作：

kubectl -n go-im logs deploy/gateway -f
# 升级：改 kustomization.yaml 的 newTag 后重新 apply；或直接
kubectl -n go-im set image deploy/gateway gateway=870027381/go-im-gateway:1.0.1
kubectl -n go-im rollout undo deploy/gateway        # 回滚
kubectl delete -k .                                 # 删除（PVC 需手动删除）

logic / gateway 均为滚动更新（maxSurge: 1、maxUnavailable: 0）：新 Pod 就绪后才停旧 Pod，升级不中断服务。

• 新旧 Pod 并存的几秒内，各自从 Redis 租用不同的 snowflake worker ID（im:snowflake:worker:<id>，网关 16–511、logic 512–1023），消息 / 群组 ID 不会冲突。Redis 不可用时回退到配置里的固定 worker_id，此时不应并存多个实例。
• 连在旧 Pod 上的用户在新 Pod 看来是离线，发给他们的消息进 Redis 离线队列；旧 Pod 退出后客户端重连到新 Pod 并拉取，不会丢消息。未读计数在进程内，重启后清零（与之前相同）。
• 数据库变更须向前兼容：新旧版本会同时读写同一个库，一个版本里只加表 / 加列，删除或改名放到下一个版本。

已有 MySQL / Redis / Kafka / 对象存储时，从 kustomization.yaml 的 resources 中去掉对应文件，把 config.json 中的地址改成外部服务即可。

⁠配置说明

Gateway 和 Logic 只读一个 JSON 配置文件（容器内 /etc/im/config.json，路径可用 CONFIG_PATH 覆盖），没有其它环境变量。完整字段见 configs/config.example.json⁠。

⁠文件直传

默认客户端经网关 POST /upload 上传，单文件上限 10 MB。开启直传后，客户端先向网关申请预签名 URL，再把文件直接 PUT 到对象存储（上限 100 MB），下载也由网关 302 到对象存储，大文件不再经过网关。未开启或对象存储不可达时，客户端自动回退到网关上传。

开启步骤：

1. 为对象存储准备一个独立域名（如 oss.example.com）或 CDN，反向代理到 RustFS 的 9000 端口，Host 头原样透传（预签名按该域名计算），并放开请求体大小（≥ 100 MB）。

   • Docker：RustFS 已映射到宿主机 127.0.0.1:9000（OSS_BIND / OSS_PORT），用宿主机上的 Caddy / nginx 代理即可，例如 Caddy：oss.example.com { reverse_proxy 127.0.0.1:9000 }。
   • Kubernetes：修改 ingress.yaml 中 go-im-oss 的域名与 TLS。

2. 修改配置的 object_storage：

   "public_endpoint": "https://oss.example.com"
   

   Copy

3. 重启 gateway，日志出现 direct upload enabled 即生效。

RustFS 的 S3 端口对外暴露后，务必修改默认的 RUSTFS_SECRET_KEY（同步改 object_storage.secret_key）。存储桶本身不开放匿名访问，客户端只能通过网关签发的短期 URL 读写。

文件按会话鉴权：只有上传者和文件被发送到的会话成员可以下载。

⁠端口

⁠生产建议

• 前面加 HTTPS（Caddy、Traefik、nginx、云负载均衡或 Ingress TLS），WebSocket 需透传 Upgrade 头。
• 修改 JWT 密钥和所有默认密码，check_origin 填写实际域名。
• 固定镜像版本，不要在生产使用 latest。
• 定期备份 MySQL 和对象存储数据卷。