Variable übergeben

Brausebernd · 19. August 2012

Hallo,
ich möchte gern wissen wie ich die Variable n an meinen client übergeben kann.
ich habe einen Server der alle 2 Sekunden einen neuen Integerwert erzeugt.
Dieser Wert soll an den Client über eine Socketverbindung gesendet werden, nur wie?

Hier mal mein Code:

Java

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Timer;
import java.util.TimerTask;


public class TCPServer
{
	static int n;


	ServerSocket server = new ServerSocket(4444);


	TCPServer() throws IOException 
	{
		System.out.println("Server gestartet!");
		System.out.println(n);


		Socket client = server.accept();
		BufferedReader input = new BufferedReader(new InputStreamReader(client.getInputStream()));
		BufferedWriter output = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
		
		String nachricht = input.readLine();
		System.out.println("Nachricht vom Client: " + nachricht);
		output.write(n);
		output.newLine();
		output.flush();
	}


	public static void main(String[] args) 
	{
		final int[] array = { 1, 2, 3, 4, 5};
		Timer timer = new Timer();
		timer.scheduleAtFixedRate(new TimerTask()
		{
			private int next = 0;
			@Override
			public void run()
			{
				n = (array[next % array.length]);
				next++;
			}
		}, 0, 2000);
		
		try 
		{
			new TCPServer();
		} 
		catch (IOException e) {
			System.out.println(e);
		}
	}


}

Alles anzeigen

Was zur Zeit passiert iost, wenn ich die Anwendung starte die Ausgabe, "Server gestartet!" und "0" bekomme.
Die variable n wird alle 2 Sekunden mit dem Wert 1,2,3,4,5,1,2... usw. belegt.
Dieser Wert soll alle an den Client gesendet werden.

Gruß
Brausebernd

Brausebernd · 21. August 2012

