x

Author: coderbradlee

main.go

@@ -1,5 +1,13 @@
 package main
 
+import (
+	"context"
+	"fmt"
+	"net"
+	"net/http"
+	"sync/atomic"
+)
+
 //
 //import (
 //	"log"
@@ -38,21 +46,47 @@ package main
 //	http.Handle("/metrics", promhttp.Handler())
 //	log.Fatal(http.ListenAndServe(":8080", nil))
 //}
-import (
-	"fmt"
-	"net/http"
-	_ "net/http/pprof"
-	"time"
-)
-
 func main() {
+	//go func() {
+	//	http.ListenAndServe(":8088", nil)
+	//}()
+	//for i := 0; i < 100; i++ {
+	//	time.Sleep(time.Second)
+	//	fmt.Println(":", i)
+	//}
+	//ch := make(chan string)
+	//<-ch
+
+	var count int32 = 0
+	server := &http.Server{
+		Addr: ":4444",
+		Handler: http.HandlerFunc(func(rw http.ResponseWriter, req *http.Request) {
+			rw.Header().Set("Connection", "close")
+		}),
+		ConnContext: func(ctx context.Context, c net.Conn) context.Context {
+			atomic.AddInt32(&count, 1)
+			if c2 := ctx.Value("count"); c2 != nil {
+				fmt.Printf("发现了遗留数据: %d\n", c2.(int32))
+			}
+			fmt.Printf("本次数据: %d\n", count)
+			return context.WithValue(ctx, "count", count)
+		},
+	}
 	go func() {
-		http.ListenAndServe(":8088", nil)
+		panic(server.ListenAndServe())
 	}()
-	for i := 0; i < 100; i++ {
-		time.Sleep(time.Second)
-		fmt.Println(":", i)
+
+	var err error
+
+	fmt.Println("第一次请求")
+	_, err = http.Get("http://localhost:4444/")
+	if err != nil {
+		panic(err)
+	}
+	fmt.Println("\n第二次请求")
+
+	_, err = http.Get("http://localhost:4444/")
+	if err != nil {
+		panic(err)
 	}
-	ch := make(chan string)
-	<-ch
 }

test/main_test.go

@@ -2,6 +2,7 @@ package test
 
 import (
 	"encoding/base64"
+	"encoding/hex"
 	"fmt"
 	"math/big"
 	"testing"
@@ -353,7 +354,7 @@ func testxx() {
 	//encodeString2 := base64.StdEncoding.EncodeToString([]byte(hex.EncodeToString(out2)))
 	//fmt.Println(encodeString2)
 
-	input := []byte("23")
+	input := []byte("18160ddd")
 	//input, _ := hex.DecodeString("0000000000000000000000006356908ace09268130dee2b7de643314bbeb36830000000000000000000000000000000000000000000000000000000000000004")
 	// 演示base64编码
 	encodeString := base64.StdEncoding.EncodeToString(input)
@@ -397,13 +398,16 @@ func testdefer() {
 	fmt.Println("testdefer")
 }
 func TestXx(t *testing.T) {
-	testdefer()
+	//testdefer()
 	//testyy()
 	//testDijkstra()
 	//testopenfile()
 	//testudp()
 	//testbroard()
 	testxx()
+	te := []byte{1, 2, 3}
+	fmt.Println(fmt.Sprintf("%x", te))
+	fmt.Println(hex.EncodeToString(te))
 	//tag := []byte("123")
 	//key := []byte("456")
 	//k := make([]byte, len(tag)+len(key))