directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trus...@apache.org
Subject svn commit: r448080 - in /directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver: codec/ stream/
Date Wed, 20 Sep 2006 06:03:49 GMT
Author: trustin
Date: Tue Sep 19 23:03:48 2006
New Revision: 448080

URL: http://svn.apache.org/viewvc?view=rev&rev=448080
Log:
Resolved issue: DIRMINA-244 (Example HTTP server using ProtocolCodeFactory)
* Added John Preston's contribution to the example package

Added:
    directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/
    directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestDecoder.java
  (with props)
    directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestMessage.java
  (with props)
    directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseEncoder.java
  (with props)
    directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseMessage.java
  (with props)
    directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpServerProtocolCodecFactory.java
  (with props)
    directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/Server.java
  (with props)
    directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/ServerHandler.java
  (with props)
    directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/package.html
  (with props)
Modified:
    directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/stream/package.html

Added: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestDecoder.java
URL: http://svn.apache.org/viewvc/directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestDecoder.java?view=auto&rev=448080
==============================================================================
--- directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestDecoder.java
(added)
+++ directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestDecoder.java
Tue Sep 19 23:03:48 2006
@@ -0,0 +1,262 @@
+/*
+ *  Licensed to the Apache Software Foundation (ASF) under one
+ *  or more contributor license agreements.  See the NOTICE file
+ *  distributed with this work for additional information
+ *  regarding copyright ownership.  The ASF licenses this file
+ *  to you under the Apache License, Version 2.0 (the
+ *  "License"); you may not use this file except in compliance
+ *  with the License.  You may obtain a copy of the License at
+ *  
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *  
+ *  Unless required by applicable law or agreed to in writing,
+ *  software distributed under the License is distributed on an
+ *  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ *  KIND, either express or implied.  See the License for the
+ *  specific language governing permissions and limitations
+ *  under the License. 
+ *  
+ */
+package org.apache.mina.example.httpserver.codec;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.Reader;
+import java.io.StringReader;
+import java.nio.charset.CharacterCodingException;
+import java.nio.charset.CharsetDecoder;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.mina.common.ByteBuffer;
+import org.apache.mina.common.IoSession;
+import org.apache.mina.filter.codec.ProtocolDecoderOutput;
+import org.apache.mina.filter.codec.demux.MessageDecoderAdapter;
+import org.apache.mina.filter.codec.demux.MessageDecoderResult;
+import org.apache.mina.util.CharsetUtil;
+
+/**
+ * A {@link MessageDecoder} that decodes {@link HttpRequest}.
+ * 
+ * @author The Apache Directory Project (mina-dev@directory.apache.org)
+ * @version $Rev$, $Date$
+ */
+public class HttpRequestDecoder extends MessageDecoderAdapter
+{
+    private static final byte[] CONTENT_LENGTH = new String( "Content-Length:" )
+            .getBytes();
+
+    private CharsetDecoder decoder = CharsetUtil.getDefaultCharset()
+            .newDecoder();
+
+    private HttpRequestMessage request = null;
+
+    public HttpRequestDecoder()
+    {
+    }
+
+    public MessageDecoderResult decodable( IoSession session, ByteBuffer in )
+    {
+        // Return NEED_DATA if the whole header is not read yet.
+        try
+        {
+            return messageComplete( in ) ? MessageDecoderResult.OK
+                    : MessageDecoderResult.NEED_DATA;
+        }
+        catch( Exception ex )
+        {
+            ex.printStackTrace();
+        }
+
+        return MessageDecoderResult.NOT_OK;
+    }
+
+    public MessageDecoderResult decode( IoSession session, ByteBuffer in,
+            ProtocolDecoderOutput out ) throws Exception
+    {
+        // Try to decode body
+        HttpRequestMessage m = decodeBody( in );
+
+        // Return NEED_DATA if the body is not fully read.
+        if( m == null )
+            return MessageDecoderResult.NEED_DATA;
+
+        out.write( m );
+
+        return MessageDecoderResult.OK;
+    }
+
+    private boolean messageComplete( ByteBuffer in ) throws Exception
+    {
+        int last = in.remaining() - 1;
+        if( in.remaining() < 4 )
+            return false;
+
+        // to speed up things we check if the Http request is a GET or POST
+        if( in.get( 0 ) == ( byte ) 'G' && in.get( 1 ) == ( byte ) 'E'
+                && in.get( 2 ) == ( byte ) 'T' )
+        {
+            // Http GET request therefore the last 4 bytes should be 0x0D 0x0A 0x0D 0x0A
+            return( in.get( last ) == ( byte ) 0x0A
+                    && in.get( last - 1 ) == ( byte ) 0x0D
+                    && in.get( last - 2 ) == ( byte ) 0x0A && in.get( last
- 3 ) == ( byte ) 0x0D );
+        }
+        else if( in.get( 0 ) == ( byte ) 'P' && in.get( 1 ) == ( byte ) 'O'
+                && in.get( 2 ) == ( byte ) 'S' && in.get( 3 ) == ( byte )
'T' )
+        {
+            // Http POST request
+            // first the position of the 0x0D 0x0A 0x0D 0x0A bytes
+            int eoh = -1;
+            for( int i = last; i > 2; i-- )
+            {
+                if( in.get( i ) == ( byte ) 0x0A
+                        && in.get( i - 1 ) == ( byte ) 0x0D
+                        && in.get( i - 2 ) == ( byte ) 0x0A
+                        && in.get( i - 3 ) == ( byte ) 0x0D )
+                {
+                    eoh = i + 1;
+                    break;
+                }
+            }
+            if( eoh == -1 )
+                return false;
+            for( int i = 0; i < last; i++ )
+            {
+                boolean found = false;
+                for( int j = 0; j < CONTENT_LENGTH.length; j++ )
+                {
+                    if( in.get( i + j ) != CONTENT_LENGTH[ j ] )
+                    {
+                        found = false;
+                        break;
+                    }
+                    found = true;
+                }
+                if( found )
+                {
+                    // retrieve value from this position till next 0x0D 0x0A
+                    StringBuilder contentLength = new StringBuilder();
+                    for( int j = i + CONTENT_LENGTH.length; j < last; j++ )
+                    {
+                        if( in.get( j ) == 0x0D )
+                            break;
+                        contentLength.append( new String( new byte[] { in
+                                .get( j ) } ) );
+                    }
+                    // if content-length worth of data has been received then the message
is complete
+                    return( Integer.parseInt( contentLength.toString().trim() )
+                            + eoh == in.remaining() );
+                }
+            }
+        }
+
+        // the message is not complete and we need more data
+        return false;
+    }
+
+    private HttpRequestMessage decodeBody( ByteBuffer in )
+    {
+        request = new HttpRequestMessage();
+        try
+        {
+            request.setHeaders( parseRequest( new StringReader( in
+                    .getString( decoder ) ) ) );
+            return request;
+        }
+        catch( CharacterCodingException ex )
+        {
+            ex.printStackTrace();
+        }
+
+        return null;
+    }
+
+    private Map parseRequest( Reader is )
+    {
+        Map map = new HashMap();
+        BufferedReader rdr = new BufferedReader( is );
+
+        try
+        {
+            // Get request URL.
+            String line = rdr.readLine();
+            String[] url = line.split( " " );
+            if( url.length < 3 )
+                return map;
+
+            map.put( "URI", new String[] { line } );
+            map.put( "Method", new String[] { url[ 0 ].toUpperCase() } );
+            map.put( "Context", new String[] { url[ 1 ].substring( 1 ) } );
+            map.put( "Protocol", new String[] { url[ 2 ] } );
+            // Read header
+            while( ( line = rdr.readLine() ) != null && line.length() > 0 )
+            {
+                String[] tokens = line.split( ": " );
+                map.put( tokens[ 0 ], new String[] { tokens[ 1 ] } );
+            }
+
+            // If method 'POST' then read Content-Length worth of data
+            if( url[ 0 ].equalsIgnoreCase( "POST" ) )
+            {
+                int len = Integer.parseInt( ( ( String[] ) map
+                        .get( "Content-Length" ) )[ 0 ] );
+                char[] buf = new char[ len ];
+                if( rdr.read( buf ) == len )
+                {
+                    line = String.copyValueOf( buf );
+                }
+            }
+            else if( url[ 0 ].equalsIgnoreCase( "GET" ) )
+            {
+                int idx = url[ 1 ].indexOf( '?' );
+                if( idx != -1 )
+                {
+                    map.put( "Context", new String[] { url[ 1 ].substring( 1,
+                            idx ) } );
+                    line = url[ 1 ].substring( idx + 1 );
+                }
+                else
+                {
+                    line = null;
+                }
+            }
+            if( line != null )
+            {
+                String[] match = line.split( "\\&" );
+                for( int i = 0; i < match.length; i++ )
+                {
+                    String[] params = new String[ 1 ];
+                    String[] tokens = match[ i ].split( "=" );
+                    switch( tokens.length )
+                    {
+                    case 0:
+                        map.put( "@".concat( match[ i ] ), new String[] {} );
+                        break;
+                    case 1:
+                        map.put( "@".concat( tokens[ 0 ] ), new String[] {} );
+                        break;
+                    default:
+                        String name = "@".concat( tokens[ 0 ] );
+                        if( map.containsKey( name ) )
+                        {
+                            params = ( String[] ) map.get( name );
+                            String[] tmp = new String[ params.length + 1 ];
+                            for( int j = 0; j < params.length; j++ )
+                                tmp[ j ] = params[ j ];
+                            params = null;
+                            params = tmp;
+                        }
+                        params[ params.length - 1 ] = tokens[ 1 ].trim();
+                        map.put( name, params );
+                    }
+                }
+            }
+        }
+        catch( IOException ex )
+        {
+            ex.printStackTrace();
+        }
+
+        return map;
+    }
+}

