Added a benchmark for the Rapidoid project.

frameworks/Java/rapidoid/README.md

@@ -0,0 +1,3 @@
+# Rapidoid Benchmarking Test
+
+This is the Rapidoid portion of a [benchmarking test suite](../) comparing a variety of web development platforms.

frameworks/Java/rapidoid/benchmark_config.json

@@ -0,0 +1,24 @@
+{
+  "framework": "rapidoid",
+  "tests": [{
+    "default": {
+      "setup_file": "setup",
+      "json_url": "/json",
+      "plaintext_url": "/plaintext",
+      "port": 8080,
+      "approach": "Realistic",
+      "classification": "Platform",
+      "database": "None",
+      "framework": "rapidoid",
+      "language": "Java",
+      "orm": "Raw",
+      "platform": "Rapidoid",
+      "webserver": "None",
+      "os": "Linux",
+      "database_os": "Linux",
+      "display_name": "rapidoid",
+      "notes": "",
+      "versus": "rapidoid"
+    }
+  }]
+}

frameworks/Java/rapidoid/install.sh

@@ -0,0 +1,3 @@
+#!/bin/bash
+
+fw_depends java7 maven

frameworks/Java/rapidoid/pom.xml

@@ -0,0 +1,66 @@
+<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/maven-v4_0_0.xsd">
+
+	<modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.techempower</groupId>
+    <artifactId>rapidoid</artifactId>
+    <version>1.0</version>
+	<packaging>jar</packaging>
+	
+     <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+    
+    <dependencies>
+        <dependency>
+            <groupId>org.rapidoid</groupId>
+            <artifactId>rapidoid-http</artifactId>
+            <version>3.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.rapidoid</groupId>
+            <artifactId>rapidoid-json</artifactId>
+            <version>3.0.0</version>
+        </dependency>
+    </dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<inherited>true</inherited>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<version>2.3.2</version>
+				<configuration>
+					<source>1.7</source>
+					<target>1.7</target>
+					<optimize>true</optimize>
+					<debug>false</debug>
+				</configuration>
+			</plugin>
+			<plugin>
+				<artifactId>maven-assembly-plugin</artifactId>
+				<configuration>
+					<archive>
+						<manifest>
+							<mainClass>hello.HelloWebServer</mainClass>
+						</manifest>
+					</archive>
+					<descriptorRefs>
+						<descriptorRef>jar-with-dependencies</descriptorRef>
+					</descriptorRefs>
+				</configuration>
+				<executions>
+					<execution>
+						<id>make-assembly</id> <!-- this is used for inheritance merges -->
+						<phase>package</phase> <!-- bind to the packaging phase -->
+						<goals>
+							<goal>single</goal>
+						</goals>
+					</execution>
+				</executions>
+			</plugin>
+		</plugins>
+	</build>
+</project>

frameworks/Java/rapidoid/setup.sh

@@ -0,0 +1,9 @@
+#!/bin/bash
+
+# load java environment variables
+source $IROOT/java7.installed
+
+mvn clean compile assembly:single
+
+cd target
+java -server -XX:+UseNUMA -XX:+UseParallelGC -XX:+AggressiveOpts -jar rapidoid-1.0-jar-with-dependencies.jar &

frameworks/Java/rapidoid/source_code

@@ -0,0 +1,7 @@
+./rapidoid/src/
+./rapidoid/src/main
+./rapidoid/src/main/java
+./rapidoid/src/main/java/hello
+./rapidoid/src/main/java/hello/HelloWebServer.java
+./rapidoid/src/main/java/hello/SimpleHttpProtocol.java
+./rapidoid/src/main/java/hello/Message.java

frameworks/Java/rapidoid/src/main/java/hello/HelloWebServer.java

@@ -0,0 +1,12 @@
+package hello;
+
+import org.rapidoid.net.Serve;
+
+public class HelloWebServer {
+
+	public static void main(String[] args) throws Exception {
+		int port = args.length > 0 ? Integer.parseInt(args[0]) : 8080;
+		Serve.server().protocol(new SimpleHttpProtocol()).port(port).build().start();
+	}
+
+}

frameworks/Java/rapidoid/src/main/java/hello/Message.java

@@ -0,0 +1,15 @@
+package hello;
+
+public class Message {
+
+	private final String message;
+
+	public Message(String message) {
+		this.message = message;
+	}
+
+	public String getMessage() {
+		return message;
+	}
+
+}

frameworks/Java/rapidoid/src/main/java/hello/SimpleHttpProtocol.java