kann mir hier keiner helfen?
ich will dich nur alle 2 Sekunnden eine Zahl senden...;-(
Gruß
Brausebernd

titus · 21. August 2012

Hi Brausebernd,

kommt beim Client was an?
Wird das System.out.println("Nachricht vom Client: " + nachricht); Ausgeben?

mfg Titus

Brausebernd · 23. August 2012

Hallo,

Zitat von titus

Wird das System.out.println("Nachricht vom Client: " + nachricht); Ausgeben?

ja es wir ausgegeben. sobald der Client eine Verbindung aufbaut.

Zitat von titus

kommt beim Client was an?

Ja da kommt was an und zwar die Zahl wo sich das Programm grad "befindet".
Danach ist aber "Ruhe" es soll aber alle 2 Sekunden der neue Wert ausgegeben werden.

Hier mal der Client Code:

Java

package com.example.tcpclient;


import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import android.annotation.SuppressLint;
import android.app.Activity;
import android.content.Intent;
import android.os.AsyncTask;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;


public class TCPClient extends Activity 
{
	private TextView IPAdresseText;
	private Button VerbindenButton;
	private EditText IPAdresseEingabefeld;
	private TextView NachrichtText;
	private Button SendenButton;
	private EditText NachrichtEingabefeld;
	String s ="0";
	String ip ="0";
	/** Called when the activity is first created. */
	
	final Handler myHandler = new Handler()
	{
		@Override
		public void handleMessage(Message msg) 
		{
			NachrichtText.setText("Antwort vom Server: "+msg.obj);  
		}
	};
		
	public void onCreate(Bundle savedInstanceState) 
	{
		super.onCreate(savedInstanceState);
			setContentView(R.layout.main);
			IPAdresseText = (TextView) findViewById(R.id.ipadresse_text);
			VerbindenButton = (Button) findViewById(R.id.verbinden_button);
			IPAdresseEingabefeld = (EditText) findViewById(R.id.ipadresse_eingabefeld);
			NachrichtText = (TextView) findViewById(R.id.nachricht_text);
			SendenButton = (Button) findViewById(R.id.senden_button);
			NachrichtEingabefeld = (EditText) findViewById(R.id.nachricht_eingabefeld);
			
			VerbindenButton.setOnClickListener(new View.OnClickListener()
	    	{
	        		public void onClick(View v) 
	        		{
	        		    	ip = IPAdresseEingabefeld.getText().toString();
	        		    	IPAdresseText.setText("verbunden");
	        		}
	    	});
			
			SendenButton.setOnClickListener(new View.OnClickListener() 
			{
				@SuppressLint("HandlerLeak")
				public void onClick(View view) 
				{
					NachrichtText.setText("Button wurde gedrückt!");
					if (NachrichtEingabefeld.getText().toString().length() != 0) 
					{
						class Verbindung implements Runnable
						{
							public void run()
							{
								String nachricht = NachrichtEingabefeld.getText().toString();
								
								try 
								{
									Socket server = new Socket(ip, 4444);						  
									BufferedReader input = new BufferedReader(new InputStreamReader(server.getInputStream()));
									BufferedWriter output = new BufferedWriter(new OutputStreamWriter(server.getOutputStream()));									 
									output.write(nachricht);
									output.newLine();
									output.flush();
									s=input.readLine();																		
									Message msg = myHandler.obtainMessage();	   	
									msg.obj = s;	   	
									myHandler.sendMessage(msg);
				
																
								} 
								catch (IOException e) 
								{
									NachrichtText.setText(e.toString());
								}
							}
						}
						Thread t = new Thread( new Verbindung() );
						t.start();
					} 
					else 
					{
						NachrichtText.setText("Bitte etwas eingeben!");
					}
				}
			});
	}
}

Alles anzeigen

Müsste ich den Handler alle 2 Sekunden "refreshen"?
oder bin ich da auf dem falschen Weg?

Gruß
Brausebernd

block_ · 23. August 2012

Zitat von Brausebernd

Müsste ich den Handler alle 2 Sekunden "refreshen"?
oder bin ich da auf dem falschen Weg?

Das liegt nicht an dem Handler, sondern generall an deiner Architektur.

Zum Server:
Der Server ist (normalerweis) ein Programm das ohne Unterbrechnung läuft. Bei dir wird alle einmal im Konstruktor abgehandel und wieder beendet.
Zu erst solltest du den Server ebenfalls in einem Thread lauf lassen, da ab Android 3.0(?) eine Exception geworfen wird. Das liegt daran das gewisse Methoden den aktuellen Thread, den Ui-Thread, blockieren und die somit die grafische Oberfläche "hängt".

In der run-Methode erstellst du mittels einer while-Schleife und einer geeigneten Abrruchbedingung (Interrupt oder ähnliches) den eigentlichen Server-Code - das warten auf einen Client, Erstellung der Streams usw. (Im Konstruktor alles initialisieren und vorbereiten was du brauchst, damit der Server seine Arbeit verrichten kann. Darunter fällt auch dein Timer, der ja schon Teil des Servers sein sollte und nicht in der Main extra erstellt wird. Die Main sollte nur den Server starten.)
Nicht vergessen, wenn der Server beendet werden soll, alles ordentlich zu schließen - Streams und den Socket.

Wie vorher erwähnt gibt es Methoden die den Thread blockieren. In deinem Code wird nach dem sich ein Client verbunden hat auf eine Nachricht des Clients gewartet (die readline() blockiert bis die Nachricht gelesen wurde). Erst danach wird die aktuelle Zahl an den Client gesendet. Je nachdem was du vorhast, kann ja sein, dass das von dir so gewollt ist, empfiehlt es sich für den Empfang von Nachrichten des Clients ebenfalls ein extra Thread zu erstellen, sodass die Methoden sich nich gegenseitig blockieren. So wird auch unabhängig davon, ob der Client eine Nachricht senden will oder nicht, die aktuelle Zahl gesendet.

Zum Client:
So wie du den Client jetzt implementiert hast, wird vom Server auch nur was empfangen wenn auf den Senden-Button geklickt wurde. Es wird jedesmall eine neue Verbindung aufbauen. Besser wäre es nur einmal eine Verbindung aufzubauen und dann über die Verbindung Nachrichten senden und empfangen. Hier empfiehlt es sich das Empfangen in einen seperaten Thread auszulagern. Das Senden kann dabei im Ui-Thread bleiben da keine Methode diesen blockieren würde. Da der Server in einer (Endlos-)Schleife läuft wird nicht nur einmal die Zahl empfangen und auch nicht erst nachdem der Client eine Nachricht geschickt hat, sondern solange die Verbindung zum Server besteht.

Noch ein paar Tipps:

Variablennamen werden am Anfang klein geschrieben
Keine neue Klassen innerhalb vom Code, das macht das Lesen nur schwieriger
Möglichst keine Warnungen ignorieren. Die Lint-Warnung besagt das es zu einem Leak führen kann, also den Handler static machen.

Hoffe das ist halbwegs verständlich und hilft dir etwas. Was mir damals auch geholfen hat ist diese Seite hier: Client/Server-Anwendung.

block_

Brausebernd · 26. August 2012

Hallo,
vielen Dank für die Antwort.
Eigentlich ist der Clientcode unwichtig.
Der Server soll nur wechselnde int Werte an den Client senden und der Client soll diese anzeigen.

Der Client Code würde so aussehen.

Java

package com.example.tcpclient;


import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import android.annotation.SuppressLint;
import android.app.Activity;
import android.content.Intent;
import android.os.AsyncTask;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;


@SuppressLint("HandlerLeak")
public class TCPClient extends Activity 
{
	private TextView NachrichtText;
	String s ="0";
	
	/** Called when the activity is first created. */
	
	final Handler myHandler = new Handler()
	{
		@Override
		public void handleMessage(Message msg) 
		{
			NachrichtText.setText("Antwort vom Server: "+msg.obj);  
		}
	};
	
	public void onCreate(Bundle savedInstanceState) 
	{
		super.onCreate(savedInstanceState);
			setContentView(R.layout.main);
			NachrichtText = (TextView) findViewById(R.id.nachricht_text);
			class Verbindung implements Runnable
			{
				public void run()
				{
					try 
					{
						Socket server = new Socket("192.168.2.3", 4444);						  
						BufferedReader input = new BufferedReader(new InputStreamReader(server.getInputStream()));
						s=input.readLine();																		
						Message msg = myHandler.obtainMessage();	   	
						msg.obj = s;	   	
						myHandler.sendMessage(msg);
					} 
					catch (IOException e) 
					{
						NachrichtText.setText(e.toString());
					}
				}
			}
			Thread t = new Thread( new Verbindung() );
			t.start();
	}		
}

Alles anzeigen

Der Servercode sieht jetzt so aus:

Java

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Timer;
import java.util.TimerTask;


public class TCPServer
{
	static ServerSocket server;
	static Socket client;
	static BufferedWriter output;
	static int n;


	public static void main(String[] args)throws IOException  
	{


			server = new ServerSocket(4444);
			System.out.println("Server gestartet!");
			client = server.accept();
			output = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
			
			final int[] array = { 1, 2, 3, 4, 5};
			Timer timer = new Timer();
			timer.scheduleAtFixedRate(new TimerTask()
			{
				private int next = 0;
				
				@Override
				public void run()
				{
					n = (array[next % array.length]);
					next++;


					try {
						
						String x = String.valueOf(n);
						output.write(x);
						System.out.println(x);
						output.newLine();
						output.flush();
						
					} catch (IOException e) 
					{
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					
				}
			}, 0, 2000);	
	}
}

Alles anzeigen

Der Server verbindet sich mit dem Client sobald die Anwendung auf dem Client gestartet wird.
Anschließend wird durch die Zeile

Code

System.out.println(x);

in der Console der Wert 1,2,3,4,5,1,2,... usw ausgegeben.
Frage:
der Wert müsste eigentlich ja durch die Zeile darüber

Code

output.write(x);

an den Client gesendet werden oder?
Also müsste ich ja nur meinen Clientcode ändern oder?
Gruß Brausebernd

block_ · 27. August 2012

Also der Server sieht schon so okay aus.

Client:

Code

class Verbindung implements Runnable
{
	private running;
	private Socket server;
	private BufferedReader input;
	
	public Verbindung()
	{
		server = new Socket("192.168.2.3", 4444);						  
		input = new BufferedReader(new InputStreamReader(server.getInputStream()));
	}


	public void run()
	{
		while(running)
		{
			try 
			{
				s = input.readLine();																		
				Message msg = myHandler.obtainMessage();	   	
				msg.obj = s;	   	
				myHandler.sendMessage(msg);
			} 
			catch (IOException e) 
			{
				NachrichtText.setText(e.toString());
			}
		}
	}
	
	public void start()
	{
		new Thread(this).start();
		running = true;
	}


	public void stop()
	{
		running = false;
		close();
	}
	
	private close()
	{
		if(input != null)
		{
			try
			{
				input.close();
			}
			catch (IOException e)
			{
				// fehlerbehandlung
			}
		}
		
		if(socket != null)
		{
			try
			{
				socket.close();
			}
			catch (IOException e)
			{
				// fehlerbehandlung
			}
		}
	}
}

Alles anzeigen

Jetzt kannst du eine Instanz von Verbindung erstellen und durch die Methode start() einfach starten lassen.

Code

Verbindung verbindung = new Verbindung();
verbindung.start();

Nun sollte immer die aktualisierte Zahl vom Server empfangen werden, solange der Thread läuft. Das Senden an den Server kannste normal um UI-Thread weitermachen, wie du es vorher hattest. Durch stop() sollte, die Verbindung dann geschlossen werden. Allerdings wird durch die Blockierung von der readline()-Methode das Schließen erst ausgeführt, nachdem eine weitere Nachricht empfangen wurde und somit die Schleife beendet werden konnte. Es gibt noch eine andere Methoden einen Thread zu beenden und zwar mit Interrupts, jedoch konnt ich das noch nicht testen, weil mein Eclipse streikt.

Zu den Tipps nochmal:
Die Namenskonventionen besagen, dass Variablennamen am Anfang klein geschrieben werden sollen. Zum Beispiel "NachrichtText" -> "nachrichtText".
Für den Leak: static final Handler myHandler {...}
Und zu der Klasse Verbindung: Verschiebe diese besser ans Ende der Datei, dadurch kann man den Code besser lesen, da die Klasse ansonsten logischen Gedanken unterbricht und man diese gegebenenfalls auch suchen muss (in deinem Fall nicht besonders schwer zu finden, aber wenn das Projekt größer werden könnte, oder mehrere Instanzen von Verbindung an unterschiedlichen Stellen benutzt werden).

Falls weitere Probleme auftauchen, sag bescheid

block_

Brausebernd · 28. August 2012

Hallo,
ich habe noch ein kleines Problem mit dem Code von block_.

Java

package com.example.client;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
import android.app.Activity;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.widget.TextView;


public class Client extends Activity 
{
	private TextView serverdaten;
	String s ="0";


	final Handler myHandler = new Handler(){
		@Override
		public void handleMessage(Message msg) {
			serverdaten.setText("Antwort vom Server: "+msg.obj);  
		}
	};
	
	public void onCreate(Bundle savedInstanceState) 
	{
		super.onCreate(savedInstanceState);
			setContentView(R.layout.activity_client);
			serverdaten = (TextView) findViewById(R.id.serverdaten);


	}
	
	class Verbindung implements Runnable
	{
		private boolean running;
		private Socket socket;
		private BufferedReader input;
		
		public Verbindung() 
		{
	
				socket = new Socket("192.168.2.3", 4444);
				input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		
		}


		public void run()
		{
			while(running)
			{
				try 
				{
					s = input.readLine();																		
					Message msg = myHandler.obtainMessage();	   	
					msg.obj = s;	   	
					myHandler.sendMessage(msg);
				} 
				catch (IOException e) 
				{
					serverdaten.setText(e.toString());
				}
			}
		}
		
		public void start()
		{
			new Thread(this).start();
			running = true;
		}


		public void stop()
		{
			running = false;
			close();
		}
		
		private void close()
		{
			if(input != null)
			{
				try
				{
					input.close();
				}
				catch (IOException e)
				{
					// fehlerbehandlung
				}
			}
			
			if(socket != null)
			{
				try
				{
					socket.close();
				}
				catch (IOException e)
				{
					// fehlerbehandlung
				}
			}
		}
	}
}

Alles anzeigen

und zwar habe an dieser Stelle

Code

public Verbindung() 
		{
	
				socket = new Socket("192.168.2.3", 4444);
				input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		
		}

die Meldung "Unhandle exception type IOExceptin"
Dieses Problem sollte nicht mehr bestehen wenn ich mit Hilfe

Code

Verbindung verbindung = new Verbindung();
verbindung.start();

eine Instanz von Verbindung erstelle und diese starte.
Meine Frage ist nun wo ich das in meinem Code einfügen muss.
Danke
Gruß
Brausebernd

block_ · 28. August 2012

Da haben sich eine paar Fehler mit eingeschlichen, da ich das alles nur im Notepad geschrieben hab

Den Konstruktor nochmal:

Code

public Verbindung() throws UnknownHostException, IOException {


	socket = new Socket("192.168.2.3", 4444);
	input = new BufferedReader(new InputStreamReader(
			socket.getInputStream()));
}

und in deine onCreate schreibste folgendes:

Code

Verbindung verbindung;


try {
	verbindung = new Verbindung();
	verbindung.start();
} catch (UnknownHostException e) {
	// fehlerbehandlung
} catch (IOException e) {
	// fehlerbehandlung
}

Alles anzeigen

Hoffe das klappt jetzt so

block_

Brausebernd · 29. August 2012

Hallo,
es funktioniert immer noch nicht.
Er meckert rum das ich in der Main Netzwerk Aufgebaen durchführen will.
Die LogCat sagt folgendes:

08-29 07:43:57.790: D/AndroidRuntime(535): Shutting down VM
08-29 07:43:57.790: W/dalvikvm(535): threadid=1: thread exiting with uncaught exception (group=0x40a3a1f8)
08-29 07:43:57.800: E/AndroidRuntime(535): FATAL EXCEPTION: main
08-29 07:43:57.800: E/AndroidRuntime(535): java.lang.RuntimeException: Unable to start activity ComponentInfo{com.example.client/com.example.client.Client}: android.os.NetworkOnMainThreadException
08-29 07:43:57.800: E/AndroidRuntime(535): at android.app.ActivityThread.performLaunchActivity(ActivityThread.java:1956)
08-29 07:43:57.800: E/AndroidRuntime(535): at android.app.ActivityThread.handleLaunchActivity(ActivityThread.java:1981)
08-29 07:43:57.800: E/AndroidRuntime(535): at android.app.ActivityThread.access$600(ActivityThread.java:123)
08-29 07:43:57.800: E/AndroidRuntime(535): at android.app.ActivityThread$H.handleMessage(ActivityThread.java:1147)
08-29 07:43:57.800: E/AndroidRuntime(535): at android.os.Handler.dispatchMessage(Handler.java:99)
08-29 07:43:57.800: E/AndroidRuntime(535): at android.os.Looper.loop(Looper.java:137)
08-29 07:43:57.800: E/AndroidRuntime(535): at android.app.ActivityThread.main(ActivityThread.java:4424)
08-29 07:43:57.800: E/AndroidRuntime(535): at java.lang.reflect.Method.invokeNative(Native Method)
08-29 07:43:57.800: E/AndroidRuntime(535): at java.lang.reflect.Method.invoke(Method.java:511)
08-29 07:43:57.800: E/AndroidRuntime(535): at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:784)
08-29 07:43:57.800: E/AndroidRuntime(535): at dalvik.system.NativeStart.main(Native Method)
08-29 07:43:57.800: E/AndroidRuntime(535): Caused by: android.os.NetworkOnMainThreadException
08-29 07:43:57.800: E/AndroidRuntime(535): at android.os.StrictMode$AndroidBlockGuardPolicy.onNetwork(StrictMode.java:1099)
08-29 07:43:57.800: E/AndroidRuntime(535): at libcore.io.BlockGuardOs.connect(BlockGuardOs.java:84)
08-29 07:43:57.800: E/AndroidRuntime(535): at libcore.io.IoBridge.connectErrno(IoBridge.java:127)
08-29 07:43:57.800: E/AndroidRuntime(535): at libcore.io.IoBridge.connect(IoBridge.java:112)
08-29 07:43:57.800: E/AndroidRuntime(535): at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:192)
08-29 07:43:57.800: E/AndroidRuntime(535): at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
08-29 07:43:57.800: E/AndroidRuntime(535): at java.net.Socket.startupSocket(Socket.java:566)
08-29 07:43:57.800: E/AndroidRuntime(535): at java.net.Socket.tryAllAddresses(Socket.java:127)
08-29 07:43:57.800: E/AndroidRuntime(535): at java.net.Socket.<init>(Socket.java:177)
08-29 07:43:57.800: E/AndroidRuntime(535): at java.net.Socket.<init>(Socket.java:149)
08-29 07:43:57.800: E/AndroidRuntime(535): at com.example.client.Client$Verbindung.<init>(Client.java:53)
08-29 07:43:57.800: E/AndroidRuntime(535): at com.example.client.Client.onCreate(Client.java:35)
08-29 07:43:57.800: E/AndroidRuntime(535): at android.app.Activity.performCreate(Activity.java:4465)
08-29 07:43:57.800: E/AndroidRuntime(535): at android.app.Instrumentation.callActivityOnCreate(Instrumentation.java:1049)
08-29 07:43:57.800: E/AndroidRuntime(535): at android.app.ActivityThread.performLaunchActivity(ActivityThread.java:1920)
08-29 07:43:57.800: E/AndroidRuntime(535): ... 11 more

