WIP(x/http/client): net/http/client

go.mod

@@ -2,4 +2,9 @@ module github.com/goplus/llgoexamples
 
 go 1.20
 
-require github.com/goplus/llgo v0.9.3-0.20240726020431-98d075728f2b
+require (
+	github.com/goplus/llgo v0.9.8-0.20240919105235-c6436ea6d196
+	golang.org/x/net v0.28.0
+)
+
+require golang.org/x/text v0.17.0 // indirect

go.sum

@@ -1,8 +1,6 @@
-github.com/goplus/llgo v0.9.0 h1:yaJzQperGUafEaHc9VlVQVskIngacoTNweEXY0GRi0Q=
-github.com/goplus/llgo v0.9.0/go.mod h1:M3UwiYdPZFyx7m2J0+6Ti1dYVA3uOO1WvSBocuE8N7M=
-github.com/goplus/llgo v0.9.1-0.20240709104849-d6a38a567fda h1:UIPwlgzCb8dV/7WFMyprhZuq8CSLAQIqwFpH5AhrNOM=
-github.com/goplus/llgo v0.9.1-0.20240709104849-d6a38a567fda/go.mod h1:zsrtWZapL4aklZc99xBSZRynGzLTIT1mLRjP0VSn9iw=
-github.com/goplus/llgo v0.9.1-0.20240712060421-858d38d314a3 h1:2fZ2zQ8S58KvOsJTx6s6MHoi6n1K4sqQwIbTauMrgEE=
-github.com/goplus/llgo v0.9.1-0.20240712060421-858d38d314a3/go.mod h1:zsrtWZapL4aklZc99xBSZRynGzLTIT1mLRjP0VSn9iw=
-github.com/goplus/llgo v0.9.3-0.20240726020431-98d075728f2b h1:z9FUoeAALL5ytBhhGhE1dXm4+L1Q2eMUTcfiqLAZgf8=
-github.com/goplus/llgo v0.9.3-0.20240726020431-98d075728f2b/go.mod h1:zsrtWZapL4aklZc99xBSZRynGzLTIT1mLRjP0VSn9iw=
+github.com/goplus/llgo v0.9.8-0.20240919105235-c6436ea6d196 h1:LckJktvgChf3x0eex+GT//JkYRj1uiT4uMLzyrg3ChU=
+github.com/goplus/llgo v0.9.8-0.20240919105235-c6436ea6d196/go.mod h1:5Fs+08NslqofJ7xtOiIXugkurYOoQvY02ZkFNWA1uEI=
+golang.org/x/net v0.28.0 h1:a9JDOJc5GMUJ0+UDqmLT86WiEy7iWyIhz8gz8E4e5hE=
+golang.org/x/net v0.28.0/go.mod h1:yqtgsTWOOnlGLG9GFRrK3++bGOUEkNBoHZc8MEDWPNg=
+golang.org/x/text v0.17.0 h1:XtiM5bkSOt+ewxlOE/aE/AKEHibwj/6gvWMl9Rsh0Qc=
+golang.org/x/text v0.17.0/go.mod h1:BuEKDfySbSR4drPmRPG/7iBdf8hvFMuRexcpahXilzY=

x/net/http/_demo/chunked/chunked.go

@@ -0,0 +1,29 @@
+package main
+
+import (
+	"fmt"
+	"io"
+
+	"github.com/goplus/llgoexamples/x/net/http"
+)
+
+func main() {
+	resp, err := http.Get("http://localhost:8080/chunked")
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	defer resp.Body.Close()
+	fmt.Println(resp.Status, "read bytes: ", resp.ContentLength)
+	for key, values := range resp.Header {
+		for _, value := range values {
+			fmt.Printf("%s: %s\n", key, value)
+		}
+	}
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(string(body))
+}

x/net/http/_demo/get/get.go

@@ -0,0 +1,29 @@
+package main
+
+import (
+	"fmt"
+	"io"
+
+	"github.com/goplus/llgoexamples/x/net/http"
+)
+
+func main() {
+	resp, err := http.Get("https://www.baidu.com")
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	defer resp.Body.Close()
+	fmt.Println(resp.Status, "read bytes: ", resp.ContentLength)
+	for key, values := range resp.Header {
+		for _, value := range values {
+			fmt.Printf("%s: %s\n", key, value)
+		}
+	}
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(string(body))
+}

x/net/http/_demo/headers/headers.go

@@ -0,0 +1,52 @@
+package main
+
+import (
+	"fmt"
+	"io"
+
+	"github.com/goplus/llgoexamples/x/net/http"
+)
+
+func main() {
+	client := &http.Client{}
+	req, err := http.NewRequest("GET", "https://www.baidu.com", nil)
+	if err != nil {
+		println(err.Error())
+		return
+	}
+
+	//req.Header.Set("accept", "*/*")
+	req.Header.Set("accept-encoding", "gzip")
+	//req.Header.Set("cache-control", "no-cache")
+	//req.Header.Set("pragma", "no-cache")
+	//req.Header.Set("priority", "u=0, i")
+	//req.Header.Set("referer", "https://jsonplaceholder.typicode.com/")
+	//req.Header.Set("sec-ch-ua", "\"Not)A;Brand\";v=\"99\", \"Google Chrome\";v=\"127\", \"Chromium\";v=\"127\"")
+	//req.Header.Set("sec-ch-ua-mobile", "?0")
+	//req.Header.Set("sec-ch-ua-platform", "\"macOS\"")
+	//req.Header.Set("sec-fetch-dest", "document")
+	//req.Header.Set("sec-fetch-mode", "navigate")
+	//req.Header.Set("sec-fetch-site", "same-origin")
+	//req.Header.Set("sec-fetch-user", "?1")
+	////req.Header.Set("upgrade-insecure-requests", "1")
+	//req.Header.Set("user-agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/127.0.0.0 Safari/537.36")
+
+	resp, err := client.Do(req)
+	if err != nil {
+		println(err.Error())
+		return
+	}
+	defer resp.Body.Close()
+	fmt.Println(resp.Status)
+	for key, values := range resp.Header {
+		for _, value := range values {
+			fmt.Printf("%s: %s\n", key, value)
+		}
+	}
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		println(err.Error())
+		return
+	}
+	fmt.Println(string(body))
+}