Propchange: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestDecoder.java
------------------------------------------------------------------------------
    svn:keywords = HeadURL Id LastChangedBy LastChangedDate LastChangedRevision

Added: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestMessage.java
URL: http://svn.apache.org/viewvc/directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestMessage.java?view=auto&rev=448080
==============================================================================
--- directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestMessage.java
(added)
+++ directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestMessage.java
Tue Sep 19 23:03:48 2006
@@ -0,0 +1,100 @@
+/*
+ *  Licensed to the Apache Software Foundation (ASF) under one
+ *  or more contributor license agreements.  See the NOTICE file
+ *  distributed with this work for additional information
+ *  regarding copyright ownership.  The ASF licenses this file
+ *  to you under the Apache License, Version 2.0 (the
+ *  "License"); you may not use this file except in compliance
+ *  with the License.  You may obtain a copy of the License at
+ *  
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *  
+ *  Unless required by applicable law or agreed to in writing,
+ *  software distributed under the License is distributed on an
+ *  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ *  KIND, either express or implied.  See the License for the
+ *  specific language governing permissions and limitations
+ *  under the License. 
+ *  
+ */
+package org.apache.mina.example.httpserver.codec;
+
+import java.util.Iterator;
+import java.util.Map;
+import java.util.Map.Entry;
+
+/**
+ * A HTTP request message.
+ * 
+ * @author The Apache Directory Project (mina-dev@directory.apache.org)
+ * @version $Rev$, $Date$
+ */
+public class HttpRequestMessage
+{
+    /** Map<String, String[]> */
+    private Map headers = null;
+
+    public void setHeaders( Map headers )
+    {
+        this.headers = headers;
+    }
+
+    public Map getHeaders()
+    {
+        return headers;
+    }
+
+    public String getContext()
+    {
+        String[] context = ( String[] ) headers.get( "Context" );
+        return context == null ? "" : context[ 0 ];
+    }
+
+    public String getParameter( String name )
+    {
+        String[] param = ( String[] ) headers.get( "@".concat( name ) );
+        return param == null ? "" : param[ 0 ];
+    }
+
+    public String[] getParameters( String name )
+    {
+        String[] param = ( String[] ) headers.get( "@".concat( name ) );
+        return param == null ? new String[] {} : param;
+    }
+
+    public String[] getHeader( String name )
+    {
+        return ( String[] ) headers.get( name );
+    }
+
+    public String toString()
+    {
+        StringBuilder str = new StringBuilder();
+
+        Iterator it = headers.entrySet().iterator();
+        while( it.hasNext() )
+        {
+            Entry e = ( Entry ) it.next();
+            str.append( e.getKey() + " : "
+                    + arrayToString( ( String[] ) e.getValue(), ',' ) + "\n" );
+        }
+        return str.toString();
+    }
+
+    public static String arrayToString( String[] s, char sep )
+    {
+        if( s == null || s.length == 0 )
+            return "";
+        StringBuffer buf = new StringBuffer();
+        if( s != null )
+        {
+            for( int i = 0; i < s.length; i++ )
+            {
+                if( i > 0 )
+                    buf.append( sep );
+                buf.append( s[ i ] );
+            }
+        }
+        return buf.toString();
+    }
+}