@@ -0,0 +1,162 @@
+package hello;
+
+/*
+ * #%L
+ * rapidoid-demo
+ * %%
+ * Copyright (C) 2014 - 2015 Nikolche Mihajlovski
+ * %%
+ * 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.
+ * #L%
+ */
+
+import org.rapidoid.buffer.Buf;
+import org.rapidoid.bytes.BytesUtil;
+import org.rapidoid.data.Range;
+import org.rapidoid.data.Ranges;
+import org.rapidoid.http.HttpParser;
+import org.rapidoid.net.Protocol;
+import org.rapidoid.net.abstracts.Channel;
+import org.rapidoid.net.impl.RapidoidHelper;
+import org.rapidoid.util.Dates;
+import org.rapidoid.wrap.BoolWrap;
+
+public class SimpleHttpProtocol implements Protocol {
+
+	private static final byte[] HTTP_200_OK = "HTTP/1.1 200 OK\r\n".getBytes();
+
+	private static final byte[] HTTP_404_NOT_FOUND = "HTTP/1.1 404 Not Found\r\nContent-Length: 10\r\n\r\nNot found!"
+			.getBytes();
+
+	private static final byte[] CONN_KEEP_ALIVE = "Connection: keep-alive\r\n"
+			.getBytes();
+
+	private static final byte[] CONN_CLOSE = "Connection: close\r\n".getBytes();
+
+	private static final byte[] SERVER_X = "Server: X\r\n".getBytes();
+
+	private static final byte[] CONTENT_LENGTH_HDR = "Content-Length: "
+			.getBytes();
+
+	private static final byte[] CONTENT_TYPE_PLAIN = "Content-Type: text/plain; charset=UTF-8\r\n"
+			.getBytes();
+
+	private static final byte[] CONTENT_TYPE_JSON = "Content-Type: application/json; charset=UTF-8\r\n"
+			.getBytes();
+
+	private static final byte[] CONTENT_LENGTH = "Content-Length:           "
+			.getBytes();
+
+	private static final byte[] RESPONSE = "Hello, World!".getBytes();
+
+	private static final byte[] DATE_HDR = "Date: ".getBytes();
+
+	private static final byte[] RESPONSE_LENGTH = String.valueOf(
+			RESPONSE.length).getBytes();
+
+	private static final byte[] URI_PLAIN = "/plaintext".getBytes();
+
+	private static final byte[] URI_JSON = "/json".getBytes();
+
+	private static final HttpParser HTTP_PARSER = new HttpParser();
+
+	public void process(Channel ctx) {
+		if (ctx.isInitial()) {
+			return;
+		}
+
+		Buf buf = ctx.input();
+		RapidoidHelper helper = ctx.helper();
+
+		Range[] ranges = helper.ranges1.ranges;
+		Ranges headers = helper.ranges2;
+
+		BoolWrap isGet = helper.booleans[0];
+		BoolWrap isKeepAlive = helper.booleans[1];
+
+		Range verb = ranges[ranges.length - 1];
+		Range uri = ranges[ranges.length - 2];
+		Range path = ranges[ranges.length - 3];
+		Range query = ranges[ranges.length - 4];
+		Range protocol = ranges[ranges.length - 5];
+		Range body = ranges[ranges.length - 6];
+
+		HTTP_PARSER.parse(buf, isGet, isKeepAlive, body, verb, uri, path,
+				query, protocol, headers, helper);
+
+		response(ctx, buf, path, isGet.value, isKeepAlive.value);
+	}
+
+	private void response(Channel ctx, Buf buf, Range path, boolean isGet,
+			boolean isKeepAlive) {
+		boolean processed = false;
+
+		if (isGet) {
+
+			ctx.write(HTTP_200_OK);
+
+			ctx.write(isKeepAlive ? CONN_KEEP_ALIVE : CONN_CLOSE);
+
+			ctx.write(SERVER_X);
+
+			ctx.write(DATE_HDR);
+			ctx.write(Dates.getDateTimeBytes());
+			ctx.write(CR_LF);
+
+			if (BytesUtil.matches(buf.bytes(), path, URI_PLAIN, true)
+					|| path.length == 1) {
+				handlePlaintext(ctx);
+				processed = true;
+			} else if (BytesUtil.matches(buf.bytes(), path, URI_JSON, true)) {
+				handleJson(ctx);
+				processed = true;
+			}
+
+			ctx.closeIf(!isKeepAlive);
+		}
+
+		if (!processed) {
+			ctx.write(HTTP_404_NOT_FOUND);
+			ctx.close();
+		}
+	}
+
+	private void handlePlaintext(Channel ctx) {
+		ctx.write(CONTENT_LENGTH_HDR);
+		ctx.write(RESPONSE_LENGTH);
+		ctx.write(CR_LF);
+
+		ctx.write(CONTENT_TYPE_PLAIN);
+		ctx.write(CR_LF);
+		ctx.write(RESPONSE);
+	}
+
+	private void handleJson(Channel ctx) {
+		Buf output = ctx.output();
+
+		ctx.write(CONTENT_TYPE_JSON);
+		ctx.write(CONTENT_LENGTH);
+
+		int posConLen = output.size() - 10;
+		ctx.write(CR_LF);
+		ctx.write(CR_LF);
+
+		int posBefore = output.size();
+
+		ctx.writeJSON(new Message("Hello, World!"));
+
+		int posAfter = output.size();
+		output.putNumAsText(posConLen, posAfter - posBefore, false);
+	}
+
+}