cocos2dx3.x利用sokcet创建客户端和服务端 (二)

Cocos2d-x 前端之家
前端之家收集整理的这篇文章主要介绍了cocos2dx3.x利用sokcet创建客户端和服务端 (二)，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。

服务端:

初始化服务端

向指定客户端发送消息

voidsendMessage(HSocketsocket,constchar*data,255); font-size:9.5pt; font-family:新宋体">intcount);

向所有客户端发送消息

void sendMessage(const char* data,int count);

当服务端开启后的回调函数

std::function<void(constchar*ip)>onStart;

当有新连接时的回调函数

void(HSocketsocket)>onNewConnection;

当有消息时的回调函数

std::function<void(intcount)>onRecv;

当有客户端断开连接时的回调函数

HSocketsocket)>onDisconnect;

SocketServer.h

[cpp] view plain copy
  1. #ifndef__SOCKET_SERVER_H__
  2. #define__SOCKET_SERVER_H__
  4. #include"SocketBase.h"
  5. classSocketServer:publicSocketBase
  6. {
  7. public:
  8. staticSocketServer*create();
  10. SocketServer();
  11. ~SocketServer();
  12. boolstartServer();
  13. voidsendMessage(HSocketsocket,constchar*data,intcount);
  14. voidsendMessage(intcount);
  15. std::function<void(char*ip)>onStart;
  16. std::function<void(HSocketsocket)>onNewConnection;
  17. intcount)>onRecv;
  18. void(HSocketsocket)>onDisconnect;
  19. private:
  20. boolinitServer();
  21. voidacceptClient();
  22. voidacceptFunc();
  23. voidnewClientConnected(HSocketsocket);
  24. voidrecvMessage(HSocketsocket);
  25. private:
  26. HSocket_socketServer;
  27. std::list<HSocket>_clientSockets;
  28. };
  29. #endif



SocketServer.cpp

    #include"SocketServer.h"
  1. SocketServer*SocketServer::create()
  2. {
  3. autoserver=newSocketServer;
  4. returnserver;
  5. }
  6. SocketServer::SocketServer():
  7. _socketServer(0),
  8. onRecv(nullptr),
  9. onStart(nullptr),248)"> onNewConnection(nullptr)
  10. }
  11. SocketServer::~SocketServer()
  12. _clientSockets.clear();
  13. if(_socketServer)
  14. this->closeConnect(_socketServer);
  15. };
  16. boolSocketServer::startServer()
  17. if(!initServer())
  18. returnfalse;
  19. true;
  20. boolSocketServer::initServer()
  21. if(_socketServer!=0)
  22. _socketServer=socket(AF_INET,SOCK_STREAM,0);
  23. if(error(_socketServer))
  24. log("socketerror!");
  25. _socketServer=0;
  26. false;
  27. do
  28. structsockaddr_insockAddr;
  29. memset(&sockAddr,sizeof(sockAddr));
  30. sockAddr.sin_family=AF_INET;
  31. sockAddr.sin_port=htons(8000);
  32. sockAddr.sin_addr.s_addr=htonl(INADDR_ANY);
  33. intret=0;
  34. ret=bind(_socketServer,(constsockaddr*)&sockAddr,153); font-weight:bold; background-color:inherit">if(ret<0)
  35. log("binderror!");
  36. break;
  37. ret=listen(_socketServer,5);
  38. if(ret<0)
  39. log("listenerror!");
  40. break;
  41. //start
  42. charhostName[256];
  43. gethostname(hostName,153); font-weight:bold; background-color:inherit">sizeof(hostName));
  44. structhostent*hostInfo=gethostbyname(hostName);
  45. char*ip=inet_ntoa(*(structin_addr*)*hostInfo->h_addr_list);
  46. this->acceptClient();
  47. if(onStart!=nullptr)
  48. log("startserver!");
  49. onStart(ip);
  50. true;
  51. }while(false);
  52. _socketServer=0;
  53. voidSocketServer::acceptClient()
  54. std::threadth(&SocketServer::acceptFunc,153); font-weight:bold; background-color:inherit">this);
  55. th.detach();
  56. voidSocketServer::acceptFunc()
  57. intlen=sizeof(sockaddr);
  58. structsockaddr_insockAddr;
  59. true)
  60. HSocketclientSock=accept(_socketServer,(sockaddr*)&sockAddr,&len);
  61. if(error(clientSock))
  62. log("accepterror!");
  63. this->newClientConnected(clientSock);
  64. voidSocketServer::newClientConnected(HSocketsocket)
  65. log("newconnect!");
  66. _clientSockets.push_back(socket);
  67. threadth(&SocketServer::recvMessage,153); font-weight:bold; background-color:inherit">this,socket);
  68. if(onNewConnection!=nullptr)
  69. onNewConnection(socket);
  70. voidSocketServer::recvMessage(HSocketsocket)
  71. charbuff[1024];
  72. ret=recv(socket,buff,153); font-weight:bold; background-color:inherit">sizeof(buff),0);
  73. log("recv(%d)error!",socket);
  74. _mutex.lock();
  75. this->closeConnect(socket);
  76. _clientSockets.remove(socket);
  77. if(onDisconnect!=nullptr)
  78. onDisconnect(socket);
  79. _mutex.unlock();
  80. else
  81. buff[ret]=0;
  82. log("recvmsg:%s",buff);
  83. if(ret>0&&onRecv!=nullptr)
  84. onRecv(buff,ret);
  85. voidSocketServer::sendMessage(HSocketsocket,87); font-weight:bold; background-color:inherit">intcount)
  86. for(auto&sock:_clientSockets)
  87. if(sock==socket)
  88. intret=send(socket,data,count,0);
  89. log("senderror!");
  90. voidSocketServer::sendMessage(intcount)
  91. for(auto&socket:_clientSockets)
  92. log("senderror!");
  93. }
