JAVA asnychrone Verarbeitung TCP

[Frank (Gast)]

Hallo zusammen,

ich fange gerade an Java-Apps für Android zu programmieren. Dabei geht 
es gerade um einen TCP-Cienten, der sich an einem PC anmeldet. Das 
funktioniert soweit alles.

Aber wie bekomm ich es hin, dass das Programm asynchron empfangene 
Zeichen verarbeiten kann und beispielsweise anzeigen kann.

Ich bekomm es nur so hin, dass ich im Vorfeld immer was schicken muss.

Hat jemand eine Idee?

package de.test.hello;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

import android.app.Activity;
import android.app.AlertDialog;
import android.os.Bundle;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.EditText;


public class HelloWorkshopActivity extends Activity implements OnClickListener, Runnable {
    /** Called when the activity is first created. */
    
    
    private Button ConnectButton;
    private Button SendButton;
    private Button DisconnectButton;
    
    
    
    
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);
        ConnectButton = (Button)findViewById(R.id.Connect);
        ConnectButton.setOnClickListener(this);
        SendButton = (Button)findViewById(R.id.Send);
        SendButton.setOnClickListener(this);
        DisconnectButton = (Button)findViewById(R.id.Disconnect);
      
        DisconnectButton.setOnClickListener(this);
        
    }

  @Override
  public void onClick(View v) {
        EditText nameField = (EditText) findViewById(R.id.name_field);
        String name = nameField.getText().toString();
        if (name.length() == 0) {
            new AlertDialog.Builder(this) 
                    .setMessage(R.string.error_name_missing)
                    .setNeutralButton(R.string.error_ok, null)
                    .show();
            return;
        }
       if (v == ConnectButton){
           try {
             connectTOTCP();
           }
           catch (Exception e ){
             new AlertDialog.Builder(this) 
               .setMessage("FEHLER")
               .setNeutralButton(R.string.error_ok, null)
               .show();
           }
       }
       if (v == SendButton){
         try {
      out.write(name);
      out.flush();
      

      
      
      String message = in.readLine();
    
    
      
      nameField.setText(message);
      
   
    } 
         catch (IOException e) {
      // TODO Auto-generated catch block
      //e.printStackTrace();
    }
       }
    if (v == DisconnectButton){
      try {
        out.write("/DISCONNECT");
        out.flush();
      } catch (IOException e) {
        // TODO Auto-generated catch block
        //e.printStackTrace();
      }
    }
        }
        
    public Socket clientSocket;
    public BufferedReader in;
    public BufferedWriter out;
    
  
    
    
  public void connectTOTCP() {

        
    try {
      clientSocket = new Socket("192.168.1.2", 1522);
      in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
       out = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
      out.write("/CONNECT|CLIENTAndroid");
      out.flush();
      
  
      
    } catch (UnknownHostException e) {
          new AlertDialog.Builder(this) 
            .setMessage("FEHLER")
            .setNeutralButton(R.string.error_ok, null)
            .show();
    } catch (IOException e) {
          new AlertDialog.Builder(this) 
            .setMessage("FEHLER")
            .setNeutralButton(R.string.error_ok, null)
            .show();
    }
    
  }

  @Override
  public void run() {
    // TODO Auto-generated method stub
    
  }


}

[Andreas B. (andreasb)]

Du musst einen neuen Thread machen. (Runnable hast du ja bereits 
implementiert).

Thread t = new Thread(this);
t.start();


public void run() {
   // hier machst du eine blockierende Operation

   while(true) {
      in.read();
      System.out.println("etwas angekommen");
   }

}

Code ist nicht getestet.


mfg Andreas

[Frank (Gast)]

Wo genau muss denn:

Thread t = new Thread(this);
t.start();


rein?

Ich habs jetzt in die ConnectTOTCP reingetan, aber da gehts irgendwie 
nicht....

[Andreas B. (andreasb)]

Frank schrieb:
> Ich habs jetzt in die ConnectTOTCP reingetan, aber da gehts irgendwie
> nicht....

Was heisst geht nicht?


mfg Andreas