Initial commit

Author: anjmao

.gitignore

@@ -0,0 +1,2 @@
+netcore/bin
+netcore/obj

README.md

@@ -1 +1,50 @@
-# netcore-vs-golang
+# netcore-vs-golang
+
+Test http client, object serialize and deserialize times
+
+## Start containers
+`docker-compose up -e HOST=192.168.1.145`
+
+Note: change HOST to your local host IP
+
+### .net core api
+
+```
+wrk --connections 256 --duration 60s --threads 8 --timeout 5s --latency --script /Users/anma/go/src/github.com/anjmao/netcore-vs-golang/wrk/requests.lua http://localhost:5000
+Running 1m test @ http://localhost:5000
+  8 threads and 256 connections
+  Thread Stats   Avg      Stdev     Max   +/- Stdev
+    Latency   135.48ms   36.55ms 307.72ms   73.63%
+    Req/Sec   228.45     83.09   555.00     60.63%
+  Latency Distribution
+     50%  133.44ms
+     75%  156.51ms
+     90%  181.22ms
+     99%  229.40ms
+  109006 requests in 1.00m, 23.57MB read
+  Socket errors: connect 0, read 415, write 2, timeout 0
+  Non-2xx or 3xx responses: 6
+Requests/sec:   1815.36
+Transfer/sec:    401.99KB
+```
+
+### golang api
+
+```
+wrk --connections 256 --duration 60s --threads 8 --timeout 5s --latency --script /Users/anma/go/src/github.com/anjmao/netcore-vs-golang/wrk/requests.lua http://localhost:5001
+Running 1m test @ http://localhost:5001
+  8 threads and 256 connections
+  Thread Stats   Avg      Stdev     Max   +/- Stdev
+    Latency    82.78ms  135.06ms   1.76s    95.92%
+    Req/Sec   234.87    172.69     1.02k    72.98%
+  Latency Distribution
+     50%   54.63ms
+     75%   85.81ms
+     90%  134.80ms
+     99%  800.28ms
+  106498 requests in 1.00m, 19.37MB read
+  Socket errors: connect 0, read 32597, write 0, timeout 0
+Requests/sec:   1772.37
+Transfer/sec:    330.17KB
+```
+

api/Dockerfile

@@ -0,0 +1,8 @@
+FROM golang:1.8.3
+
+WORKDIR /go/src/app
+COPY . .
+
+RUN go-wrapper install 
+
+CMD ["go-wrapper", "run"]

api/Makefile

@@ -0,0 +1,7 @@
+build:
+	docker build -t api .
+
+run:
+	docker run  -it --rm \
+		-p 5002:5002 \
+		api

api/main.go

@@ -0,0 +1,41 @@
+package main
+
+import (
+	"encoding/json"
+	"fmt"
+	"log"
+	"math/rand"
+	"net/http"
+	"strconv"
+	"time"
+)
+
+type Response struct {
+	Id   string
+	Name string
+	Time int64
+}
+
+func main() {
+
+	http.HandleFunc("/data", func(w http.ResponseWriter, r *http.Request) {
+		rsp := Response{
+			Id:   "id_" + strconv.Itoa(rand.Int()),
+			Name: "name_" + strconv.Itoa(rand.Int()),
+			Time: time.Now().Unix(),
+		}
+
+		js, err := json.Marshal(rsp)
+		if err != nil {
+			http.Error(w, err.Error(), http.StatusInternalServerError)
+			return
+		}
+
+		w.Header().Set("Content-Type", "application/json")
+		w.Write(js)
+	})
+
+	addr := ":5002"
+	fmt.Println("listening on " + addr)
+	log.Fatal(http.ListenAndServe(addr, nil))
+}

docker-compose.yml

@@ -0,0 +1,25 @@
+version: '3'
+services:
+  api:
+    build: ./api
+    ports:
+     - "5002:5002"
+
+  go:
+    build: ./go
+    ports:
+     - "5001:5001"
+    environment:
+     - HOST=${HOST}
+    depends_on:
+     - api
+
+  netcore:
+    build: ./netcore
+    ports:
+     - "5000:5000"
+    environment:
+     - HOST=${HOST}
+    depends_on:
+     - api
+

go/Dockerfile

@@ -0,0 +1,8 @@
+FROM golang:1.8.3
+
+WORKDIR /go/src/app
+COPY . .
+
+RUN go-wrapper install 
+
+CMD ["go-wrapper", "run"]

go/Makefile

@@ -0,0 +1,11 @@
+# Update to your host
+DOCKER_HOST=192.168.1.145
+
+build:
+	docker build -t goapp .
+
+run:
+	docker run  -it --rm \
+		-e DOCKER_HOST=$(DOCKER_HOST) \
+		-p 5001:5001 \
+		goapp

go/main.go

