【利用 Unity + Mirror 网络框架、Node.js 后端和 MySQL 数据库】

要实现一个简单的1v1战斗小游戏，利用 Unity + Mirror 网络框架、Node.js 后端和 MySQL 数据库，我们可以将其分为几个主要部分：客户端（Unity）、服务器（Node.js）和数据库（MySQL）。以下是实现的详细步骤和代码示例：

1. Unity 客户端实现

在 Unity 中，使用 Mirror 网络框架来处理玩家的网络连接、同步和玩家动作的管理。这个部分主要包括玩家的控制、网络同步、以及与后端的通信。

1.1 设置 Unity 项目

首先，安装 Mirror 网络框架：

在 Unity 中，打开 Window -> Package Manager。
点击 Add package from git URL，然后输入 https://github.com/vis2k/Mirror.git 来安装 Mirror。

1.2 创建玩家和网络管理器

玩家控制脚本 (PlayerController.cs)

这个脚本用于控制玩家的移动、同步玩家状态以及与服务器进行通信。

using Mirror;
using UnityEngine;public class PlayerController : NetworkBehaviour
{public float moveSpeed = 5f;private Rigidbody rb;private void Start(){if (isLocalPlayer){rb = GetComponent<Rigidbody>();}}private void Update(){if (isLocalPlayer){HandleMovement();}}private void HandleMovement(){float moveX = Input.GetAxis("Horizontal");float moveZ = Input.GetAxis("Vertical");Vector3 movement = new Vector3(moveX, 0, moveZ) * moveSpeed * Time.deltaTime;rb.MovePosition(transform.position + movement);}[Command]public void CmdAttack(){RpcAttack();}[ClientRpc]public void RpcAttack(){// 在客户端同步攻击动作Debug.Log("Player is attacking!");}
}

网络管理器 (GameNetworkManager.cs)

这个脚本负责处理连接、断开连接和玩家匹配等功能。

using Mirror;
using UnityEngine;public class GameNetworkManager : NetworkManager
{public GameObject playerPrefab;public override void OnServerAddPlayer(NetworkConnection conn){GameObject player = Instantiate(playerPrefab);NetworkServer.AddPlayerForConnection(conn, player);}public override void OnServerDisconnect(NetworkConnection conn){base.OnServerDisconnect(conn);Debug.Log("Player disconnected.");}
}

1.3 设置玩家预制体

在 Unity 中创建一个简单的玩家角色（可以使用一个 Cube 或任何自定义模型）。
为玩家对象添加 Rigidbody 和 NetworkIdentity 组件。
在 NetworkManager 中设置玩家预制体为创建的玩家对象。

1.4 连接后端

在 Unity 中，我们使用 WebSocket 与后端进行通信，接收和发送玩家匹配信息。

using UnityEngine;
using WebSocketSharp;public class WebSocketManager : MonoBehaviour
{private WebSocket ws;private void Start(){ws = new WebSocket("ws://localhost:8080");ws.OnMessage += OnMessageReceived;ws.Connect();}private void OnMessageReceived(object sender, MessageEventArgs e){Debug.Log("Received message: " + e.Data);// 处理服务器返回的匹配信息if (e.Data.Contains("match_found")){Debug.Log("Match found, start game!");}}public void SendMatchmakingRequest(int playerId){string message = $"{{\"type\": \"matchmaking\", \"playerId\": {playerId}}}";ws.Send(message);}
}

2. Node.js 后端实现

Node.js 后端负责处理玩家匹配、管理游戏房间，并向客户端发送匹配成功的消息。WebSocket 用于与 Unity 客户端实时通信。

2.1 安装依赖

首先，安装必要的依赖：

npm install express mysql ws

2.2 创建 MySQL 数据库

在 MySQL 中创建一个简单的玩家表，用于存储玩家信息和匹配状态。

CREATE DATABASE game_db;USE game_db;CREATE TABLE players (id INT AUTO_INCREMENT PRIMARY KEY,player_name VARCHAR(255) NOT NULL,status ENUM('waiting', 'matched') DEFAULT 'waiting'
);

2.3 后端代码 (server.js)

Node.js 后端通过 WebSocket 与客户端通信，通过 MySQL 管理玩家的匹配状态。

const express = require('express');
const mysql = require('mysql');
const WebSocket = require('ws');const app = express();
const port = 3000;// 数据库连接
const db = mysql.createConnection({host: 'localhost',user: 'root',password: 'yourpassword',database: 'game_db'
});db.connect((err) => {if (err) throw err;console.log('Connected to the database');
});// WebSocket 服务器
const wss = new WebSocket.Server({ port: 8080 });wss.on('connection', (ws) => {console.log('A player connected');ws.on('message', (message) => {console.log('Received: ' + message);const data = JSON.parse(message);if (data.type === 'matchmaking') {handleMatchmaking(ws, data.playerId);}});ws.on('close', () => {console.log('Player disconnected');});
});// 玩家匹配逻辑
function handleMatchmaking(ws, playerId) {// 查找一个等待匹配的玩家db.query('SELECT * FROM players WHERE status = "waiting" LIMIT 1', (err, results) => {if (err) throw err;if (results.length > 0) {const opponent = results[0];// 更新玩家和对手的状态为 'matched'db.query('UPDATE players SET status = "matched" WHERE id = ?', [playerId], (err) => {if (err) throw err;});db.query('UPDATE players SET status = "matched" WHERE id = ?', [opponent.id], (err) => {if (err) throw err;});// 发送匹配成功消息ws.send(JSON.stringify({ type: 'match_found', opponent: opponent }));} else {// 没有找到对手，等待db.query('UPDATE players SET status = "waiting" WHERE id = ?', [playerId], (err) => {if (err) throw err;});// 发送等待消息ws.send(JSON.stringify({ type: 'waiting' }));}});
}