Adding a perf optimized helloworld example

rx-netty-examples/README.md

@@ -9,6 +9,7 @@ Examples Catalog
 
 Protocol | Example / Test | Description
 ---------|---------|------------
+HTTP | [Plain text](src/main/java/io/reactivex/netty/examples/http/plaintext)              | A performance optimized helloworld. Use this as a template for any simple perf tests.
 HTTP | [Hello World](src/main/java/io/reactivex/netty/examples/http/helloworld)            | Simple HTTP GET client/server implementation.
 HTTP | [SSL Hello World](src/main/java/io/reactivex/netty/examples/http/ssl)               | Hello World version with SSL connection.
 HTTP | [Simple POST](src/main/java/io/reactivex/netty/examples/http/post)                  | Simple HTTP POST client/server implementation.

rx-netty-examples/build.gradle

@@ -16,6 +16,8 @@
 
 
 
+
+
 sourceCompatibility = JavaVersion.VERSION_1_6
 targetCompatibility = JavaVersion.VERSION_1_6
 
@@ -45,6 +47,23 @@ task runHelloWorldServer (dependsOn: [classes], type: JavaExec) {
     classpath = sourceSets.main.runtimeClasspath
 }
 
+task runPlainTextServer (dependsOn: [classes], type: JavaExec) {
+    group = "Examples"
+    description = "Run Plain text HTTP server"
+
+    main = "io.reactivex.netty.examples.http.plaintext.PlainTextServer"
+    classpath = sourceSets.main.runtimeClasspath
+}
+
+task runPlainTextClient (dependsOn: [classes], type: JavaExec) {
+    group = "Examples"
+    description = "Run Plain text HTTP client"
+
+    args "8111"
+    main = "io.reactivex.netty.examples.http.helloworld.HelloWorldClient"
+    classpath = sourceSets.main.runtimeClasspath
+}
+
 task runSslHelloWorldClient (dependsOn: [classes], type: JavaExec) {
     group = "Examples"
     description = "Run SSL Hello World client"

rx-netty-examples/src/main/java/io/reactivex/netty/examples/http/helloworld/HelloWorldClient.java

@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.reactivex.netty.examples.http.helloworld;
 
 import io.netty.buffer.ByteBuf;
@@ -76,6 +77,10 @@ public void printResponseHeader(HttpClientResponse<ByteBuf> response) {
     }
 
     public static void main(String[] args) {
-        new HelloWorldClient(DEFAULT_PORT).sendHelloRequest();
+        int port = DEFAULT_PORT;
+        if (args.length > 0) {
+            port = Integer.parseInt(args[0]);
+        }
+        new HelloWorldClient(port).sendHelloRequest();
     }
 }

rx-netty-examples/src/main/java/io/reactivex/netty/examples/http/plaintext/PlainTextServer.java

@@ -0,0 +1,71 @@
+/*
+ * Copyright 2014 Netflix, Inc.
+ *
+ * Licensed 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 io.reactivex.netty.examples.http.plaintext;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.handler.codec.http.HttpHeaders;
+import io.reactivex.netty.RxNetty;
+import io.reactivex.netty.protocol.http.server.HttpServer;
+import io.reactivex.netty.protocol.http.server.HttpServerRequest;
+import io.reactivex.netty.protocol.http.server.HttpServerResponse;
+import io.reactivex.netty.protocol.http.server.RequestHandler;
+import rx.Observable;
+
+/**
+ * @author Nitesh Kant
+ */
+public final class PlainTextServer {
+
+    static final int DEFAULT_PORT = 8111;
+    public static final String WELCOME_MSG = "Welcome!!";
+    private static final byte[] WELCOME_MSG_BYTES = WELCOME_MSG.getBytes();
+    private static final String CONTENT_LENGTH_HEADER_VAL = String.valueOf(WELCOME_MSG_BYTES.length); // Does not use int as this omits conversion to string for every response.
+
+    private final int port;
+
+    public PlainTextServer(int port) {
+        this.port = port;
+    }
+
+    public HttpServer<ByteBuf, ByteBuf> createServer() {
+        HttpServer<ByteBuf, ByteBuf> server =
+                RxNetty.createHttpServer(port,
+                                         new RequestHandler<ByteBuf, ByteBuf>() {
+                                             @Override
+                                             public Observable<Void> handle(HttpServerRequest<ByteBuf> request,
+                                                                            final HttpServerResponse<ByteBuf> response) {
+                                                 response.getHeaders().set(HttpHeaders.Names.CONTENT_LENGTH,
+                                                                           CONTENT_LENGTH_HEADER_VAL); // This makes RxNetty write a single Full response as opposed to writing header, content & lastHttpContent.
+                                                 ByteBuf content = response.getAllocator()
+                                                                           .buffer(WELCOME_MSG_BYTES.length)
+                                                                           .writeBytes(WELCOME_MSG_BYTES);
+                                                 response.write(content);
+                                                 return response.close(
+                                                         false); // Let RxNetty take care of flushing appropriately. Do NOT use when processing in a different thread.
+                                             }
+                                         });
+
+        return server;
+    }
+
+    public static void main(final String[] args) throws InterruptedException {
+        HttpServer<ByteBuf, ByteBuf> server = new PlainTextServer(DEFAULT_PORT).createServer();
+        server.start();
+        System.out.println("HTTP plain text server started at port: " + server.getServerPort());
+        server.waitTillShutdown();
+    }
+}

rx-netty-examples/src/main/java/io/reactivex/netty/examples/http/plaintext/README.md

@@ -0,0 +1,27 @@
+Overview
+========
+
+This example is intended to be a sample used for "helloworld" performance tests for RxNetty and has optimizations specific
+for helloworld kind of tests.
+
+The following are the primary differences over the [HelloWorld example](../helloworld) 
+
+- This example does NOT aggregate HTTP requests.
+- This example does NOT print the request headers.
+
+Running
+=======
+
+To run the example execute:
+
+```
+$ cd RxNetty/rx-netty-examples
+$ ../gradlew runPlainTextServer
+```
+
+and in another console:
+
+```
+$ cd RxNetty/rx-netty-examples
+$ ../gradlew runPlainTextClient
+```

rx-netty-examples/src/test/java/io/reactivex/netty/examples/http/plaintext/PlainTextServerTest.java

@@ -0,0 +1,55 @@
+/*
+ * Copyright 2014 Netflix, Inc.
+ *
+ * Licensed 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 io.reactivex.netty.examples.http.plaintext;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.handler.codec.http.HttpResponseStatus;
+import io.reactivex.netty.examples.ExamplesEnvironment;
+import io.reactivex.netty.examples.http.helloworld.HelloWorldClient;
+import io.reactivex.netty.protocol.http.server.HttpServer;
+import org.junit.After;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+
+import static io.reactivex.netty.examples.http.plaintext.PlainTextServer.DEFAULT_PORT;
+
+/**
+ * @author Tomasz Bak
+ */
+public class PlainTextServerTest extends ExamplesEnvironment {
+
+    private HttpServer<ByteBuf, ByteBuf> server;
+
+    @Before
+    public void setupHttpHelloServer() {
+        server = new PlainTextServer(DEFAULT_PORT).createServer();
+        server.start();
+    }
+
+    @After
+    public void stopServer() throws InterruptedException {
+        server.shutdown();
+    }
+
+    @Test
+    public void testRequestReplySequence() {
+        HelloWorldClient client = new HelloWorldClient(DEFAULT_PORT); // The client is no different than hello world.
+        HttpResponseStatus statusCode = client.sendHelloRequest();
+        Assert.assertEquals(HttpResponseStatus.OK, statusCode);
+    }
+}