Propchange: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestMessage.java
------------------------------------------------------------------------------
    svn:keywords = HeadURL Id LastChangedBy LastChangedDate LastChangedRevision

Added: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseEncoder.java
URL: http://svn.apache.org/viewvc/directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseEncoder.java?view=auto&rev=448080
==============================================================================
--- directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseEncoder.java
(added)
+++ directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseEncoder.java
Tue Sep 19 23:03:48 2006
@@ -0,0 +1,117 @@
+/*
+ *  Licensed to the Apache Software Foundation (ASF) under one
+ *  or more contributor license agreements.  See the NOTICE file
+ *  distributed with this work for additional information
+ *  regarding copyright ownership.  The ASF licenses this file
+ *  to you under the Apache License, Version 2.0 (the
+ *  "License"); you may not use this file except in compliance
+ *  with the License.  You may obtain a copy of the License at
+ *  
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *  
+ *  Unless required by applicable law or agreed to in writing,
+ *  software distributed under the License is distributed on an
+ *  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ *  KIND, either express or implied.  See the License for the
+ *  specific language governing permissions and limitations
+ *  under the License. 
+ *  
+ */
+package org.apache.mina.example.httpserver.codec;
+
+import java.nio.charset.CharacterCodingException;
+import java.nio.charset.CharsetEncoder;
+import java.util.Collections;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.Map.Entry;
+import java.util.Set;
+
+import org.apache.mina.common.ByteBuffer;
+import org.apache.mina.common.IoSession;
+import org.apache.mina.filter.codec.ProtocolEncoderOutput;
+import org.apache.mina.filter.codec.demux.MessageEncoder;
+import org.apache.mina.util.CharsetUtil;
+
+/**
+ * A {@link MessageEncoder} that encodes {@link HttpResponseMessage}.
+ * 
+ * @author The Apache Directory Project (mina-dev@directory.apache.org)
+ * @version $Rev$, $Date$
+ */
+public class HttpResponseEncoder implements MessageEncoder
+{
+    private static final Set TYPES;
+
+    static
+    {
+        Set types = new HashSet();
+        types.add( HttpResponseMessage.class );
+        TYPES = Collections.unmodifiableSet( types );
+    }
+
+    private static final byte[] CRLF = new byte[] { 0x0D, 0x0A };
+
+    public HttpResponseEncoder()
+    {
+    }
+
+    public void encode( IoSession session, Object message,
+            ProtocolEncoderOutput out ) throws Exception
+    {
+        HttpResponseMessage msg = ( HttpResponseMessage ) message;
+        ByteBuffer buf = ByteBuffer.allocate( 256 );
+        // Enable auto-expand for easier encoding
+        buf.setAutoExpand( true );
+
+        try
+        {
+            // output all headers except the content length
+            CharsetEncoder encoder = CharsetUtil.getDefaultCharset()
+                    .newEncoder();
+            buf.putString( "HTTP/1.1 ", encoder );
+            buf.putString( String.valueOf( msg.getResponseCode() ), encoder );
+            switch( msg.getResponseCode() )
+            {
+            case HttpResponseMessage.HTTP_STATUS_SUCCESS:
+                buf.putString( " OK", encoder );
+                break;
+            case HttpResponseMessage.HTTP_STATUS_NOT_FOUND:
+                buf.putString( " Not Found", encoder );
+                break;
+            }
+            buf.put( CRLF );
+            for( Iterator it = msg.getHeaders().entrySet().iterator(); it
+                    .hasNext(); )
+            {
+                Entry entry = ( Entry ) it.next();
+                buf.putString( ( String ) entry.getKey(), encoder );
+                buf.putString( ": ", encoder );
+                buf.putString( ( String ) entry.getValue(), encoder );
+                buf.put( CRLF );
+            }
+            // now the content length is the body length
+            buf.putString( "Content-Length: ", encoder );
+            buf.putString( String.valueOf( msg.getBodyLength() ), encoder );
+            buf.put( CRLF );
+            buf.put( CRLF );
+            // add body
+            buf.put( msg.getBody() );
+            //System.out.println("\n+++++++");
+            //for (int i=0; i<buf.position();i++)System.out.print(new String(new byte[]{buf.get(i)}));
+            //System.out.println("\n+++++++");
+        }
+        catch( CharacterCodingException ex )
+        {
+            ex.printStackTrace();
+        }
+
+        buf.flip();
+        out.write( buf );
+    }
+
+    public Set getMessageTypes()
+    {
+        return TYPES;
+    }
+}