原文链接：https://www.f2er.com/cocos2dx/345114.html

猜你在找的Cocos2d-x相关文章

创建自定义的Cocos2d-x场景
操作步骤 1、创建cocos2d-x工程 2、新建 Scene1.cpp Scene1.h Scene1.h代码 #ifndef __SCE...
给vs2010安装上cocos2d-x的模版
开发环境：OS(WINDOWS 8.1 X64 企业版) cocos2d-x 2.2.1 vs2010 想给vs安装上cocos的模版，...
Python创建Cocos2d-x 2.2方法
把创建项目做成一个批处理，当创建项目时可以省时省力很多。 操作步骤 1、在 E:cocos2d-x-...
cocos2dx 物理碰撞
https://www.cnblogs.com/JiaoQing/p/3906780.html 四个响应函数 1 EventListenerPhysics...
cocos2d-js 自定义事件监听派发
转载于 http://www.cnblogs.com/kenkofox/p/3926797.html 熟悉js的dom事件或者flash事件的...
cocos常用 实用 公共函数 lua代码
公共资源加载，缓存retain；防止被自动销毁 2. 数字滚动递增；用于得奖后，总金币跳动增加...
cocos creator box2d
title Map 使用box2d var sfloors = this.tiledMap.getObjectGroup(‘Special_Floor‘).g...
（转）让quick-cocos2d-x支持加密的plist文件
前篇：quick-cocos2d-x图片资源加密 在前篇里面，我们实现了图片资源的加密，但还没有实现...
（转）quick-cocos2d-x图片资源加密(续)
摘要: 对在quick-cocos2d-x上实现的资源加密方法的补充 前篇： quick-cocos2d-x图片资源加...
Cocos Creator 动态改变sprite图片
首先将存放图片最外层文件夹命名为resources 　　 changeBj: function(){ 　　　　var url...
iOSAndroidSwiftHybridCocos2d-xFlutterXcodeSilverlightcocoaCordova
调试桥筛选栏假异步不会丢失AndPermissio权限申请抽屉式systemUI信号栏多行排列跨多行显示viewmode数据共享录制语音视频通话多行显示Studio3.5拉伸控件望远镜发动态走势图点赞控件显示牌冷启动v3签名v2签名v1签名本地html外接键盘流式标签