kann man das alles nicht irgendwie total einfach lösen?
ich will doch nur alle 2 Sekunden Daten vom Server empfangen.
Gruß
Brausebernd

matthias · 29. August 2012

Hi,

Dinge wie Netzwerkabfragen darf man in Android nicht von dem Haupt Thread aus machen, das muss man in einen eigenen Thread auslagern. Würde sonst diverse Nebeneffekte haben, wie dass die Oberfläche einfriert usw. da deine Netzwerkabfrage andauernd 2 Sekunden schlafen will. Bau einfach eine eigene Java Klasse, die von Thread erbt und wirf das Teil in deiner Main dann an.

Gruß,
matze

EDIT: ahja, wer lesen kann hättest du eh versucht. Vielleicht liegts an der inneren Klasse? mach da mal ne eigene bitte. Vielleicht auch mal die Kombination mit extends Thread anstatt implements Runnable, da kriegt man das ein oder andere geschenkt ....

Brausebernd · 31. August 2012

Hallo,
ich glaube eher das mein Servercode nicht ganz ok ist.
Habe mich jetzt nochmal belesen und habe daraufhin folgenden Clientcode erstellt:

Java

package com.example.client;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.annotation.SuppressLint;
import android.app.Activity;
import android.widget.TextView;


@SuppressLint("HandlerLeak")
public class Client extends Activity 
{
	
