本文在上一篇博文的基礎上繼續介紹使用Unity3d遊戲客戶端與Photon Server資料通訊

開啟Unity3d2017，新建專案，在Asset目錄下新建Plugins資料夾

找到Photon SDK目錄下的lib檔案PhotonUnity3D.dll檔案，將其拖動到Unity Plugins目錄下

新建一個指令碼，這裡我命名為GamContext，將其掛載到場景空物件中

using System.Linq;
using System.Collections.Generic;
using UnityEngine;
using UnityEngine.UI;
using ExitGames.Client.Photon;

public class GameContext : MonoBehaviour,IPhotonPeerListener
{
    private PhotonPeer peer;

    public void DebugReturn(DebugLevel level, string message)
    {       
    }

    //接收伺服器發來的事件
    public void OnEvent(EventData eventData)
    {
        switch (eventData.Code)
        {
            case 0:
                //獲取事件資料
                object value = eventData.Parameters.FirstOrDefault(q => q.Key == 1).Value;

                Debug.Log(value.ToString());

                break;
            default:
                break;
        }
    }

    //接收響應資料（客戶端傳送了請求）
    public void OnOperationResponse(OperationResponse operationResponse)
    {
        int operationCode = operationResponse.OperationCode;
        switch (operationCode)
        {
            case 0:
                //讀取資料包
                Dictionary<byte, object> responsedata = operationResponse.Parameters;
                object value = responsedata.FirstOrDefault(q => q.Key == 1).Value;

                Debug.Log(value.ToString());
                break;
            default:
                break;
        }
    }

    //連線狀態傳送改變
    public void OnStatusChanged(StatusCode statusCode)
    {
        Debug.Log("資料連線狀態發生的改變:" + statusCode);
    }

    private void Start()
    {
        //傳輸協議UDP 、 通過Listener接收伺服器端的響應
        peer = new PhotonPeer(this, ConnectionProtocol.Udp);
        //連線本地伺服器
        peer.Connect("127.0.0.1:5055", "MYGameServer");

        GameObject.Find("SendRequest").GetComponent<Button>().onClick.AddListener(()=> {

            //傳輸資料
            Dictionary<byte, object> myData = new Dictionary<byte, object>();
            myData.Add(1,"劉俊良");
            myData.Add(2, 20);

            //向伺服器傳送資料請求
            peer.OpCustom(0, myData, true);
        });
    }

    private void Update()
    {
        //和伺服器實時保持資料連線
        peer.Service();    
    }

    private void OnDestroy()
    {
        if (peer != null && peer.PeerState == PeerStateValue.Connected)
        {
            //斷開連線
            peer.Disconnect();
        }
    }
}
 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Photon.SocketServer;
using PhotonHostRuntimeInterfaces;

namespace MyGameServer
{
    class ClientPeer : Photon.SocketServer.ClientPeer
    {
        public ClientPeer(InitRequest ir) : base(ir) { }

        //該客戶端斷開連線
        protected override void OnDisconnect(DisconnectReason reasonCode, string reasonDetail)
        {
            
        }

        //該客戶端出操作請求
        protected override void OnOperationRequest(OperationRequest operationRequest, SendParameters sendParameters)
        {
            /*****解析客戶端請求資料*****/
            ReadRequestData(operationRequest);
            /****************************/

            /*****向客戶端傳送響應*****/
            OperationResponse operationResponse = new OperationResponse();
            operationResponse.OperationCode = 0;
            //資料包
            operationResponse.Parameters = new Dictionary<byte, object> { { 1, "資料提交成功" } };
            //向客戶端傳送請求響應
            SendOperationResponse(operationResponse, sendParameters);
            /**************************/

            /*****向客戶端傳送事件*****/
            EventData eventData = new EventData(0, new Dictionary<byte, object> { { 1, "伺服器事件" } });
            SendEvent(eventData, new SendParameters());
            /**************************/
        }

        private void ReadRequestData(OperationRequest operationRequest)
        {            
            int operationCode = operationRequest.OperationCode;
            switch (operationCode)
            {
                case 0:
                    Dictionary<byte, object> requestData = operationRequest.Parameters;
                    object value1 = requestData.FirstOrDefault(q => q.Key == 1).Value;
                    object value2 = requestData.FirstOrDefault(q => q.Key == 2).Value;

                    MyGameServer.LOG.Info("資料一：" + value1 + "資料二：" + value2);
                    break;
                default:
                    break;
            }
        }
    }
}
 

重新生成專案

開啟PhotonServer，開啟MyGameServer

執行Unity3d，點選按鈕，向伺服器傳送請求

此時Debug正常列印，檢視MyGameServer.log日誌檔案也正常輸出

這裡我總結了下客戶端與伺服器端資料互動流程，如圖所示