一、背景

由于cocos2dx本身的NotificationCenter是没有进行线程安全处理的，所以当我们在cocos2dx里面使用多线程进行消息同步的时候，

会出现问题。那么为了解决这个问题，我们只需要进行线程安全锁定即可。

为了不修改源码，我模仿NotificationCenter，自定义了一个消息管理。

二、思路

首先，我们定义一个消息体的数据类型 Message。他里面存储有消息名称Name,消息处理函数，消息目标，消息内容。 @H_403_15@

@H_403_15@

然后，我们定义一个消息管理类。他里面有消息容器。去容纳每一个消息。 @H_403_15@

管理类对外暴漏的接口只有添加消息和发送消息。具体内容需要自己实现。 @H_403_15@

@H_403_15@

最后，将消息容器每次操作加锁即可。一个可以重复利用的，多线消息处理机制就完成了。 @H_403_15@

@H_403_15@

三、代码

头文件：

/**************************************************************
 * Copyright (c) 2014-11-12 by real.Xm  
 * Blog Address:	http://blog.csdn.net/q229827701
 * Email: 229827701@qq.com
 **************************************************************/
 
#ifndef __XMESSAGE__H
#define __XMESSAGE__H
 
 
#include "cocos2d.h"
class XMessage;
class CC_DLL MessageMsg : public cocos2d::Ref
{
public:
	MessageMsg();
	virtual ~MessageMsg();
	static MessageMsg* getInstance();
	bool addObserver(const std::string &msgName,cocos2d::Ref* target,cocos2d::SEL_CallFuncO selector,cocos2d::Ref* msgContent = nullptr);
	bool postMessage(const std::string &msgName,cocos2d::Ref* msgContent);
	bool removeObserverByName(const std::string &msgName,cocos2d::Ref* target = nullptr);
	bool removeAllObservers(cocos2d::Ref* target);
protected: 
	XMessage* getMessageByName(const std::string &msgName) const;
private:
	//message container
	cocos2d::Vector<XMessage*> _msgContainer; 
};
class CC_DLL XMessage: public cocos2d::Ref
{
public:
	XMessage(const std::string &msgName,cocos2d::Ref* msgContent);
	~XMessage();
	void handerMessage(cocos2d::Ref* msgContent);
CC_SYNTHESIZE_READONLY(std::string,_msgName,MessageName);//message name
CC_SYNTHESIZE_READONLY(cocos2d::Ref*,_target,Target);   //target
CC_SYNTHESIZE_READONLY(cocos2d::SEL_CallFuncO,_selector,Selector);//function
CC_SYNTHESIZE_READONLY(cocos2d::Ref*,_msgContent,MessageConent);//function args
};
 
#endif // !_XMESSAGE_H

@H_403_15@

实现文件

@H_403_15@

#include "XMessageManger.h"
 
std::mutex _ContainerMutex;
static MessageMsg* _Manager = nullptr;
MessageMsg::MessageMsg()
{
 
}
 
MessageMsg::~MessageMsg()
{
	_msgContainer.clear();
}
 
MessageMsg* MessageMsg::getInstance()
{
	if (!_Manager)
	{
		_Manager = new MessageMsg;
	}
	return _Manager;
}
 
bool MessageMsg::addObserver( const std::string &msgName,cocos2d::Ref* msgContent /*= nullptr*/ )
{
	if (!getMessageByName(msgName))
	{
		auto msg = new XMessage(msgName,target,selector,msgContent);
		IF_NULL_RETURN_FALSE(msg);
		msg->autorelease();
		std::lock_guard<std::mutex> ul(_ContainerMutex);
		_msgContainer.pushBack(msg);
		return true;
	}
	return false;
}
 
bool MessageMsg::postMessage( const std::string &msgName,cocos2d::Ref* msgContent )
{
	auto msg = getMessageByName(msgName);
	if (msg)
	{
		msg->handerMessage(msgContent);
		return true;
	}
	return false;
}
 
XMessage* MessageMsg::getMessageByName( const std::string &msgName ) const
{
	std::lock_guard<std::mutex> ul(_ContainerMutex);
	for (auto &msg : _msgContainer)
	{
		if (msgName == msg->getMessageName())
		{
			return msg;
		}
	}
	return nullptr;
}
 
bool MessageMsg::removeObserverByName( const std::string &msgName,cocos2d::Ref* target /*= nullptr*/ )
{
	std::lock_guard<std::mutex> ul(_ContainerMutex);
	for (auto &msg : _msgContainer)
	{
		if (msgName == msg->getMessageName()
			&&(target == msg->getTarget()||!target))
		{
			_msgContainer.eraSEObject(msg,true);
			return true;
		}
	}
	return false;
}
 
bool MessageMsg::removeAllObservers( cocos2d::Ref* target )
{
	std::lock_guard<std::mutex> ul(_ContainerMutex);
	for (auto &msg : _msgContainer)
	{
		if (target == msg->getTarget())
		{
			_msgContainer.eraSEObject(msg,true);
			return true;
		}
	}
	return false;
}
 
//////////////////////////////////////////////////////////////////////////
///   XMessage Class
/////////////////////////////////////////////////////////////////////////
 
XMessage::XMessage( const std::string &msgName,cocos2d::Ref* msgContent )
				   :_msgName(msgName),_target(target),_selector(selector),_msgContent(msgContent)
{
 
}
 
XMessage::~XMessage()
{
 
}
 
void XMessage::handerMessage( cocos2d::Ref* msgContent )
{
	if (_target)
	{
		if (msgContent) {
			(_target->*_selector)(msgContent);
		} else {
			(_target->*_selector)(msgContent);
		}
	}
}