android – 保持连接打开并读取数据,直到强制关闭

当我的活动加载时,我正在连接到Web服务.当我从服务中得到响应时,我再次呼叫服务等等.

@Override
protected void onCreate(Bundle savedInstanceStatE) {  
….  
callWebMethod();
}  

// Called on getTing response  
@Override
public void run(String value) {  
….  
callWebMethod();  
}

这就是我连接服务的方式

httpGet @R_801_10613@est = new httpGet(url + combinedParams);  
httpClient client = new DefaulthttpClient(httpParameters);

    httpResponse httpResponse;

        httpResponse = client.execute(@R_801_10613@est);
        responseCode = httpResponse.getStatusLine().getStatusCode();
        message = httpResponse.getStatusLine().getReasonPhrase();

        httpentity entity = httpResponse.getEntity();

        if (entity != null) {

            InputStream instream = entity.getContent();
            response = convertStreamToString(instream);
            response = StringUtils.remove(response,"\n");
            response = StringUtils.remove(response,'"');
        }

我是否有可能在开始时只连接一次服务,然后连接保持打开状态,应用程序继续从服务中读取数据,直到强制关闭连接.
如果需要更多代码,请告诉我.

更新：然后我尝试使用ClientConnectionManager但仍然连接一次又一次初始化.虽然它正在获取数据.我想要的是连接保持打开状态,并继续从服务中读取数据.

httpParams httpParameters = new BasichttpParams();

SharedPreferences preferences = context.getSharedPreferences(
            "MyPreferences",Context.MODE_PRIVATE);

    int timeoutConnection = Integer.parseInt(preferences.getString(
            "timeout","60")) * 1000;
    httpconnectionParams.setConnectionTimeout(httpParameters,timeoutConnection);

    httpconnectionParams.setSoTimeout(httpParameters,2000);
    System.setProperty("http.keepAlive","true");
    httpClient client = new DefaulthttpClient(httpParameters);

    ClientConnectionManager mgr = client.getConnectionManager();
    client = new DefaulthttpClient(new ThreadSafeClientConnManager(
            client.getParams(),mgr.getscheR_54_11845@eRegistry()),client.getParams());
    while (true) {

        httpResponse httpResponse;

        try {
            httpResponse = client.execute(@R_801_10613@est);
            responseCode = httpResponse.getStatusLine().getStatusCode();
            message = httpResponse.getStatusLine().getReasonPhrase();

            httpentity entity = httpResponse.getEntity();

            if (entity != null) {

                InputStream instream = entity.getContent();
                response = convertStreamToString(instream);
                response = StringUtils.remove(response,"\n");
                response = StringUtils.remove(response,'"');
                ((Activity) context).runOnUiThread(new Runnable() {
                    public void run() {
                        callBACk.run(responsE);  // This calls activity callBACk function.
                    }
                });

                // Closing the input stream will trigger connection release
                // instream.close();
            }

        } catch (ConnectTimeoutException E) {
         ….  
         }