Thread für SocketServer nur einmal starten

[KartoffelKiffer]

Hallo,

ich arbeite zurzeit an einem Konstrukt JSP mit JavaCore im Backend.

Die JSP-Datei importiert sich bestimmte Packages aus dem Core und führt benötigte Methoden aus. So auch meine index.jsp, welche auf die Klasse SocketServer in meinem Java-Projekt zugreift. Der SocketServer wird in einem eigenen Thread gestartet und lauscht auf Port 11111.

SocketServer server = new SocketServer();
server.start();

Wenn nun noch jemand anderes auf meine index.jsp zugreift, wird allerdings erneut versucht den Thread und somit den SocketServer zu starten, dies mislingt natürlich und es kommt zu einer Exception, die ich zwar abfange, aber es ist trotzdem unschön.

Jetzt habe ich schon versucht die Methode run (in meiner SocketServer-Klasse), welche den SocketServer startet, auf synchronized zu setzen, in der Hoffnung der Thread wird somit nicht erneut gestartet. Funktioniert natürlich nicht, sonst wäre ich nicht hier.

Über jegliche Hilfe wäre ich dankbar.




Mfg Tom

 

[SlaterB]

setzte eine boolean-Variable (notfalls statisch oder im Application-Kontext)
udn wenn dieses schon gesetzt ist, dann starte den Socket nicht neu, oder gleich den ganzen Thread dazu oder was auch immer,

evtl. verschiebst du einfach diesen Aufruf aus der JSP in irgendein Init-Servlet

 

[kleiner_held]

Singleton Pattern verwenden.

 

[KartoffelKiffer]

Hallo,

die Lösung mit den Pattern war mir noch garnicht bekannt, ich danke dafür! Auf die Schnelle habe ich es aber mittels flag (boolschen Wert) gelöst. Allerdings beinhaltet meine Applikation noch einen Fehler. Da ich auch im Threadtitel von Sockets geredet habe, denke ich geht es iO, wenn ich es hier direkt schildere, und keinen neuen Beitrag eröffne:

Ich bin dabei eine Kommunikation mittels Sockets aufzubauen. Einen SocketServer, der lauscht, Anfragen per InputStream entgegennimmt und sie mittels OutputStream wieder in die freie Welt schickt:

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Date;

public class SocketServer extends Thread {

	public static void main(String[] args) {
		
		new SocketServer().start();
	}
	
	public static boolean flag = false;
	
	synchronized public void run() {
		
		flag = true;
		
		ServerSocket server = null;
		try {
			
			server = new ServerSocket(11111);
		} catch (Exception e) {
			
			System.out.println("Error: Cannot start SocketServer");
		}
		System.out.println("Server startet at " + new Date());
		
		while (true) {
			
			BufferedReader in;
			PrintWriter out;
			int i;
			String input = null;
			
			try {
				
				Socket client = server.accept();
				
				in = new BufferedReader(new InputStreamReader(client.getInputStream()));
				out = new PrintWriter(client.getOutputStream());
				
				try {
					
					i = 0;
					while(i == 0) {
						
						input = in.readLine();
						i = 1;
						if (input == null) {

							break;
						}
						System.out.println("Got message: " + input);
						out.write(input + "\0");
						out.flush();
					}
					out.close();
				} catch (Exception e) {
				
					System.out.println("Error while getting message from client: " + e.getMessage());
				}
			} catch (Exception e) {
				
				System.out.println("Error while building socket connection with client: " + e.getMessage());
			}
		}
	}
}

Dazu kommt ein Sender und ein Empfänger für Messages.

Der Sender baut eine Verbindung zum Server auf und sendet per OutputStream eine Mitteilung:

public static void main(String[] args) {

		try {
		
			Socket socket = new Socket("192.168.3.51", 11111);
			PrintWriter out = new PrintWriter(socket.getOutputStream());
			
			out.write("1234" + "\0");
			out.flush();
			
			out.close();
			socket.close();
		} catch (Exception e) {
			
			System.out.println("Error while sending socket message: " + e.getMessage());
		}
	}

Der Empfänger baut ebenfalls eine Verbindung auf, und empfängt mittels InputStream die gesendeten Mitteilungen des Servers:

