Socket Mehrere Clientanmeldungen am Server

[goodcat]

Hi,

ich habe eine Frage bezüglich der Socketprogrammierung in Java.

Vielleicht kurz meine Klassen (Ausschnitt):

TCPServer.java

public void run() {

		try	{
			
			//Erzeugen des Socket
			ServerSocket socket = new ServerSocket (SERVER_PORT);
			
			print("Warten auf Verbindungen ...");
			
			while(true) {

				this.client = socket.accept();

				print( "Clientanmeldung: IP-Adresse: " + client.getInetAddress().getHostAddress() + " Port: " + client.getPort());
				
				//Thread erzeugen, der Kommunikation
				//mit Client übernimmt
				
			}
		}
		catch(BindException e1) {
			print("Address already in use.");
	    }
		catch(Exception e)	{
			e.printStackTrace();
		}
	    
	}

Wenn sich ein Client anmeldet befindet er sich in "Wartestellung" wenn der Server dann ein Ereignis feststellt z.B. ich drücke auf der ServerGui auf einen Button dann wird ein Thread erstellt...

TCPThread.java

public void run() {
		try	{

			OutputStream output = client.getOutputStream();

			byte[] antwort = ( sqlID.getBytes() );
			output.write (antwort);
			
			// Verbindung beenden
//			client.close();
//			print ( ":\tClient erfolgreich bedient ...");
		}
		catch (Exception e)	{
			// Wenn ein Fehler auftritt ...
			e.printStackTrace();
		}
	}

Und die Daten (in meinem Fall eine SQLID) werden an den Client gesendet
Das funktioniert auch ganz prima! (Mit einem Client)

Hier vielleicht noch meine TCPClient.java KLasse die Daten empfangen soll:

public void run() {
		
		if ( this.connect == 1 ) {
	
			try	{
				// Erzeugen des Socket und Aufbau der Verbindung
				this.socket = new Socket ( server_hostname, server_port );
				this.socket.setKeepAlive(true);
	
				notifyListenerStaus( new DataEvent( this, "Verbindung mit " + this.socket.getRemoteSocketAddress() + " hergestellt") );
				notifyListenerConnection(1);
				
				InputStream stream = this.socket.getInputStream();
				StringBuilder readCharacter; 	
	
				while(true) {
					
					readCharacter = new StringBuilder(); 
					readCharacter.append((char)stream.read()); 
										
					notifyListener( new DataEvent( this, readCharacter.toString() ) );
				}
				
			}
			catch (UnknownHostException e) {
				// Wenn Rechnername nicht bekannt ist ...
				System.out.println ("Rechnername unbekannt:\n" + e.getMessage());
			}
			catch (java.net.ConnectException e) {
				notifyListenerStaus( new DataEvent( this, "Verbindung zu " + server_hostname + ":" + server_port + " konnte nicht aufgebaut werden!" ) );
				notifyListenerConnection(0);
			}
			catch (Exception e) {
				// Wenn die Kommunikation fehlschlägt
				System.out.println ("Fehler während der Kommunikation:\n" +
				e.getMessage());
				e.printStackTrace();
			}
			finally {
				// Beenden der Kommunikationsverbindung
				closeConnection();
			}
		}
		else {
			notifyListenerStaus( new DataEvent( this, "Verbindung zum Server wird nicht aufgebaut..." ) );
			notifyListenerConnection(0);
		}
	}

Jetzt zu meiner Frage und zwar soll sich nicht nur ein Client anmelden sondern vielleicht noch ein zweiter oder dritter. Das Problem ist das (das ist meine Vermutung) der socket mit der zweiten Anmeldung überschrieben wird und daher nur der Client bedient wird der sich als zweites angemeldet hat. Zur Info ich bin noch ein Java Anfänger :rtfm:

Jemand eine Idde wie dieses Prob. zu lösen ist?? Hatte schon dran gedacht jede neue Clientanmeldung in ein Array bzw. was dynamisches z.B. eine ArrayList zu schreiben. Wie ich mit ArrayListen umgehe weis ich aber ich hab keinen schimmer wie ich das mit einem Socket umsetzten soll.

Vielen Dank,
Goodcat

 

[SlaterB]

> Wie ich mit ArrayListen umgehe weis ich aber ich hab keinen schimmer wie ich das mit einem Socket umsetzten soll.

das klingt so sinnvoll wie 'was eine Einkaufstüte ist weiß ich, aber habe keinen Schimmer wie ich eine Dose Ravioli kaufe'
was macht eine Liste wenn nicht Element aufzunehmen? was ist bei einem Socket anders? Socket in die Liste und fertig