Propchange: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseEncoder.java
------------------------------------------------------------------------------
    svn:keywords = HeadURL Id LastChangedBy LastChangedDate LastChangedRevision

Added: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseMessage.java
URL: http://svn.apache.org/viewvc/directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseMessage.java?view=auto&rev=448080
==============================================================================
--- directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseMessage.java
(added)
+++ directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseMessage.java
Tue Sep 19 23:03:48 2006
@@ -0,0 +1,120 @@
+/*
+ *  Licensed to the Apache Software Foundation (ASF) under one
+ *  or more contributor license agreements.  See the NOTICE file
+ *  distributed with this work for additional information
+ *  regarding copyright ownership.  The ASF licenses this file
+ *  to you under the Apache License, Version 2.0 (the
+ *  "License"); you may not use this file except in compliance
+ *  with the License.  You may obtain a copy of the License at
+ *  
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *  
+ *  Unless required by applicable law or agreed to in writing,
+ *  software distributed under the License is distributed on an
+ *  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ *  KIND, either express or implied.  See the License for the
+ *  specific language governing permissions and limitations
+ *  under the License. 
+ *  
+ */
+package org.apache.mina.example.httpserver.codec;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.mina.common.ByteBuffer;
+
+/**
+ * A HTTP response message.
+ * 
+ * @author The Apache Directory Project (mina-dev@directory.apache.org)
+ * @version $Rev$, $Date$
+ */
+public class HttpResponseMessage
+{
+    /** HTTP response codes */
+    public static final int HTTP_STATUS_SUCCESS = 200;
+
+    public static final int HTTP_STATUS_NOT_FOUND = 404;
+
+    /** Map<String, String> */
+    private Map headers = new HashMap();
+
+    /** Storage for body of HTTP response. */
+    private ByteArrayOutputStream body = new ByteArrayOutputStream( 1024 );
+
+    private int responseCode = HTTP_STATUS_SUCCESS;
+
+    public HttpResponseMessage()
+    {
+        String[] ver = Server.VERSION_STRING.split( " " );
+        headers.put( "Server", "HttpServer - Revision: " + ver[ 1 ] + " "
+                + ver[ 7 ] + " " + ver[ 8 ] + " " + ver[ 9 ] + " " + ver[ 10 ] );
+        headers.put( "Cache-Control", "private" );
+        headers.put( "Content-Type", "text/html; charset=iso-8859-1" );
+        headers.put( "Connection", "keep-alive" );
+        headers.put( "Keep-Alive", "200" );
+        headers.put( "Date", new SimpleDateFormat(
+                "EEE, dd MMM yyyy HH:mm:ss zzz" ).format( new Date() ) );
+        headers.put( "Last-Modified", new SimpleDateFormat(
+                "EEE, dd MMM yyyy HH:mm:ss zzz" ).format( new Date() ) );
+    }
+
+    public Map getHeaders()
+    {
+        return headers;
+    }
+
+    public void setContentType( String contentType )
+    {
+        headers.put( "Content-Type", contentType );
+    }
+
+    public void setResponseCode( int responseCode )
+    {
+        this.responseCode = responseCode;
+    }
+
+    public int getResponseCode()
+    {
+        return this.responseCode;
+    }
+
+    public void appendBody( byte[] b )
+    {
+        try
+        {
+            body.write( b );
+        }
+        catch( IOException ex )
+        {
+            ex.printStackTrace();
+        }
+    }
+
+    public void appendBody( String s )
+    {
+        try
+        {
+            body.write( s.getBytes() );
+        }
+        catch( IOException ex )
+        {
+            ex.printStackTrace();
+        }
+    }
+
+    public ByteBuffer getBody()
+    {
+        return ByteBuffer.wrap( body.toByteArray() );
+    }
+
+    public int getBodyLength()
+    {
+        return body.size();
+    }
+}