	static private TextView serverdaten;
	String s ="0";
	Socket socket;
	BufferedReader input;
	Thread verbindung;


	static Handler myHandler = new Handler()
	{
		@Override
		public void handleMessage(Message msg) {
			serverdaten.setText("Antwort vom Server: "+msg.obj);  
		}
	};
	
	public void onCreate(Bundle savedInstanceState) 
	{
		super.onCreate(savedInstanceState);
			setContentView(R.layout.activity_client);
			serverdaten = (TextView) findViewById(R.id.serverdaten);
			this.verbindung = new Thread(new Verbindung());
			this.verbindung.start();
	}
	
	class Verbindung extends Thread
	{
		Thread empfang;
		
		public void run()
		{
			try 
			{
				socket = new Socket("192.168.2.3", 4444);						  
				input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			} 
			catch (IOException e) 
			{
				serverdaten.setText(e.toString());
			}
			this.empfang = new Thread(new Empfang());
			this.empfang.start();
		}
	}
	
	class Empfang extends Thread
	{
		public void run()
		{
			try 
			{
				s=input.readLine();																		
				Message msg = myHandler.obtainMessage();	   	
				msg.obj = s;	   	
				myHandler.sendMessage(msg);
				input.close();
			} 
			catch (IOException e) 
			{
				serverdaten.setText(e.toString());
			}
		}
	}
	
}

