KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > codehaus > loom > demos > helloworld > HelloWorldHandler


1 /* ====================================================================
2  * Loom Software License, version 1.1
3  *
4  * Copyright (c) 2003, Loom Group. All rights reserved.
5  * Redistribution and use in source and binary forms, with or without
6  * modification, are permitted provided that the following conditions
7  * are met:
8  *
9  * 1. Redistributions of source code must retain the above copyright
10  * notice, this list of conditions and the following disclaimer.
11  *
12  * 2. Redistributions in binary form must reproduce the above copyright
13  * notice, this list of conditions and the following disclaimer in
14  * the documentation and/or other materials provided with the
15  * distribution.
16  *
17  * 3. Neither the name of the Loom Group nor the name "Loom" nor
18  * the names of its contributors may be used to endorse or promote
19  * products derived from this software without specific prior
20  * written permission.
21  *
22  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
23  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
24  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
25  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
26  * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
27  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
28  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
29  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
30  * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
31  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
32  * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
33  * POSSIBILITY OF SUCH DAMAGE.
34  *
35  * ====================================================================
36  *
37  * Loom includes code from the Apache Software Foundation
38  *
39  * ====================================================================
40  * The Apache Software License, Version 1.1
41  *
42  * Copyright (c) 1997-2003 The Apache Software Foundation. All rights
43  * reserved.
44  *
45  * Redistribution and use in source and binary forms, with or without
46  * modification, are permitted provided that the following conditions
47  * are met:
48  *
49  * 1. Redistributions of source code must retain the above copyright
50  * notice, this list of conditions and the following disclaimer.
51  *
52  * 2. Redistributions in binary form must reproduce the above copyright
53  * notice, this list of conditions and the following disclaimer in
54  * the documentation and/or other materials provided with the
55  * distribution.
56  *
57  * 3. The end-user documentation included with the redistribution,
58  * if any, must include the following acknowledgment:
59  * "This product includes software developed by the
60  * Apache Software Foundation (http://www.apache.org/)."
61  * Alternately, this acknowledgment may appear in the software
62  * itself, if and wherever such third-party acknowledgments
63  * normally appear.
64  *
65  * 4. The names "Jakarta", "Avalon", and "Apache Software Foundation"
66  * must not be used to endorse or promote products derived from this
67  * software without prior written permission. For written
68  * permission, please contact apache@apache.org.
69  *
70  * 5. Products derived from this software may not be called "Apache",
71  * nor may "Apache" appear in their name, without prior written
72  * permission of the Apache Software Foundation.
73  *
74  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
75  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
76  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
77  * DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
78  * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
79  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
80  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
81  * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
82  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
83  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
84  * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
85  * SUCH DAMAGE.
86  */
87 package org.codehaus.loom.demos.helloworld;
88
89 import java.io.IOException JavaDoc;
90 import java.io.InterruptedIOException JavaDoc;
91 import java.io.PrintWriter JavaDoc;
92 import java.net.Socket JavaDoc;
93 import java.net.SocketException JavaDoc;
94 import org.apache.avalon.framework.logger.AbstractLogEnabled;
95 import org.apache.avalon.phoenix.BlockContext;
96 import org.codehaus.spice.netserve.connection.RequestHandler;
97
98 /**
99  * This handles an individual incoming request.
100  * It outputs a greeting as html.
101  *
102  * @author Paul Hammant <Paul_Hammant at yahoo.com>
103  * @author Federico Barbieri <scoobie at systemy.it>
104  * @version 1.0
105  */
106 final class HelloWorldHandler
107     extends AbstractLogEnabled
108     implements RequestHandler
109 {
110     /** Request counter */
111     private static int c_counter;
112
113     /** HelloWorld server reference */
114     private HelloWorldServer m_helloWorldServer;
115
116     /** The block context */
117     private BlockContext m_context;
118
119
120     /**
121      * Crate a new HelloWorld request handler.
122      *
123      * @param helloWorldServer The helloworld server
124      * @param context The block context
125      */
126     HelloWorldHandler( final HelloWorldServer helloWorldServer,
127                        final BlockContext context )
128     {
129         m_helloWorldServer = helloWorldServer;
130         m_context = context;
131     }
132
133     /**
134      * Handle a connection. This handler is responsible for processing
135      * connections as they occur.
136      *
137      * @param socket the connection
138      * @throws IOException if an error reading from socket occurs
139      */
140     public void handleConnection( final Socket JavaDoc socket )
141     {
142         final String JavaDoc remoteHost = socket.getInetAddress().getHostName();
143         final String JavaDoc remoteIP = socket.getInetAddress().getHostAddress();
144
145         try
146         {
147             final PrintWriter JavaDoc out =
148               new PrintWriter JavaDoc( socket.getOutputStream(), true );
149
150             out.println( "<html><body>" );
151             out.println( "<b>" + m_helloWorldServer.getGreeting() + "</b><br>" );
152             out.println( "Requests so far = " + ++c_counter + "<br>" );
153             out.println( "You are " + remoteHost + " at " + remoteIP + "<br>" );
154             out.println( "<p>The application will shutdown after 10 requests." );
155             out.println( "</body></html>" );
156
157             socket.close();
158         }
159         catch( final SocketException JavaDoc se )
160         {
161             getLogger().debug( "Socket to " + remoteHost
162               + " closed remotely in HelloWorld", se );
163         }
164         catch( final InterruptedIOException JavaDoc iioe )
165         {
166             getLogger().debug(
167               "Socket to " + remoteHost + " timeout in HelloWorld", iioe );
168         }
169         catch( final IOException JavaDoc ioe )
170         {
171             getLogger().debug( "Exception in HelloWorld handling socket to "
172               + remoteHost, ioe );
173         }
174         catch( final Exception JavaDoc e )
175         {
176             getLogger().debug( "Exception in HelloWorld opening socket", e );
177         }
178         finally
179         {
180             try
181             {
182                 socket.close();
183             }
184             catch( final IOException JavaDoc ioe )
185             {
186                 getLogger().error( "Exception closing socket ", ioe );
187             }
188         }
189
190         getLogger().info(
191           "Connection from " + remoteHost + " (" + remoteIP + ")" );
192
193         // A test of shutting down a block & app programatically.
194 if( c_counter >= 10 )
195         {
196             System.out.println( "Testing Auto-Shutdown after 10 requests." );
197             m_context.requestShutdown();
198         }
199     }
200
201     /**
202      * Shutdown the handler and any requests currently being handled.
203      */
204     public void shutdown( long timeout )
205     {
206     }
207 }
208
Popular Tags