cocos2d-x学习篇之网络（http）篇

classCCHttpRequest:publicCCObject
1. public:
2. /**请求类型枚举，可以通过setReqeustType(param)设置*/
3. typedefenum
4. kHttpGet,
5. kHttpPost,
6. kHttpUnkown,248)"> }HttpRequestType;
7. /**Constructor
8. BecauseHttpRequestobjectwillbeusedbetweenUItheadandnetworkthread,
9. requestObj->autorelease()isforbiddentoavoidcrashesinCCAutoreleasePool
10. new/retain/releasestillworks,whichmeansyouneedtoreleaseitmanually
11. PleaserefertoHttpRequestTest.cpptofinditsusage
12. 这里是有注释的，因为要跨线程，所以就不能用autorelease()
13. 我们在使用HttpRequest的时候，需要自己new，然后再release下就可以了
14. 当我们把HttpRequest传递给CCHttpClient的时候，CCHttpClient已经帮我们retain了
15. 工作线程中，需要使用CCHttpRequest对象new一个CCHttpResponse,CCHttprequest会retain一次，所以工作线程也会release一次
16. 具体的后文有
17. */
18. CCHttpRequest()
19. _requestType=kHttpUnkown;
20. _url.clear();
21. _requestData.clear();
22. _tag.clear();
23. _pTarget=NULL;
24. _pSelector=NULL;
25. _pUserData=NULL;
26. };
27. virtual~CCHttpRequest()
28. if(_pTarget)
29. _pTarget->release();
30. /**重载autorelease函数，禁止调用*/
31. CCObject*autorelease(void)
32. CCAssert(false,"HttpResponseisusedbetweennetworkthreadanduithread
33. therefore,autoreleaseisforbiddenhere");
34. returnNULL;
35. //setter/gettersforproperties
36. /**设置请求类型
37. 目前支持kHttpGet和kHttpPost
38. inlinevoidsetRequestType(HttpRequestTypetype)
39. _requestType=type;
40. /**返回请求类型*/
41. inlineHttpRequestTypegetRequestType()
42. return_requestType;
43. };
44. /**设置请求url
45. voidsetUrl(constchar*url)
46. _url=url;
47. /**获取请求url*/
48. char*getUrl()
49. return_url.c_str();
50. /**这个设置用于post方式的data数据
51. voidsetRequestData(char*buffer,unsignedintlen)
52. _requestData.assign(buffer,buffer+len);
53. /**Gettherequestdatapointerback*/
54. inlinechar*getRequestData()
55. return&(_requestData.front());
56. /**Getthesizeofrequestdataback*/
57. intgetRequestDataSize()
58. return_requestData.size();
59. /**为每个请求设置一个字符串标示，可以通过HttpResponse->getHttpRequest->getTag()获取，因为HttpResponse会将对应的HttpRequest封装在里面
60. */
61. voidsetTag(char*tag)
62. _tag=tag;
63. /**Getthestringtagbacktoidentifytherequest.
64. ThebestpracticeistouseitinyourMyClass::onMyHttpRequestCompleted(sender,HttpResponse*)callback
65. char*getTag()
66. return_tag.c_str();
67. /**Optionfield.Youcanattachacustomeddataineachrequest,andgetitbackinresponsecallback.
68. Butyouneedtonew/deletethedatapointermanully
69. voidsetUserData(void*pUserData)
70. _pUserData=pUserData;
71. /**Getthepre-settedcustomdatapointerback.
72. Don'tforgettodeleteit.HttpClient/HttpResponse/HttpRequestwilldonothingwiththispointer
73. void*getUserData()
74. return_pUserData;
75. /**通过这个函数设置我们的数据处理回调函数
76. voidsetResponseCallback(CCObject*pTarget,SEL_CallFuncNDpSelector)
77. _pTarget=pTarget;
78. _pSelector=pSelector;
79. _pTarget->retain();
80. /**Getthetargetofcallbackselectorfuntion,mainlyusedbyCCHttpClient*/
81. inlineCCObject*getTarget()
82. return_pTarget;
83. /**Gettheselectorfunctionpointer,mainlyusedbyCCHttpClient*/
84. inlineSEL_CallFuncNDgetSelector()
85. return_pSelector;
86. /**Setanycustomheaders**/
87. voidsetHeaders(std::vector<std::string>pHeaders)
88. _headers=pHeaders;
89. /**Getcustomheaders**/
90. inlinestd::vector<std::string>getHeaders()
91. return_headers;
92. protected:
93. //properties
94. HttpRequestType_requestType;///请求方式
95. std::string_url;///请求url
96. char>_requestData;///用于POST
97. std::string_tag;///用户自定义标识，可以用来在response回调中区分request
98. CCObject*_pTarget;///回调对象
99. SEL_CallFuncND_pSelector;///回调函数例如MyLayer::onHttpResponse(CCObject*sender,void*data)
100. void*_pUserData;///用户自定义数据，和_tag用法一样，只不过是用途不一样
101. std::vector<std::string>_headers;///customhttpheaders
102. };

