here is my server code
TCPSelectorHandler tcp_handler = new TCPSelectorHandler();
Controller controller = new Controller();
tcp_handler.setSelectionKeyHandler(new
DefaultSelectionKeyHandler());
tcp_handler.setTcpNoDelay(true);
tcp_handler.setReuseAddress(true);
controller.setSelectorHandler(tcp_handler);
ProtocolFilter ping = new PingFilter();
ProtocolFilter read = new ReadFilter();
controller.setProtocolChainInstanceHandler(new
DefaultProtocolChainInstanceHandler() {
public ProtocolChain poll() {
ProtocolChain protocol_chain =
protocolChains.poll();
if (protocol_chain == null) {
protocol_chain = new DefaultProtocolChain();
protocol_chain.addFilter(read);
protocol_chain.addFilter(ping);
}
return protocol_chain;
}
});
final DefaultThreadPool pool = new DefaultThreadPool();
pool.setCorePoolSize(30);
pool.setMaximumPoolSize(100);
pool.setByteBufferType(ByteBufferType.DIRECT);
pool.setThreadFactory(new ThreadFactory() {
public Thread newThread(Runnable r) {
WorkerThreadImpl thread = new WorkerThreadImpl(pool,
pool.getName() + "-WorkerThread()", r, pool.getInitialByteBufferSize());
thread.setUncaughtExceptionHandler(pool);
thread.setByteBufferType(ByteBufferType.DIRECT);
thread.setByteBuffer(ByteBufferFactory.allocate(ByteBufferType.DIRECT,
8096));
return thread;
}
});
controller.setThreadPool(pool);
controller.setReadThreadsCount(30);
pool.execute(controller);
Here is my ping filter on the server
public boolean execute(Context ctx) throws IOException {
int id = 0;
ByteBuffer buffer = workerThread.getByteBuffer();
buffer.flip();
if (buffer.hasRemaining()) {
.... parse the buffer to get the id ...
}
final WorkerThread workerThread =
((WorkerThread)Thread.currentThread());
SelectableChannel channel = ctx.getSelectionKey().channel();
final ByteBuffer buffer = workerThread.getByteBuffer();
buffer.clear();
buffer.putInt(id);
bufer.flip();
OutputWriter.flushChannel(channel, bufer);
bufer.clear();
here is my code for the client
init() {
ProtocolFilter pingResponse = new PingResponseFilter();
connectorHandler.setController(controller);
tcp_handler.setTcpNoDelay(true);
tcp_handler.setReuseAddress(true);
tcp_handler.setSelectionKeyHandler(new
DefaultSelectionKeyHandler());
controller.setSelectorHandler(tcp_handler);
controller.setProtocolChainInstanceHandler(new
DefaultProtocolChainInstanceHandler() {
public ProtocolChain poll() {
ProtocolChain protocol_chain =
protocolChains.poll();
if (protocol_chain == null) {
protocol_chain = new DefaultProtocolChain();
protocol_chain.addFilter(read);
protocol_chain.addFilter(pingResponse);
}
return protocol_chain;
}
}); // end overridden method
final DefaultThreadPool pool = new DefaultThreadPool();
pool.setCorePoolSize(30);
pool.setMaximumPoolSize(100);
pool.setByteBufferType(ByteBufferType.DIRECT);
pool.setThreadFactory(new ThreadFactory() {
public Thread newThread(Runnable r) {
WorkerThreadImpl thread = new WorkerThreadImpl(pool,
pool.getName() + "-WorkerThread()", r, pool.getInitialByteBufferSize());
thread.setUncaughtExceptionHandler(pool);
thread.setByteBufferType(ByteBufferType.DIRECT);
thread.setByteBuffer(ByteBufferFactory.allocate(ByteBufferType.DIRECT,
8096));
return thread;
}
});
controller.setThreadPool(pool);
controller.setReadThreadsCount(30);
controller.addStateListener(new ControllerStateListenerAdapter() {
public void onException(Throwable e) {
}
public void onReady() {
started.countDown();
}
});
pool.execute(controller);
}
public void ping() throws Exception {
BlockingQueue blocking = new ArrayBlockingQueue(1);
int id = getRequestId();
requests.put(Integer.toString(id), blocking);
byte[]array = ... insert the id into the byte array
ByteBuffer byteBuffer = ByteBuffer.wrap(array, 0, array.length);
connectorHandler.writeToAsyncQueue(byteBuffer);
blocking.take();
}
I chopped up the code and kept the relevant parts
The client connects, then keeps calling ping over and over.
The client filter PingResponse reads the buffer and wakes up the thread that
initiated the ping.
--
View this message in context: http://www.nabble.com/performance-tp23102751p23105479.html
Sent from the Grizzly - Users mailing list archive at Nabble.com.