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

Cocos2d-x 3.x利用Socket创建客户端和服务端

分类：Cocos2d-x作者：编程之家

From:http://cn.cocos2d-x.org/tutorial/show?id=2193

Socket基类

包括Socket的初始化,主要是Windows上，在Android上就不需要了。

如果平台为Windows，则需要初始化

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
SocketBase::SocketBase()
{
_bInitSuccess= false ;
# if (CC_TARGET_PLATFORM==CC_PLATFORM_WIN32)
WORD wVersionRequested;
wVersionRequested=MAKEWORD(2,0);
WSADATAwsaData;
int nRet=WSAStartup(wVersionRequested,&wsaData);
if (nRet!=0)
{
fprintf (stderr, "InitilizeError!\n" );
return ;
}
_bInitSuccess= true ;
#endif
}

当然析构时也要释放资源

1
2
3
4
5
6
7
8
9
SocketBase::~SocketBase()
{
# if (CC_TARGET_PLATFORM==CC_PLATFORM_WIN32)
if (_bInitSuccess)
{
WSACleanup();
}
#endif
}

因为Windows的socket()返回的socket句柄为SOCKET(UINT_PTR)与Android的socket()返回的socket句柄int,类型不一样，所以都定义为HSocket。


对于服务端和客户端都有关闭连接，所以基类就实现共同的。

1
2
3
4
5
6
7
8
void SocketBase::closeConnect(HSocketsocket)
{
# if (CC_TARGET_PLATFORM==CC_PLATFORM_ANDROID)
close(socket);
#elif(CC_TARGET_PLATFORM==CC_PLATFORM_WIN32)
closesocket(socket);
#endif
}

当执行socket()出错时，Windows返回SOCKET_ERROR,Android返回<0，所以实现error()

1
2
3
4
5
6
7
8
bool SocketBase::error(HSocketsocket)
{
# if (CC_TARGET_PLATFORM==CC_PLATFORM_WIN32)
return socket==SOCKET_ERROR;
#elif(CC_TARGET_PLATFORM==CC_PLATFORM_ANDROID)
return socket<0;
#endif
}

SocketBase.h

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
@H_155_502@ 32
33
34
35
36
37
38
39
40
41
42
43
#ifndef__SOCKET_BASE_H__
#define__SOCKET_BASE_H__
#include"cocos2d.h"
#include<list>
#include<thread>
USING_NS_CC;
//对于windows平台
#if(CC_TARGET_PLATFORM==CC_PLATFORM_WIN32)
#include<WinSock2.h>
#pragmacomment(lib,"WS2_32.lib")
#defineHSocketSOCKET
//对于android平台
#elif(CC_TARGET_PLATFORM==CC_PLATFORM_ANDROID)
#include<arpa/inet.h> //forinet_**
#include<netdb.h> //forgethost**
#include<netinet/in.h> //forsockaddr_in
#include<sys/types.h> //forsocket
#include<sys/socket.h> //forsocket
#include<unistd.h>
#include<stdio.h> //forprintf
#include<stdlib.h> //forexit
#include<string.h> //forbzero
#defineHSocketint
#endif
class SocketBase: public Ref
{
public :
SocketBase();
~SocketBase();
@H_155_502@ protected :
void closeConnect(HSocketsocket);
bool error(HSocketsocket);
protected :
std::mutex_mutex;
private :
bool _bInitSuccess;
};
#endif


服务端

初始化服务端

向指定客户端发送消息

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

向所有客户端发送消息

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

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

1
std::function< void ( const char *ip)>onStart;

当有新连接时的回调函数

1
std::function< void (HSocketsocket)>onNewConnection;

当有消息时的回调函数

1
std::function< void ( const char *data, int count)>onRecv;

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

1
std::function< void (HSocketsocket)>ondisconnect;

