cocos2d-x3.2与服务端框架Firefly的网络编程深入网络通讯

上一篇记录的是服务端框架firefly在cocos2dx中实现初级网络通讯，让初学者可以有一个大概的网络通讯认识，明白大概的流程和实现方式，但看9秒发布的游戏源码“暗黑世界”，可以发现，其实和Firefly通信并没有我们看上去的那么简，在源代码里有一个专门的网络通讯实现框架，并且还有更好的通信协议实现-protobuf，protobuf在网络通信领域应该已经是很常用了，在《烽烟OLine》的源码中就可以看到它已经用到了protobuf，下面是正题：

上篇并没有给出客户端接收服务器返回消息的解析代码，这里先给出实现代码：

		//先拿到时协议头数据，根据里面的信息判断应该调用哪些回调函数进行下一步数据处理
		//while(true){
		int getRevDataLength=recv(m_sock,recvBuf,17,0);
		if(getRevDataLength==17){
			CCLOG("recvThread OK,getDataProcess=%d",getRevDataLength);	

//读取buf中的内容
 int i=0;
 unsigned char cmd[5];   //消息头的前5个参数
 byte servID[4];		//serverVersion
 byte dataLength[4];	//包的长度
 byte commandId[4];		//命令号


//前5位对应着头协议头的前5个参数
 memcpy(cmd,&recvBuf,5);
 while(i<5)
 {
  CCLOG("%d",cmd[i]);
  i++;
 };
 //取serverVersion
 int j=0;
  while(i<9){
	 servID[j]=recvBuf[i];
	  //CCLog("%d",j);
	  i++;
	 j++;
 }
 CCLog("serverVersion=%d",bytesToInt(servID));

 //取整个包的长度
 j=0;
  while(i<13){
	 dataLength[j]=recvBuf[i];
	  //CCLog("%d",j);
	  i++;
	 j++;
 }
 CCLog("dataLength=%d",bytesToInt(dataLength));

 //取命令号
 j=0;
  while(i<17){
	  commandId[j]=recvBuf[i];
	  //CCLog("%d",j);
	  i++;
	 j++;
 }
  CCLog("commandId=%d",bytesToInt(commandId));

可以发现，返回的数据其实就是一个char，我们需要按元素位来把数据从里面copy出来，该转的转，这样就能取出数据，当然，代码肯定没必要一定要像上面那样写……完整的代码其实有两次recive，第一次是拿到消息头，根据消息头里的数据再执行一次接收，把data的主体收回，解析后就可以拿到消息主体的数据……这个后面再给出解析data主体的代码。

上面是客户端的消息解析，再来看看服务端的相关代码：

import google.protobuf
import addressbook_pb2

@netserviceHandle    
def echo_2(_conn,data):
    cAddressBook=addressbook_pb2.Person()
    cAddressBook.name="Clark Yang"
    cAddressBook.id=1981
    cAddressBook.email="[e-mail]"
    #打包数据
    addressData=cAddressBook.SerializeToString()    
    '''cAddressBook.ParseFromString(entity_attr_str)'''
    print addressData
    #解析数据
    cAddressBook.ParseFromString(data)
    print "-----------------"
    print "id num=%d" %cAddressBook.id
    print "name="+cAddressBook.name
    print "email="+cAddressBook.email
    print "-----------------"
    return addressData

说通俗点，protobuf就是一个小型的数据处理功能实现，而其具备添加和索引解析数据的功能，下面一步步来说明具体的使用方法：

要使用protobuf，首先当然是下载了，为了方便我这里上传了一份算是新版本的protobuf源码包，它可以应用在java、c++、python……上，点击我下载

我们要使用的分别是两个版本，先把它安装进python。解压后可以找到其中的python目录，进去以后可以看到setup.py，进入cmd命令行，记住！先执行setup.py build，然后再setup.py install，最后你可以使用setup.py test，当然，好像我的是没执行成功，不过要检查安装是否成功可以直接进Firefly的项目里，添加导入代码import google.protobuf，如果没有红标，那应该是成功了的。

第二步，如果是在windows下使用的话，我们需要用VS编译一下protobuf，找到vsprojects目录，里面会有protobuf.sln，打开后生成解决方案，有错不用管，只要正确生成了主要的文件就行，然后就可以在生成目录下找到三个lib和一个protoc.exe，后面这个执行文件是在windows平台下用来编译.proto文件到各种语言平台的程序。

第三步，学会编译.proto文件，这个文件其实是protobuf的源文件，当你想制作一个消息模型时，比如您想在消息里加上一个人的名字，身份ID等字段（和数据库一样），那你可以按照protobuf的具体使用规则和方法来制定一个自定的消息模型，用来传递相应的信息，这里就不具体说了，给段链接自己去看，点击查看。我们需要通过上面生成的protoc.exe来根据需要，编译出对应平台的pb文件，这个文件也是通过cmd命令行来执行，我一般是把这个文件放到和需要编译的proto文件一样的目录，下面来看python和C++的编译：

1.python

protoc --python_out=D:\protobuf-2.5.0\protobuf-2.5.0\examples addressbook.proto

2.C++

protoc --cpp_out=D:\protobuf-2.5.0\protobuf-2.5.0\examples addressbook.proto

执行完上面的命令将会看到目录下出现的三个文件，分别是python的addressbook_pb2.py和C++的addressbook.pb.cc与addressbook.pb.h

后面我们就能使用这三个文件分别在python和C++中使用了

第四步，在python中使用自定的消息模型时，可以直接引用我们上面生成的py文件就可以了，而cocos2dx中使用还需要一些处理，首先当然是引用生成的两个文件，然后还需要在VS中加入附加引用目录，也就是源码目录下的src目录，添加后再引用前面我们编译出的三个lib：1.libprotobuf.lib，2.libprotobuf-lite.lib，3.libprotoc.lib，然后就可以在工程中使用了，下面是一段解析data主体的示例代码：

  //取data主体数据
 
  int idataLength=bytesToInt(dataLength)-4;
  char* recvDataBuf=new char[idataLength];
  int getRevDataBodyLength=recv(m_sock,recvDataBuf,idataLength,0);
  if(getRevDataBodyLength==idataLength){	
	  Person serverPerson;
	  serverPerson.ParseFromString(recvDataBuf);
	  CCLog("personID=%d",serverPerson.id());
	  CCLog("personName=%s",serverPerson.name().c_str());
	  CCLog("personEmail=%s",serverPerson.email().c_str());
	//CCLog(recvDataBuf);
  }

上面我也是用protobuf里的示例文件还做的，相关的proto文件可以在examples下可以找到，其实上面还要引用一个命名空间 using namespace tutorial;

最后一步就可以开始通讯了，按照上一遍的方法，我们只要把传送的数据改为我们复用自定的消息模型封装的消息包就可以了：

	//构造protobuf消息
	Person person;
	std::string personData;
	person.set_id(1981);
	person.set_name("Clark Yang");
	person.set_email("[e-mail]");
	personData=person.SerializeAsString();
	//构造发送消息包
	Message* msg=constructMessage(personData.c_str(),2);
		//Message* msg=constructMessage("getSendMessage successful!",1);
		//发消息
		Send(msg->data,msg->datalength(),0);

和上一篇代码执行时一样，发送后可以在服务端的控制台上看到对应的消息输出，里面的三个字段值都是可以显示出来的……完整的客户端代码可以通过下面的链接下载：

http://download.csdn.net/detail/cyistudio/8136351