1、核心类NetWorkCore，处理发送请求

view plain
  1. importjava.io.IOException;
  2. importjava.io.InputStream;
  4. importorg.apache.http.HttpEntity;
  5. importorg.apache.http.HttpHost;
  6. importorg.apache.http.HttpResponse;
  7. importorg.apache.http.HttpStatus;
  8. importorg.apache.http.client.ClientProtocolException;
  9. importorg.apache.http.client.HttpClient;
  10. importorg.apache.http.client.methods.HttpGet;
  11. importorg.apache.http.client.methods.HttpPost;
  12. importorg.apache.http.conn.params.ConnRouteParams;
  13. importorg.apache.http.entity.ByteArrayEntity;
  14. importorg.apache.http.entity.StringEntity;
  15. importorg.apache.http.impl.client.DefaultHttpClient;
  16. importorg.apache.http.params.BasicHttpParams;
  17. importorg.apache.http.params.HttpConnectionParams;
  18. importorg.apache.http.params.HttpParams;
  20. /**
  21. *网络请求核心类，用于处理发送请求和返回，单例
  22. *
  23. *@authorAdministrator
  24. *
  25. */
  26. publicclassNetworkCore{
  27. //连接超时(ms)
  28. privatestaticfinalinttimeoutConnection=30000;
  29. //响应超时(ms)
  30. privatestaticfinalinttimeoutSocket=50000;
  32. privatestaticNetworkCoreinstance;
  33. /*get请求*/
  34. privateHttpGethttpGet;
  35. /*post请求*/
  36. privateHttpPosthttpPost;
  38. publicstaticNetworkCoreInstance(){
  39. if(instance==null){
  40. instance=newNetworkCore();
  41. }
  42. returninstance;
  43. }
  44. /**
  45. *发送请求
  46. *@paramrequest请求线程对象
  47. *@return请求结果
  48. */
  49. publicNetWorkResponseMsgperform(DoRequestRunnablerequest){
  50. NetWorkResponseMsgmsg=null;
  51. NetworkRequestMsgmNetworkRequestMsg=request.getmNetworkRequestMsg();
  52. try{
  53. if(NetworkRequestMsg.POST.equals(mNetworkRequestMsg.getType())){
  54. msg=handlePostRequest(mNetworkRequestMsg);
  55. }else{
  56. msg=handleGetRequest(mNetworkRequestMsg);
  57. }
  58. if(msg.getInputStream()==null){
  59. msg.setResponseMsg(NetworkError.NODATA);
  60. }
  61. request.handleNetResponseMsg(msg);
  62. }catch(IOExceptione){
  63. msg.setResponseMsg(NetworkError.CONNECT_ERROR);
  64. }finally{
  65. msg.closeStream();
  66. }
  67. returnmsg;
  68. }
  69. /**
  70. *get请求
  71. *@parammNetworkRequestMsg
  72. *@return
  73. *@throwsClientProtocolException
  74. *@throwsIOException
  75. */
  76. privateNetWorkResponseMsghandleGetRequest(NetworkRequestMsgmNetworkRequestMsg)
  77. throwsClientProtocolException,IOException{
  78. InputStreamis=null;
  79. StringBufferfinalURL=newStringBuffer(mNetworkRequestMsg.getUrl());
  80. intindex=finalURL.indexOf("?");
  81. if(null!=mNetworkRequestMsg.getParam()){
  82. for(StringparamName:mNetworkRequestMsg.getParam()
  83. .getParamNames()){
  84. if(index==-1){
  85. finalURL.append("?"
  86. +paramName
  87. +"="
  88. +mNetworkRequestMsg.getParam().getParamValue(
  89. paramName));
  90. }else{
  91. finalURL.append("&"
  92. +paramName
  93. +"="
  94. +mNetworkRequestMsg.getParam().getParamValue(
  95. paramName));
  96. }
  97. index++;
  98. }
  99. mNetworkRequestMsg.setUrl(finalURL.toString());
  100. }
  101. httpGet=newHttpGet(finalURL.toString());
  102. if(mNetworkRequestMsg.getParam().getParamNames().size()>0){
  103. for(StringheaderName:mNetworkRequestMsg.getParam()
  104. .getHeaderNames()){
  105. httpGet.addHeader(headerName,mNetworkRequestMsg.getParam()
  106. .getHeaderValue(headerName));
  107. }
  108. }
  109. mNetworkRequestMsg.getParam().clearCache();
  110. HttpParamshttpParameters=newBasicHttpParams();
  111. HttpConnectionParams.setConnectionTimeout(httpParameters,
  112. timeoutConnection);
  113. HttpConnectionParams.setSoTimeout(httpParameters,timeoutSocket);
  115. HttpClienthttpclient=newDefaultHttpClient(httpParameters);
  116. if(mNetworkRequestMsg.isNeedProxy()){
  117. Stringaddress=mNetworkRequestMsg.getProxyAddress()==null?NetworkConfig.DEFAULT_PROXY
  118. :mNetworkRequestMsg.getProxyAddress();
  119. intport=mNetworkRequestMsg.getProxyPort()==0?NetworkConfig.DEFAULT_PROXYPORT
  120. :mNetworkRequestMsg.getProxyPort();
  121. setProxy(httpclient,address,port);
  122. }
  123. HttpResponsehttpResponse=httpclient.execute(httpGet);
  124. if(httpResponse.getStatusLine().getStatusCode()==HttpStatus.SC_OK){
  125. is=httpResponse.getEntity().getContent();
  126. }
  127. returnnewNetWorkResponseMsg(is,httpResponse.getStatusLine().getStatusCode());
  128. }
  129. /**
  130. *post请求
  131. *@parammNetworkRequestMsg
  132. *@return
  133. *@throwsClientProtocolException
  134. *@throwsIOException
  135. */
  136. privateNetWorkResponseMsghandlePostRequest(NetworkRequestMsgmNetworkRequestMsg)
  137. throwsClientProtocolException,IOException{
  138. InputStreamis=null;
  139. HttpEntityhttpentity=null;
  140. StringBufferfinalURL=newStringBuffer(mNetworkRequestMsg.getUrl());
  141. intindex=finalURL.indexOf("?");
  142. if(null!=mNetworkRequestMsg.getParam()){
  143. for(StringparamName:mNetworkRequestMsg.getParam()
  144. .getParamNames()){
  145. if(index==-1){
  146. finalURL.append("?"
  147. +paramName
  148. +"="
  149. +mNetworkRequestMsg.getParam().getParamValue(
  150. paramName));
  151. }else{
  152. finalURL.append("&"
  153. +paramName
  154. +"="
  155. +mNetworkRequestMsg.getParam().getParamValue(
  156. paramName));
  157. }
  158. index++;
  159. }
  160. mNetworkRequestMsg.setUrl(finalURL.toString());
  161. }
  162. httpPost=newHttpPost(finalURL.toString());
  163. if(mNetworkRequestMsg.getParam().getParamNames().size()>0){
  164. for(StringheaderName:mNetworkRequestMsg.getParam()
  165. .getHeaderNames()){
  166. httpPost.addHeader(headerName,mNetworkRequestMsg.getParam()
  167. .getHeaderValue(headerName));
  168. }
  169. }
  170. mNetworkRequestMsg.getParam().clearCache();
  171. if(mNetworkRequestMsg.getParam().getArrayBody()!=null){
  172. httpentity=newByteArrayEntity(mNetworkRequestMsg.getParam()
  173. .getArrayBody());
  174. }elseif(mNetworkRequestMsg.getParam().getBody()!=null){
  175. httpentity=newStringEntity(mNetworkRequestMsg.getParam()
  176. .getBody());
  177. }
  178. if(null!=httpentity){
  179. httpPost.setEntity(httpentity);
  180. }
  181. HttpParamshttpParameters=newBasicHttpParams();
  182. HttpConnectionParams.setConnectionTimeout(httpParameters,
  183. timeoutConnection);
  184. HttpConnectionParams.setSoTimeout(httpParameters,timeoutSocket);
  185. HttpClienthttpclient=newDefaultHttpClient(httpParameters);
  186. if(mNetworkRequestMsg.isNeedProxy()){
  187. Stringaddress=mNetworkRequestMsg.getProxyAddress()==null?NetworkConfig.DEFAULT_PROXY
  188. :mNetworkRequestMsg.getProxyAddress();
  189. intport=mNetworkRequestMsg.getProxyPort()==0?NetworkConfig.DEFAULT_PROXYPORT
  190. :mNetworkRequestMsg.getProxyPort();
  191. setProxy(httpclient,address,port);
  192. }
  193. HttpResponsehttpResponse=httpclient.execute(httpPost);
  194. if(httpResponse.getStatusLine().getStatusCode()==HttpStatus.SC_OK){
  195. is=httpResponse.getEntity().getContent();
  196. }
  197. returnnewNetWorkResponseMsg(is,httpResponse.getStatusLine().getStatusCode());
  198. }
  199. /**
  200. *断开连接
  201. */
  202. publicvoidabort(){
  203. if(httpGet!=null){
  204. if(!httpGet.isAborted()){
  205. httpGet.abort();
  206. }
  207. }
  208. if(httpPost!=null){
  209. if(!httpPost.isAborted()){
  210. httpPost.abort();
  211. }
  212. }
  213. }
  214. /**
  215. *
  216. *@paramhttpclient
  217. *@paramaddress
  218. *@paramport
  219. */
  220. privatevoidsetProxy(HttpClienthttpclient,Stringaddress,intport){
  221. HttpHostproxy=newHttpHost(address,port);
  222. httpclient.getParams().setParameter(ConnRouteParams.DEFAULT_PROXY,
  223. proxy);
  224. }
  226. }

