0

Estoy trabajando un desarrollo el cual consiste en poder realizar peticiones HTTP utilizando como intermediario el cable usb y la pc, he seguido esta página la cual me ayudó pero estoy teniendo un pequeño problema el cual no consigo corregir, aquí mi código:

Tengo mi clase LoginActivity.java, en la cual realizo la inicialización del socket y ademas el logueo.

public class LoginActivity extends AppCompatActivity {

private boolean isChekedOffLine = false;

private Handler handler = new Handler();
private ServerSocket serverSocket;
private int SERVERPORT;
private int TIMEOUT_SERVER;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_login);
    initUI();        

    SERVERPORT = Parameters.SERVER_PORT;
    TIMEOUT_SERVER = Parameters.SERVER_TIMEOUT;

    Thread fst = new Thread(new ServerThread());
    fst.start();
}

private void initUI() {
    String userLogin = null;        
    ....
    ....

    final Button btnAccess = (Button) findViewById(R.id.btnAccess);                
    btnAccess.setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View v) {
            Login loginBean = new Login();
            String user = txtUser.getText().toString().trim();
            String pass = txtPass.getText().toString().trim();
            if (!user.equals("")){
                if(!pass.equals("")){
                    loginBean.setUser(user.toUpperCase());
                    loginBean.setPass(pass);
                    loginBean.setType("A");
                    loginBean.setIsOffline(isChekedOffLine);
                }else {
                    txtPass.setError(getString(R.string.err_pass));
                    return;
                }
            }else {
                txtUser.setError(getString(R.string.err_user));
                return;
            }
            LoginTask loginTask = new LoginTask(LoginActivity.this, loginBean);
            loginTask.execute();
        }
    });        

