Bael 770 jetty (#1548)

* BAEL-770 add jetty simple test case

* BAEL-770 jetty async and blocking servlets

* BAEL-766 reorder

libraries/pom.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
         <artifactId>parent-modules</artifactId>
         <groupId>com.baeldung</groupId>
@@ -72,6 +72,26 @@
             <artifactId>javers-core</artifactId>
             <version>${javers.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.eclipse.jetty</groupId>
+            <artifactId>jetty-server</artifactId>
+            <version>${jetty.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.jetty</groupId>
+            <artifactId>jetty-servlet</artifactId>
+            <version>${jetty.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>${httpclient.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>commons-io</groupId>
+            <artifactId>commons-io</artifactId>
+            <version>${commons.io.version}</version>
+        </dependency>
     </dependencies>
 
     <properties>
@@ -84,6 +104,9 @@
         <assertj.version>3.6.2</assertj.version>
         <jsonassert.version>1.5.0</jsonassert.version>
         <javers.version>3.1.0</javers.version>
+        <jetty.version>9.4.2.v20170220</jetty.version>
+        <httpclient.version>4.5.3</httpclient.version>
+        <commons.io.version>2.5</commons.io.version>
     </properties>
 
 </project>

libraries/src/main/java/com/baeldung/jetty/AsyncServlet.java

@@ -0,0 +1,42 @@
+package com.baeldung.jetty;
+
+import javax.servlet.AsyncContext;
+import javax.servlet.ServletException;
+import javax.servlet.ServletOutputStream;
+import javax.servlet.WriteListener;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.nio.ByteBuffer;
+import java.nio.charset.StandardCharsets;
+
+public class AsyncServlet extends HttpServlet {
+    private static final String HEAVY_RESOURCE = "This is some heavy resource that will be served in an async way";
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        ByteBuffer content = ByteBuffer.wrap(HEAVY_RESOURCE.getBytes(StandardCharsets.UTF_8));
+
+        AsyncContext async = request.startAsync();
+        ServletOutputStream out = response.getOutputStream();
+        out.setWriteListener(new WriteListener() {
+            @Override
+            public void onWritePossible() throws IOException {
+                while (out.isReady()) {
+                    if (!content.hasRemaining()) {
+                        response.setStatus(200);
+                        async.complete();
+                        return;
+                    }
+                    out.write(content.get());
+                }
+            }
+
+            @Override
+            public void onError(Throwable t) {
+                getServletContext().log("Async Error", t);
+                async.complete();
+            }
+        });
+    }
+}

libraries/src/main/java/com/baeldung/jetty/BlockingServlet.java

@@ -0,0 +1,17 @@
+package com.baeldung.jetty;
+
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+public class BlockingServlet extends HttpServlet {
+
+    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+        response.setContentType("application/json");
+        response.setStatus(HttpServletResponse.SC_OK);
+        response.getWriter().println("{ \"status\": \"ok\"}");
+    }
+}
+

libraries/src/main/java/com/baeldung/jetty/JettyServer.java

@@ -0,0 +1,32 @@
+package com.baeldung.jetty;
+
+import org.eclipse.jetty.server.Connector;
+import org.eclipse.jetty.server.Server;
+import org.eclipse.jetty.server.ServerConnector;
+import org.eclipse.jetty.servlet.ServletHandler;
+
+public class JettyServer {
+
+    private Server server;
+
+    public void start() throws Exception {
+
+        server = new Server();
+        ServerConnector connector = new ServerConnector(server);
+        connector.setPort(8090);
+        server.setConnectors(new Connector[]{connector});
+
+        ServletHandler servletHandler = new ServletHandler();
+        server.setHandler(servletHandler);
+
+        servletHandler.addServletWithMapping(BlockingServlet.class, "/status");
+        servletHandler.addServletWithMapping(AsyncServlet.class, "/heavy/async");
+
+        server.start();
+
+    }
+
+    public void stop() throws Exception {
+        server.stop();
+    }
+}

libraries/src/test/java/com/baeldung/jetty/JettyTest.java

@@ -0,0 +1,58 @@
+package com.baeldung.jetty;
+
+
+import org.apache.commons.io.IOUtils;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.HttpClientBuilder;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+import java.nio.charset.StandardCharsets;
+
+import static org.assertj.core.api.AssertionsForInterfaceTypes.assertThat;
+
+public class JettyTest {
+    private JettyServer jettyServer;
+
+    @Before
+    public void setup() throws Exception {
+        jettyServer = new JettyServer();
+        jettyServer.start();
+    }
+
+    @After
+    public void cleanup() throws Exception {
+        Thread.sleep(2000);
+        jettyServer.stop();
+    }
+
+    @Test
+    public void givenServer_whenSendRequestToBlockingServlet_thenReturnStatusOK() throws Exception {
+        //given
+        String url = "http://localhost:8090/status";
+        HttpClient client = HttpClientBuilder.create().build();
+        HttpGet request = new HttpGet(url);
+        HttpResponse response = client.execute(request);
+
+        //then
+        assertThat(response.getStatusLine().getStatusCode()).isEqualTo(200);
+
+    }
+
+    @Test
+    public void givenServer_whenSendRequestToNonBlockingServlet_thenReturnStatusOK() throws Exception {
+        //when
+        String url = "http://localhost:8090/heavy/async";
+        HttpClient client = HttpClientBuilder.create().build();
+        HttpGet request = new HttpGet(url);
+        HttpResponse response = client.execute(request);
+
+        //then
+        assertThat(response.getStatusLine().getStatusCode()).isEqualTo(200);
+        String responseContent = IOUtils.toString(response.getEntity().getContent(), StandardCharsets.UTF_8);
+        assertThat(responseContent).isEqualTo("This is some heavy resource that will be served in an async way");
+    }
+}