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

news2025/1/9 4:56:16

要实现一个简单的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' }));
 }
 });
}