General question about concurrent connections and Netty.

[javadevmtl]

Ok so I wrote a sample application that simply responds with a "hello world"
and the error still happens. The goal is 200 concurrent
connections/requests/responses under 1 second.

The pipeline uses

ReadTimeoutHanlder
MyCustomHearderDecoder
StringEncoder
StringDecoder
ExecutionHandler
MyHandler

The code...
Main: http://pastebin.com/hfgkWeu0
IntegerHeaderFrameDecoder: http://pastebin.com/Jv0UnNmC
MyPipelineFactory: http://pastebin.com/UHfPysEL
MyHandler: http://pastebin.com/FQDM3Zx8

The setup...
JAVA: 1.6_20
Netty: 3.1.5GA
Server: W2K3 SP2, 2.13Ghz, 1GB RAM

2 client computers attempting 100 connections each. Client software uses
ScheduledThreadPoolExecutor to execute each request and standard JAVA
sockets/streams to write/read.

Each connection/request/response is scheduled as follows...

ScheduledThreadPoolExecutor myPool = new ScheduledThreadPoolExecutor(200);
for (int i=0; i<200; i++)
{
	myPool.scheduleAtFixedRate(
		new MyThread(...), delayCreationSec*1000, 1000-overheadEstMilliSec,
TimeUnit.MILLISECONDS);
}
-- 
View this message in context: http://netty-forums-and-mailing-lists.685743.n2.nabble.com/General-question-about-concurrent-connections-and-Netty-tp5179056p5234842.html
Sent from the Netty User Group mailing list archive at Nabble.com.