NET - ClientManager.cs - 客户端连接器
/// <summary>/// 这个是用来管理跟服务器端的Socket连接/// </summary>public class ClientManager :BaseManager { private const string IP = "127.0.0.1"; private const int PORT = 6688; private Socket clientSocket; //实例化信息 private Message msg = new Message(); public ClientManager(GameFacade facade) : base(facade) { } //连接服务器 public override void OnInit(){} //监听 private void Start(){} //接收数据 private void ReceiveCallback(IAsyncResult ar){} private void OnProcessDataCallback(动作码,数据){} //发送请求 public void SendRequest(请求码,动作码,数据){} //关闭游戏 public override void OnDestroy(){}
/// <summary>/// 这个是用来管理跟服务器端的Socket连接/// </summary>public class ClientManager :BaseManager { private const string IP = "127.0.0.1"; private const int PORT = 6688; private Socket clientSocket; //实例化信息 private Message msg = new Message(); public ClientManager(GameFacade facade) : base(facade) { } //连接服务器 public override void OnInit(){} //监听 private void Start(){} //接收数据 private void ReceiveCallback(IAsyncResult ar){} private void OnProcessDataCallback(ActionCode actionCode,string data){} //发送请求 public void SendRequest(RequestCode requestCode, ActionCode actionCode, string data){} //关闭游戏 public override void OnDestroy(){}
using System.Collections;using System.Collections.Generic;using UnityEngine;using System.Net.Sockets;using System;using Common;/// <summary>/// 这个是用来管理跟服务器端的Socket连接/// </summary>public class ClientManager :BaseManager { private const string IP = "127.0.0.1"; private const int PORT = 6688; private Socket clientSocket; //实例化信息 private Message msg = new Message(); public ClientManager(GameFacade facade) : base(facade) { } //连接服务器 public override void OnInit() { base.OnInit(); clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); try { clientSocket.Connect(IP, PORT); Start(); } catch (Exception e) { Debug.LogWarning("无法连接到服务器端，请检查您的网络！！" + e); } } //监听 private void Start() { clientSocket.BeginReceive(msg.Data,msg.StartIndex,msg.RemainSize, SocketFlags.None, ReceiveCallback, null); } //接收数据 private void ReceiveCallback(IAsyncResult ar) { try { if (clientSocket == null || clientSocket.Connected == false) return; int count = clientSocket.EndReceive(ar); msg.ReadMessage(count, OnProcessDataCallback); Start(); } catch(Exception e) { Debug.Log(e); } } private void OnProcessDataCallback(ActionCode actionCode,string data) { facade.HandleReponse(actionCode, data); } //发送请求 public void SendRequest(RequestCode requestCode, ActionCode actionCode, string data) { byte[] bytes = Message.PackData(requestCode, actionCode, data); clientSocket.Send(bytes); } //关闭游戏 public override void OnDestroy() { base.OnDestroy(); try { clientSocket.Close(); }catch(Exception e) { Debug.LogWarning("无法关闭跟服务器端的连接！！" + e); } }}
