Socket Socket Verbindung

[Firekill]

Hi,

Kann man wenn ich mehrere Socket Verbindungen aufgebaut hab (die dauerhaft laufen) von einem weiterem Thread Daten über die IP und den Port verschicken (die Aktiv sind)? Ich möchte das ich später nur 10 Leuten Daten verschicke wenn jetzt beispielsweise 20 socket verbindung aufgebaut sind.

Ich hoffe ihr könnt mir helfen komm grad nicht mehr weiter
Danke für die hilfe

Gruss Manni

 

[Michael...]

Was verstehst Du unter "aktiv"?
Können die "nicht aktiv" sein, obwohl die Verbindung noch aufgebaut ist?

 

[Geeeee]

"Natürlich" ist das möglich. Du musst dich nur gut mit Threads auseinandersetzen, damit das alles ordentlich läuft.
Ich denke mal, dass du meinst, dass 20 Leute (zum Serverprogramm) verbunden sind und nur 10 ausgesuchte auch Daten bekommen sollen?

 

[Firekill]

Ja genau aber ich weiss nicht wie ich speziell einem dann Daten schicke.

hier der Server:

try {
ServerSocket ss = new ServerSocket(4040);
ss.setSoTimeout(10000);
while (true) {
try{
Socket sock = ss.accept();
sock.setSoTimeout(0);
client.add(sock);
pool.execute(new NetzwerkVerbindung(sock));

}catch(IOException e){
continue;
}
}

} catch (Exception e) {
} finally{
pool.shutdown();
}

Jetzt stellt der Client ne neue Verbindung auf und möchte beispiels weise sich an einem Tisch anmelden funktionier auch alles aber ich möchte den anderen die an dem Tisch sind auch sagen hey hier ist ein neuer ...

Client:

public void ClientVerbindung() {
try {
dataSocket = new Socket("localhost", 4040);//213.217.123.165
writer = new PrintWriter(dataSocket.getOutputStream());
reader = new BufferedReader(new InputStreamReader(dataSocket.getInputStream()));

Thread n = new Thread(new EingehendenStrom());
n.start();

a = new Thread(new EmpfangAll((dataSocket.getPort()+1)));
a.start();



} catch (Exception e) {
System.out.println("Fehler " + e);
}
}

Damit bau ich die Verbindung auf die Dauerhaft ist bis er das java programm schließt
und dort läuft dann auch der Thread:

public void ClienEmpfang() {
try {
String SDaten;
while ((SDaten = reader.readLine()) != null) {

if (SDaten != null) {
if (!SDaten.equals("$STOP$")) {
if (!SDaten.isEmpty()) {
doWork(SDaten);
}
}
}
}
} catch (IOException e) {
System.out.println("Test:" + e);
}
}

ich hoffe das ist nicht zuviel

danke für die schnelle antwort

 

[Michael...]

Jetzt stellt der Client ne neue Verbindung auf und möchte beispiels weise sich an einem Tisch anmelden funktionier auch alles aber ich möchte den anderen die an dem Tisch sind auch sagen hey hier ist ein neuer ...

Dann muss der Server "nachschauen" welche Clients sich am selben Tisch befinden und diesen eben die gewünschte Nachricht schicken.

 

[Firekill]

sprich ich schicke von einem Client aus meine Anmeldung zum Tisch und dadurch wird denen dann eine Nachricht zugesendet die auf dem Tisch sind.

 

[Firekill]

Ja genau vom Prinzip ist mir das klar

Ich hab auch alles in einer Datenbank eingetragen wer aktiv im Tisch angemeldet ist.

Mein problem ist das ich jetzt bei einer neuen Anmeldung an einem Tisch den anderen bescheid gebe muss/möchte :/

sprich der Server muss Wissen welcher Thread welche IP hat und wer wo angemeldet ist... dann muss er auch noch erfahren wann einer sich anmeldet... aber wie arg

 

[Michael...]

sprich der Server muss Wissen welcher Thread welche IP hat

Nein, die IP ist wurscht, er muss nur wissen auf welchen Outputstreams er die Mitteilung versenden muss.

 

[Firekill]

aber wie kann ich ihm das genau sagen welcher outputstream das ist? wie man oben sieht erstellt er ja immer ein neues thread und in einem der Threads empfängt der Server jetzt die daten. Aber woher soll der Server wissen welche Thread die an dem Tisch angemeldet sind.

Ich weiss was du meinst aber ich weiss leider nicht wie ich das umsetzten kann ohman sprich woher weiss er welcher Tisch er ist!

 

[Michael...]

wie man oben sieht erstellt er ja immer ein neues thread und in einem der Threads empfängt der Server jetzt die daten.

Ich seh davon garnichts. Ich sehe nur, dass das Socket an ein Object NetzwerkVerbindung übergeben wird. Wie die In und Out Streams auf serverseites verwaltet werden ist nicht zu sehen.

 

[Firekill]

Server Versand:
public void ServerVersand(ArrayList<String> Daten, Socket sock) {
try {
currentTime = new Date();
PrintWriter writer = new PrintWriter(new OutputStreamWriter(sock.getOutputStream()));
for (int i = 0; i < Daten.size(); i++) {
text.append(formatter.format(currentTime) + " => Versandt (): " + Daten.get(i) + "\n");
writer.println(Daten.get(i));
}
writer.flush();
} catch (Exception e) {
}

Server Empfang:

public void ServerEmpfang() {
try {

String SDaten;
reader = new BufferedReader(new InputStreamReader(sock.getInputStream()));

while (!sock.isClosed()) {
SDaten = reader.readLine();
if (SDaten != null) {

if (!SDaten.isEmpty()) {
doWork(SDaten);
}


}


}
} catch (IOException e) {
System.out.println(e);
}
}