Alles anzeigen

rein vom logischen her, müsste der Client so funktionieren.
Wenn ich nun aber eine Verbindung zum Server herstelle, kommt folgender Fehler

java.net.SocketException: Software caused connection abort: socket write error
at java.net.SocketOutputStream.socketWrite0(Native Method)
at java.net.SocketOutputStream.socketWrite(Unknown Source)
at java.net.SocketOutputStream.write(Unknown Source)
at sun.nio.cs.StreamEncoder.writeBytes(Unknown Source)
at sun.nio.cs.StreamEncoder.implFlushBuffer(Unknown Source)
at sun.nio.cs.StreamEncoder.implFlush(Unknown Source)
at sun.nio.cs.StreamEncoder.flush(Unknown Source)
at java.io.OutputStreamWriter.flush(Unknown Source)
at java.io.BufferedWriter.flush(Unknown Source)
at server.Server$1.run(Server.java:45)
at java.util.TimerThread.mainLoop(Unknown Source)
at java.util.TimerThread.run(Unknown Source)

Daraufhin habe ich den Servercode wie folgt angepasst:

Java

package server;


import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Timer;
import java.util.TimerTask;


public class Server
{
	static int n;
	static String x;
	static BufferedWriter output;
	static  int[] array = { 1, 2, 3, 4, 5};
	static Timer timer = new Timer();


