Since a servlet is blocking, a normal HTTP communication makes the thread wait. So there is a possibility that all the threads in the pool can be used up. By using the asynchronous http client framework Asynchronous HTTP Client framework (AHC javadocs), the thread can be released back into the pool and be made available for other purposes until the answer comes back. When the answer comes back, a callback is fired which then relays the response back to the client.

The async http client is to be used in conjunction with web containers that are configured for non blocking communication. CometProcesor with Tomcat and Continuation with Jetty are some good examples. This example uses Tomcat.

This document is organized in the following sections:

Table of Contents

About this example

This example seeks to demonstrate the usage of the async http client by first configuring the Geronimo server. It then deploys an app which we shall call http-local-app on this configured server. Another webapp call http-remote-app is deployed on any other server. The servlet on the http-local-app delegates requests to the async http client and returns immediately. The async http client connects to the remote app and when it recieves a response, a callback is fired which relays the message back to the original response stream.

The http-local-app

The AsyncServlet in this app uses the AHC and implements the CometProcessor interface. The CometProcessor will make it's event method invoked rather than the usual service method, according to the event which occurred. The event object gives access to the usual request and response objects, which may be used in the usual way. More information about this can be read here.

The servlet also generates a random delay time and a random http status code. Using the async client, it connects to a remote url and passes these randomly generated values to it. The remote url is initialized from the servlet's <init-param> value. Once the async client sends a request to the remote app, the servlet returns without waiting for a response from the remote app. This app has a callback listener which holds the CometEvent object. When it receives the answer from the remote app, it gets the original response from the event object and passes the message to it.

The http-remote-app

A simple servlet in this app reads the two request parameters delay and code. It sleeps for the amount of time specified in the delay. If the code is 200, it serves a file called dummy.html. For the status code 500, it does a divide by zero to throw a servlet exception. For other status codes, it sets the appropriate response code in the response.sendError(). It then returns. This simulates varous response times and return status codes from an external app. This app can be run on any other server and machine.

Configuring the server

Use one of the following methods to configure your server. Little-G assemblies do not have a console.

Using console

Install a geronimo server with tomcat webcontainer and start it. Log onto the console by using system/manager as your credentials. Click on the "Web Server" link on the left hand navigation frame. Under "Add new:" section, click on "Tomcat NIO HTTP connector". Specify a uniquename for the connector and take all the default values. Save this configuration. Your new connector must be listed in the Network Listeners.

Now delete the TomcatWebConnector in the Network Listeners list so that all connections are made to the new Tomcat NIO HTTP connector.

Editing the config.xml

Stop the server.
edit geronimo_home/var/config/config.xml
add load="false" to the TomcatWebConnector gbean. The line would now look like this
<gbean load="false" name="TomcatWebConnector">

for the module org.apache.geronimo.configs/tomcat6/<version>/car, add the following gbean

Code Block

	XML
	XML
borderStyle	solid


<gbean gbeanInfo="org.apache.geronimo.tomcat.connector.Http11NIOConnectorGBean"
       name="org.apache.geronimo.configs/tomcat6/2.0.1/car?ServiceModule=org.apache.geronimo.configs/tomcat6/2.0.1/car,j2eeType=GBean,name=TomcatNIOConnector">