public class ServerThread implements Runnable {
    public void run() {
        Socket client = null;
        try {
            serverSocket = new ServerSocket(SERVERPORT);
            serverSocket.setSoTimeout(TIMEOUT_SERVER);

            client = serverSocket.accept();
            Globals.socketIn = new BufferedReader(new InputStreamReader(client.getInputStream()));
            Globals.socketOut = new PrintWriter(client.getOutputStream(),true);

        }catch (SocketTimeoutException e){
            handler.post(new Runnable() {
                @Override
                public void run() {
                    Toast.makeText(LoginActivity.this,"Tiempo de espera terminado",Toast.LENGTH_SHORT).show();
                }
            });
        }catch (IOException e) {
            handler.post(new Runnable() {
                @Override
                public void run() {
                    Toast.makeText(LoginActivity.this,"Ocurrio un error al inicia el servicio",Toast.LENGTH_SHORT).show();
                }
            });
            e.printStackTrace();
        }finally {
            try {
                if (serverSocket != null) {
                    serverSocket.close();
                }
            } catch (IOException e) {
                Log.e("LoginActivity",e.getMessage());
                e.printStackTrace();
            }
        }

        if (client != null) {
            Globals.connected = true;
            handler.post(new Runnable() {
                @Override
                public void run() {
                    Toast.makeText(LoginActivity.this,"Conexión establecida con exito.!!",Toast.LENGTH_SHORT).show();
                }
            });
        }
    }
}

  @Override
  protected void onStop() {
    super.onStop();
    try {
        if (serverSocket != null) {
            serverSocket.close();
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
  }

  public static class Globals {
      public static boolean connected;
      public static BufferedReader socketIn;
      public static PrintWriter socketOut;
  }

}

Luego en mi clase LoginTask.java, para realizar la validación mando una petición HTTP a través del método getValidateUser().

public class LoginTask extends AsyncTask {

private ProgressDialog progressDialog;
private Context context;
private Resources resources;
private Login loginParams;
private String msgAccess;

public LoginTask(Context context, Login loginParams){
    this.context = context;
    this.resources = context.getResources();
    this.loginParams = loginParams;
}

@Override
protected void onPreExecute(){
    progressDialog = new ProgressDialog(context);
    progressDialog.setMessage(resources.getString(R.string.msg_access));
    progressDialog.setCancelable(true);
    progressDialog.setProgressStyle(ProgressDialog.STYLE_SPINNER);
    progressDialog.show();
}

@Override
protected String doInBackground(Object[] objects) {        
    msgAccess = getValidateUser();
    return msgAccess;
}

@Override
protected void onPostExecute(Object o){
    if (msgAccess != null) {
        if (msgAccess.equals("OK")) {
            ....
            ....
        } else{
            AlertDialog.Builder builder = new AlertDialog.Builder(context);
            builder.setTitle(R.string.msg_alert_title_login);
            builder.setMessage(msgAccess);
            builder.setPositiveButton("Aceptar", new DialogInterface.OnClickListener() {
                @Override
                public void onClick(DialogInterface dialogInterface, int i) {
                }
            });
            builder.show();
        }
    }else{
        AlertDialog.Builder builder = new AlertDialog.Builder(context);
        builder.setTitle(R.string.msg_alert_title_login);
        builder.setMessage(R.string.err_msg_null);
        builder.setPositiveButton("Aceptar", new DialogInterface.OnClickListener() {
            @Override
            public void onClick(DialogInterface dialogInterface, int i) {
            }
        });
        builder.show();
    }

    if (progressDialog.isShowing()) {
        progressDialog.dismiss();
    }
}

private String getValidateUser(){        
    String isUser = null;
    String line;
    JSONArray json;
    StringBuilder builder = new StringBuilder();
    StringBuilder requestURL = new StringBuilder();
    URL url;
    URLConnection conn;
    BufferedReader reader;
    try {
        requestURL.append(Parameters.REQUEST_URL_SERVICE_COLLID).append("/").append(loginParams.getUser());
        if (LoginActivity.Globals.connected){
            url = new URL(requestURL.toString());
            conn = url.openConnection();
            conn.setConnectTimeout(Parameters.TIMEOUT);
            conn.setReadTimeout(Parameters.TIMEOUT);
            LoginActivity.Globals.socketOut.println(requestURL.toString());
            LoginActivity.Globals.socketOut.flush();
            // Aqui se queda y tiene al ProcessDialog sin terminar y no puede pasar al método onPostExecute
            while ((line = LoginActivity.Globals.socketIn.readLine()) != null) {                    
                builder.append(line);
            }                
        }else {
            url = new URL(requestURL.toString());
            conn = url.openConnection();
            conn.setConnectTimeout(Parameters.TIMEOUT);
            conn.setReadTimeout(Parameters.TIMEOUT);
            reader = new BufferedReader(new InputStreamReader(conn.getInputStream()));
            while ((line = reader.readLine()) != null) {
                builder.append(line);
            }
        }
        if (builder.toString().length() > 2) {
            JSONObject jsonObj = new JSONObject("{\"users\": [" + builder.toString() + "]}");
            json = jsonObj.getJSONArray("users");
            for (int i=0;i<json.length();i++){
                JSONObject responseObject = json.getJSONObject(i);
                if (responseObject != null) {                        
                    ....
                    ....  
                }
            }
        }
    } catch (Exception e) {
        Log.e(tag,e.getMessage());
        e.printStackTrace();
    }
    return isUser;
}
}

El problema se da en el while (comentado en el código), dado que por algún motivo se queda en un bucle sin terminar (o terminar y queda allí), he puesto los Log para ir mostrando las lineas que se imprimen y veo que solo se muestra una sola linea, que es la que requiero pero ahí queda sin terminar, posiblemente algo este haciendo mal o me este faltando algo más.

Espero haberme explicado, Gracias.

2 respuestas 2

1

@BrandoT revisa tu código si pones el puntero del mouse sobre la línea, puedo asegurar que tendrás un mensaje como este:

Condition '(line = LoginActivity.Globals.socketIn.readLine()) != null' is always 'true'

Lo cual indica que tienes un "loop" infinito, puedes realizar este cambio para que funcione adecuadamente:

   String line = LoginActivity.Globals.socketIn.readLine();
    while (line != null) {
        builder.append(line);
        line = LoginActivity.Globals.socketIn.readLine();
    }
}
2
  • 1
    Gracias @Elenasys, realize la adecuación y adicionalmente agregue una validación.
    – Brando T.
    Commented el 2 jun. 2016 a las 21:24
  • Hola @BrandoT. si pudiste ver el mensaje que te menciono, en realidad tenias un loop infinito =(. Saludos!
    – Jorgesys
    Commented el 2 jun. 2016 a las 21:29
0

Bueno, luego de probar varias alternativas di con la solución, o al menos con la que me funciona. En la parte del while agregue la siguiente validación.

String line = LoginActivity.Globals.socketIn.readLine();
while (line != null) {
    Log.e(tag,line);
    builder.append(line);
    if (LoginActivity.Globals.socketIn.ready()){ // Aquí la validación
          line = LoginActivity.Globals.socketIn.readLine();
    }else{
          line = null;
    }
}

Espero sea de utilidad.

Tu Respuesta

By clicking “Publica tu respuesta”, you agree to our terms of service and acknowledge you have read our privacy policy.

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.