	ServerSocket socket = new ServerSocket(4444);


	Server() throws IOException 
	{
		System.out.println("Server gestartet!");
		Socket client = socket.accept();
		output = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
	}


	public static void main(String[] args) 
	{


		timer.scheduleAtFixedRate(new TimerTask()
		{
			private int next = 0;
			@Override
			public void run()
			{
				n = (array[next % array.length]);
				next++;
				x = String.valueOf(n);
			}
		}, 0, 2000);
		
		try 
		{
			new Server();
			System.out.println(x);
			output.write(x);
			output.newLine();
			output.flush();
		} 
		catch (IOException e) {
			System.out.println(e);
		}
	}
}

Alles anzeigen

Jetzt wird alle 2 Sekunden ein neuer Wert n erzeugt.
Wenn ich mich jetzt verbinde wird der aktuelle Wert zum Client gesendet und angezeigt.
Das Problem liegt jetzt darin das ich die Ausgebe zum Client

Code

output.write(x);
output.newLine();
output.flush();

irgendwie in die TimerTask implementieren müsste, kann mir da irgendeiner helfen?
Gruß
Brausebernd

block_ · 1. September 2012

Beim Testen von meinem Vorschlag hat alles soweit funktioniert und es wurde keine Exception geworfen. Habs jetzt mit dem Emulator nochmal getestet und den Fehler beseitig.