public static void main(String[] args) {
		
		try {
			
			Socket socket = new Socket("192.168.3.51", 11111);
			BufferedReader in;
			String line = null;

			in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			while((line = in.readLine()) != null) {

				System.out.println(">>>" + line);
			}
			
			in.close();
			socket.close();
		} catch (Exception e) {
			
			System.out.println(e.getMessage());
		}
	}

Und genau im Empfänger liegt mein Problem. Der Sender und der Server kommunizieren problemlos. Ich schicke etwas ab, und der Server gibt die Mitteilung aus (System.out.println("Got message: " + input)
Es ist allerdings so gedacht, dass der Sender an den Server eine Mitteilung schickt, und der Empfänger auf Mitteilungen lauscht, und sobal eine vorhanden ist, sie ausgibt.

Habe ich alle drei Klasse gestartet und sende eine Mitteilung an den Server, so sagt der mir lediglich, dass ein Client connectet hat. und etwas schicken möchte. Die Mitteilung, die ich sende, kommt am Server aber nicht an. Auch der Empfänger bekommt nichts und wartet lediglich.

Erst wenn ich den Empfänger schließe kommt die Mitteilung vom Sender am Server an.

Irgendwie blockiert also der Empfänger die ganze Kommunikation.

Weiß da irgendjemand einen Rat? Jegliche Tipps können mir weiterhelfen.




Mfg Tom

 

[kleiner_held]

1. Dein Server sollte zur Bearbeitung jeder Client-Verbindung einen neuen Thread starten
2. Du solltest einen Erkennungsmechanismus einbauen ob ein Client nun ein "Sender" oder "Empfänger" ist - ansonsten weiss der Server ja nicht ob er bei der Verbindung Daten empfangen oder Senden soll.

 

[KartoffelKiffer]

Hallo,

ich bin ein Stückchen weiter gekommen. Bin gerade dabei einen Thread für eine Klasse Out und eine Klasse In zu erstellen.

Server:

import java.net.ServerSocket;
import java.net.Socket;
import java.util.Date;

public class SocketServer extends Thread {

	public static void main(String[] args) {

		new SocketServer().start();
	}

	public static boolean flag = false;

	public void run() {

		flag = true;
		ServerSocket server = null;
		
		try {

			server = new ServerSocket(11111);
		} catch (Exception e) {

			System.out.println("Error: Cannot start SocketServer");
		}
		
		System.out.println("Server startet at " + new Date());

		while (true) {

			try {
				
				Socket client = server.accept();

				In in = new In(client.getInputStream());			
				in.start();
				String input = in.getInput();
				
				//Out.setOutput(client, input);
				
				System.out.println("Input >>> " + input);
				
				client.close();
			} catch (Exception e) {

				System.out.println("Error while building socket connection with client: " + e.getMessage());
			}
		}
	}
}

Klasse In:

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;

public class In extends Thread {

	public static void main(String[] args) {
		

	}
	
	private String input = "";
	private InputStream is;
	
	public In(InputStream is) {

		this.is = is;
	}
	
	public void run() {
		
		String input = null;
		StringBuilder sb = new StringBuilder(255);
		
		try {

			InputStreamReader isr = new InputStreamReader(this.is);			
			BufferedReader in = new BufferedReader(isr); 
			
			while ((input = in.readLine()) != null) {
	
				if (input.length() > 0) {
				
					sb.append(input);
				}
			}
	
			input = sb.toString();
		} catch (Exception e) {
			
			System.out.println("Error while getting inputstream: " + e.getMessage());
		}
		
		this.input = input;
	}
	
	protected String getInput() {
		
		return this.input;
	}
}

Ich erstelle eine Instanz von der Klasse In und übergebe dem Konstruktor den InputStream des Sockets. Diesen speichere ich dann in eine Instanzvariable is.

Jetzt meine Frage: Wo ich den Thread mittels in.start() anschmeiße, wird von der Klasse erneut eine Instanz erstellt, sodass meine Instanzvariable is der Klasse In verschwindet?

Wenn ich die Instanz erstelle, kann ich testweise im Konstruktor eine Ausgabe des ersten bytes des InputStreams machen. Sobald aber der Thread gestartet ist, verliert die Instanzvariable ihren Wert und es kommt die Fehlermeldung "Socket closed" bei weiterer Verarbeitung des InputStreams

InputStreamReader isr = new InputStreamReader(this.is);

Mfg Tom