wobei das vielleicht nicht zu empfehlen ist, besser wohl mehrere Objekte der Klasse TCPClient, und die dann in eine Liste,
irgendwo muss das natürlich organisiert sein, das ist bestimmt eher dein Problem,
wo steht steht die Liste, wer befüllt sie usw.

 

[goodcat]

Hi SlaterB danke für deine Antwort.

Bis jetzt exitiert noch keine Liste o.ä. das war nur eine Idee. Aber keine Ahnung ob das wirklich sinnvoll ist bzw. ob es nicht eine etwas besser Lösung gibt.

Zur Info. Es gibt 2 Programme, ein Serverprogramm (TCPServer und TCPThread.java) welches Anmeldungen annehmen soll und in einen Wartezustand versetzten soll bis Daten verfügbar sind. Und ein Clientprogramm (TCPCLient.java) welches die Daten empfangen soll.

wobei das vielleicht nicht zu empfehlen ist, besser wohl mehrere Objekte der Klasse TCPClient, und die dann in eine Liste,
irgendwo muss das natürlich organisiert sein, das ist bestimmt eher dein Problem,

Du meinst dann pro Verbindung ein neues TCPServer Objekt anlegen?
Aber würde es nicht reichen die sockets (also pro Clientverbindung) zu "verpacken" (array etc.. ka).

Zur Organisation. Das ist auch ein Problem bis jetzt hat das mit einem Client super funktioniert. Ich dachte ich kann den vorhanden Code so anpassen das mehrere Anfragen in unterschiedlichen Sockets gespeichert werden und beim senden der Daten einfach alle sockets angesprochen werden. (Wenn am Server was passiert sollen alle Clients mit den gleichen Daten gefüttert werden).

Aber ich bin offen für Vorschläge.

Thx Goodcat

 

[SlaterB]

> Du meinst dann pro Verbindung ein neues TCPServer Objekt anlegen?
nein, TCPClient wie ich schrieb ,
betrifft ja meinem Verständnis nach hauptsächlich die Client-Seite, dort gibts ja gar keinen Server,
auf Serverseite gibt es sowieso schon die Infrastruktur für mehrere Verbindungen?

 

[Michael...]

Du meinst dann pro Verbindung ein neues TCPServer Objekt anlegen?

Nein, das meint er mit "besser wohl mehrere Objekte der Klasse TCPClient, und die dann in eine Liste" nicht.
Damit der Server mehrer Clients bzw. eigentlich deren Output und InputStreams "bedienen" kann, muss dieser ja die Referenzen darauf halten. Und Listen bieten sich nun mal an um Objekte gleichen Typs zu verwalten.

 

[goodcat]

Jau Michael so war das gedacht.

Beim TCPServer wird folgendes gestartet:

while(true) {
 
                this.client = socket.accept();
 
                print( "Clientanmeldung: IP-Adresse: " + client.getInetAddress().getHostAddress() + " Port: " + client.getPort());
                
                //Thread erzeugen, der Kommunikation
                //mit Client übernimmt
                
            }

Ich habe das so verstanden das pro Client diese Zeile ausgeführt wird:

this.client = socket.accept();

und in einem (this.client) socket befindet sich dann 1 Clientverbindung. Nun sollen mehrere Verbindungen zu den Clients behandelt werden. Deshalb die Idee mit der Liste.

Und da war jetzt die Frage wie ich das gestalten kann. Ich muss ja eine Abfrage schreiben die jedesmal wenn ein neuer Client anfragt diese Referenz (this.client) auf den Socket in ein neues Objekt packt.

Thx Goodcat

 

[Michael...]

Und da war jetzt die Frage wie ich das gestalten kann. Ich muss ja eine Abfrage schreiben die jedesmal wenn ein neuer Client anfragt diese Referenz (this.client) auf den Socket in ein neues Objekt packt.

Nein, einfach nur

liste.add(this.client)

Da Java kein Call by Reference kennt, geht das ohne Probleme.

 

[goodcat]

Oh ok das hab ich mit gedacht. Mit ArrayListen hab ich das eine oder andere mal gearbeitet allerdings nie mit Objekten gefüllt. Nur ich hätte mal die Methode accept() etwas genauer anschauen sollen. Dort wird ja gewartet bis ein Client anfragt...

Die Klasse TCPServer.java habe ich angepasst.
Die Methode sendData( String sqlID ); wird dann von aussen aufgerufen.

private ArrayList<Socket> socketList = new ArrayList<Socket>();