Propchange: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseMessage.java
------------------------------------------------------------------------------
    svn:keywords = HeadURL Id LastChangedBy LastChangedDate LastChangedRevision

Added: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpServerProtocolCodecFactory.java
URL: http://svn.apache.org/viewvc/directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpServerProtocolCodecFactory.java?view=auto&rev=448080
==============================================================================
--- directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpServerProtocolCodecFactory.java
(added)
+++ directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpServerProtocolCodecFactory.java
Tue Sep 19 23:03:48 2006
@@ -0,0 +1,38 @@
+/*
+ *  Licensed to the Apache Software Foundation (ASF) under one
+ *  or more contributor license agreements.  See the NOTICE file
+ *  distributed with this work for additional information
+ *  regarding copyright ownership.  The ASF licenses this file
+ *  to you under the Apache License, Version 2.0 (the
+ *  "License"); you may not use this file except in compliance
+ *  with the License.  You may obtain a copy of the License at
+ *  
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *  
+ *  Unless required by applicable law or agreed to in writing,
+ *  software distributed under the License is distributed on an
+ *  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ *  KIND, either express or implied.  See the License for the
+ *  specific language governing permissions and limitations
+ *  under the License. 
+ *  
+ */
+package org.apache.mina.example.httpserver.codec;
+
+import org.apache.mina.filter.codec.demux.DemuxingProtocolCodecFactory;
+
+/**
+ * Provides a protocol codec for HTTP server.
+ * 
+ * @author The Apache Directory Project (mina-dev@directory.apache.org)
+ * @version $Rev$, $Date$
+ */
+public class HttpServerProtocolCodecFactory extends
+        DemuxingProtocolCodecFactory
+{
+    public HttpServerProtocolCodecFactory()
+    {
+        super.register( HttpRequestDecoder.class );
+        super.register( HttpResponseEncoder.class );
+    }
+}

