Skip to content

Instantly share code, notes, and snippets.

@muratsplat

muratsplat/post.go

Created February 25, 2016 21:12
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save muratsplat/88a283614a00c9ffe1b0 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save muratsplat/88a283614a00c9ffe1b0 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. muratsplat created this gist Feb 25, 2016.
    65 changes: 65 additions & 0 deletions post.go
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,65 @@
    package main

    import (
    "fmt"
    "log"
    "net/http"
    "strings"
    "time"
    )

    var numberOfPost int32 = 0
    var runtimes int = 1020

    var failed int = 0
    var success int = 0

    func main() {

    respChan := make(chan int)

    for i := 0; i < runtimes; i++ {
    go Post(i, respChan)
    }

    go func() {
    for {
    statusCode := <-respChan
    if statusCode == int(200) {
    success++
    } else {
    failed++
    }

    log.Println("Success: ", success)
    log.Println("Failed: ", failed)
    }
    }()

    select {}
    }

    func Post(msg int, respCh chan int) {

    json := `{"no":"%d"}`

    reader := strings.NewReader(fmt.Sprintf(json, msg))

    client := &http.Client{}
    client.Timeout = 60 * time.Second

    req, err := http.NewRequest("POST", "http://localhost:8000/post", reader)
    req.Header.Add("Content-type", "application/json")

    if err != nil {
    panic(err)
    }

    resp, err := client.Do(req)

    if err != nil {
    panic(err)
    }
    respCh <- resp.StatusCode
    defer resp.Body.Close()
    }
    31 changes: 31 additions & 0 deletions srv.go
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,31 @@
    package main

    import (
    "io/ioutil"
    "log"
    "net/http"
    "time"
    )

    var numberOfRequest = 0

    func main() {
    http.HandleFunc("/post", Index)

    http.ListenAndServe("localhost:8000", nil)
    }

    func Index(w http.ResponseWriter, r *http.Request) {

    rBody, err := ioutil.ReadAll(r.Body)

    if err != nil {
    panic(err)
    }

    time.Sleep(time.Second * 4)
    log.Println(string(rBody))
    numberOfRequest++
    log.Println(numberOfRequest)
    defer r.Body.Close()
    }