standard/pressure-test.go

package main

import (
	"flag"
	"fmt"
	"net"
	"time"
)

func main(){
	var cur int
	var timeout int
	flag.IntVar(&cur, "cur", 0, "")
	flag.IntVar(&timeout, "time", 0, "")
	flag.Parse()
	//for i:=0;i<cur;i++ {
	//	go build()
	//}
	//for {
	//	c := time.After(time.Duration(timeout) * time.Minute)
	//	select {
	//	case <-c:
	//		return
	//	}
	//}
	conn,_ := net.Dial("tcp","127.0.0.1:16666")
	conn2,_ := net.Dial("tcp","127.0.0.1:16666")
	conn.Write([]byte("222"))
	conn2.Write([]byte("222"))
}

func build(){
	conn,_ := net.Dial("tcp","127.0.0.1:16666")
	if conn == nil{
		fmt.Println("conn is nil")
		return
	}
	defer func() {
		if conn != nil {
			conn.Close()
		}

	}()

	buffer := make([]byte,1024)
	for {
		line := "11111"
		_,err := conn.Write([]byte(line))
		if err != nil{
			fmt.Println(err.Error())
		}
		n,_ := conn.Read(buffer)
		fmt.Println(string(buffer[:n]))
		time.Sleep(10*time.Second)
	}
}