5.AsyncHttp、post

httpClient
  1. 	// 网络访问请求
  2. 		new Thread(new Runnable() {
  4. 			@Override
  5. 			public void run() {
  6. 				String url = "http://192.168.1.101:8080/ChatServer/register";
  7. 				// 创建 httpClient
  8. 				HttpClient client = new DefaultHttpClient();
  10. 				// 创建 post请求
  11. 				HttpPost post = new HttpPost(url);
  12. 				List<NameValuePair> pairs = new ArrayList<NameValuePair>();
  13. 				// 配置请求头
  14. 				// post.addHeader("", "");
  16. 				// 配置请求参数
  17. 				pairs.add(new BasicNameValuePair("account", account));
  18. 				pairs.add(new BasicNameValuePair("password", password));
  20. 				try {
  21. 					post.setEntity(new UrlEncodedFormEntity(pairs));
  22. 					HttpResponse response = client.execute(post);
  24. 					int statusCode = response.getStatusLine().getStatusCode();
  25. 					if (statusCode == 200) {
  26. 						// 拿到网络的返回结果
  27. 						final String result = EntityUtils.toString(response
  28. 								.OgetEntity());
  30. 						Log.d("result : ", "" + result);
  31. 						// 需要在主线线程中做UI操作
  33. 						getActivity().runOnUiThread(new Runnable() {
  35. 							@Override
  36. 							public void run() {
  37. 								doResult(result);
  38. 							}
  39. 						});
  40. 					}
  41. 				} catch (Exception e) {
  42. 					e.printStackTrace();
  43. 				}
  44. 			}
  45. 		}).start();
AsyncHttp
  1. // 创建 访问端
  2. 		AsyncHttpClient client = new AsyncHttpClient();
  4. 		// 接口地址
  5. 		String url = "http://192.168.1.101:8080/ChatServer/register";
  7. 		//
  8. 		RequestParams params = new RequestParams();
  9. 		params.put("account", account);
  10. 		params.put("password", password);
  12. 		// 调用post方法访问网络
  13. 		client.post(context, url, params, new TextHttpResponseHandler() {
  15. 			@Override
  16. 			public void onSuccess(int statusCode, Header[] headers,
  17. 					String responseString) {
  18. 				Log.d("success", responseString + "");
  20. 				JsonParser parser = new JsonParser();
  21. 				JsonElement element = parser.parse(responseString);
  22. 				JsonObject root = element.getAsJsonObject();
  24. 				JsonPrimitive flagJson = root.getAsJsonPrimitive("flag");
  25. 				boolean flag = flagJson.getAsBoolean();
  27. 				if (flag) {
  28. 					JsonObject dataObject = root.getAsJsonObject("data");
  29. 					if (dataObject != null) {
  30. 						Account user = new Gson().fromJson(dataObject,
  31. 								Account.class);
  33. 						Log.d("", user.toString());
  34. 					}
  35. 				} else {
  36. 					JsonPrimitive errorCodeJson = root
  37. 							.getAsJsonPrimitive("errorCode");
  38. 					JsonPrimitive errorStringJson = root
  39. 							.getAsJsonPrimitive("errorString");
  41. 					Log.d("", errorCodeJson.getAsInt() + " : "
  42. 							+ errorStringJson.getAsString());
  43. 				}
  44. 			}
  46. 			@Override
  47. 			public void onFailure(int statusCode, Header[] headers,
  48. 					String responseString, Throwable throwable) {
  49. 				Log.d("error", responseString + " : " + throwable.getMessage());
  50. 			}
  51. 		});
由于不需要每个页面访问网络都去写这一段代码，抽取：

回调接口：
  1. public abstract class ObjectCallback<T> {
  3. 	private final Class<T> clazz;
  5. 	@SuppressWarnings("unchecked")
  6. 	public ObjectCallback() {
  7. 		ParameterizedType type = (ParameterizedType) this.getClass()
  8. 				.getGenericSuperclass();
  9. 		clazz = (Class<T>) type.getActualTypeArguments()[0];//获取泛型
  10. 	}
  12. 	public Class<T> getDataClass() {
  13. 		return clazz;
  14. 	}
  16. 	public abstract void onSuccess(T data);
  18. 	public abstract void onFailure(int errorCode, String errorString);
  19. }