Propchange: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpServerProtocolCodecFactory.java
------------------------------------------------------------------------------
    svn:keywords = HeadURL Id LastChangedBy LastChangedDate LastChangedRevision

Added: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/Server.java
URL: http://svn.apache.org/viewvc/directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/Server.java?view=auto&rev=448080
==============================================================================
--- directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/Server.java
(added)
+++ directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/Server.java
Tue Sep 19 23:03:48 2006
@@ -0,0 +1,69 @@
+/*
+ *  Licensed to the Apache Software Foundation (ASF) under one
+ *  or more contributor license agreements.  See the NOTICE file
+ *  distributed with this work for additional information
+ *  regarding copyright ownership.  The ASF licenses this file
+ *  to you under the Apache License, Version 2.0 (the
+ *  "License"); you may not use this file except in compliance
+ *  with the License.  You may obtain a copy of the License at
+ *  
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *  
+ *  Unless required by applicable law or agreed to in writing,
+ *  software distributed under the License is distributed on an
+ *  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ *  KIND, either express or implied.  See the License for the
+ *  specific language governing permissions and limitations
+ *  under the License. 
+ *  
+ */
+package org.apache.mina.example.httpserver.codec;
+
+import java.net.InetSocketAddress;
+
+import org.apache.mina.common.IoAcceptor;
+import org.apache.mina.transport.socket.nio.SocketAcceptor;
+import org.apache.mina.transport.socket.nio.SocketAcceptorConfig;
+
+/**
+ * (<b>Entry point</b>) HTTP server
+ * 
+ * @author The Apache Directory Project (mina-dev@directory.apache.org)
+ * @version $Rev$, $Date$
+ */
+public class Server
+{
+    /** Default HTTP port */
+    private static int DEFAULT_PORT = 80;
+
+    /** Tile server revision number */
+    public static final String VERSION_STRING = "$Revision$ $Date$";
+
+    public static void main( String[] args )
+    {
+        int port = DEFAULT_PORT;
+
+        for( int i = 0; i < args.length; i++ )
+        {
+            if( args[ i ].equals( "-port" ) )
+            {
+                port = Integer.parseInt( args[ i + 1 ] );
+            }
+        }
+
+        try
+        {
+            // Create ServiceRegistry.
+            IoAcceptor acceptor = new SocketAcceptor();
+            ( ( SocketAcceptorConfig ) acceptor.getDefaultConfig() )
+                    .setReuseAddress( true );
+            acceptor.bind( new InetSocketAddress( port ), new ServerHandler() );
+
+            System.out.println( "Server now listening on port " + port );
+        }
+        catch( Exception ex )
+        {
+            ex.printStackTrace();
+        }
+    }
+}

