AI导航网
微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

跟着BOY 学习COCOS2D-X 网络篇---强联网采用技术 BSD SOCKET+多线程技术 +protobuf客户端实战篇

分类：Cocos2d-x作者：编程之家
http://blog.csdn.net/zzhboy/article/details/9878941
分类：cocos2d-x 编译cocos2d-x SOCKETgoogle protobuf 2013-08-10 16:41 9314人阅读 评论(36) 收藏 举报
cocos2d-x 多线程 google protobuf socket 网络

如果按照上面的一讲 你如果把环境搭建好了，下面我们就正式开始客户端的搭建 首先我献给大家画一张我的客户端实现的流程图

我PS 画的大家不要见怪啊 不过流程就是这样的

搭建看到我上面的框架图的时候 就知道我的大概设计思路，

boy 在这里强调一点 这个是用异步的结构实现 其中线程类 我是参照java 里面的方法。

好了废话不多 首先先上 BSD SOCKET 这个核心类

[cpp] view plain copy
  1. /*
  2. *definefileaboutportablesocketclass.
  3. *description:thissockissuitbothwindowsandlinux
  4. *design:odison
  5. *e-mail:odis[email protected]>
  6. *
  7. */
  9. #ifndef_ODSOCKET_H_
  10. #define_ODSOCKET_H_
  12. #ifdefWIN32
  13. #include<winsock2.h>
  14. typedefintsocklen_t;
  15. #else
  16. #include<sys/socket.h>
  17. #include<netinet/in.h>
  18. #include<netdb.h>
  19. #include<fcntl.h>
  20. #include<unistd.h>
  21. #include<sys/stat.h>
  22. #include<sys/types.h>
  23. #include<arpa/inet.h>
  24. intSOCKET;
  25. //#pragmaregiondefinewin32constvariableinlinux
  26. #defineINVALID_SOCKET-1
  27. #definesOCKET_ERROR-1
  28. //#pragmaendregion
  29. #endif
  30. classODSocket{
  31. public:
  32. ODSocket(SOCKETsock=INVALID_SOCKET);
  33. ~ODSocket();
  34. //Createsocketobjectforsnd/recvdata
  35. boolCreate(intaf,inttype,87); font-weight:bold; background-color:inherit">intprotocol=0);
  36. //Connectsocket
  37. boolConnect(constchar*ip,unsignedshortport);
  38. //#regionserver
  39. //Bindsocket
  40. boolBind(unsignedshortport);
  41. //Listensocket
  42. boolListen(intbacklog=5);
  43. //Acceptsocket
  44. boolAccept(ODSocket&s,87); font-weight:bold; background-color:inherit">char*fromip=NULL);
  45. //#endregion
  46. intSelect();
  47. //Sendsocket
  48. intSend(char*buf,87); font-weight:bold; background-color:inherit">intlen,87); font-weight:bold; background-color:inherit">intflags=0);
  49. //Recvsocket
  50. intRecv(intflags=0);
  51. //Closesocket
  52. intClose();
  53. //Geterrno
  54. intGetError();
  55. //#pragmaregionjustforwin32
  56. //InitwinsockDLL
  57. staticintInit();
  58. //CleanwinsockDLL
  59. intClean();
  60. //#pragmaendregion
  61. //Domainparse
  62. boolDnsParse(char*domain,87); font-weight:bold; background-color:inherit">char*ip);
  63. ODSocket&operator=(SOCKETs);
  64. operatorSOCKET();
  65. protected:
  66. SOCKETm_sock;
  67. fd_setfdr;
  68. };
  69. #endif
对于这个类 我主要讲解四个方法 一个就是Connect 这个方法 这个主要是用来连接的

第二个 Send 方法 这个主要是用来发送数据的

第三个方法Recv 这个主要是用来接收数据的、

第四个方法Select 这个主要用来判断当前socket 的状态，这里我只用了 判断是否有数据回来这个方法。


这里说明一下 一旦调用recv 这个方法 他会一直等到读取到数据，所以在我们正常的开发游戏过程中。我们都会把它放到单独的线程中来执行。防止我们的主线程卡死。