HMChatManager 
  1. public class HMChatManager {
  3. 	private static HMChatManager instance;
  4. 	private Context context;
  6. 	public static HMChatManager getInstance(Context context) {
  7. 		if (instance == null) {
  8. 			synchronized (HMChatManager.class) {
  9. 				if (instance == null) {
  10. 					instance = new HMChatManager(context);
  11. 				}
  12. 			}
  13. 		}
  14. 		return instance;
  15. 	}
  17. 	private HMChatManager(Context context) {
  18. 		this.context = context;
  19. 	}
  21. 	@SuppressWarnings("rawtypes")
  22. 	public HttpFuture sendRequest(String url, final ObjectCallback callback) {
  23. 		return sendRequest(url, null, callback);
  24. 	}
  26. 	@SuppressWarnings("rawtypes")
  27. 	public HttpFuture sendRequest(String url, Map<String, String> headers,
  28. 			Map<String, String> paramters, final ObjectCallback callback) {
  29. 		// 创建 访问端
  30. 		AsyncHttpClient client = new AsyncHttpClient();
  32. 		// 请求消息头
  33. 		if (headers != null) {
  34. 			for (Map.Entry<String, String> me : headers.entrySet()) {
  35. 				client.addHeader(me.getKey(), me.getValue());
  36. 			}
  37. 		}
  39. 		// 请求参数
  40. 		RequestParams params = new RequestParams();
  41. 		// params.put("account", account);
  42. 		// params.put("password", password);
  44. 		if (paramters != null) {
  45. 			for (Map.Entry<String, String> me : paramters.entrySet()) {
  46. 				params.put(me.getKey(), me.getValue());
  47. 			}
  48. 		}
  50. 		// 调用post方法访问网络
  51. 		RequestHandle handle = client.post(context, url, params,
  52. 				new TextHttpResponseHandler() {
  54. 					@SuppressWarnings("unchecked")
  55. 					@Override
  56. 					public void onSuccess(int statusCode, Header[] headers,
  57. 							String responseString) {
  58. 						Log.d("success", responseString + "");
  60. 						JsonParser parser = new JsonParser();
  61. 						JsonElement element = parser.parse(responseString);
  62. 						JsonObject root = element.getAsJsonObject();
  64. 						JsonPrimitive flagJson = root
  65. 								.getAsJsonPrimitive("flag");
  66. 						boolean flag = flagJson.getAsBoolean();
  68. 						if (flag) {
  69. 							JsonObject dataObject = root
  70. 									.getAsJsonObject("data");
  71. 							if (dataObject != null) {
  72. 								if (callback != null) {
  73. 									@SuppressWarnings("unchecked")
  74. 									Object obj = new Gson().fromJson(
  75. 											dataObject, callback.getDataClass());
  76. 									callback.onSuccess(obj);
  77. 								}
  78. 							}
  79. 						} else {
  80. 							JsonPrimitive errorCodeJson = root
  81. 									.getAsJsonPrimitive("errorCode");
  82. 							JsonPrimitive errorStringJson = root
  83. 									.getAsJsonPrimitive("errorString");
  85. 							Log.d("", errorCodeJson.getAsInt() + " : "
  86. 									+ errorStringJson.getAsString());
  88. 							if (callback != null) {
  89. 								callback.onFailure(errorCodeJson.getAsInt(),
  90. 										errorStringJson.getAsString());
  91. 							}
  92. 						}
  93. 					}
  95. 					@Override
  96. 					public void onFailure(int statusCode, Header[] headers,
  97. 							String responseString, Throwable throwable) {
  98. 						Log.d("error",
  99. 								responseString + " : " + throwable.getMessage());
  101. 						if (callback != null) {
  102. 							callback.onFailure(HMError.ERROR_SERVER, "服务器连接问题");
  103. 						}
  105. 					}
  106. 				});
  108. 		return new HttpFuture(handle);
  109. 	}
访问的的时候
  1. String url = "http://192.168.1.101:8080/ChatServer/register";
  2. 		Map<String, String> paramters = new HashMap<String, String>();
  3. 		paramters.put("account", account);
  4. 		paramters.put("password", password);
  6. 		future = HMChatManager.getInstance(getActivity()).sendRequest(url,
  7. 				paramters, new ObjectCallback<Account>() {
  9. 					@Override
  10. 					public void onSuccess(Account data) {
  12. 						Log.d("onSuccess", data.toString());
  14. 						// 数据的存储
  15. 						AccountDao dao = new AccountDao(getActivity());
  16. 						data.setCurrent(true);
  18. 						Account localAccount = dao.getByAccount(data
  19. 								.getAccount());
  20. 						if (localAccount != null) {
  21. 							dao.updateAccount(data);
  22. 						} else {
  23. 							dao.addAccount(data);
  24. 						}
  26. 						// 页面跳转
  27. 						((LoginActivity) getActivity()).go2FillInfo();
  28. 					}
  30. 					@Override
  31. 					public void onFailure(int errorCode, String errorString) {
  32. 						Log.d("onFailure", errorCode + " : " + errorString);
  34. 						switch (errorCode) {
  35. 						case HMError.ERROR_CLIENT_NET:
  36. 							Log.d(TAG, "客户端网络异常");
  37. 							ToastUtil.show(getActivity(), "客户端网络异常");
  38. 							break;
  39. 						case HMError.ERROR_SERVER:
  40. 							Log.d(TAG, "服务器异常");
  41. 							ToastUtil.show(getActivity(), "服务器异常");
  42. 							break;
  43. 						case HMError.Register.ACCOUNT_EXIST:
  44. 							Log.d(TAG, "用户已经存在");
  45. 							ToastUtil.show(getActivity(), "用户已经存在");
  46. 							break;
  47. 						default:
  48. 							break;
  49. 						}
  50. 					}
  51. 				});

 

附件列表

    【推广】 免费学中医，健康全家人
    原文地址：https://www.cnblogs.com/sixrain/p/5188137.html