classCCHttpResponse:/**Constructor,it'susedbyCCHttpClientinternal,usersdon'tneedtocreateHttpResponsemanually
1. @paramrequestthecorrespondingHttpRequestwhichleadstothisresponse
2. CCHttpResponse(CCHttpRequest*request)
3. _pHttpRequest=request;
4. if(_pHttpRequest)
5. _pHttpRequest->retain();
6. _succeed=false;
7. _responseData.clear();
8. _errorBuffer.clear();
9. /**Destructor,itwillbecalledinCCHttpClientinternal,
10. usersdon'tneedtodesturctHttpResponSEObjectmanully
11. virtual~CCHttpResponse()
12. if(_pHttpRequest)
13. _pHttpRequest->release();
14. /**Overrideautoreleasemethodtopreventdevelopersfromcallingit*/
15. CCObject*autorelease(void)
16. CCAssert(thread
17. therefore,autoreleaseisforbiddenhere");
18. returnNULL;
19. //getters,willbecalledbyusers
20. /**GetthecorrespondingHttpRequestobjectwhichleadstothisresponse
21. There'snopairedsetterforit,cozit'salreadysettedinclassconstructor
22. inlineCCHttpRequest*getHttpRequest()
23. return_pHttpRequest;
24. /**Toseeifthehttpreqeustisreturnedsuccessfully,0); background-color:inherit">Althroughuserscanjudgeif(httpreturncode=200),wewantaneasierway
25. Ifthisgetterreturnsfalse,youcancallgetResponseCodeandgetErrorBuffertofindmoredetails
26. boolisSucceed()
27. return_succeed;
28. /**Getthehttpresponserawdata*/
29. inlinestd::vector<char>*getResponseData()
30. return&_responseData;
31. /**GetthehttpresponseerrorCode
32. *Iknowthatyouwanttoseehttp200:)
33. intgetResponseCode()
34. return_responseCode;
35. /**Gettherrorbufferwhichwilltellyoumoreaboutthereasonwhyhttprequestfailed
36. char*getErrorBuffer()
37. return_errorBuffer.c_str();
38. //setters,willbecalledbyCCHttpClient
39. //usersshouldavoidinvokingthesemethods
40. /**Setifthehttprequestisreturnedsuccessfully,0); background-color:inherit">Althroughuserscanjudgeif(httpcode==200),wewantaeasierway
41. ThissetterismainlyusedinCCHttpClient,usersmustn'tsetitdirectly
42. voidsetSucceed(boolvalue)
43. _succeed=value;
44. /**Setthehttpresponserawbuffer,isusedbyCCHttpClient
45. voidsetResponseData(std::vector<char>*data)
46. _responseData=*data;
47. /**SetthehttpresponseerrorCode
48. voidsetResponseCode(intvalue)
49. _responseCode=value;
50. /**Settheerrorbufferwhichwilltellyoumorethereasonwhyhttprequestfailed
51. voidsetErrorBuffer(char*value)
52. _errorBuffer.assign(value);
53. boolinitWithRequest(CCHttpRequest*request);
54. //这里要留意下，每个response中都会包含对应的request，所以能在数据处理回调函数中，获取我们在设置request的所有参数，比如像tag,userdata
55. CCHttpRequest*_pHttpRequest;///thecorrespondingHttpRequestpointerwholeadstothisresponse
56. bool_succeed;///toindecateifthehttpreqeustissuccessfulsimply
57. std::vector<char>_responseData;///thereturnedrawdata.Youcanalsodumpitasastring
58. int_responseCode;///thestatuscodereturnedfromlibcurl,e.g.200,404
59. std::string_errorBuffer;///if_responseCode!=200,pleaseread_errorBuffertofindthereason
60. };

copy

//CCHttpClient是一个单例模式的类，整个程序共享一个实例对象
1. classCCHttpClient:publicCCObject
2. public:
3. /**获取共享的单例对象**/
4. staticCCHttpClient*getInstance();
5. /**Relasethesharedinstance**/
6. staticvoiddestroyInstance();
7. /**
8. *Addagetrequesttotaskqueue
9. *@paramrequestaCCHttpRequestobject,whichincludesurl,responsecallbacketc.
10. pleasemakesurerequest->_requestDataisclearbeforecalling"send"here.
11. *@returnNULL
12. voidsend(CCHttpRequest*request);
13. /**
14. *Changetheconnecttimeout
15. *@paramtimeout
16. voidsetTimeoutForConnect(intvalue){_timeoutForConnect=value;};
17. *Getconnecttimeout
18. *@returnint
19. *
20. intgetTimeoutForConnect(){return_timeoutForConnect;}
21. *Changethedownloadtimeout
22. *@paramvalue
23. *@returnNULL
24. voidsetTimeoutForRead(intvalue){_timeoutForRead=value;};
25. *Getdownloadtimeout
26. intgetTimeoutForRead(){return_timeoutForRead;};
27. private:
28. CCHttpClient();
29. virtual~CCHttpClient();
30. boolinit(void);
31. *Initpthreadmutex,semaphore,andcreatenewthreadforhttprequests
32. *@returnbool
33. boollazyInitThreadSemphore();
34. /**Pollfunctioncalledfrommainthreadtodispatchcallbackswhenhttprequestsfinished**/
35. voiddispatchResponseCallbacks(floatdelta);
36. private:
37. int_timeoutForConnect;//连接超时时间
38. int_timeoutForRead;//接收数据超时时间
39. //std::stringreqId;
40. };