Propchange: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/Server.java
------------------------------------------------------------------------------
    svn:keywords = HeadURL Id LastChangedBy LastChangedDate LastChangedRevision

Added: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/ServerHandler.java
URL: http://svn.apache.org/viewvc/directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/ServerHandler.java?view=auto&rev=448080
==============================================================================
--- directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/ServerHandler.java
(added)
+++ directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/ServerHandler.java
Tue Sep 19 23:03:48 2006
@@ -0,0 +1,119 @@
+/*
+ *  Licensed to the Apache Software Foundation (ASF) under one
+ *  or more contributor license agreements.  See the NOTICE file
+ *  distributed with this work for additional information
+ *  regarding copyright ownership.  The ASF licenses this file
+ *  to you under the Apache License, Version 2.0 (the
+ *  "License"); you may not use this file except in compliance
+ *  with the License.  You may obtain a copy of the License at
+ *  
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *  
+ *  Unless required by applicable law or agreed to in writing,
+ *  software distributed under the License is distributed on an
+ *  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ *  KIND, either express or implied.  See the License for the
+ *  specific language governing permissions and limitations
+ *  under the License. 
+ *  
+ */
+package org.apache.mina.example.httpserver.codec;
+
+import org.apache.mina.common.IdleStatus;
+import org.apache.mina.common.IoHandler;
+import org.apache.mina.common.IoSession;
+import org.apache.mina.filter.codec.ProtocolCodecFactory;
+import org.apache.mina.filter.codec.ProtocolCodecFilter;
+
+/**
+ * An {@link IoHandler} for HTTP.
+ * 
+ * @author The Apache Directory Project (mina-dev@directory.apache.org)
+ * @version $Rev$, $Date$
+ */
+public class ServerHandler implements IoHandler
+{
+    public ServerHandler()
+    {
+    }
+
+    public void sessionCreated( IoSession session ) throws Exception
+    {
+        ProtocolCodecFactory codec = new HttpServerProtocolCodecFactory();
+
+        session.getFilterChain().addFirst( "protocolFilter",
+                new ProtocolCodecFilter( codec ) );
+        //    session.getFilterChain().addLast("logger", new LoggingFilter());
+    }
+
+    public void sessionOpened( IoSession session )
+    {
+        System.out.println( "SERVER SESSIOn OPENED - "
+                + session.getRemoteAddress() );
+        // set idle time to 60 seconds
+        session.setIdleTime( IdleStatus.BOTH_IDLE, 60 );
+    }
+
+    public void sessionClosed( IoSession session )
+    {
+        System.out.println( "SERVER SESSIOn CLOSED" );
+    }
+
+    public void messageReceived( IoSession session, Object message )
+    {
+        HttpResponseMessage response = null;
+
+        HttpRequestMessage msg = ( HttpRequestMessage ) message;
+
+        System.out
+                .println( "***************************  REQUEST  ***************************"
);
+        System.out.println( msg );
+        System.out
+                .println( "*****************************************************************"
);
+
+        // Check that we can service the request context
+        response = new HttpResponseMessage();
+        response.setContentType( "text/plain" );
+        response.setResponseCode( HttpResponseMessage.HTTP_STATUS_SUCCESS );
+        response.appendBody( "CONNECTED" );
+
+        // msg.setResponseCode(HttpResponseMessage.HTTP_STATUS_SUCCESS);
+        // byte[] b = new byte[ta.buffer.limit()];
+        // ((ByteBuffer)ta.buffer.rewind()).get(b);
+        // msg.appendBody(b);
+        // System.out.println("####################");
+        // System.out.println("  GET_TILE RESPONSE SENT - ATTACHMENT GOOD DIAMOND.SI="+d.si+
+        // ", "+new java.text.SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss.SSS").format(new
java.util.Date()));
+        // System.out.println("#################### - status="+ta.state+", index="+message.getIndex());
+
+        //// Unknown request
+        // response = new HttpResponseMessage();
+        // response.setResponseCode(HttpResponseMessage.HTTP_STATUS_NOT_FOUND);
+        // response.appendBody(String.format(
+        // "<html><body><h1>UNKNOWN REQUEST %d</h1></body></html>",
+        // HttpResponseMessage.HTTP_STATUS_NOT_FOUND));
+
+        if( response != null )
+            session.write( response ).join();
+    }
+
+    public void messageSent( IoSession session, Object message )
+    {
+        System.out.println( "  MESSAGE SENT - WRITTEN BYTES="
+                + session.getWrittenBytes() );
+    }
+
+    public void sessionIdle( IoSession session, IdleStatus status )
+    {
+        System.out.println( "Disconnecting the idle." );
+        // disconnect an idle client
+        session.close();
+    }
+
+    public void exceptionCaught( IoSession session, Throwable cause )
+    {
+        cause.printStackTrace();
+        // close the connection on exceptional situation
+        session.close();
+    }
+}

