Diskuze: Sítové programování Socket - blokování
V předchozím kvízu, Online test znalostí Java, jsme si ověřili nabyté zkušenosti z kurzu.
Jiří Hrdina:18.11.2018 10:35
Tak se mi to podařilo zprovoznit v konzoli, prozatím bez GUI. Nicméně měl bych ještě jeden dotaz. V těch vláknech mám cykly - v read vláknu, ve write vláknu a i v ClientHandler vláknu, což je privátní vnořená třída a toto vlákno se vytváří vždy, když se připojí nový klient. Úplně mi to nepřijde nejlepší, tam mít všude nekonečné cykly - nebo je to v pohodě?
Run metoda ve vnitřní třídě Server - v ClientHandler
@Override
public void run() {
while(true){
try {
Message msg = (Message) in.readObject();
System.out.println("Přečtená zpráva " + msg);
msg.setMessage(msg.getMessage() + " - SENDIMG TO ALL");
sendAll(msg);
} catch (Exception e){
System.out.println("Exception in CLIENTHANDLER THREAD");
}
}
}
}VLÁKNO PRO POSÍLÁNÍ v Clientovi
Thread sendMessages = new Thread(() -> {
String fromUser = "";
BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
while(true){
System.out.println("IN SENDMESSAGES");
try {
fromUser = stdIn.readLine();
Message message = new Message("Peter", null);
message.setMessage(fromUser);
System.out.println(message);
if(fromUser != null){
System.out.println("POSÍLÁM NA SERVER" + fromUser);
out.writeObject(message);
}
} catch (IOException e){
System.out.println("Exception in SENDMESSAGES thread");
}
}
});Vlákno pro přijímání zpráv
Thread readMessages = new Thread(() -> {
Message ms;
try {
while (true) {
ms = (Message) in.readObject();
System.out.println("Received message " + ms);
}
} catch (Exception e){
System.out.println("EXCEPTION IN READ THREAD");
}
});Děkuji 
Jiří Hrdina:22.11.2018 21:38
Díky za všechny rady. Dostal jsem se do stádia, kdy pracuji již i s Javou FX.
Mám ze strany treeView, kde se mi načtou všechny online kontakty, když
načtu, tak s nimi chci psát, ale pro každého chci mít vytvořený vlastní
ListView, který mám vedle těch online kontaktů. Jakým způsobem toho
docílit?
Běží mi tam service, který hlídá nové zprávy, které mám uložené v
Queue v daném klientovi, ale bohužel se mi to všechno vypisuje do jednoho
listView...
Díky
Jiří Hrdina:23.11.2018 14:28
ale tímto způsobem nedocílím toho, že se mi budou zprávy přidávat
dynamicky, ne? Jenom pouze, když kliknu na toho klienta, chápu to správně?
Jiří Hrdina:23.11.2018 15:20
Dobře, díky, mrknu na to zítra. Každopádně bych měl ještě jeden dotaz... Jak moc takováto
aplikace by měla žrát CPU? Pokud pustím 3 klienty naráz na jednom ntb a
server, tak to teda docela žere opravdu hodně...
Jiří Hrdina:24.11.2018 10:22
Tak jsem na to přišel zřejmě.
Thread sendMessages = new Thread(() -> {
while(true){
try {
while(messagesToSend.size() > 0){
Message message = messagesToSend.take();
System.out.println("BUDU POSÍLAT ZPRÁVZ");
out.writeObject(message);
}
} catch (Exception e){
System.out.println("Exception in SENDMESSAGES thread");
}
}
});Po tom, co jsem přidal do tohodle vlákna Thread.sleep(3000) za catch, tak
mi to žere 0,2-0,8% CPU (Což je z 25% docela slušný skok
Šlo by to asi vyřešit lépe. než ten sleep, že? Ideálně nějakou blokovací metodu, že když nebudou k dispozici zprávy k poslání tak spi...
Zobrazeno 32 zpráv z 32.