using ServerCore.Manager; using System.Net.Sockets; namespace ServerCore.NetWork { public class NetMsg { private static NetMsg instance = new NetMsg(); public static NetMsg Instance { get { return instance; } } private Dictionary<int, List<Delegate>> netEventDic = new Dictionary<int, List<Delegate>>(128); private NetMsg() { } #region RegisterMsgEvent public void RegNetMsgEvent(int cmd, Action<Socket, byte[]> callback) { InterRegNetMsgEvent(cmd, callback); } private void InterRegNetMsgEvent(int cmd, Delegate callback) { if (netEventDic.ContainsKey(cmd)) { if (netEventDic[cmd].IndexOf(callback) < 0) { netEventDic[cmd].Add(callback); } } else { netEventDic.Add(cmd, new List<Delegate>() { callback }); } } #endregion #region UnregisterCMD public void UnregisterCMD(int cmd, Action<Socket, byte[]> callback) { Delegate tempDelegate = callback; InterUnregisterCMD(cmd, tempDelegate); } private void InterUnregisterCMD(int cmd, Delegate callback) { if (netEventDic.ContainsKey(cmd)) { netEventDic[cmd].Remove(callback); if (netEventDic[cmd].Count == 0) netEventDic.Remove(cmd); } } #endregion #region PostEvent public void PostNetMsgEvent(int cmd, Socket arg1, byte[] arg2) { List<Delegate> eventList = GetNetEventDicList(cmd); if (eventList != null) { foreach (Delegate callback in eventList) { try { ((Action<Socket, byte[]>)callback)(arg1, arg2); } catch (Exception e) { ServerManager.g_Log.Error(e.Message); } } } } #endregion /// <summary> /// 获取所有事件 /// </summary> /// <param name="cmd"></param> /// <returns></returns> private List<Delegate> GetNetEventDicList(int cmd) { if (netEventDic.ContainsKey(cmd)) { List<Delegate> tempList = netEventDic[cmd]; if (null != tempList) { return tempList; } } return null; } } }