Android-обработчик отправляет только одно сообщение

Question

Я пытаюсь реализовать интерфейс REST в android, и мне нужен поток в фоновом режиме, отправляющий сообщения «Я жив» на ip-адрес. Для этого я создал вызванный поток RestPostThread, который работает в фоновом режиме, пока я делаю что-то в своем потоке пользовательского интерфейса.

Проблема в том, что после отправки первого сообщения в RestPostThread я не могу выйти из петлителя или отправить ему другое сообщение с другим IP-адресом или чем-то другим.

Вот код как для пользовательского интерфейса и RestPostThread:

public class MainActivity extends AppCompatActivity{ 

Handler workerThreadHandler; 


protected void onCreate(Bundle savedInstanceState) { 
    super.onCreate(savedInstanceState); 
    setContentView(R.layout.activity_main); 
    Toolbar toolbar = (Toolbar) findViewById(R.id.toolbar); 
    final TextView text1 = (TextView) findViewById(R.id.text1); 
    final TextView text2 = (TextView) findViewById(R.id.text2); 
    setSupportActionBar(toolbar); 


    final RestPostThread RPT = new RestPostThread(); 
    RPT.start(); 

    while(workerThreadHandler == null) { 
     workerThreadHandler = RPT.getThreadHandler(); 
    } 

    Button buttonStop = (Button) findViewById(R.id.buttonStop); 
    buttonStop.setOnClickListener(new View.OnClickListener(){ 
     public void onClick(View view) { 
      try { 



       workerThreadHandler.getLooper().quit(); 
      }catch(Exception e){ 
       text1.setText(e.getMessage()); 
       text2.setText("Exception!"); 
      } 

     } 
    }); 

    Button buttonSend = (Button) findViewById(R.id.buttonSend); 
    buttonSend.setOnClickListener(new View.OnClickListener(){ 
     public void onClick(View view) { 
      try { 
       text1.setText(new RestGet().execute(editText.getText().toString()).get()); 
       text2.setText("everything went well!"); 
      }catch(Exception e){ 
       text1.setText(e.getMessage()); 
       text2.setText("Exception!"); 
      } 

     } 
    }); 
} 

А вот код для RestPostThread:

public class RestPostThread extends Thread { 
public Handler mHandler; 

@Override 
public void run(){ 

    Looper.prepare(); 
    mHandler = new Handler() { 
     public void handleMessage(Message msg) { 
      Log.d("MYASDASDPOASODAPO", "dentro mensaje"); 
      while (!msg.obj.equals(null)) { 
       try { 
        Thread.sleep(1000); 
        URL url = new URL(msg.obj.toString()); 
        HttpURLConnection conn = (HttpURLConnection) url.openConnection(); 
        conn.setDoOutput(true); 
        conn.setRequestMethod("POST"); 
        String input = "<Instruction><type>put_me_in</type><room>Room 1</room></Instruction>"; 

        OutputStream os = conn.getOutputStream(); 
        os.write(input.getBytes()); 
        os.flush(); 

        if (conn.getResponseCode() != HttpURLConnection.HTTP_CREATED) { 
         // throw new RuntimeException("Failed : HTTP error code : " + conn.getResponseCode()); 
        } 
        BufferedReader br = new BufferedReader(new InputStreamReader((conn.getInputStream()))); 
        String output; 
        String aux = new String(); 
        while ((output = br.readLine()) != null) { 
         aux = aux + output; 
        } 
        conn.disconnect(); 
        //return aux; 
       } catch(MalformedURLException e) { 
        e.printStackTrace(); 
        //return null; 
       } catch(IOException e) { 
        e.printStackTrace(); 
        //return null; 
       } catch(Exception e) { 
       } 
      } 
      Log.d("CLOSING MESSAGE", "Closing thread"); 
     } 
    }; 
    Looper.loop(); 
} 

public Handler getThreadHandler() { 
    return this.mHandler; 
} 

Answer 1

Мне удалось решить проблему. Проблема заключалась в том, что я обмотать все внутри этого:

while (!msg.obj.equals(null)) {} 

Я реализовал обработчик как в этом потоке и в потоке пользовательского интерфейса, и теперь у меня есть связь назад и вперед между обеими, моим RestPostThread будет выглядеть так:

public class RestPostThread extends Thread { 

public Handler mHandler,uiHandler; 


public RestPostThread(Handler handler) { 
    uiHandler = handler; 
} 

@Override 
public void run(){ 
    Looper.prepare(); 
    mHandler = new Handler() { 
     public void handleMessage(Message msg) { 
       try { 
        //Thread.sleep(1000); 
        URL url = new URL(msg.obj.toString()); 
        HttpURLConnection conn = (HttpURLConnection) url.openConnection(); 
        conn.setDoOutput(true); 
        conn.setRequestMethod("POST"); 
        String input = "<Instruction><type>put_me_in</type><room>Room 1</room></Instruction>"; 

        OutputStream os = conn.getOutputStream(); 
        os.write(input.getBytes()); 
        os.flush(); 

        if (conn.getResponseCode() != HttpURLConnection.HTTP_CREATED) { 
         // throw new RuntimeException("Failed : HTTP error code : " + conn.getResponseCode()); 
        } 
        BufferedReader br = new BufferedReader(new InputStreamReader((conn.getInputStream()))); 
        String output; 
        String aux = new String(); 
        while ((output = br.readLine()) != null) { 
         aux = aux + output; 
        } 
        conn.disconnect(); 
        Message msg2 = uiHandler.obtainMessage(); 
        msg2.obj = aux; 
        uiHandler.sendMessage(msg2); 
       }catch(MalformedURLException e){ 
        e.printStackTrace(); 
       }catch(IOException e){ 
        e.printStackTrace(); 
       }catch(Exception e){ 
       } 
      } 
    }; 
    Looper.loop(); 
} 


public Handler getThreadHandler() { 
    return this.mHandler; 
} 

}

и в моем MainActivity у меня есть этот обработчик, который позволяет мне «петля» (в основном только собирается туда и обратно между RestPostThread и UIThread) мое сообщение сообщение, пока я не решу, чтобы остановить от MainActivity меняет boolean loop:

public Handler uiHandler = new Handler() { 
    public void handleMessage(Message inputMessage) { 
     Log.d("FROM UI THREAD",inputMessage.obj.toString()); 
     if(loop) { 
      Message msg = workerThreadHandler.obtainMessage(); 
      String url = "http://192.168.1.224:9000/xml/android_reply"; 
      msg.obj = url; 
      workerThreadHandler.sendMessageDelayed(msg,1000); 
     } 
    } 
}; 

Answer 2

Посмотрите HandlerThread для борьбы с потоком до обрабатывать только сообщения. Ваш Handler не должен зацикливаться на таком сообщении, это не сработает. Это работа Looper, чтобы иметь дело с новыми, входящими Message или Runnable объектами, отправленными на Handler, который связан с Looper.

Независимо от этого, вы должны более подробно рассмотреть использование Loader для обработки API типа REST; или, изучите стороннюю библиотеку, такую ​​как модификация, для работы с REST.