2、请求封装类NetworkRequestMsg： view plain
  1. publicclassNetworkRequestMsgextendsMessage{
  3. publicstaticfinalStringGET="GET";
  4. publicstaticfinalStringPOST="POST";
  7. /**
  8. *产生自增ID计数器
  9. */
  10. privatestaticshortID=0;
  12. /**
  13. *当前消息id
  14. */
  15. privateshortid=0;
  17. /**
  18. *当前请求类型(GET/POST)
  19. */
  20. privateStringtype;
  22. /**
  23. *请求地址URL
  24. */
  25. privateStringurl;
  27. /**
  28. *请求消息参数
  29. */
  30. privateParameterparam;
  32. /**
  33. *数据连接返回值
  34. */
  35. privatebyteretcode=-1;
  37. /**
  38. *请求是否取消
  39. */
  40. privatebooleancancel=false;
  42. /**
  43. *是否正在发送数据
  44. */
  45. privatebooleansending=false;
  47. /**
  48. *是否是下载类型
  49. */
  50. privatebooleandownload=false;
  52. /**
  53. *重发次数
  54. */
  55. privatebytesendTime=0;
  57. /**
  58. *网络数据解析协议
  59. */
  60. privateStringprotocol;
  62. /**
  63. *是否需要代理
  64. */
  65. privatebooleanisNeedProxy;
  67. /**
  68. *代理地址
  69. */
  70. privateStringproxyAddress;
  73. /**
  74. *代理端口
  75. */
  76. privateintproxyPort;
  81. publicNetworkRequestMsg(String_url,String_type,Parameter_param,booleanisNeedProxy,String_proxyAddress,int_proxyPort){
  83. this.url=_url;
  84. this.type=_type;
  85. this.isNeedProxy=isNeedProxy;
  86. this.param=_param;
  87. this.proxyAddress=_proxyAddress;
  88. this.proxyPort=_proxyPort;
  90. }
  93. publicstaticshortgetID(){
  94. returnID;
  95. }
  97. publicstaticvoidsetID(shortiD){
  98. ID=iD;
  99. }
  101. publicshortgetId(){
  102. returnid;
  103. }
  105. publicvoidsetId(shortid){
  106. this.id=id;
  107. }
  109. publicStringgetType(){
  110. returntype;
  111. }
  113. publicvoidsetType(Stringtype){
  114. this.type=type;
  115. }
  117. publicStringgetUrl(){
  118. returnurl;
  119. }
  121. publicvoidsetUrl(Stringurl){
  122. this.url=url;
  123. }
  125. publicbytegetRetcode(){
  126. returnretcode;
  127. }
  129. publicvoidsetRetcode(byteretcode){
  130. this.retcode=retcode;
  131. }
  133. publicbooleanisCancel(){
  134. returncancel;
  135. }
  137. publicvoidsetCancel(booleancancel){
  138. this.cancel=cancel;
  139. }
  141. publicbooleanisSending(){
  142. returnsending;
  143. }
  145. publicvoidsetSending(booleansending){
  146. this.sending=sending;
  147. }
  149. publicbooleanisDownload(){
  150. returndownload;
  151. }
  153. publicvoidsetDownload(booleandownload){
  154. this.download=download;
  155. }
  157. publicbytegetSendTime(){
  158. returnsendTime;
  159. }
  161. publicvoidsetSendTime(bytesendTime){
  162. this.sendTime=sendTime;
  163. }
  164. publicParametergetParam(){
  165. returnparam;
  166. }
  169. publicvoidsetParam(Parameterparam){
  170. this.param=param;
  171. }
  178. publicStringgetProtocol(){
  179. returnprotocol;
  180. }
  183. publicvoidsetProtocol(Stringprotocol){
  184. this.protocol=protocol;
  185. }
  188. publicbooleanisNeedProxy(){
  189. returnisNeedProxy;
  190. }
  193. publicvoidsetNeedProxy(booleanisNeedProxy){
  194. this.isNeedProxy=isNeedProxy;
  195. }
  197. publicStringgetProxyAddress(){
  198. returnproxyAddress;
  199. }
  201. publicvoidsetProxyAddress(StringproxyAddress){
  202. this.proxyAddress=proxyAddress;
  203. }
  205. publicintgetProxyPort(){
  206. returnproxyPort;
  207. }
  209. publicvoidsetProxyPort(intproxyPort){
  210. this.proxyPort=proxyPort;
  211. }
  212. }

