【Unity MySQL小白教程⑥】完整项目实战——玩家管理系统从0到部署

2025-07-25

前言

恭喜你来到本系列终章！前五篇我们分别搞定了架构选型、MySQL建表、Unity驱动配置、CRUD封装和HTTP API搭建。本篇把它们全部串联，交付一个可运行的玩家管理系统Demo，涵盖注册登录、个人信息查看、背包管理、排行榜四个核心功能，并给出完整的部署上线清单。

一、系统架构总览

┌─────────────┐     HTTPS      ┌──────────────────┐    TCP     ┌─────────┐
│ Unity Client │ ←────────────→ │ Node.js API Server│ ←────────→ │  MySQL  │
│ (UGUI界面)   │   JSON + JWT   │ (Express + mysql2)│  Prepared  │ game_db │
└─────────────┘                 └──────────────────┘  Statements └─────────┘
                                       ↑
                                  Nginx反向代理
                                  + Let's Encrypt

二、API接口清单

方法	路径	鉴权	说明
POST	/api/player/register	❌	注册新账号
POST	/api/player/login	❌	登录获取JWT
GET	/api/player/:id	✅	查看玩家信息
PUT	/api/player/nickname	✅	修改昵称
GET	/api/player/items	✅	获取背包列表
POST	/api/player/items/use	✅	使用物品
GET	/api/leaderboard	❌	金币排行榜Top50
POST	/api/player/logout	✅	登出(客户端清除Token)

三、服务端补充代码

3.1 背包接口

// src/models/itemModel.js
const pool = require('../config/db');

class ItemModel {
    static async getByPlayerId(playerId) {
        const [rows] = await pool.execute(
            'SELECT item_id, quantity, extra_data, obtained_at FROM player_items WHERE player_id = ? ORDER BY obtained_at DESC',
            [playerId]
        );
        return rows;
    }

    static async useItem(playerId, itemId, count) {
        const conn = await pool.getConnection();
        try {
            await conn.beginTransaction();

            // 检查库存
            const [rows] = await conn.execute(
                'SELECT quantity FROM player_items WHERE player_id = ? AND item_id = ? FOR UPDATE',
                [playerId, itemId]
            );
            if (!rows[0] || rows[0].quantity < count) {
                throw new Error('物品数量不足');
            }

            // 扣减
            await conn.execute(
                'UPDATE player_items SET quantity = quantity - ? WHERE player_id = ? AND item_id = ?',
                [count, playerId, itemId]
            );

            // 清理零库存
            await conn.execute(
                'DELETE FROM player_items WHERE player_id = ? AND item_id = ? AND quantity <= 0',
                [playerId, itemId]
            );

            await conn.commit();
            return true;
        } catch (err) {
            await conn.rollback();
            throw err;
        } finally {
            conn.release();
        }
    }
}

module.exports = ItemModel;

💡 事务+行锁(FOR UPDATE) 保证并发安全。两个请求同时使用同一物品时不会出现负数库存。

3.2 修改昵称接口

// Controller中新增
static async updateNickname(req, res) {
    try {
        const { nickname } = req.body;
        if (!nickname || nickname.length < 2 || nickname.length > 20) {
            return res.status(400).json({ error: '昵称长度2-20字符' });
        }

        const [result] = await pool.execute(
            'UPDATE players SET nickname = ? WHERE id = ?',
            [nickname, req.user.playerId]
        );

        if (result.affectedRows === 0) {
            return res.status(404).json({ error: '玩家不存在' });
        }

        res.json({ message: '昵称修改成功', nickname });
    } catch (err) {
        res.status(500).json({ error: err.message });
    }
}

四、Unity客户端UI实现

4.1 登录面板

// Assets/Scripts/UI/LoginPanel.cs
using UnityEngine;
using UnityEngine.UI;

public class LoginPanel : MonoBehaviour
{
    [SerializeField] private InputField _usernameInput;
    [SerializeField] private InputField _passwordInput;
    [SerializeField] private Button _loginBtn;
    [SerializeField] private Text _msgText;

    private void Start()
    {
        _loginBtn.onClick.AddListener(OnLoginClick);
    }

    private async void OnLoginClick()
    {
        _msgText.text = "登录中...";
        _loginBtn.interactable = false;

        var token = await GameApiClient.LoginAsync(
            _usernameInput.text.Trim(),
            _passwordInput.text
        );

        if (token != null)
        {
            _msgText.text = "";
            GameManager.Instance.OnLoginSuccess(token);
        }
        else
        {
            _msgText.text = "登录失败，请检查用户名和密码";
        }

        _loginBtn.interactable = true;
    }
}

4.2 排行榜面板

// Assets/Scripts/UI/LeaderboardPanel.cs
using System.Collections.Generic;
using UnityEngine;
using UnityEngine.Networking;