<attribute name="useExecutor">true</attribute>
<attribute name="maxThreads">40</attribute>
<attribute name="pollerThreadCount">1</attribute>
<attribute name="socket_soTimeout">5000</attribute>
<attribute name="selectorTimeout">1000</attribute>
<attribute name="connectionTimeout">60000</attribute>
<attribute name="socket_soLingerOn">true</attribute>
<attribute name="acceptorThreadCount">1</attribute>
<attribute name="port">8080</attribute>
<attribute name="pollerThreadPriority">5</attribute>
<attribute name="compressableMimeType">text/html,text/xml,text/plain</attribute>
<attribute name="socket_performanceLatency">0</attribute>
<attribute name="useComet">true</attribute>
<attribute name="useIPVHosts">false</attribute>
<attribute name="maxHttpHeaderSize">4096</attribute>
<attribute name="restrictedUserAgents" value=""/>
<attribute name="acceptorThreadPriority">5</attribute>
<attribute name="proxyPort">0</attribute>
<attribute name="maxPostSize">2097152</attribute>
<attribute name="minSpareThreads">10</attribute>
<attribute name="socketBuffer">9000</attribute>
<attribute name="redirectPort">8443</attribute>
<attribute name="bufferSize">2048</attribute>
<attribute name="socket_soReuseAddress">false</attribute>
<attribute name="useSendfile">true</attribute>
<attribute name="threadPriority">5</attribute>
<attribute name="socket_tcpNoDelay">false</attribute>
<attribute name="useBodyEncodingForURI">false</attribute>
<attribute name="maxSpareThreads">100</attribute>
<attribute name="enableLookups">true</attribute>
<attribute name="socket_performanceConnectionTime">1</attribute>
<attribute name="socket_appWriteBufSize">8192</attribute>
<attribute name="maxKeepAliveRequests">100</attribute>
<attribute name="socket_ooBInline">true</attribute>
<attribute name="socket_keyCache">500</attribute>
<attribute name="disableUploadTimeout">true</attribute>
<attribute name="socket_bufferPoolSize">104857600</attribute>
<attribute name="keepAliveTimeout">60000</attribute>
<attribute name="acceptCount">100</attribute>
<attribute name="socket_txBufSize">43800</attribute>
<attribute name="connectionLinger">-1</attribute>
<attribute name="command_line_options">true</attribute>
<attribute name="tcpNoDelay">true</attribute>
<attribute name="oomParachute">1048576</attribute>
<attribute name="socket_appReadBufSize">8192</attribute>
<attribute name="selectorPool_maxSpareSelectors">-1</attribute>
<attribute name="xpoweredBy">false</attribute>
<attribute name="socket_rxBufSize">25188</attribute>
<attribute name="maxSavePostSize">4096</attribute>
<attribute name="socket_soLingerTime">25</attribute>
<attribute name="compression">off</attribute>
<attribute name="host">0.0.0.0</attribute>
<attribute name="socket_eventCache">500</attribute>
<attribute name="socket_performanceBandwidth">1</attribute>
<attribute name="noCompressionUserAgents" value=""/>
<attribute name="name">TomcatNIOConnector</attribute>
<attribute name="socket_soKeepAlive">false</attribute>
<attribute name="socket_soTrafficClass">28</attribute>
<attribute name="socket_directBuffer">false</attribute>
<attribute name="selectorPool_maxSelectors">200</attribute>
<attribute name="emptySessionPath">false</attribute>
<attribute name="uriEncoding">ISO-8859-1</attribute>
<attribute name="allowTrace">false</attribute>
<attribute name="processCache">200</attribute>
<attribute name="socket_processorCache">500</attribute>
<attribute name="server" null="true"/>
<attribute name="proxyName" null="true"/>
<reference name="TomcatContainer">
<pattern>
<groupId>org.apache.geronimo.configs</groupId>
<artifactId>tomcat6</artifactId>
<version>2.0.1</version>
<type>car</type>
<name>TomcatWebContainer</name>
</pattern>
</reference>
<reference name="ServerInfo">
<pattern>
<groupId>org.apache.geronimo.configs</groupId>
<artifactId>j2ee-system</artifactId>
<version>2.0.1</version>
<type>car</type>
<name>ServerInfo</name>
</pattern>
</reference>
</gbean>

The gbean uses version 2.0.1. Replace that with the appropriate version of your server
Start the server.

Building the sample

Download the zip file which contains both the apps discussed above.
Unzip the file into a directory of your choice, say samples.
cd into samples\async-http directory\http-local-app\src\main\webapp\WEB-INF directory.
edit the web.xml there and change the value of the <remoteUrl> initi-param. This should be set to the machine where your remote app will be deployed.
cd back to async-http directory.
execute mvn. This will build the 2 WARs.

Testing the sample with a browser

