纳金网

标题: 消息机制相关代码地址 [打印本页]

作者: 拥抱仙人掌 时间: 2016-8-22 15:52
标题: 消息机制相关代码地址
1、IMsgReceiver.cs

using UnityEngine;
	using System.Collections;

	namespace QFramework.Event {

	public interface IMsgReceiver {


	}
	}

2、IMsgReceiver.cs.meta

fileFormatVersion: 2
	guid: 2f3fb1f60e8d54abf8cfc00457144456
	timeCreated: 1465056425
	licenseType: Pro
	MonoImporter:
	serializedVersion: 2
	defaultReferences: []
	executionOrder: 0
	icon: {instanceID: 0}
	userData:
	assetBundleName:
	assetBundleVariant:

3、IMsgSender.cs

using UnityEngine;
	using System.Collections;

	namespace QFramework.Event {

	public interface IMsgSender {

	}
	}

4、IMsgSender.cs.meta

fileFormatVersion: 2
	guid: fb4f40f1d1e914022a708cfeaec95cd1
	timeCreated: 1465056639
	licenseType: Pro
	MonoImporter:
	serializedVersion: 2
	defaultReferences: []
	executionOrder: 0
	icon: {instanceID: 0}
	userData:
	assetBundleName:
	assetBundleVariant:

5、QMsgDispatcher.cs.meta

fileFormatVersion: 2
	guid: eabc1f17069f64f8bb6b47708cfca98f
	timeCreated: 1465053562
	licenseType: Pro
	MonoImporter:
	serializedVersion: 2
	defaultReferences: []
	executionOrder: 0
	icon: {instanceID: 0}
	userData:
	assetBundleName:
	assetBundleVariant:

作者: 拥抱仙人掌 时间: 2016-8-22 15:53
QMsgDispatcher.cs

using UnityEngine;
using System.Collections;
using System.Collections.Generic;
using System;

