在我的应用程序中,我需要将各种 POST
请求发送到服务器 . 其中一些请求有回复,有些则没有 .
这是我用来发送请求的代码:
private static final String TAG = "Server";
private static final String PATH = "http://10.0.0.2:8001/data_connection";
private static HttpResponse response = null;
private static StringEntity se = null;
private static HttpClient client;
private static HttpPost post = null;
public static String actionKey = null;
public static JSONObject sendRequest(JSONObject req) {
try {
client = new DefaultHttpClient();
actionKey = req.getString("actionKey");
se = new StringEntity(req.toString());
se.setContentEncoding(new BasicHeader(HTTP.CONTENT_ENCODING, "application/json"));
se.setContentType(new BasicHeader(HTTP.CONTENT_TYPE, "application/json"));
post = new HttpPost(PATH);
post.setEntity(se);
Log.d(TAG, "http request is being sent");
response = client.execute(post);
Log.d(TAG, "http request was sent");
if (response != null) {
InputStream in = response.getEntity().getContent();
String a = convertFromInputStream(in);
in.close();
return new JSONObject(a);
}
} catch (UnsupportedEncodingException e) {
Log.d(TAG, "encoding request to String entity faild!");
e.printStackTrace();
} catch (ClientProtocolException e) {
Log.d(TAG, "executing the http POST didn't work");
e.printStackTrace();
} catch (IOException e) {
Log.d(TAG, "executing the http POST didn't work");
e.printStackTrace();
} catch (JSONException e) {
Log.d(TAG, "no ActionKey");
e.printStackTrace();
}
return null;
}
private static String convertFromInputStream(InputStream in)
throws IOException {
BufferedReader br = new BufferedReader(new InputStreamReader(in));
StringBuilder sb = new StringBuilder();
String line = null;
while ((line = br.readLine()) != null) {
sb.append(line);
}
return (sb.toString());
}
这是发送请求的 AsyncTask
类的代码:
class ServerRequest extends AsyncTask<JSONObject, Void, JSONObject> {
@Override
protected JSONObject doInBackground(JSONObject... params) {
JSONObject req = params[0];
JSONObject response = Server.sendRequest(req);
return response;
}
@Override
protected void onPostExecute(JSONObject result) {
// HANDLE RESULT
super.onPostExecute(result);
}
}
当服务器未返回响应时,我的问题就开始了 . 即使在完成工作后, AsyncTask
线程仍保持打开状态,因为 HTTPClient
永远不会关闭连接 .
有没有办法不等待回应?这肯定会给服务器增加很多开销,因为尝试连接它的所有Android应用程序都会使连接保持活动状态,并且可能会在应用程序本身造成很多问题 .
基本上,我正在寻找的是一种方法,它允许我发送到 POST
消息并在发送请求后立即终止连接,因为没有响应我的方式 .
1 回答
只是,用HttpClient对象设置
ConnectionTimeOut
(代码是为了你的理解,它可能会有所不同)现在,它将在您定义的 TimeoOut 之后终止连接 . 但请确保这将抛出
TimeOutException
所以您必须在 HttpRequest 中处理此异常..(使用Try -catch)EDIT: 或者您可以使用 HttpRequestExecutor 类 .
从包org.apache.http.protocol的类HttpRequestExecutor
确定响应是否附带实体 . 此类中的实现基于RFC 2616.未知方法和响应代码应表示对实体的响应 . 派生执行程序可以重写此方法以处理RFC 2616中未指定的方法和响应代码 .