Client:

Code

public class Client extends Activity {
	private static TextView serverdaten;


	static final Handler myHandler = new Handler() {
		@Override
		public void handleMessage(Message msg) {
			serverdaten.setText("Antwort vom Server: " + msg.obj);
		}
	};


	public void onCreate(Bundle savedInstanceState) 
	{
		super.onCreate(savedInstanceState);
			setContentView(R.layout.activity_client);
			serverdaten = (TextView) findViewById(R.id.serverdaten);
			 


			Verbindung	verbindung = new Verbindung(myHandler);
			verbindung.start();


	}
}

Alles anzeigen

Verbindung:

Code

public class Verbindung implements Runnable {
	private boolean running;
	private Socket socket;
	private BufferedReader input;
	private Handler myHandler;


	public Verbindung(Handler handler) {
		myHandler = handler;
	}


	public void run() {
		try {
			socket = new Socket("192.168.0.101", 4444);
			input = new BufferedReader(new InputStreamReader(
					socket.getInputStream()));
		} catch (UnknownHostException e1) {
			e1.printStackTrace();
		} catch (IOException e1) {
			e1.printStackTrace();
		}
		while (running) {
			try {
				Message msg = myHandler.obtainMessage();
				msg.obj = input.readLine();
				myHandler.sendMessage(msg);
			} catch (IOException e) {
				System.out.println(e.getMessage());
			}
		}
	}