SocketServer.h

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
@H_155_502@ 32
33
34
35
36
37
38
#ifndef__SOCKET_SERVER_H__
#define__SOCKET_SERVER_H__
#include"SocketBase.h"
class SocketServer: public SocketBase
{
public :
static SocketServer*create();
SocketServer();
~SocketServer();
bool startServer();
void sendMessage(HSocketsocket, int count);
void sendMessage( const char *data, int count);
std::function< void ( const char *ip)>onStart;
std::function< void (HSocketsocket)>onNewConnection;
std::function< void ( const char *data, int count)>onRecv;
std::function< void (HSocketsocket)>ondisconnect;
private :
bool initServer();
void acceptClient();
void acceptFunc();
void newClientConnected(HSocketsocket);
void recvMessage(HSocketsocket);
private :
HSocket_socketServer;
@H_155_502@
private :
std::list<HSocket>_clientSockets;
};
#endif

SocketServer.cpp

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
@H_155_502@ 32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
@H_86_1404@ 62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
@H_983_1502@ 111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
#include"SocketServer.h"
SocketServer*SocketServer::create()
{
autoserver= new SocketServer;
return server;
}
SocketServer::SocketServer():
_socketServer(0),
onRecv(nullptr),
onStart(nullptr),
onNewConnection(nullptr)
{
}
SocketServer::~SocketServer()
{
_clientSockets.clear();
if (_socketServer)
{
this ->closeConnect(_socketServer);
}
};
bool SocketServer::startServer()
{
if (!initServer())
@H_155_502@ {
return false ;
}
return true ;
}
bool SocketServer::initServer()
{
if (_socketServer!=0)
{
this ->closeConnect(_socketServer);
}
_socketServer=socket(AF_INET,SOCK_STREAM,0);
if (error(_socketServer))
{
log ( "socketerror!" );
_socketServer=0;
return false ;
}
do
{
struct sockaddr_insockAddr;
memset (&sockAddr, sizeof (sockAddr));
sockAddr.sin_family=AF_INET;
sockAddr.sin_port=htons(8000);
sockAddr.sin_addr.s_addr=htonl(INADDR_ANY);
int ret=0;
ret=bind(_socketServer,( const sockaddr*)&sockAddr, sizeof (sockAddr));
@H_86_1404@ if (ret<0)
{
log ( "binderror!" );
break ;
}
ret=listen(_socketServer,5);
if (ret<0)
{
log ( "listenerror!" );
break ;
}
//start
char hostName[256];
gethostname(hostName, sizeof (hostName));
struct hostent*hostInfo=gethostbyname(hostName);
char *ip=inet_ntoa(*( struct in_addr*)*hostInfo->h_addr_list);
this ->acceptClient();
if (onStart!=nullptr)
{
log ( "startserver!" );
onStart(ip);
}
return true ;
} while ( false );
this ->closeConnect(_socketServer);
_socketServer=0;
return false ;
}
void SocketServer::acceptClient()
{
std:: thread th(&SocketServer::acceptFunc, this );
th.detach();
}
void SocketServer::acceptFunc()
{
int len= sizeof (sockaddr);
struct sockaddr_insockAddr;
while ( true )
{
HSocketclientSock=accept(_socketServer,(sockaddr*)&sockAddr,&len);
if (error(clientSock))
{
@H_983_1502@ log ( "accepterror!" );
break ;
}
this ->newClientConnected(clientSock);
}
}
void SocketServer::newClientConnected(HSocketsocket)
{
log ( "newconnect!" );
_clientSockets.push_back(socket);
std:: thread th(&SocketServer::recvMessage, this ,socket);
th.detach();
if (onNewConnection!=nullptr)
{
onNewConnection(socket);
}
}
void SocketServer::recvMessage(HSocketsocket)
{
char buff[1024];
int ret=0;
while ( true )
{
ret=recv(socket,buff, sizeof (buff),0);
if (ret<0)
{
log ( "recv(%d)error!" ,socket);
_mutex.lock();
this ->closeConnect(socket);
_clientSockets. remove (socket);
if (ondisconnect!=nullptr)
{
ondisconnect(socket);
}
_mutex.unlock();
break ;
}
else
{
buff[ret]=0;
log ( "recvmsg:%s" ,buff);
if (ret>0&&onRecv!=nullptr)
{
onRecv(buff,ret);
}
}
}
}
void SocketServer::sendMessage(HSocketsocket, int count)
{
for (auto&sock:_clientSockets)
{
if (sock==socket)
{
int ret=send(socket,data,count,0);
if (ret<0)
{
log ( "senderror!" );
}
break ;
}
}
}
void SocketServer::sendMessage( const char *data, int count)
{
for (auto&socket:_clientSockets)
{
int ret=send(socket,0);
if (ret<0)
{
log ( "senderror!" );
}
}
}