public class LeaderboardPanel : MonoBehaviour
{
    [SerializeField] private Transform _itemParent;
    [SerializeField] private GameObject _rowPrefab;

    public async void Refresh()
    {
        using var req = UnityWebRequest.Get($"{GameApiClient.BaseUrl}/leaderboard?limit=50");
        await req.SendWebRequest();

        if (req.result != UnityWebRequest.Result.Success) return;

        var list = JsonHelper.FromJson<RankItem>(req.downloadHandler.text);

        // 清空旧数据
        foreach (Transform child in _itemParent) Destroy(child.gameObject);

        // 填充新数据
        for (int i = 0; i < list.Count; i++)
        {
            var row = Instantiate(_rowPrefab, _itemParent);
            var texts = row.GetComponentsInChildren<Text>();
            texts[0].text = $"#{i + 1}";
            texts[1].text = list[i].nickname;
            texts[2].text = $"Lv.{list[i].level}";
            texts[3].text = $"{list[i].gold:N0}";
        }
    }

    [System.Serializable]
    private class RankItem { public long id; public string nickname; public int level; public long gold; }
}

五、部署上线Checklist

5.1 服务端部署

步骤	命令/操作	验证方式
安装Node.js 20 LTS	`curl -fsSL https://deb.nodesource.com/setup_20.x \| sudo bash - && sudo apt install nodejs`	`node -v`
安装依赖	`cd game-api && npm ci --production`	`ls node_modules/mysql2`
配置环境变量	创建 `.env` 文件，填入DB/JWT密钥	`cat .env`
PM2启动	`pm2 start src/app.js --name game-api -i max`	`pm2 status`
Nginx反向代理	配置upstream + proxy_pass	`curl http://localhost/api/leaderboard`
HTTPS证书	`certbot --nginx -d api.yourgame.com`	浏览器访问https
防火墙	`ufw allow 80 && ufw allow 443`	外网访问测试
MySQL备份	crontab每日mysqldump	检查备份文件大小

5.2 Unity打包注意事项

检查项	说明
API地址切换	开发用localhost:3000，发布用https://api.yourgame.com
IL2CPP link.xml	保留Newtonsoft.Json/System.Net相关类型
Android网络安全配置	`network_security_config.xml` 允许HTTPS
iOS ATS	Info.plist中配置NSAppTransportSecurity
超时设置	UnityWebRequest.timeout = 10秒
重试机制	网络失败自动重试1次，间隔2秒
Token刷新	401响应时跳转登录页

六、性能基线与监控

指标	目标值	监控工具
API平均响应时间	< 100ms	PM2 + Prometheus
P99响应时间	< 500ms	Grafana
MySQL慢查询	< 1s	slow_query_log
连接池使用率	< 80%	mysql2 pool events
错误率	< 0.1%	日志聚合(ELK/Loki)
服务器CPU	< 70%	htop / Cloud Monitor
内存使用	< 80%	free -m

七、后续扩展方向

方向	技术选型	适用场景
缓存层	Redis	排行榜/会话/热点数据
消息队列	RabbitMQ / Kafka	异步任务/事件解耦
全文搜索	Elasticsearch	玩家搜索/聊天记录
实时通信	WebSocket / Netcode	对战/聊天/推送
数据分析	ClickHouse / BigQuery	埋点/留存/付费分析
ORM升级	FreeSql / Prisma	减少手写SQL
微服务拆分	gRPC + K8s	DAU > 10万

八、全系列知识回顾

Unity MySQL 小白教程·知识体系
│
├── 🟢 认知层 (第1篇)
│   └── 架构选型 + 安全五原则
│
├── 🔵 基础层 (第2-3篇)
│   ├── MySQL安装 + 表结构设计
│   └── Unity驱动配置 + 第一个查询
│
├── 🟡 核心层 (第4篇)
│   └── CRUD完整实现 + DAO封装
│
├── 🟠 架构层 (第5篇)
│   └── HTTP API中间层 + JWT鉴权
│
└── 🔴 实战层 (第6篇·本篇)
    └── 全栈项目 + 部署上线 + 监控扩展

总结

从”要不要用MySQL”到”完整项目上线”，六篇走完了一条从小白到实战的完整路径。记住三个核心认知：

生产环境永远走API中间层，客户端不碰数据库
安全是设计出来的不是补丁打出来的，参数化查询+JWT+HTTPS缺一不可
先跑通再优化，别在Hello World阶段就纠结百万并发

这个系列能教给你的技术是有限的，但希望你建立的安全意识和架构思维是无限的。

去造点什么吧。 🚀

系列导航
← 第5篇：HTTP API中间层实战
🏁 本篇为系列终章

前言