HttpClient.cpp

staticpthread_ts_networkThread;//工作线程句柄
1. staticpthread_mutex_ts_requestQueueMutex;//请求队列互斥变量
2. staticpthread_mutex_ts_responseQueueMutex;//接收队列互斥变量
3. staticsem_t*s_pSem=NULL;//用来驱动线程工作的信号量
4. staticunsignedlongs_asyncRequestCount=0;//当前需要处理的request个数
5. #ifCC_TARGET_PLATFORM==CC_PLATFORM_IOS
6. #defineCC_ASYNC_HTTPREQUEST_USE_NAMED_SEMAPHORE1
7. #else
8. #defineCC_ASYNC_HTTPREQUEST_USE_NAMED_SEMAPHORE0
9. #endif
10. #ifCC_ASYNC_HTTPREQUEST_USE_NAMED_SEMAPHORE
11. #defineCC_ASYNC_HTTPREQUEST_SEMAPHORE"ccHttpAsync"
12. staticsem_ts_sem;
13. #if(CC_TARGET_PLATFORM==CC_PLATFORM_WIN32)
14. typedefintint32_t;
15. staticboolneed_quit=false;//退出标识
16. staticCCArray*s_requestQueue=NULL;//请求队列（下面都说request队列）
17. staticCCArray*s_responseQueue=NULL;//接收队列（下面都说response队列）
18. staticCCHttpClient*s_pHttpClient=NULL;//全局单例CCHttpClient对象
19. chars_errorBuffer[CURL_ERROR_SIZE];//错误提示buffer
20. size_t(*write_callback)(void*ptr,size_tsize,87); font-weight:bold; background-color:inherit">size_tnmemb,153); font-weight:bold; background-color:inherit">void*stream);//这个是用于cURL收到数据的回调函数
21. //这个便是当cURL接收到数据回调的函数，也就是在这里对response进行填充，这里的声明方式和fwrite()函数一样
22. size_twriteData(void*stream)
23. //ptr指向接受到的数据，sizes为字节数
24. //这里传过来的stream中保存了CCHttpResponse::_responseData
25. char>*recvBuffer=(std::vector<char>*)stream;
26. size_tsizes=size*nmemb;
27. //adddatatotheendofrecvBuffer
28. //将接受到的数据写到response中去
29. recvBuffer->insert(recvBuffer->end(),(char*)ptr,(char*)ptr+sizes);
30. returnsizes;
31. //Prototypes
32. boolconfigureCURL(CURL*handle);
33. intprocessGetTask(CCHttpRequest*request,write_callbackcallback,153); font-weight:bold; background-color:inherit">void*stream,int32_t*errorCode);
34. intprocessPostTask(CCHttpRequest*request,int32_t*errorCode);
35. //intprocessDownloadTask(HttpRequest*task,void*stream,int32_t*errorCode);
36. //工作线程
37. void*networkThread( CCHttpRequest*request=NULL;
38. while(true)
39. //等待主线程发送信号，就是调用send()函数
40. intsemWaitRet=sem_wait(s_pSem);
41. if(semWaitRet<0){
42. CCLog("HttpRequestasyncthreadsemaphoreerror:%sn",strerror(errno));
43. break;
44. //退出
45. if(need_quit)
46. break;
47. //step1:sendhttprequestiftherequestQueueisn'tempty
48. request=NULL;
49. pthread_mutex_lock(&s_requestQueueMutex);//给request队列上锁
50. if(0!=s_requestQueue->count())
51. request=dynamic_cast<CCHttpRequest*>(s_requestQueue->objectAtIndex(0));//取得第一个request
52. s_requestQueue->removeObjectAtIndex(0);//将其移除队列
53. //这里的request的引用次数为1，因为只有在send()函数中retain了一次
54. pthread_mutex_unlock(&s_requestQueueMutex);//request队列解锁
55. if(NULL==request)
56. continue;
57. //同步调用cURL库
58. //使用request来创建一个response
59. CCHttpResponse*response=newCCHttpResponse(request);
60. //在CCHttpTtpResponse构造中，会将request再retain一次
61. request->release();
62. //这里，只有response中有request的一次引用计数
63. intresponseCode=-1;
64. intretValue=0;
65. //根据请求类型设置cURL参数
66. switch(request->getRequestType())
67. caseCCHttpRequest::kHttpGet://HTTPGET
68. retValue=processGetTask(request,248)"> writeData,108); list-style:decimal-leading-zero outside; color:inherit; line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important"> response->getResponseData(),248)"> &responseCode);
69. caseCCHttpRequest::kHttpPost://HTTPPOST
70. retValue=processPostTask(request,108); list-style:decimal-leading-zero outside; color:inherit; line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important"> writeData,248)"> response->getResponseData(),108); list-style:decimal-leading-zero outside; color:inherit; line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important"> &responseCode);
71. default:
72. true,"CCHttpClient:unkownrequesttype,onlyGETandPOStaresupported");
73. //设置返回代码
74. response->setResponseCode(responseCode);
75. if(retValue!=0)
76. response->setSucceed(false);
77. response->setErrorBuffer(s_errorBuffer);
78. else
79. response->setSucceed(true);
80. //将response加入队列
81. pthread_mutex_lock(&s_responseQueueMutex);//给response加锁
82. s_responseQueue->addObject(response);
83. pthread_mutex_unlock(&s_responseQueueMutex);//解锁
84. //启动CCScheduler调度
85. CCDirector::sharedDirector()->getScheduler()->resumeTarget(CCHttpClient::getInstance());
86. //线程退出，清理request队列
87. pthread_mutex_lock(&s_requestQueueMutex);
88. s_requestQueue->removeAllObjects();
89. pthread_mutex_unlock(&s_requestQueueMutex);
90. s_asyncRequestCount-=s_requestQueue->count();
91. if(s_pSem!=NULL){
92. sem_unlink(CC_ASYNC_HTTPREQUEST_SEMAPHORE);
93. sem_close(s_pSem);
94. #else
95. sem_destroy(s_pSem);
96. #endif
97. s_pSem=NULL;
98. //释放互斥变量
99. pthread_mutex_destroy(&s_requestQueueMutex);
100. pthread_mutex_destroy(&s_responseQueueMutex);
101. s_requestQueue->release();
102. s_responseQueue->release();
103. pthread_exit(NULL);
104. return0;
105. //设置cURL超时属性
106. boolconfigureCURL(CURL*handle)
107. if(!handle){
108. returnfalse;
109. int32_tcode;
110. //设置错误信息缓冲
111. code=curl_easy_setopt(handle,CURLOPT_ERRORBUFFER,s_errorBuffer);
112. if(code!=CURLE_OK){
113. //设置超时时间
114. code=curl_easy_setopt(handle,CURLOPT_TIMEOUT,CCHttpClient::getInstance()->getTimeoutForRead());
115. if(code!=CURLE_OK){
116. true;
117. //处理get方式请求
118. //stream传递过来的是response->getResponseData()
119. //关于cURL的东西这里就不多说了
120. int*responseCode)
121. CURLcodecode=CURL_LAST;
122. //初始化cURL
123. CURL*curl=curl_easy_init();
124. do{
125. if(!configureCURL(curl))//配置cURL
126. /*handlecustomheaderdata*/
127. /*createcurllinkedlist*/
128. structcurl_slist*cHeaders=NULL;
129. /*getcustomheaderdata(ifset)*/
130. std::vector<std::string>headers=request->getHeaders();
131. if(!headers.empty())
132. for(std::vector<std::string>::iteratorit=headers.begin();it!=headers.end();it++)
133. /*appendcustomheadersonebyone*/
134. cHeaders=curl_slist_append(cHeaders,it->c_str());
135. /*setcustomheadersforcurl*/
136. code=curl_easy_setopt(curl,CURLOPT_HTTPHEADER,cHeaders);
137. if(code!=CURLE_OK)
138. //这里将response->_responseData设置为cURL回调函数中的stream参数
139. code=curl_easy_perform(curl);
140. /*freethelinkedlistforheaderdata*/
141. curl_slist_free_all(cHeaders);
142. code=curl_easy_getinfo(curl,CURLINFO_RESPONSE_CODE,responseCode);
143. if(code!=CURLE_OK||*responseCode!=200)
144. code=CURLE_HTTP_RETURNED_ERROR;
145. }while(0);
146. if(curl){
147. curl_easy_cleanup(curl);
148. return(code==CURLE_OK?0:1);
149. //这个就不说了，其实都一样的，cURL承担了所有工作
150. CURLcodecode=CURL_LAST;
151. if(!configureCURL(curl)){
152. /*handlecustomheaderdata*/
153. /*createcurllinkedlist*/
154. structcurl_slist*cHeaders=NULL;
155. /*getcustomheaderdata(ifset)*/
156. std::vector<std::string>headers=request->getHeaders();
157. if(!headers.empty())
158. for(std::vector<std::string>::iteratorit=headers.begin();it!=headers.end();it++)
159. /*appendcustomheadersonebyone*/
160. cHeaders=curl_slist_append(cHeaders,it->c_str());
161. /*setcustomheadersforcurl*/
162. code=curl_easy_setopt(curl,cHeaders);
166. code=curl_easy_perform(curl);
167. if(code!=CURLE_OK||*responseCode!=200){
168. code=CURLE_HTTP_RETURNED_ERROR;
169. }while(0);
170. //返回共享实例
171. CCHttpClient*CCHttpClient::getInstance()
172. if(s_pHttpClient==NULL){
173. s_pHttpClient=newCCHttpClient();
174. returns_pHttpClient;
175. voidCCHttpClient::destroyInstance()
176. CCAssert(s_pHttpClient,"");
177. //将CCHttpClient::dispatchResponseCallbacks()函数从CCShecduler中取消挂载
178. CCDirector::sharedDirector()->getScheduler()->unscheduleSelector(schedule_selector(CCHttpClient::dispatchResponseCallbacks),s_pHttpClient);
179. s_pHttpClient->release();
180. CCHttpClient::CCHttpClient()
181. :_timeoutForConnect(30)
182. ,_timeoutForRead(60)
183. //将成员函数dispatchTesponseCallbacks()挂载至CCSheduler
184. CCDirector::sharedDirector()->getScheduler()->scheduleSelector(
185. schedule_selector(CCHttpClient::dispatchResponseCallbacks),false);
186. //初始化为停止调度，由工作线程接收到了数据之后启用调度
187. CCDirector::sharedDirector()->getScheduler()->pauseTarget(this);
188. CCHttpClient::~CCHttpClient()
189. need_quit=true;
190. sem_post(s_pSem);
191. s_pHttpClient=NULL;
192. //只有在第一次调用send()时调用，去初始化队列、创建线程、初始化互斥变量等
193. boolCCHttpClient::lazyInitThreadSemphore()
194. else{
195. s_pSem=sem_open(CC_ASYNC_HTTPREQUEST_SEMAPHORE,O_CREAT,0644,0);
196. if(s_pSem==SEM_FAILED){
197. CCLog("OpenHttpRequestSemaphorefailed");
198. s_pSem=NULL;
199. intsemRet=sem_init(&s_sem,0);
200. if(semRet<0){
201. CCLog("InitHttpRequestSemaphorefailed");
202. s_pSem=&s_sem;
203. s_requestQueue=newCCArray();
204. s_requestQueue->init();
205. s_responseQueue=newCCArray();
206. s_responseQueue->init();
207. pthread_mutex_init(&s_requestQueueMutex,NULL);
208. pthread_mutex_init(&s_responseQueueMutex,NULL);
209. pthread_create(&s_networkThread,NULL,networkThread,248)"> pthread_detach(s_networkThread);
210. //Addagettasktoqueue
211. voidCCHttpClient::send(CCHttpRequest*request)
212. //第一次调用的时候初始化
213. if(false==lazyInitThreadSemphore())
214. if(!request)
215. //将当前需要处理的request个数++
216. ++s_asyncRequestCount;
217. //在这里对request进行第一次retain，
218. request->retain();
219. //这里request的引用次数为1
220. pthread_mutex_lock(&s_requestQueueMutex);//request队列加锁
221. s_requestQueue->addObject(request);//push到request队列
222. //发送信号唤醒工作线程
223. //将response队列数据分发
224. voidCCHttpClient::dispatchResponseCallbacks(floatdelta)
225. //CCLog("CCHttpClient::dispatchResponseCallbacksisrunning");
226. CCHttpResponse*response=NULL;
227. pthread_mutex_lock(&s_responseQueueMutex);//给response队列上锁
228. if(s_responseQueue->count())
229. response=dynamic_cast<CCHttpResponse*>(s_responseQueue->objectAtIndex(0));//取出response
230. s_responseQueue->removeObjectAtIndex(0);//将其从response队列移除
231. pthread_mutex_unlock(&s_responseQueueMutex);//解锁
232. if(response)
233. --s_asyncRequestCount;
234. CCHttpRequest*request=response->getHttpRequest();
235. CCObject*pTarget=request->getTarget();//获取request回调函数的对象
236. SEL_CallFuncNDpSelector=request->getSelector();//获取回调函数
237. if(pTarget&&pSelector)
238. (pTarget->*pSelector)((CCNode*)//调用回调函数，并把本单例对象和response传递给我们设置在request中的回调函数
239. response->release();
240. if(0==s_asyncRequestCount)//如果没有没有请求，停止调度
241. }

花了大半天时间，终于写的差不多了，其实我当初是想看看cocos2d-x是怎样封装socket这一块的，结果是这样，用的cURL库。。。
这篇文章是我的处女做，哪里有不好的地方大家提出来共同进步，欢迎交流

本人今年刚毕业，接触cocos2d-x也才两个月（写的不好不要扔砖就好），前一个多月一直在搞粒子系统这块，这几天把改造后的粒子系统工具开发完了，时间稍微多点，就看看其他的模块了，看完了收获也不少，由于经常逛csdn，拜读大神的文章，所以就想着咱也来发表一遍学习心得吧，这样既可以提高自己，也可以和大家交流交流心得，更重要的是我发现写博客可以提升学习的兴趣

好了，就到这里了，以后有时间再继续

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!