Java Multithread Server

30. Januar 201615. Februar 2016frithjofJava

Der Multithread Server

Im Letzten Teil wurde ein Server erzeugt der einen Cleint nach dem anderen Bedienen kann.

Jetzt hat man oft das Problem das man mehrere Clients gleichzeitig bedienen möchte.

Um dieses Problem zu lösen nutzt man Multihread Server. d.H jeder Client hat seinen eigenen Thread in dem er läuft.

Jetzt kann zwar jeder Client sich mit dem Server verbinden aber noch keine Nachrichten untereinfander austauschen. Diese Erweiterung kommt später.

public class main {

	public static void main(String[] args) {
		
		//Demo mit einem Thread
		// zum Start Kommentar umsetzen!
		//SinglethreadServer t = new SinglethreadServer();
		MultithreadServer t = new MultithreadServer();
		t.starteServer();	
	}
}

public class main {

public static void main(String[] args) {

//Demo mit einem Thread

// zum Start Kommentar umsetzen!

//SinglethreadServer t = new SinglethreadServer();

MultithreadServer t = new MultithreadServer();

t.starteServer();

}

Die erweiterte Java Serverklasse

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;


public class MultithreadServer {
	public void  starteServer(){
		try {
			//Starte den Server
			ServerSocket server = new ServerSocket(5555);
			
			//Gibt den Hoast und die IP auf der console aus.
			InetAddress adresse = InetAddress.getLocalHost();
			System.out.println("Server gestartet \n" +
								"Server auf IP:  " +  adresse.getHostAddress() + adresse.getHostName());
			
			//Startet einen Trhead für JEDE neue Verbindung:
			while (true){
				Socket client = server.accept();
				//den Thread Starten und den clienten übergeben:
				new echo(client).start();
			}
			
		} catch (Exception e) {
			
		}
		
	}
	//den Thread in einer inneren Klasse laufen lassen:
	private class echo extends Thread{
		private Socket client;
		public echo(Socket client){
			//einfaches Setter im construktor um den empfangenen Socket zuzuordnen:
			this.client = client;
		}
		public void run(){
			
			//Jetzt können wir auch direckt die IP vom Client.
			String clientAdresse;
			clientAdresse = client.getInetAddress().getHostAddress() + client.getInetAddress().getHostName();
			System.out.println(clientAdresse);
			try {
				BufferedReader rein = new BufferedReader(new InputStreamReader(client.getInputStream()));
				
				PrintWriter senden = new PrintWriter(client.getOutputStream());
				/**
				 * Diese Endlosschleife ist dazu da jede anfrage der Clients anzunemen und zurück zu senden.
				 * Eine Empfangene Nachricht wird in den Zwischenspeicher gelegt. 
				 * Anschliessend wird dieser String mit dem Wort "Antwort versehen" und zurück gesendet.
				 */
				String zwischenspeicher;
				while((zwischenspeicher = rein.readLine()) != null){
					zwischenspeicher = "Antwort: " + zwischenspeicher;
					//Printwriter mit Inhalt füllen:
					senden.println(zwischenspeicher);
					//Printwriter senden:
					senden.flush();
					//Zur sicherheit nochmal auf der Console ausgeben:
					System.out.println("Gesendt wurde: " + zwischenspeicher);
				}
			
		
			} catch (Exception e) {
			
		}
	}

}
}

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.InetAddress;

import java.net.ServerSocket;

import java.net.Socket;

public class MultithreadServer {

public void starteServer(){

try {

//Starte den Server

ServerSocket server = new ServerSocket(5555);

//Gibt den Hoast und die IP auf der console aus.

InetAddress adresse = InetAddress.getLocalHost();

System.out.println("Server gestartet \n" +

"Server auf IP: " + adresse.getHostAddress() + adresse.getHostName());

//Startet einen Trhead für JEDE neue Verbindung:

while (true){

Socket client = server.accept();

//den Thread Starten und den clienten übergeben:

new echo(client).start();

}

} catch (Exception e) {

}

//den Thread in einer inneren Klasse laufen lassen:

private class echo extends Thread{

private Socket client;

public echo(Socket client){

//einfaches Setter im construktor um den empfangenen Socket zuzuordnen:

this.client = client;

}

public void run(){

//Jetzt können wir auch direckt die IP vom Client.

String clientAdresse;

clientAdresse = client.getInetAddress().getHostAddress() + client.getInetAddress().getHostName();

System.out.println(clientAdresse);

try {

BufferedReader rein = new BufferedReader(new InputStreamReader(client.getInputStream()));

PrintWriter senden = new PrintWriter(client.getOutputStream());

/**

* Diese Endlosschleife ist dazu da jede anfrage der Clients anzunemen und zurück zu senden.

* Eine Empfangene Nachricht wird in den Zwischenspeicher gelegt.

* Anschliessend wird dieser String mit dem Wort "Antwort versehen" und zurück gesendet.

String zwischenspeicher;

while((zwischenspeicher = rein.readLine()) != null){

zwischenspeicher = "Antwort: " + zwischenspeicher;

//Printwriter mit Inhalt füllen:

senden.println(zwischenspeicher);

//Printwriter senden:

senden.flush();

//Zur sicherheit nochmal auf der Console ausgeben:

System.out.println("Gesendt wurde: " + zwischenspeicher);

}

} catch (Exception e) {

}

IT Stream

Mein IT und Technik Notizbuch

Mein neuer 15 Stunden Android 7 Kurs

Java Multithread Server

Der Multithread Server

One thought on “Java Multithread Server”