好下面介绍一下我们的 连接线程类

copy
    #pragmaonce
  1. #include"ODSocket.h"
  2. #include"pthread.h"
  3. classSocketThread
  4. {
  5. public:
  6. ~SocketThread(void);
  7. staticSocketThread*GetInstance();
  8. intstart();
  9. ODSocketgetSocket();
  10. intstate;//0表示连接成功1表示连接失败
  11. ODSocketcsocket;
  12. voidstop();//函数中止当前线程。
  13. private:
  14. pthread_tpid;
  15. staticvoid*start_thread(void*);//静态成员函数,相当于C中的全局函数
  16. SocketThread(staticSocketThread*m_pInstance;
  17. };

这个线程类是用来连接 我们的 服务器的 大家看到我上面的方法就可以才想到 我这个类是一个单利的模式。因为一个游戏中正常情况下只需要一个 套接字即可。所以我这个类采用了单利的模式可以获取一个套接字对象 。

下面贴上实现

copy

    #include"SocketThread.h"
  1. #include"cocos2d.h"
  2. #include"ResPonseThread.h"
  3. USING_NS_CC;
  4. intSocketThread::start(){
  5. interrCode=0;
  6. do{
  7. pthread_attr_ttAttr;
  8. errCode=pthread_attr_init(&tAttr);
  9. CC_BREAK_IF(errCode!=0);
  10. //但是上面这个函数其他内容则主要为你创建的线程设定为分离式
  11. errCode=pthread_attr_setdetachstate(&tAttr,PTHREAD_CREATE_DETACHED);
  12. if(errCode!=0){
  13. pthread_attr_destroy(&tAttr);
  14. break;
  15. }
  16. errCode=pthread_create(&pid,&tAttr,start_thread,this);
  17. }while(0);
  18. returnerrCode;
  19. void*SocketThread::start_thread(void*arg){
  20. SocketThread*thred=(SocketThread*)arg;
  21. ODSocketcdSocket;
  22. cdSocket.Init();
  23. boolisok=cdSocket.Create(AF_INET,SOCK_STREAM,0);
  24. booliscon=cdSocket.Connect("127.0.0.1",8888);
  25. if(iscon){
  26. thred->state=0;
  27. ResPonseThread::GetInstance()->start();//启动响应参数
  28. cclOG("conection");
  29. }else{
  30. thred->state=1;
  31. }
  32. thred->csocket=cdSocket;
  33. returnNULL;
  34. ODSocketSocketThread::getSocket(){
  35. returnthis->csocket;
  36. SocketThread*SocketThread::m_pInstance=newSocketThread;
  37. SocketThread*SocketThread::GetInstance(){
  38. returnm_pInstance;
  39. voidSocketThread::stop(){
  40. pthread_cancel(pid);
  41. pthread_detach(pid);
  42. SocketThread::SocketThread(void)
  43. {
  44. SocketThread::~SocketThread(if(m_pInstance!=NULL){
  45. deletem_pInstance;
  46. }
对于多线程不是很熟悉的同学们可以在 百度 下相关的资料。只要实现了上面的类，我们就可以连接tong服务器了

下面贴出

接收线程类

copy

    //此类主要处理服务器推送过来的消息
  1. #include"BaseResponseMsg.h"
  2. typedefvoid(cocos2d::CCObject::*ResPonseThreadEvent)(BaseResponseMsg*);
  3. #definecallFunc_selectormsg(_SELECTOR)(ResPonseThreadEvent)(&_SELECTOR)
  4. #defineM_ADDCALLBACKEVENT(varName)\
  5. protected:cocos2d::CCObject*m_##varName##listener;ResPonseThreadEventvarName##selector;\
  6. public:voidadd##varName##ListenerEvent(ResPonseThreadEventm_event,cocos2d::CCObject*listener){m_##varName##listener=listener;varName##selector=m_event;}
  7. classResPonseThread
  8. ~ResPonseThread(void);
  9. staticResPonseThread*GetInstance();//获取该类的单利
  10. intstart(void*=NULL);//函数是线程启动函数，其输入参数是无类型指针。
  11. voidsleep(inttesec);//函数让当前线程休眠给定时间，单位为毫秒秒。
  12. voiddetach();//
  13. void*wait();
  14. ResPonseThread( pthread_thandle;
  15. boolstarted;
  16. booldetached;
  17. void*threadFunc(void*);
  18. staticResPonseThread*m_pInstance;
  19. M_ADDCALLBACKEVENT(msg);//聊天回调函数
  20. M_ADDCALLBACKEVENT(notcon);//断网回调函数
  21. 这个并不算一个完整的类，因为不同的命令对应的回调函数不一样 当然你也可以弄成一个回调函数，不过我喜欢把东西分开来写

    实现代码

    copy

    #include"BaseResponseMsg.h"
  1. ResPonseThread*ResPonseThread::m_pInstance=newResPonseThread;
  2. ResPonseThread*ResPonseThread::GetInstance(){
  3. ResPonseThread::ResPonseThread(this->m_msglistener=NULL;
  4. started=detached=false;
  5. ResPonseThread::~ResPonseThread(void)
  6. stop();
  7. intResPonseThread::start(void*param){
  8. interrCode=0;
  9. do{
  10. pthread_attr_tattributes;
  11. errCode=pthread_attr_init(&attributes);
  12. CC_BREAK_IF(errCode!=0);
  13. //但是上面这个函数其他内容则主要为你创建的线程设定为分离式
  14. errCode=pthread_attr_setdetachstate(&attributes,PTHREAD_CREATE_DETACHED);
  15. if(errCode!=0){
  16. pthread_attr_destroy(&attributes);
  17. break;
  18. errCode=pthread_create(&handle,&attributes,threadFunc,153); font-weight:bold; background-color:inherit">this);
  19. started=true;
  20. void*ResPonseThread::threadFunc(void*arg){
  21. ResPonseThread*thred=(ResPonseThread*)arg;
  22. ODSocketcsocket=SocketThread::GetInstance()->getSocket();
  23. if(SocketThread::GetInstance()->state==0){
  24. while(true){
  25. //表示服务器端有消息推送过来
  26. if(csocket.Select()==-2){
  27. charrecvBuf[8];//获取请求头的数据
  28. inti=csocket.Recv(recvBuf,8,0);
  29. if(i==8){
  30. chardc1[2]={recvBuf[1],recvBuf[0]};
  31. shortlen=*(short*)&dc1[0];
  32. chardc2[2]={recvBuf[3],recvBuf[2]};
  33. shortcode=*(short*)&dc2[0];
  34. chardc3[4]={recvBuf[7],recvBuf[6],recvBuf[5],recvBuf[4]};
  35. intplayId=*(int*)&dc3[0];
  36. cclOG("%d",playId);
  37. char*messbody=NULL;
  38. intmyl=0;
  39. if(len>8){
  40. myl=len-8;
  41. messbody=newchar[myl];
  42. csocket.Recv(messbody,myl,0);
  43. ////1001=com.lx.command.player.LoginCmd
  44. //1002=com.lx.command.player.RegisterCmd
  45. //1003=com.lx.command.player.HeartBeatCmd
  46. //登陆
  47. BaseResponseMsg*basmsg=newBaseResponseMsg();
  48. basmsg->code=code;
  49. basmsg->len=len;
  50. basmsg->playerId=playId;
  51. //表示服务器推动过来的消息
  52. if(code==1000){
  53. if(thred->m_msglistener){
  54. basmsg->setStringToMsg(messbody,myl);
  55. (thred->m_msglistener->*(thred->msgselector))(basmsg);
  56. else{
  57. cclOG("%d",code);
  58. if(thred->m_notconlistener){
  59. basmsg->state=1;//连接断开
  60. (thred->m_notconlistener->*(thred->notconselector))(basmsg);
  61. voidResPonseThread::stop(){
  62. if(started&&!detached){
  63. pthread_cancel(handle);
  64. pthread_detach(handle);
  65. detached=void*ResPonseThread::wait(){
  66. void*status=NULL;
  67. if(started&&!detached){
  68. pthread_join(handle,&status);
  69. returnstatus;
  70. voidResPonseThread::sleep(intsecstr){
  71. timevaltimeout={secstr/1000,secstr%1000};
  72. select(0,NULL,&timeout);
  73. voidResPonseThread::detach(){
  74. pthread_detach(handle);
  75. }

当大家看到接收代码的时候或许很困惑。这里是引文大小端的问。还有前八个字节是我们规定好的，所以只要解析出前八个字节我们就知道服务器给传送过来的什么。 然后调用响应的回调 通知请求方即可。

下面贴出 一个消息体组装类

copy

    #include<string.h>
  1. #include"ConvertEndianUtil.h"
  2. structmessageHead{
  3. shortlen;
  4. shortcode;
  5. intplayerid;
  6. }messagehead;
  7. template<typenameRquest>classBaseRequestMsg
  8. BaseRequestMsg( ~BaseRequestMsg(voidsetRequestMessage(Rquestmessage);//设置请求体
  9. voidsetMessageHead(shortcode,87); font-weight:bold; background-color:inherit">intplayer=0);//设置请求头
  10. boolsendMessage();//发送信息
  11. private:
  12. Rquestrequestmessage;
  13. messageheadmessageHead;
  14. char*getSendMessage();
  15. shortdateLength;
  16. std::stringrequestMessage;
  17. };
  18. typenameRquest>
  19. BaseRequestMsg<Rquest>::BaseRequestMsg(void){
  20. typenameRquest>
  21. BaseRequestMsg<Rquest>::~BaseRequestMsg(void){
  22. voidBaseRequestMsg<Rquest>::setRequestMessage(Rquestmessage){
  23. std::stringdata;
  24. message.SerializetoString(&data);
  25. this->requestMessage=data;
  26. voidBaseRequestMsg<Rquest>::setMessageHead(intplayer){
  27. messageHead.code=ConvertEndianUtil::convertEndianShort(code);
  28. messageHead.playerid=ConvertEndianUtil::convertForInt(player);
  29. char*BaseRequestMsg<Rquest>::getSendMessage(){
  30. shorttotal=8+requestMessage.length();
  31. dateLength=total;
  32. messageHead.len=ConvertEndianUtil::convertEndianShort(total);
  33. char*requestmessage=char[total];
  34. char*requestmessagehead=(char*)&messageHead;
  35. inti=sizeof(messageHead);
  36. intlen=sizeof(requestMessage.c_str())/sizeof(char);
  37. memcpy(requestmessage,requestmessagehead,8);
  38. memcpy(&requestmessage[8],requestMessage.c_str(),requestMessage.length());
  39. returnrequestmessage;
  40. boolBaseRequestMsg<Rquest>::sendMessage(){
  41. ODSocketcSocket=SocketThread::GetInstance()->getSocket();
  42. char*dd=this->getSendMessage();
  43. intcout=cSocket.Send(this->getSendMessage(),this->dateLength,153); font-weight:bold; background-color:inherit">if(cout==this->dateLength){
  44. false;
  45. }
这里采用了C++ 类模板 这样可以让我们的程序更通用一点。 这个主要是针对protobuf 协议体的组装。

下面给大家贴上一段调用代码

copy

    BaseRequestMsg<zzboy::protobuf::ChatMsgReq>*baserlong=newBaseRequestMsg<zzboy::protobuf::ChatMsgReq>();
  1. zzboy::protobuf::ChatMsgReqreq;
  2. req.set_msgtype(1);
  3. req.set_message("ddddd");
  4. baserlong->setMessageHead((short)1000,(int)1);
  5. baserlong->setRequestMessage(req);
  6. baserlong->sendMessage();
这就是一个发送消息的方法，哈哈看起来很简单吧。

这里我做的demo 是 聊天系统。在很多游戏里面都有聊天。这里就是一个简单的实现。不过整体的思路应该是这样

红色区域内 1 表示我自己说的话 4545 是别人说的话。其实只要服务器通知我 有人给我发送消息。都会在这里展示出来。

在这里我遇见一个BUG 就是 cclabelTTF* lable = cclabelTTF::create(tem,"Arial",24); 这个标签的创建 在线程的回调函数中我始终穿件不成功。导致我用了另外的一个办法解决。这里如果谁知道这个BUG 为什么 请私信给我活着留言给我。咱们共同进步

哈哈 写到这里网络连接着一块就完了，其实感觉也没什么，最重要的就是你解析过数据之后要干什么。大家发现BOY 是不是全才 服务器和客户端都会 。我感觉如果时间允许我自己可以做一个小型的多人在线网络游戏。 哈哈。

关于上面讲到的可能有些人还是不明白。可以留言给我或者在码农哥的群里给我说，如果我看到了都会给大家讲解。这两天这是忍着病给大家写的 有哪些写的不好请见谅。

客户端源码下载

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。

相关推荐

如何使用CCRenderTexture创建动态纹理 Cocos2d-x 2 1 4
    本文实践自 RayWenderlich、Ali Hafizji 的文章《How To Create Dynamic Textures with CCRenderTexture in Cocos2D 2.X》，文中使用Cocos2D，我在这里使用Cocos2D-x 2.1.4进行学习和移植。在这...
Cocos-code-ide使用入门学习
Cocos-code-ide使用入门学习地点：杭州滨江邮箱：[email protected]微信公众号：HopToad 欢迎转载，转载标注出处：http://blog.csdn.netotbaron/article/details/424343991.  软件准备 下载地址：http://cn.cocos...
Cocos2D-x-3.0 编译(Win7)
第一次開始用手游引擎挺激动！！！进入正题。下载资源1：从Cocos2D-x官网上下载，进入网页http://www.cocos2d-x.org/download，点击Cocos2d-x以下的Download  v3.0，保存到自定义的文件夹2：从python官网上下载。进...
Cocos2d-x 2 0 在Windows平台下的使用
    Cocos2d-x是一款强大的基于OpenGLES的跨平台游戏开发引擎，易学易用，支持多种智能移动平台。官网地址：http://cocos2d-x.org/当前版本：2.0    有很多的学习资料，在这里我只做为自己的笔记记录下来，错...
quick-cocos2d-x实例之挑战记忆极限设计文档
1.  来源 QuickV3sample项目中的2048样例游戏，以及最近《最强大脑》娱乐节目。将2048改造成一款挑战玩家对数字记忆的小游戏。邮箱：[email protected]微信公众号：HopToadAPK下载地址：http://download.csdn.net/...
Cocos2d-x 3 X CMake MinGW版本编译运行
   Cocos2d-x3.x已经支持使用CMake来进行构建了，这里尝试以QtCreatorIDE来进行CMake构建。Cocos2d-x3.X地址：https://github.com/cocos2d/cocos2d-x1.打开QtCreator，菜单栏→"打开文件或项目..."，打...
vs 2013 编译cocos2d-x-3.9
 下载地址：链接:https://pan.baidu.com/s/1IkQsMU6NoERAAQLcCUMcXQ提取码:p1pb下载完成后，解压进入build目录使用vs2013打开工程设置平台工具集，打开设置界面设置： 点击开始编译等待编译结束编译成功在build文件...
cocos2d-x游戏开发系列教程-超级玛丽01-前言
分享一下我老师大神的人工智能教程吧。零基础！通俗易懂！风趣幽默！还带黄段子！希望你也加入到我们人工智能的队伍中来！http://www.captainbed.net前言上次用象棋演示了cocos2dx的基本用法，但是对cocos2dx并没有作...
Cocos2d-x CCControlPotentiometer之圆形音量button及特效
1. 圆形音量button事实上作者的本意应该是叫做“电位计button”。可是我觉得它和我们的圆形音量button非常像，所以就这么叫它吧~先看效果：好了，不多解释，本篇到此为止。（旁白： 噗。就这样结束了？）啊才怪~我...
Cocos2d-x入门教程二简单的静态显示对象
原文链接：http://www.cnblogs.com/physwf/archive/2013/04/26/3043912.html为了进一步深入学习贯彻Cocos2d，我们将自己写一个场景类，但我们不会走的太远，凡是都要循序渐进，哪怕只前进一点点，那也至少是前进了，...
    pythonJavaScriptjavaHTMLreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-bootreact-native