Android Von einem Thread auf anderen zugreifen

[ATKA-Soft]

Hi,
ich bin gerade dabei nen kleinen Chat mit Android zu programmieren und hab dabei Probleme mit dem Client.
Nachdem ich herausgefunden habe, dass man die Sockets und das ganze Netzwerkgedöns nicht in den Mainthread packen darf, habe ich ne zweite Klasse angelegt die Runnable implementiert und diese mit dem ganzen Netzwerkzeug drin in nem neuen Thread gestartet. Problem ist jetzt nur, dass ich von der Main Klasse jetzt nicht mehr auf den Netzwerk-Klassen-Thread zugreifen kann.
Sprich, wenn auf den Button gedrückt wird, soll der Text aus einem EditText verschickt werden. Geht leider nicht so einfach, da der GUI Kram im Mainthread ist, und der Netzwerk Kram im Netzwerk-Klassen-Thread. Ebenso bei der Ausgabe von empfangenen Nachrichten vom Server in nem TextView.

Daher meine Frage, wie kann ich es machen, dass die beiden Threads gegenseitig aufeinander zugreifen können.

Mainclass:

protected void onCreate() {
    Button b = (Button)findViewById(R.id.button1);
    b.setOnClickListener(new OnClickListener() {
    
    @Override
    public void onClick(View v) {
        Thread connThread =new Thread(new Connection());
        connThread.start();
        Connection con = new Connection();
        con.send("<|cldt|name|"+n+"|>");
    });
}

public void newMsg(String msg){
    Toast.makeText(getBaseContext(), "Message: "+msg, Toast.LENGTH_SHORT).show();
    System.out.println("Message: "+msg);
}

Connectionclass:

public class Connection implements Runnable{

	Socket client;
	BufferedReader reader;
	PrintWriter writer;
	public Connection (){
		
	}
	
	

	@Override
	public void run() {
		try {
			String server =InetAddress.getByName("MyServer").getHostAddress().toString();
		    client = new Socket(server, 8000);
		    System.out.println("Connected");
		    InputStreamReader streamReader = new InputStreamReader(client.getInputStream());
		    reader = new BufferedReader(streamReader);
		    writer = new PrintWriter(client.getOutputStream());
		    
		    Thread readerThread = new Thread(new recive());
		    readerThread.start();
		 
		} catch (UnknownHostException e) {
		     e.printStackTrace();
		} catch (IOException e) {
		     e.printStackTrace();
	    }		
	}
	
	public void send(String msg){
		System.out.println("Send");
		try {
			writer.println(msg);
			writer.flush();
			System.out.println("Message Send");
		} catch (Exception e){
			e.printStackTrace();
		}
	}
	
	public class recive implements Runnable {

		@Override
		public void run() {
			System.out.println("Reading");
			String msg;
			MainActivity main = new MainActivity();
			try {
				while ((msg=reader.readLine()) != null) {
					main.newMsg(msg);
				}
			}catch (Exception e) {
				e.printStackTrace();
			}
			
		}
		
	}

}

So weit mein Code, funktioniert aber nicht. Ich hoffe mir kann hier jemand helfen.

 

[Michel95]

Hi,

das gleiche Problem hatte ich auch, wenn auf ein View aus einem anderen Thread zugreifen willst, kannst du das mit der post()-Methode machen:

deinView.post(new Runnable() {
   public void run() {
       deinView.setText("neuer Text");
   }
})

Ebenfalls kannst du eine Implementierung der Klasse

AsyncTask

verwenden, dazu habe ich mir diesen Link angeschaut:
Android Background Processing with Handlers and AsyncTask and Loaders - Tutorial

 

[ATKA-Soft]

Danke für die Antwort, ich hab mir jetzt mal das ganze da zu den AsyncTasks durchgelesen und es damitgemacht. Leider klappt es jetzt immer noch nicht.Er connected zwar und mein Server zeigt mir dass auch an, aber wenn ich einen Text absende, crasht die App.

Woran liegt es bzw. was sollte ich anderst machen? (Tschuldigung, dass ich das so blöd frage, aber nach 1 1/2 Stunden grübeln, komm ich irgendwie gar nicht mehr weiter ;( )

public class MainActivity extends Activity implements android.view.View.OnClickListener {
	
	private TextView MessageView;
	private Button button;
	private EditText input;
	Socket sock;
	BufferedReader reader;
	PrintWriter writer;
	


    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        
        MessageView = (TextView)findViewById(R.id.Textfield);
        MessageView.append("Hello User \n");
        
        input=(EditText)findViewById(R.id.editText1);
        
        button = (Button)findViewById(R.id.button1);
        button.setOnClickListener(this);        
        
        int corePoolSize = 60;
	int maximumPoolSize = 80;
	int keepAliveTime = 10;

	BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(maximumPoolSize);
		Executor threadPoolExecutor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS, workQueue);
        new connect().executeOnExecutor(threadPoolExecutor);
    }
    
	@Override
	public void onClick(View v) {
		int corePoolSize = 60;
		int maximumPoolSize = 80;
		int keepAliveTime = 10;

		BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(maximumPoolSize);
		Executor threadPoolExecutor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS, workQueue);
		new send().executeOnExecutor(threadPoolExecutor);
	}
	
	class connect extends AsyncTask<Void,Integer,String>{

		@Override
		protected String doInBackground(Void... params) {
			String t="";
			try {
				String server =InetAddress.getByName("jarves-server.no-ip.info").getHostAddress().toString();
				sock= new Socket(server, 8000);
				InputStreamReader streamReader = new InputStreamReader(sock.getInputStream());
				reader= new BufferedReader(streamReader);
				writer= new PrintWriter(sock.getOutputStream());
				
				
				int corePoolSize = 60;
				int maximumPoolSize = 80;
				int keepAliveTime = 10;

				BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(maximumPoolSize);
				Executor threadPoolExecutor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS, workQueue);
				new send().executeOnExecutor(threadPoolExecutor);
				//new receive().executeOnExecutor(threadPoolExecutor);				
			} catch (Exception e) {
				System.out.println(e.toString());
			}
			
			return t;
		}
		
		@Override
		protected void onPostExecute(String v){
			MessageView.append("Connected");
		}
	}
	
	class send extends AsyncTask<Void, Integer, String>{
		String sendmsg;
		
		@Override
		protected void onPreExecute(){	
			sendmsg=input.getText().toString();
			input.setText("");
			input.requestFocus();
		}
		
		@Override
		protected String doInBackground(Void... arg0) {
			writer.write(sendmsg);
			writer.flush();
			return sendmsg;
		}
		
		@Override
		protected void onPostExecute(String v){
			MessageView.append("\n Me: "+v);
		}
		
	}
	
	class receive extends AsyncTask<Void, Integer, String>{
		String msg;
		
		@Override
		protected String doInBackground(Void... params) {
			try {
				msg=reader.readLine();
			} catch (Exception e) {
				System.out.println(e.toString());
			}
			return msg;
		}
		
		@Override
		protected void onPostExecute(String v){
			MessageView.append("Server: "+v);
		}
		
	}
    
}

 

[dzim]

Ok. Ein paar Sachen vorweg:
1) Es gibt im Forum eine Suchfunktion. Der Thread, den Michael95 meint, ist noch unter den ersten im Abschnitt "Mobile Geräte" gewesen...
2) Verwende kein System.[out|err].* - Es gibt die Klasse android.util.Log mit den statischen Methoden #e (error), #w (warning), #d (debug), #i (info), #v (verbose) und für die ganz kniffligen Probleme #wtf (kein Scherz)
3) Bei einem Crash ist der Code zwar schon mal gut, aber idealerweise lieferst du auch einen Stacktrace. Das macht es noch einfacher.