x/net/http/_demo/maxConnsPerHost/maxConnsPerHost.go

@@ -0,0 +1,36 @@
+package main
+
+import (
+	"fmt"
+	"io"
+
+	"github.com/goplus/llgoexamples/x/net/http"
+)
+
+func main() {
+	client := &http.Client{
+		Transport: &http.Transport{
+			MaxConnsPerHost: 2,
+		},
+	}
+	req, err := http.NewRequest("GET", "https://www.baidu.com", nil)
+	resp, err := client.Do(req)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	defer resp.Body.Close()
+	fmt.Println(resp.Status, "read bytes: ", resp.ContentLength)
+	fmt.Println(resp.Proto)
+	for key, values := range resp.Header {
+		for _, value := range values {
+			fmt.Printf("%s: %s\n", key, value)
+		}
+	}
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(string(body))
+}

x/net/http/_demo/parallelRequest/parallelRequest.go

@@ -0,0 +1,43 @@
+package main
+
+import (
+	"fmt"
+	"sync"
+
+	"github.com/goplus/llgoexamples/x/net/http"
+)
+
+func worker(id int, wg *sync.WaitGroup) {
+	defer wg.Done()
+	resp, err := http.Get("http://www.baidu.com")
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(id, ":", resp.Status)
+	//body, err := io.ReadAll(resp.Body)
+	//if err != nil {
+	//	fmt.Println(err)
+	//	return
+	//}
+	//fmt.Println(string(body))
+	resp.Body.Close()
+}
+
+func main() {
+	var wait sync.WaitGroup
+	for i := 0; i < 500; i++ {
+		wait.Add(1)
+		go worker(i, &wait)
+	}
+	wait.Wait()
+	fmt.Println("All done")
+
+	resp, err := http.Get("http://www.baidu.com")
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(resp.Status)
+	resp.Body.Close()
+}

x/net/http/_demo/post/post.go

@@ -0,0 +1,31 @@
+package main
+
+import (
+	"bytes"
+	"fmt"
+	"io"
+
+	"github.com/goplus/llgoexamples/x/net/http"
+)
+
+func main() {
+	data := []byte(`{"id":1,"title":"foo","body":"bar","userId":"1"}`)
+	resp, err := http.Post("https://jsonplaceholder.typicode.com/posts", "application/json; charset=UTF-8", bytes.NewBuffer(data))
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	defer resp.Body.Close()
+	fmt.Println(resp.Status)
+	for key, values := range resp.Header {
+		for _, value := range values {
+			fmt.Printf("%s: %s\n", key, value)
+		}
+	}
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(string(body))
+}

x/net/http/_demo/postform/postform.go

@@ -0,0 +1,29 @@
+package main
+
+import (
+	"fmt"
+	"io"
+	"net/url"
+
+	"github.com/goplus/llgoexamples/x/net/http"
+)
+
+func main() {
+	formData := url.Values{
+		"name":  {"John Doe"},
+		"email": {"johndoe@example.com"},
+	}
+
+	resp, err := http.PostForm("http://httpbin.org/post", formData)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	defer resp.Body.Close()
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(string(body))
+}

x/net/http/_demo/redirect/redirect.go

@@ -0,0 +1,30 @@
+package main
+
+import (
+	"fmt"
+	"io"
+
+	"github.com/goplus/llgoexamples/x/net/http"
+)
+
+func main() {
+	resp, err := http.Get("http://localhost:8080") // Start "../server/redirectServer.go" before running
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	defer resp.Body.Close()
+	fmt.Println(resp.Status, "read bytes: ", resp.ContentLength)
+	fmt.Println(resp.Proto)
+	for key, values := range resp.Header {
+		for _, value := range values {
+			fmt.Printf("%s: %s\n", key, value)
+		}
+	}
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(string(body))
+}

x/net/http/_demo/reuseConn/reuseConn.go

@@ -0,0 +1,50 @@
+package main
+
+import (
+	"fmt"
+	"io"
+
+	"github.com/goplus/llgoexamples/x/net/http"
+)
+
+func main() {
+	// Send request first time
+	resp, err := http.Get("https://www.baidu.com")
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(resp.Status, "read bytes: ", resp.ContentLength)
+	for key, values := range resp.Header {
+		for _, value := range values {
+			fmt.Printf("%s: %s\n", key, value)
+		}
+	}
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(string(body))
+	resp.Body.Close()
+
+	// Send request second time
+	resp, err = http.Get("https://www.baidu.com")
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(resp.Status, "read bytes: ", resp.ContentLength)
+	for key, values := range resp.Header {
+		for _, value := range values {
+			fmt.Printf("%s: %s\n", key, value)
+		}
+	}
+	body, err = io.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(string(body))
+	resp.Body.Close()
+}