请求参数封装类Parameter： view plain
  1. importjava.util.ArrayList;
  2. importjava.util.HashMap;
  4. publicclassParameter{
  6. privateHashMap<String,String>header=newHashMap<String,String>();
  7. privateArrayList<String>allHeaderNames=newArrayList<String>();
  8. //参数信息
  9. privateHashMap<String,String>param=newHashMap<String,String>();
  10. privateArrayList<String>allParamNames=newArrayList<String>();
  11. //实体信息
  12. privateStringbody;
  14. privatebyte[]arrayBody;
  16. publicStringgetParamValue(String_name){
  17. returnparam.get(_name);
  18. }
  19. publicStringgetHeaderValue(String_name){
  20. returnheader.get(_name);
  21. }
  23. publicvoidaddHeader(String_name,String_value)throwsException{
  24. if(null!=_name&&null!=_value){
  25. header.put(_name,_value);
  26. allHeaderNames.add(_name);
  27. }else{
  28. thrownewException("头信息请求参数非法");
  29. }
  30. }
  32. publicvoidaddParam(String_name,String_value)throwsException{
  33. if(null!=_name&&null!=_value){
  34. param.put(_name,_value);
  35. allParamNames.add(_name);
  36. }else{
  37. thrownewException("请求参数非法");
  38. }
  39. }
  42. publicArrayList<String>getHeaderNames(){
  43. returnallHeaderNames;
  44. }
  45. publicArrayList<String>getParamNames(){
  46. returnallParamNames;
  47. }
  49. publicvoidclearCache(){
  50. if(null!=header){
  51. header.clear();
  52. }
  53. if(null!=allHeaderNames){
  54. allHeaderNames.clear();
  55. }
  56. if(null!=param){
  57. param.clear();
  58. }
  59. if(null!=allParamNames){
  60. allParamNames.clear();
  61. }
  63. }
  65. publicStringgetBody(){
  66. returnbody;
  67. }
  69. publicvoidsetBody(Stringbody){
  70. this.body=body;
  71. }
  74. publicbyte[]getArrayBody(){
  75. returnarrayBody;
  76. }
  77. publicvoidsetArrayBody(byte[]arrayBody){
  78. this.arrayBody=arrayBody;
  79. }
  80. publicParameter(){
  81. clearCache();
  82. }
  85. }

