import com.sun.grizzly.http.SelectorThread; 
import com.sun.grizzly.tcp.Adapter; 
import com.sun.grizzly.tcp.OutputBuffer; 
import com.sun.grizzly.tcp.Request; 
import com.sun.grizzly.tcp.Response; 
import com.sun.grizzly.util.buf.ByteChunk; 
 
import java.net.HttpURLConnection; 
 
public class HttpServer implements Adapter { 
    public static void main(String[] args) 
    { 
        SelectorThread st = new SelectorThread(); 
        st.setPort(8087); 
        st.setAdapter(new HttpServer()); 
        System.out.println("My Test Web Server"); 
        try 
        { 
            st.initEndpoint(); 
            st.startEndpoint(); 
        } 
        catch(Exception e) 
        { 
            System.out.println("Exception in SelectorThread"+e); 
             
        } 
        finally 
        { 
            if(st.isRunning()) 
            { 
                st.stopEndpoint(); 
            } 
        } 
    } 
    public void service(Request request, Response response) throws Exception 
    { 
        String requestURI=request.requestURI().toString(); 
         
        System.out.println("New Incomming request with URI: "+requestURI); 
        System.out.println("Request Method is : "+request.method()); 
        if(request.method().toString().equalsIgnoreCase("GET")) 
        { 
            response.setStatus(HttpURLConnection.HTTP_OK); 
            byte[] bytes = "Here is my response text".getBytes(); 
             
            ByteChunk chunk = new ByteChunk(); 
            response.setContentLength(bytes.length); 
            response.setContentType("text/plain"); 
            chunk.append(bytes, 0, bytes.length); 
            OutputBuffer buffer = response.getOutputBuffer(); 
            buffer.doWrite(chunk, response); 
            response.finish(); 
        } 
    } 
    public void afterService(Request request, Response response) 
    { 
        request.recycle(); 
        response.recycle(); 
    } 
 
    public void fireAdapterEvent(String string, Object object) 
    { 
         
    } 
}