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

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

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

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

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

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

对于这个类我主要讲解四个方法一个就是Connect 这个方法这个主要是用来连接的

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

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

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

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

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

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

对于多线程不是很熟悉的同学们可以在百度下相关的资料。只要实现了上面的类，我们就可以连接tong服务器了下面贴出

接收线程类

这个并不算一个完整的类，因为不同的命令对应的回调函数不一样当然你也可以弄成一个回调函数，不过我喜欢把东西分开来写实现代码

#include"ResPonseThread.h"
#include"cocos2d.h"
#include"SocketThread.h"
#include"BaseResponseMsg.h"
ResPonseThread*ResPonseThread::m_pInstance=newResPonseThread;
ResPonseThread*ResPonseThread::GetInstance(){
returnm_pInstance;
}
ResPonseThread::ResPonseThread(void)
{
this->m_msglistener=NULL;
started=detached=false;
}
ResPonseThread::~ResPonseThread(void)
{
stop();
}
intResPonseThread::start(void*param){
interrCode=0;
do{
pthread_attr_tattributes;
errCode=pthread_attr_init(&attributes);
CC_BREAK_IF(errCode!=0);
errCode=pthread_attr_setdetachstate(&attributes,PTHREAD_CREATE_DETACHED);
if(errCode!=0){
pthread_attr_destroy(&attributes);
break;
}
errCode=pthread_create(&handle,&attributes,threadFunc,this);
started=true;
}while(0);
returnerrCode;
}
void*ResPonseThread::threadFunc(void*arg){
ResPonseThread*thred=(ResPonseThread*)arg;
ODSocketcsocket=SocketThread::GetInstance()->getSocket();
if(SocketThread::GetInstance()->state==0){
while(true){
if(csocket.Select()==-2){
charrecvBuf[8];
inti=csocket.Recv(recvBuf,8,0);
if(i==8){
chardc1[2]={recvBuf[1],recvBuf[0]};
shortlen=*(short*)&dc1[0];
chardc2[2]={recvBuf[3],recvBuf[2]};
shortcode=*(short*)&dc2[0];
chardc3[4]={recvBuf[7],recvBuf[6],recvBuf[5],recvBuf[4]};
intplayId=*(int*)&dc3[0];
CCLOG("%d",playId);
char*messbody=NULL;
intmyl=0;
if(len>8){
myl=len-8;
messbody=newchar[myl];
csocket.Recv(messbody,myl,0);
}
BaseResponseMsg*basmsg=newBaseResponseMsg();
basmsg->code=code;
basmsg->len=len;
basmsg->playerId=playId;
if(code==1000){
if(thred->m_msglistener){
basmsg->setStringToMsg(messbody,myl);
(thred->m_msglistener->*(thred->msgselector))(basmsg);
}
}
else{
CCLOG("%d",code);
}
}else{
if(thred->m_notconlistener){
BaseResponseMsg*basmsg=newBaseResponseMsg();
basmsg->state=1;
(thred->m_notconlistener->*(thred->notconselector))(basmsg);
}
break;
}
}
}
}
returnNULL;
}
voidResPonseThread::stop(){
if(started&&!detached){
pthread_cancel(handle);
pthread_detach(handle);
detached=true;
}
}
void*ResPonseThread::wait(){
void*status=NULL;
if(started&&!detached){
pthread_join(handle,&status);
}
returnstatus;
}
voidResPonseThread::sleep(intsecstr){
timevaltimeout={secstr/1000,secstr%1000};
select(0,NULL,&timeout);
}
voidResPonseThread::detach(){
if(started&&!detached){
pthread_detach(handle);
}
detached=true;
}

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

这里采用了C++ 类模板这样可以让我们的程序更通用一点。这个主要是针对protobuf 协议体的组装。下面给大家贴上一段调用代码

这就是一个发送消息的方法，哈哈看起来很简单吧。这里我做的demo 是聊天系统。在很多游戏里面都有聊天。这里就是一个简单的实现。不过整体的思路应该是这样

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

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

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

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

客户端源码下载

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

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

相关推荐