3 响应请求封装类NetWorkResponseMsg：
view plain
  1. importjava.io.IOException;
  2. importjava.io.InputStream;
  4. publicclassNetWorkResponseMsg{
  6. privateInputStreaminputStream;
  8. privateintresponseCode=200;
  10. privateStringresponseMsg=null;
  12. publicNetWorkResponseMsg(){
  13. }
  16. publicNetWorkResponseMsg(InputStreaminputStream,intresponseCode){
  17. this.inputStream=inputStream;
  18. this.responseCode=responseCode;
  19. }
  22. publicNetWorkResponseMsg(InputStreaminputStream,intresponseCode,
  23. StringresponseMsg){
  24. this.inputStream=inputStream;
  25. this.responseCode=responseCode;
  26. this.responseMsg=responseMsg;
  27. }
  29. publicStringgetResponseMsg(){
  30. returnresponseMsg;
  31. }
  33. publicvoidsetResponseMsg(StringresponseMsg){
  34. this.responseMsg=responseMsg;
  35. }
  38. publicInputStreamgetInputStream(){
  39. returninputStream;
  40. }
  42. publicvoidsetInputStream(InputStreaminputStream){
  43. this.inputStream=inputStream;
  44. }
  46. publicintgetResponseCode(){
  47. returnresponseCode;
  48. }
  50. publicvoidsetResponseCode(intresponseCode){
  51. this.responseCode=responseCode;
  52. }
  54. publicvoidcloseStream(){
  55. try{
  56. if(inputStream!=null){
  57. inputStream.close();
  58. }
  59. }catch(IOExceptione){
  60. }
  61. }
  63. }

更多相关文章

  1. mybatisplus的坑 insert标签insert into select无参数问题的解决
  2. Python技巧匿名函数、回调函数和高阶函数
  3. python list.sort()根据多个关键字排序的方法实现
  4. android中文api(89)——ViewManager
  5. Android使用Retrofit进行网络请求
  6. Android(安卓)bluetooth介绍（四）： a2dp connect流程分析
  7. Android调用天气预报的WebService简单例子
  8. Android(安卓)Activity的启动
  9. Android(安卓)开发中的倒计时

随机推荐

  1. php 的变量与常量----0426
  2. js 中 for，foreach 遍历数组，与PHP 中 for，f
  3. 网站安全响应头缺失和php配置漏洞
  4. php之请求api数据与composer
  5. 本地git的配置和一些命令
  6. php之mvc架构思想
  7. 白话Thinkphp5.1
  8. javascript内容整理
  9. 坚持自己的学习方法不动摇
  10. 小白的PHP之路