Propchange: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/ServerHandler.java
------------------------------------------------------------------------------
    svn:keywords = HeadURL Id LastChangedBy LastChangedDate LastChangedRevision

Added: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/package.html
URL: http://svn.apache.org/viewvc/directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/package.html?view=auto&rev=448080
==============================================================================
--- directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/package.html
(added)
+++ directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/package.html
Tue Sep 19 23:03:48 2006
@@ -0,0 +1,8 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 3.2 Final//EN">
+<html>
+<head>
+</head>
+<body>
+A HTTP server implemented with protocol codec.
+</body>
+</html>

Propchange: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/codec/package.html
------------------------------------------------------------------------------
    svn:keywords = HeadURL Id LastChangedBy LastChangedDate LastChangedRevision

Modified: directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/stream/package.html
URL: http://svn.apache.org/viewvc/directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/stream/package.html?view=diff&rev=448080&r1=448079&r2=448080
==============================================================================
--- directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/stream/package.html
(original)
+++ directory/trunks/mina/example/src/main/java/org/apache/mina/example/httpserver/stream/package.html
Tue Sep 19 23:03:48 2006
@@ -3,6 +3,6 @@
 <head>
 </head>
 <body>
-Simplistic HTTP server which demonstates stream-based I/O support.
+A simplistic HTTP server which demonstates stream-based I/O support.
 </body>
 </html>



Mime
View raw message