[Java] notify pri prichozich datech v input streamu ?

[ariczek 170]

Zdravicko... mam problem v javě:

 

Mam vlakno receiver, ktere vypada nejak takhle:

 

private DataInputStream dis;
private boolean umri;

@Override
public void run() {
	while (true) {
		if (umri) {
			umri();
			return();
		}
		if (dis.available() > 0)
			zpracuj();
		try {
			Thread.sleep(5000);
		} catch (InterruptedException e) {
		}
	}
private void zpracuj() { ... }
private void umri() { ... }
}

 

dis je otevrenej input stream nad socketem - TCPkovy spojeni.

tohle reseni se sleepem, se mi nelibi... protoze pouzivam protokol, kde se musi zvladnout 3way vymena (př. client -> server -> client) do 10s... a jindy se 4 minuty nestane nic, zadna data...

metodou aktivniho cekani - na tvrdo volat porad read()... bez mezilehleho sleepu... nemuzu, tech vlaken pobezi na servru spousta...

 

idealni by pro me bylo... kdyby existoval mechanismus announceru - kdyz prijde paket do inputstreamu, zavola se metoda interfacu, kterou si naimplementuju dle potreby... nejsnazsi zpusob by byl wait(), a ten announcer pres notify() na mnou urceny objekt... bohuzel to nedokazu najit ani navrhnout jak to udelat, aniz bych pridaval dalsi thread... dalsi zatez (aktivni cekani pres available() bez timeoutu... pripadne blokujici read() s krkolomnym predavanim precteneho mezi thready...).

 

Pripadne nejaka blokujici funkce read()... s moznosti interrupt().

 

Nejake rady nekdo ?

[bLuma 225]

Ten sleep je zbytečně velký, bez problémů by fungovalo klidně cca 50-100 ms. Ale jinak můžeš použít novější API v java.nio.*, kde je podporován neblokující režim.

[Lukasas 162]

Nevím proč řešíš kolik těch vláken poběží... Já bych to všechno nechal připojovat do vláken, tam bych to zadržel read a přes jiný vlákno (třeba hlavní) bych všem připojeným klientům poslal zprávu. Ty "dis" si ukládej do nějakého pole nebo mapy a potom je cyklem odtud "vyděláš" a pošleš přes to zprávu

 

edit: sice o java moc nevím, ale tímto způsobem bych to asi udělal já

Edited August 25, 2011 by Lukasas

[ariczek 170]

Ten sleep je zbytečně velký, bez problémů by fungovalo klidně cca 50-100 ms. Ale jinak můžeš použít novější API v java.nio.*, kde je podporován neblokující režim.

 

s tim java.nio to vyzkousim... ale moc se mi nezda ze je to to, co potrebuju :-\

 

 

Nevím proč řešíš kolik těch vláken poběží... Já bych to všechno nechal připojovat do vláken, tam bych to zadržel read a přes jiný vlákno (třeba hlavní) bych všem připojeným klientům poslal zprávu. Ty "dis" si ukládej do nějakého pole nebo mapy a potom je cyklem odtud "vyděláš" a pošleš přes to zprávu

 

edit: sice o java moc nevím, ale tímto způsobem bych to asi udělal já

 

no prave ze resim pocet vlaken... tak jak to mam ted napsany... je hlavni serverovy vlakno... a pro kazdyho clienta vytvarim vlakno receiver, a vlakno sender... protoze kazdej klient komunikuje sam za sebe... a pri plnym vytizeni muzu mit 60000 clientu... to je uz ted 120000 vlaken... budu to muset nejak predelat asi...

[Lukasas 162]

Proč by jsi měl vytvářek každýmu vlákno sender ? Vytvoř si nějaký dynamický pole či mapu a vkládej to tam. Potom můžeš jen přes hlavní vlákno odeslat všem nebo jen někomu data který chceš.

[ariczek 170]

prislo mi to jako intuitivni nejlepsi reseni... ale zatim plichtim dohromady prototyp, pak to jeste predelam... stejne se nevyhnu tomu abych mel konekcne zavislej pocet threadu... protoze nevim jak dlouho muze trvat cyklus pres 60000 konekci, a na kazdym vyzkouset jestli neco prislo, ci jestli je neco k odeslani... ale rek bych ze dele nez potrebuju.