Deploy samples\async-http\http-local-app\target\http-local-app-2.0-SNAPSHOT.war on the Geronimo server we configured earlier using either the consoleor the command line
$geronimo_home/bin>./deploy.sh deploy samples\async-http\http-local-app\target\http-local-app-2.0-SNAPSHOT.war
Deploy samples\async-http directory\http-remote-app\target\http-remote-app-2.0-SNAPSHOT.war on any server on the remote machine.
Point your browser to http://localhost:8080/localApp/async. If you wish to override the remoteUrl set in the <init-param> of the web.xml, you may pass it as a request param (http://localhost:8080/localApp/async?remoteUrl=http://foo:8080)
You should see either a dummy html or one of the popular HTTP errors.

Running the sample under heavy load

The true powers of the AHC can be seen only when the app using it is stressed under a heavy load. The client stressing the app can be any multi-threaded simulating simultaneous HTTP requests.

To leverage the full potential of AHC, the Geronimo server running it and the 3 machines (machines running the client, the local app with AHC and remote server) in the test setup must be tuned. This is necessary because the AHC starts devouring sockets and making remote connections at the same pace at which it gets the requests. If more sockets are made available to it, the AHC spends less time waiting for existing ones to free up. The bottleneck now has been transferred to establishing connections rather than at a normal blocking servlet.

Tuning

Here are some of the parameters that can be tuned.

acceptCount This attribute can be adjusted in TomcatNIOConnector gbean that you created above. Each incoming request requires a thread for the duration of that request. If more simultaneous requests are received than can be handled by the currently available request processing threads, additional threads will be created up to the configured maximum (the value of the maxThreads attribute). If still more simultaneous requests are received, they are stacked up inside the server socket created by the Connector, up to the configured maximum (the value of the acceptCount attribute). Any further simultaneous requests will receive "connection refused" errors, until resources are available to process them. So set the value of this attribute to be atleast equal to the number of the client threads pounding the AHC.
TIME_WAIT (TcpTimedWaitDelay) This setting determines the length of time that a connection will stay in the TIME_WAIT state before being closed
SYN_COOKIES This detects syn attacks. This should be turned off/disabled.
SOCKET_QUEUE (same as MaxUserPort ?) The Windows system limits the maximum port number assigned to outgoing connections. By default this value is 5000. You may want to increase that value to 20,000 or more
TcpNumConnections On Windows, this parameter limits the maximum number of connections that TCP can have open at the same time.

Stress Test

Download the client python script. You will need python installed on your machine to run this script. You can download Python from here.
The script takes 3 arguments - the name of the machine running http-local-app (AHC), the url of the server on the remote app and the number of threads.
ahcrequest.py local_machine http://remote_machine:8080 200

Test Results

The following test results show a comparison between an AHC enhanced servlet and a normal blocking servlet. Each of these servlets are pounded by 16, 200 and 500 simultaneous requests. The output captured from the python script shows the response time for each request. These tests also demonstrate the significance of tuning the IP stacks. When none of the machines are tuned, the response time starts increasing as the number of threads start increasing. Executing a netstat command shows that most sockets are either in TIME_WAIT or CLOSED_WAIT state.

Threads	Blocking Servlet max response time (secs)	AHC Servlet max response time(secs)	HttpComponents max response time (secs)
16	5.252	2.081	1.974
100			2.975
200	25.935	7.575	3.358
400			6.694
500	39.590	12.917	13.051

Code location and References

Browse the sample code at http://svn.apache.org/viewvc/geronimo/samples/trunk/samples/async-http/

Check out code from svn using
svn co https://svn.apache.org/repos/asf/geronimo/samples/trunk/samples/async-http async-http

Browse the AHC code at http://svn.apache.org/viewvc/geronimo/sandbox/AsyncHttpClient

Check out code from svn using
svn co https://svn.apache.org/repos/asf/geronimo/sandbox/AsyncHttpClient ahc

View AHC's javadocs at AHC javadocs

Child pages

Versions Compared

Old Version 1

New Version Current

Key

About this example

The http-local-app

The http-remote-app

Configuring the server

Using console

Editing the config.xml

Building the sample

Testing the sample with a browser

Running the sample under heavy load

Tuning

Stress Test

Test Results

Code location and References

Child pages

Page History

Versions Compared

Old Version 1

New Version Current

Key

About this example

The http-local-app

The http-remote-app

Configuring the server

Using console

Editing the config.xml

Building the sample

Testing the sample with a browser

Running the sample under heavy load

Tuning

Stress Test

Test Results

Code location and References