j2me openOutputStream поток уже открыт - PullRequest
Новая
       48

j2me openOutputStream поток уже открыт

0 голосов
/ 03 сентября 2011

У меня проблемы с отправкой данных HttpConnection на мой сервер. В первый раз все идет хорошо. Во второй раз это говорит; «Поток уже открыт», но я закрываю все после ответа.

Вот мой код: 

import javax.microedition.io.Connector;
import javax.microedition.io.HttpConnection;
import javax.microedition.location.*;
import java.io.*;

class GetSnowheights
{    
    HttpConnection http = null;
    QualifiedCoordinates q = null;
    public String result = "Geen data";
    private boolean running;

    public GetSnowheights(QualifiedCoordinates q) {        
        try
        {
            /*
            this.http = (HttpConnection)Connector.open("http://www.diamond4it.nl/bb/");                
            this.http.setRequestMethod(HttpConnection.POST);
            this.http.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
            */
            //Internet.getInstance();
            this.http = Internet.getConnection();
        }catch(Exception err){
           err.printStackTrace();
        }
        this.q = q;
        this.result = "Running";
    }

    public void GetResult(){
        StringBuffer sb = new StringBuffer();        
        this.result = "GetResult";

        if(this.http != null){

            OutputStream os = null;
            InputStream is = null;
            try
            {
                //Send request
                os = this.http.openOutputStream();
                String data = "lat=1&lng=1";
                //String data = "lat=" + this.q.getLatitude() + "&lng=" + this.q.getLongitude();
                os.write(data.getBytes());
                os.flush();
                os.close();
                this.result = "dataSend";                

                //Check response and read data
                int res = this.http.getResponseCode();
                this.result = "Result: " + res;
                if(res == 200){
                    is = this.http.openInputStream();
                    int ch;
                    // Check the Content-Length first 
                    long len = this.http.getLength();
                    if(len!=-1) { 
                        for(int i = 0;i<len;i++){
                            if((ch = is.read())!= -1){
                                sb.append((char)ch);
                            }
                        }
                    } else { 
                        // if the content-length is not available 
                        while ((ch = is.read()) != -1){
                            sb.append((char)ch); 
                        }
                    }
                    is.close();
                }

                this.result = sb.toString();

            }catch(Exception err){
                //err.printStackTrace();
                this.result = err.toString() + "\r\n" + err.getMessage();
            }finally{
                if(is != null){
                    try{
                        is.close();
                    }catch(Exception err){
                        err.printStackTrace();
                    }
                }
                if(os != null){
                    try{
                        //os.flush();
                        os.close();
                    }catch(Exception err){
                        err.printStackTrace();
                    }
                }

                /*
                if(http != null){
                    try{
                        http.close();
                    }catch(Exception err){
                        err.printStackTrace();
                    }
                }
                */
            }

        }else{
            this.result = "No connection";
        }
    }    

}

1 Ответ

0 голосов
/ 03 сентября 2011

2 идеи:

  1. Почему вы закомментировали блок http.close() in finally? Мы всегда должны закрывать HttpConnections.

  2. Разве вы не вызываете GetResult() из нескольких потоков одновременно? Если да, то синхронизируйте метод, добавив в его определение ключевое слово synchronized.

P.S. Я нахожу дизайн класса немного вводящим в заблуждение. Ошибочно использовать ошибку очень легко. Я бы объединил GetSnowheights и GetResult в единственный синхронизированный метод.

...