public void sendData( String sqlID ) {
		new TCPThread(this.socketList, sqlID).start();
	}
	
	public void run() {

		try	{
			
			ServerSocket socket = new ServerSocket (SERVER_PORT);
			
			print("Warten auf Verbindungen ...");
			
			while(true) {

				this.socketList.add(socket.accept());

				print( "Clientanmeldung: IP-Adresse: " + client.getInetAddress().getHostAddress() + " Port: " + client.getPort());
				
			}
		}
		catch(BindException e1) {
			print("Address already in use.");
	    }
		catch(Exception e)	{
			e.printStackTrace();
		}
		finally {
			try {
				client.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	    
	}

TCPThread.java

public void run() {
		try	{

			for ( int i = 0; i < socketList.size(); i++ ) {
				this.output = socketList.get(i).getOutputStream();
				
				this.daten = ( sqlID.getBytes() );
				this.output.write(this.daten);
				
			}
			
			// Verbindung beenden
//			client.close();
//			print ( ":\tClient erfolgreich bedient ...");
		}
		catch (Exception e)	{
			// Wenn ein Fehler auftritt ...
			e.printStackTrace();
		}
	}

Die For Schleife geht jeden Eintrag in der ArrayList durch nur wird der erste Client der sich am Server anmeldet bedient. Der zweite wird ignoriert. Nur wieso bekommt der 2. Client keine Daten. Die schleife läuft bei zwei Anmeldungen zwei mal durch, also sind auch 2 Sockets in der Liste.
Eine Idee?

Goodcat

 

[SlaterB]

der Code sieht so richtig aus, ich denke da ist kein Fehler zu erkennen,
wann wird sendData() aufgerufen, nicht zu früh?
baue Log-Ausgaben in die Schleife ein, wird wirklich an zwei Sockets gesendet?

letztlich ist wohl ein vollständiges Testprogramm nötig, wenn nicht sonst wer genialere Einfälle hat

 

[goodcat]

Ach shit ja sieht nicht nur richtig aus ist es auch, bis auf den TCPServer da hatte ich noch eine Statusmeldung, blöderweise gibt es natürlich das Obj this.client nicht mehr... Sorry :toll:

Super nur eine Frage noch bezüglich einer getrennten Verbindung. Ich habe die ArrayList, was ist wenn der erste Client das Programm schließt und vorher die Verbindung nicht getrennt wird.

Ich bekomme eine Exception die auch absolut nachvollziehbar ist. Und zwar gibt es den socket nicht bzw. kann auf den socket nicht geschrieben werden. ich habe es mit einer if Abfrage probiert (isBound, isClosed, isConnected - klappt alles nicht).

if ( this.socketList.get(i).isClosed() == false ) {
					this.output = this.socketList.get(i).getOutputStream();
					
					System.out.println("Angemeldeter Client socket: " + this.socketList.get(i).getInetAddress() + "\n");
					
					this.daten = ( sqlID.getBytes() );
					this.output.write(this.daten);
				}
				else {
					this.socketList.remove(i);
				}

java.net.SocketException: Connection reset by peer: 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 de.TimeTrackerV3Server.Socket.TCPThread.run(TCPThread.java:41)

Kennst Du eine Methode die aprüft ob der CLient überhaupt noch da ist? Oder würdest Du das mit try/catch machen? Was ist die sauberste Möglichkeit das umzusetzten?

Vielen Dank!

 

[Michael...]

Oder würdest Du das mit try/catch machen?

Die Absicherung über try catch benötigt man sowieso, da ja aus verschiedenen Gründen die Verbindung nicht mehr existent sein kann.
Wenn eine solche SocketException fliegt, den entsprechenden Eintrag aus der Liste entfernen.

 

[goodcat]

Ja stimmt. Habe ich in den anderen Teilen des Programms auch immer gemacht.
Ach das ärgert mich, manchmal sieht man den Wald vor lauter Bäumen nicht mehr. Das nächste mal werde ich euch nicht mit solchen Kleinigkeiten nerven ... Einfach mal die API besser lesen. Bin aber auch nur ein kleines byte :lol:

Vielen Dank Michael.. und SlaterB!!!

 

[cable545]

Mit ArrayListen hab ich das eine oder andere mal gearbeitet allerdings nie mit Objekten gefüllt.

Sorry der Nachfrage, aber was kann man mit einer ArrayList machen wenn keine Objekte darin sind?

 

[goodcat]

Ja ist quatsch. Da hätte ich mich anders ausdrücken sollen.
Ich habe ArrayLists immer nur für simple Strings oder int benutzt aber nie für z.B. ein ganzes socket Objekt...