@@ -0,0 +1,66 @@
+package main
+
+import (
+	"encoding/json"
+	"fmt"
+	"html"
+	"log"
+	"net/http"
+	"os"
+)
+
+type Response struct {
+	Id   string
+	Name string
+	Time int64
+}
+
+func main() {
+	url := "http://" + os.Getenv("HOST") + ":5002/data"
+	tr := &http.Transport{
+		MaxIdleConns:        2000,
+		MaxIdleConnsPerHost: 2000,
+	}
+	client := &http.Client{Transport: tr}
+
+	http.HandleFunc("/test", func(w http.ResponseWriter, r *http.Request) {
+		rsp, err := client.Get(url)
+		if err != nil {
+			serverError(w, err.Error())
+			return
+		}
+
+		rsp.Close = true
+		defer rsp.Body.Close()
+
+		// deserialize
+		obj := Response{}
+		err = json.NewDecoder(rsp.Body).Decode(&obj)
+		if err != nil {
+			serverError(w, err.Error())
+			return
+		}
+
+		// serialize
+		jsonStr, err := json.Marshal(&obj)
+		if err != nil {
+			serverError(w, err.Error())
+			return
+		}
+
+		w.Header().Set("Content-Type", "application/json")
+		w.Write(jsonStr)
+	})
+
+	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
+		fmt.Fprintf(w, "Hello, %q", html.EscapeString(r.URL.Path))
+	})
+
+	addr := ":5001"
+	fmt.Println("listening on " + addr)
+	log.Fatal(http.ListenAndServe(addr, nil))
+}
+
+func serverError(w http.ResponseWriter, msg string) {
+	http.Error(w, msg, http.StatusInternalServerError)
+}

netcore/Dockerfile

@@ -0,0 +1,12 @@
+FROM microsoft/dotnet:2.0.0-preview2-sdk
+
+WORKDIR /dotnetapp
+
+# copy project.json and restore as distinct layers
+COPY netcore.csproj .
+RUN dotnet restore
+
+# copy and build everything else
+COPY . .
+RUN dotnet publish -c Release -o out
+ENTRYPOINT ["dotnet", "out/netcore.dll"]

netcore/Makefile

@@ -0,0 +1,8 @@
+
+build:
+	docker build -t netcore .
+
+run:
+	docker run  -it --rm \
+		-p 5000:5000 \
+		netcore

netcore/Program.cs

@@ -0,0 +1,72 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Net.Http;
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+using Newtonsoft.Json;
+
+class Program
+{
+    public static void Main(string[] args)
+    {
+        BuildWebHost(args).Run();
+    }
+
+    public static IWebHost BuildWebHost(string[] args) =>
+        WebHost.CreateDefaultBuilder(args)
+            .UseStartup<Startup>()
+            .UseUrls("http://*:5000")
+            .Build();
+}
+class Response
+{
+    public string Id { get; set; }
+    public string Name { get; set; }
+    public long Time { get; set; }
+}
+
+class Startup
+{
+    private static readonly HttpClient _http = new HttpClient
+    {
+        BaseAddress = new Uri($"http://{Environment.GetEnvironmentVariable("HOST")}:5002")
+    };
+
+    private static Random _random = new Random();
+
+    private static void HandleTest(IApplicationBuilder app)
+    {
+        app.Run(async ctx =>
+        {
+            var rsp = await _http.GetAsync("/data");
+            var str = await rsp.Content.ReadAsStringAsync();
+
+            // deserialize
+            var obj = JsonConvert.DeserializeObject<Response>(str);
+
+            // serialize
+            var json = JsonConvert.SerializeObject(obj);
+            
+            ctx.Response.ContentType = "application/json";
+            await ctx.Response.WriteAsync(json);
+        });
+    }
+
+    public void Configure(IApplicationBuilder app)
+    {
+        app.Map("/test", HandleTest);
+
+        app.Run(async ctx =>
+        {
+            await ctx.Response.WriteAsync($"Hello, {ctx.Request.Path}");
+        });
+    }
+}

netcore/netcore.csproj

@@ -0,0 +1,17 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>netcoreapp2.0</TargetFramework>
+  </PropertyGroup>
+
+    <ItemGroup>
+    <PackageReference Include="Microsoft.AspNetCore.All" Version="2.0.0-preview2-final" />
+    <PackageReference Include="Newtonsoft.Json" Version="10.0.2" />
+  </ItemGroup>
+
+   <ItemGroup>
+    <DotNetCliToolReference Include="Microsoft.VisualStudio.Web.CodeGeneration.Tools" Version="2.0.0-preview2-final" />
+  </ItemGroup>
+
+</Project>

wrk/Makefile

@@ -0,0 +1,13 @@
+URL?=http://localhost:5000
+
+WRK=wrk --connections 256 \
+	--duration 60s \
+	--threads 8 \
+	--timeout 5s \
+	--latency \
+	--script \
+	$(shell pwd)/requests.lua \
+	$(URL)
+
+run:
+	$(WRK)

wrk/requests.lua

@@ -0,0 +1,26 @@
+math.randomseed(os.time())
+
+
+function generate_query()
+    local query = {}
+
+    seq = math.random(100000, 200000)
+
+    query["fn"] = string.format("Firstname_%s", seq)
+    query["ln"] = string.format("Lastname_%s", seq)
+    query["rn"] = string.format("ref_%s", seq)
+
+    local keyvals = {}
+
+    for key, val in pairs(query) do
+        table.insert(keyvals, string.format("%s=%s", key, val))
+    end
+
+    return string.format("/test?%s", table.concat(keyvals, "&"))
+end
+
+
+request = function()
+   local path = generate_query()
+   return wrk.format(nil, path)
+end