namespace QFramework.Event {

public enum QMsgChannel {
Global, // 全局
UI,
Logic,
}

/// <summary>
/// 消息分发器
/// C# this扩展需要静态类
/// </summary>
public static class QMsgDispatcher  {

/// <summary>
/// 消息捕捉器
/// </summary>
class QMsgHandler {

public IMsgReceiver receiver;
public  VoidDelegate.WithParams callback;

/*
   * VoidDelegate.WithParams 是一种委托 ,定义是这样的
   *
   *  public class VoidDelegate{
   *    public delegate void WithParams(params object[] paramList);
   *  }
   */
public QMsgHandler(IMsgReceiver receiver,VoidDelegate.WithParams callback)
{
this.receiver = receiver;
this.callback = callback;
}
}

/// <summary>
/// 每个消息名字维护一组消息捕捉器。
/// </summary>
static Dictionary<QMsgChannel,Dictionary<string,List<QMsgHandler>>> mMsgHandlerDict = new Dictionary<QMsgChannel,Dictionary<string,List<QMsgHandler>>> ();

/// <summary>
/// 注册消息,
/// 注意第一个参数,使用了C# this的扩展,
/// 所以只有实现IMsgReceiver的对象才能调用此方法
/// </summary>
public static void RegisterGlobalMsg(this IMsgReceiver self, string msgName,VoidDelegate.WithParams callback)
{
// 略过
if (string.IsNullOrEmpty(msgName)) {
Debug.LogError("RegisterMsg:" + msgName + " is Null or Empty");
return;
}

// 略过
if (null == callback) {
Debug.LogError ("RegisterMsg:" + msgName + " callback is Null");
return;
}

// 添加消息通道
if (!mMsgHandlerDict.ContainsKey (QMsgChannel.Global)) {
mMsgHandlerDict [QMsgChannel.Global] = new Dictionary<string, List<QMsgHandler>> ();
}

// 略过
if (!mMsgHandlerDict[QMsgChannel.Global].ContainsKey (msgName)) {
mMsgHandlerDict[QMsgChannel.Global] [msgName] = new List<QMsgHandler> ();
}

// 看下这里
var handlers = mMsgHandlerDict [QMsgChannel.Global][msgName];

// 略过
// 防止重复注册
foreach (var handler in handlers) {
if (handler.receiver == self && handler.callback == callback) {
Debug.LogWarning ("RegisterMsg:" + msgName + " ayready Register");
return;
}
}

// 再看下这里
handlers.Add (new QMsgHandler (self, callback));
}

/// <summary>
/// 注册消息,
/// 注意第一个参数,使用了C# this的扩展,
/// 所以只有实现IMsgReceiver的对象才能调用此方法
/// </summary>
public static void RegisterMsgByChannel(this IMsgReceiver self, QMsgChannel channel,string msgName,VoidDelegate.WithParams callback)
{
// 略过
if (string.IsNullOrEmpty(msgName)) {
Debug.LogError("RegisterMsg:" + msgName + " is Null or Empty");
return;
}

// 略过
if (null == callback) {
Debug.LogError ("RegisterMsg:" + msgName + " callback is Null");
return;
}

// 添加消息通道
if (!mMsgHandlerDict.ContainsKey (channel)) {
mMsgHandlerDict [channel] = new Dictionary<string, List<QMsgHandler>> ();
}

// 略过
if (!mMsgHandlerDict[channel].ContainsKey (msgName)) {
mMsgHandlerDict[channel] [msgName] = new List<QMsgHandler> ();
}

// 看下这里
var handlers = mMsgHandlerDict [channel][msgName];

// 略过
// 防止重复注册
foreach (var handler in handlers) {
if (handler.receiver == self && handler.callback == callback) {
Debug.LogWarning ("RegisterMsg:" + msgName + " ayready Register");
return;
}
}

// 再看下这里
handlers.Add (new QMsgHandler (self, callback));
}

/// <summary>
/// 其实注销消息只需要Object和Go就足够了不需要callback
/// </summary>
public static void UnRegisterGlobalMsg(this IMsgReceiver self,string msgName)
{
if (CheckStrNullOrEmpty (msgName)) {
return;
}

if (!mMsgHandlerDict.ContainsKey (QMsgChannel.Global)) {
Debug.LogError ("Channel:" + QMsgChannel.Global.ToString() + " doesn't exist");
return;
}

var handlers = mMsgHandlerDict[QMsgChannel.Global] [msgName];

int handlerCount = handlers.Count;

// 删除List需要从后向前遍历
for (int index = handlerCount - 1; index >= 0; index--) {
var handler = handlers [index];
if (handler.receiver == self) {
handlers.Remove (handler);
break;
}
}
}

/// <summary>
/// 其实注销消息只需要Object和Go就足够了不需要callback
/// </summary>
public static void UnRegisterMsgByChannel(this IMsgReceiver self,QMsgChannel channel,string msgName)
{
if (CheckStrNullOrEmpty (msgName)) {
return;
}

if (!mMsgHandlerDict.ContainsKey (channel)) {
Debug.LogError ("Channel:" + channel.ToString () + " doesn't exist");
return;
}

var handlers = mMsgHandlerDict[channel] [msgName];

int handlerCount = handlers.Count;

// 删除List需要从后向前遍历
for (int index = handlerCount - 1; index >= 0; index--) {
var handler = handlers [index];
if (handler.receiver == self) {
handlers.Remove (handler);
break;
}
}
}

static bool CheckStrNullOrEmpty(string str)
{
if (string.IsNullOrEmpty (str)) {
Debug.LogWarning ("str is Null or Empty");
return true;
}
return false;
}

static bool CheckDelegateNull(VoidDelegate.WithParams callback)
{
if (null == callback) {
Debug.LogWarning ("callback is Null");

return true;
}
return false;
}

/// <summary>
/// 发送消息
/// 注意第一个参数
/// </summary>
public static void SendGlobalMsg(this IMsgSender sender, string msgName,params object[] paramList)
{
if (CheckStrNullOrEmpty (msgName)) {
return;
}

if (!mMsgHandlerDict.ContainsKey (QMsgChannel.Global)) {
Debug.LogError ("Channel:" + QMsgChannel.Global.ToString() + " doesn't exist");
return;
}

// 略过,不用看
if (!mMsgHandlerDict[QMsgChannel.Global].ContainsKey(msgName)){
Debug.LogError("SendMsg is UnRegister");
return;
}

// 开始看!!!!
var handlers = mMsgHandlerDict[QMsgChannel.Global][msgName];

var handlerCount = handlers.Count;

// 之所以是从后向前遍历,是因为  从前向后遍历删除后索引值会不断变化
// 参考文章,http://www.2cto.com/kf/201312/266723.html
for (int index = handlerCount - 1;index >= 0;index--)
{
var handler = handlers[index];

if (handler.receiver != null) {
Debug.Log ("SendLogicMsg:" + msgName + " Succeed");
handler.callback (paramList);
} else {
handlers.Remove (handler);
}
}
}

public static void SendMsgByChannel(this IMsgSender sender,QMsgChannel channel,string msgName,params object[] paramList)
{
if (CheckStrNullOrEmpty (msgName)) {
return;
}

if (!mMsgHandlerDict.ContainsKey (channel)) {
Debug.LogError ("Channel:" +channel.ToString() + " doesn't exist");
return;
}

// 略过,不用看
if (!mMsgHandlerDict[channel].ContainsKey(msgName)){
Debug.LogWarning("SendMsg is UnRegister");
return;
}

// 开始看!!!!
var handlers = mMsgHandlerDict[channel][msgName];

var handlerCount = handlers.Count;

// 之所以是从后向前遍历,是因为  从前向后遍历删除后索引值会不断变化
// 参考文章,http://www.2cto.com/kf/201312/266723.html
for (int index = handlerCount - 1;index >= 0;index--)
{
var handler = handlers[index];

if (handler.receiver != null) {
Debug.Log ("SendLogicMsg:" + msgName + " Succeed");
handler.callback (paramList);
} else {
handlers.Remove (handler);
}
}
}

[Obsolete("RegisterLogicMsg已经弃用了,请使用RegisterGlobalMsg")]
public static void RegisterLogicMsg(this IMsgReceiver self, string msgName,VoidDelegate.WithParams callback,QMsgChannel channel = QMsgChannel.Global)
{
if (CheckStrNullOrEmpty (msgName)||CheckDelegateNull(callback)) {
return;
}

// 添加消息通道
if (!mMsgHandlerDict.ContainsKey (channel)) {
mMsgHandlerDict [channel] = new Dictionary<string, List<QMsgHandler>> ();
}

// 略过
if (!mMsgHandlerDict[channel].ContainsKey (msgName)) {
mMsgHandlerDict[channel] [msgName] = new List<QMsgHandler> ();
}

// 看下这里
var handlers = mMsgHandlerDict [channel][msgName];

// 略过
// 防止重复注册
foreach (var handler in handlers) {
if (handler.receiver == self && handler.callback == callback) {
Debug.LogWarning ("RegisterMsg:" + msgName + " ayready Register");
return;
}
}

// 再看下这里
handlers.Add (new QMsgHandler (self, callback));
}

[Obsolete("SendLogicMsg已经弃用了,请使用使用SendGlobalMsg或SendMsgByChannel")]
public static void SendLogicMsg(this IMsgSender sender, string msgName,params object[] paramList)
{
if (CheckStrNullOrEmpty (msgName)) {
return;
}

if (!mMsgHandlerDict.ContainsKey (QMsgChannel.Global)) {
Debug.LogError ("Channel:" + QMsgChannel.Global.ToString() + " doesn't exist");
return;
}

// 略过,不用看
if (!mMsgHandlerDict[QMsgChannel.Global].ContainsKey(msgName)){
Debug.LogWarning("SendMsg is UnRegister");
return;
}

// 开始看!!!!
var handlers = mMsgHandlerDict[QMsgChannel.Global][msgName];

var handlerCount = handlers.Count;

// 之所以是从后向前遍历,是因为  从前向后遍历删除后索引值会不断变化
// 参考文章,http://www.2cto.com/kf/201312/266723.html
for (int index = handlerCount - 1;index >= 0;index--)
{
var handler = handlers[index];

if (handler.receiver != null) {
Debug.Log ("SendLogicMsg:" + msgName + " Succeed");
handler.callback (paramList);
} else {
handlers.Remove (handler);
}
}
}

[Obsolete("UnRegisterMsg已经弃用了,请使用UnRegisterMsg")]
public static void UnRegisterMsg(this IMsgReceiver self,string msgName,VoidDelegate.WithParams callback,QMsgChannel channel = QMsgChannel.Global)
{
if (CheckStrNullOrEmpty (msgName) || CheckDelegateNull(callback)) {
return;
}

// 添加通道
if (!mMsgHandlerDict.ContainsKey (channel)) {
Debug.LogError ("Channel:" + channel.ToString () + " doesn't exist");
return;
}

var handlers = mMsgHandlerDict [channel] [msgName];

int handlerCount = handlers.Count;

// 删除List需要从后向前遍历
for (int index = handlerCount - 1; index >= 0; index--) {
var handler = handlers [index];
if (handler.receiver == self && handler.callback == callback) {
handlers.Remove (handler);
break;
}
}
}

[Obsolete("UnRegisterMsg已经弃用了,请使用UnRegisterGlobalMsg")]
public static void UnRegisterMsg(this IMsgReceiver self,string msgName)
{
if (CheckStrNullOrEmpty (msgName)) {
return;
}

if (!mMsgHandlerDict.ContainsKey (QMsgChannel.Global)) {
Debug.LogError ("Channel:" + QMsgChannel.Global.ToString() + " doesn't exist");
return;
}

var handlers = mMsgHandlerDict[QMsgChannel.Global] [msgName];

int handlerCount = handlers.Count;

// 删除List需要从后向前遍历
for (int index = handlerCount - 1; index >= 0; index--) {
var handler = handlers [index];
if (handler.receiver == self) {
handlers.Remove (handler);
break;
}
}
}
}
}

欢迎光临纳金网 (http://rs.narkii.com/club/)