	public void start() {
		new Thread(this).start();
		running = true;
	}


	public void stop() {
		running = false;
		close();
	}


	private void close() {
		if (input != null) {
			try {
				input.close();
			} catch (IOException e) {
				// fehlerbehandlung
			}
		}


		if (socket != null) {
			try {
				socket.close();
			} catch (IOException e) {
				// fehlerbehandlung
			}
		}
	}
}

Alles anzeigen

Server:

Code

public class TCPServer
{
	static ServerSocket server;
	static Socket client;
	static BufferedWriter output;
	static int n;


	public static void main(String[] args)throws IOException  
	{


			server = new ServerSocket(4444);
			System.out.println("Server gestartet!");
			client = server.accept();
			output = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
			
			final int[] array = { 1, 2, 3, 4, 5};
			Timer timer = new Timer();
			timer.scheduleAtFixedRate(new TimerTask()
			{
				private int next = 0;
				
				@Override
				public void run()
				{
					n = (array[next % array.length]);
					next++;


					try {
						
						String x = String.valueOf(n);
						output.write(x);
						System.out.println(x);
						output.newLine();
						output.flush();
						
					} catch (IOException e) 
					{
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					
				}
			}, 0, 2000);	
	}
}

Alles anzeigen

block_

Brausebernd · 2. September 2012

Hallo,
ihr werdet es nicht glauben, aber es funktioniert!
Vielen vielen Dank an block_!
Und natürlich an alle anderen die sich damit beschäftigt haben!
Gruß
Brausebernd

snipor · 2. September 2012

Der Code hat mir auch sehr geholfen, danke dafür an Alle die beteiligt waren.
Ich habe bei meiner Anwendung festgestellt dass die Nachricht vom Server nicht sofort am Client angezeigt wird.

Schickt der Server z.B. folgendes: test/r/n so wird erstmal nichts angezeigt, erst sobald ein weiteres Zeichen geschickt wird erscheint die Meldung am Client.
Es muss jedoch kein zweites return nach dem Zeichen erfolgen, es reicht wie gesagt ein weiteres beliebiges Zeichen. Kann es sein dass der Bufferinhalt erst übergeben wird sobald er wieder mit neuen Daten befüllt wird?

Danke

Gruß snipor

Brausebernd · 4. September 2012

Hallo,
kurze Frage noch, die App stürzt ab wenn der Server nicht gestartet ist, bzw. wenn eine falsche Server IP eingestellt ist.
Wie kann ich das beheben?
Gruß
Brausebernd

Edit: Behoben!

titus · 4. September 2012

Hi Brausebernd,

mit welcher Fehlermeldung?

Mfg Titus

snipor · 4. September 2012

Hat niemand eine Erklärung / Lösung für mein Problem?

Danke

block_ · 4. September 2012

Hast du ein Codebeispiel wie du den Text einliest/verschickst? (Sollte es nicht \n und \r sein? )

block_

snipor · 5. September 2012

Es ist natürlich \n \r Hab mich vertan
Als Client dient der Code hier aus Beitrag 13. Diesen hab ich einfach mal so übernommen.

Als Server dient ein WIZFI 630 Modul, welches einfach die Daten von einer seriellen Schnittstelle auf einen TCP Port weitergibt.

Danke

snipor

Variable übergeben

Jetzt mitmachen!

Teilen

Benutzer online in diesem Thema