Add golang http implementation

Dockerfile

@@ -10,6 +10,8 @@ ENV WORKON_HOME /usr/local/python-venvs
 ENV GOMAXPROCS 1
 
 RUN mkdir -p /usr/local/python-venvs
+RUN mkdir -p /usr/go/
+ENV GOPATH /usr/go/
 
 RUN DEBIAN_FRONTEND=noninteractive \
         apt-get update && apt-get install -y \
@@ -21,7 +23,8 @@ RUN vex --python=python3.5 -m bench pip install -U pip
 RUN mkdir -p /var/lib/cache/pip
 
 ADD servers /usr/src/servers
-RUN cd /usr/src/servers && go build goecho.go
+RUN cd /usr/src/servers && go build goecho.go && \
+        go get github.com/golang/groupcache/lru && go build gohttp.go
 RUN vex bench pip --cache-dir=/var/lib/cache/pip \
         install -r /usr/src/servers/requirements.txt
 

run_benchmarks

@@ -181,6 +181,12 @@ benchmarks = [{
     'server': nodejs + ['/usr/src/servers/nodejs_http_server.js'],
     'server_address': tcp_address,
     'client': http_client,
+}, {
+    'name': 'http-golang',
+    'title': 'HTTP server (golang)',
+    'server': ['/usr/src/servers/gohttp'],
+    'server_address': tcp_address,
+    'client': http_client,
 }]
 
 

servers/.gitignore

 /goecho
+/gohttp

servers/asyncio_http_server.py

@@ -13,6 +13,7 @@ from socket import *
 
 PRINT = 0
 
+_RESP_CACHE = {}
 
 class HttpRequest:
     __slots__ = ('_protocol', '_url', '_headers', '_version')
@@ -99,7 +100,11 @@ class HttpProtocol(asyncio.Protocol):
             payload_size = 1024
         else:
             payload_size = int(payload_size)
-        response.write(b'X' * payload_size)
+        resp = _RESP_CACHE.get(payload_size)
+        if resp is None:
+            resp = b'X' * payload_size
+            _RESP_CACHE[payload_size] = resp
+        response.write(resp)
         self._current_parser = None
         self._current_request = None
 
@@ -112,7 +117,12 @@ def abort(msg):
 def aiohttp_server(loop, addr):
     async def handle(request):
         payload_size = int(request.match_info.get('size', 1024))
-        return web.Response(body=b'X' * payload_size)
+        resp = _RESP_CACHE.get(payload_size)
+        if resp is None:
+            resp = b'X' * payload_size
+            _RESP_CACHE[payload_size] = resp
+        response.write(resp)
+        return web.Response(body=resp)
 
     app = web.Application(loop=loop)
     app.router.add_route('GET', '/{size}', handle)

servers/gohttp.go

+package main
+
+import (
+    "fmt"
+    "net/http"
+    "strconv"
+    "strings"
+
+    "github.com/golang/groupcache/lru"
+)
+
+var cache *lru.Cache
+
+func handler(w http.ResponseWriter, r *http.Request) {
+    var resp string
+
+    respSize := r.URL.Path[1:]
+    s, err := strconv.Atoi(respSize)
+    if err != nil {
+        s = 1024
+    }
+
+    val, ok := cache.Get(s)
+    if ok {
+        resp = val.(string)
+    } else {
+        resp = strings.Repeat("X", s)
+        cache.Add(s, resp)
+    }
+
+    fmt.Fprintf(w, resp)
+}
+
+func main() {
+    cache = lru.New(10)
+    http.HandleFunc("/", handler)
+    fmt.Println("Serving on :25000")
+    http.ListenAndServe(":25000", nil)
+}