客户端

连接服务端

1
bool connectServer( const char *serverIP,unsigned short port);

向服务端发送消息

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

接受服务端数据的回调函数

1
std::function< void ( const char *data, int count)>onRecv;

断开连接的回调函数

1
std::function< void ()>ondisconnect;

SocketClient.h

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
#ifndef__SOCKET_CLIENT_H__
#define__SOCKET_CLIENT_H__
#include"SocketBase.h"
class SocketClient: public SocketBase
{
public :
SocketClient( void );
~SocketClient( void );
bool connectServer( const char *serverIP,unsigned short port);
void sendMessage( const char *data, int count);
std::function< void ( const char *data, int count)>onRecv;
std::function< void ()>ondisconnect;
private :
bool initClient();
void recvMessage();
private :
HSocket_socketServer;
HSocket_socektClient;
};
#endif

SocketClient.cpp

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
@H_155_502@ 32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
@H_86_1404@ 62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
#include"SocketClient.h"
SocketClient::SocketClient( void ):
onRecv(nullptr),
_socektClient(0)
{
}
SocketClient::~SocketClient( void )
{
if (_socektClient!=0)
{
_mutex.lock();
this ->closeConnect(_socektClient);
_mutex.unlock();
}
}
bool SocketClient::initClient()
{
if (_socektClient!=0)
{
_mutex.lock();
this ->closeConnect(_socektClient);
_mutex.unlock();
}
_socektClient=socket(AF_INET,0);
if (error(_socketServer))
@H_155_502@ {
log ( "initclienterror!" );
_socektClient=0;
return false ;
}
return true ;
}
bool SocketClient::connectServer( const char *serverIP,unsigned short port)
{
if (! this ->initClient())
{
return false ;
}
struct sockaddr_inserverAddr;
memset (&serverAddr, sizeof ( struct sockaddr_in));
serverAddr.sin_family=AF_INET;
serverAddr.sin_port=htons(port);
serverAddr.sin_addr.s_addr=inet_addr(serverIP);
int ret=0;
ret=connect(_socektClient,( struct sockaddr*)&serverAddr, sizeof ( struct sockaddr));
if (ret<0)
{
this ->closeConnect(_socektClient);
_socektClient=0;
return false ;
@H_86_1404@ }
std:: thread recvThread(&SocketClient::recvMessage, this );
recvThread.detach();
return true ;
}
void SocketClient::recvMessage()
{
char recvBuf[1024];
int ret=0;
while ( true )
{
ret=recv(_socektClient,recvBuf, sizeof (recvBuf),0);
if (ret<0)
{
log ( "recverror" );
break ;
}
if (ret>0&&onRecv!=nullptr)
{
onRecv(recvBuf,ret);
}
}
_mutex.lock();
this ->closeConnect(_socektClient);
if (ondisconnect!=nullptr)
{
ondisconnect();
}
_socektClient=0;
_mutex.unlock();
}
void SocketClient::sendMessage( const char *data, int count)
{
if (_socektClient!=0)
{
int ret=send(_socektClient,0);
if (ret<0)
{
log ( "senderror!" );
}
}
}

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [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