开发 - GoLang - 并发简单理解

‍

前言

emm这里会记录下我学Go的一些小基础吧，毕竟之后肯定会接触Go，用一些简单的例子来解释一些内容，这里大家可以尝试以写端口扫描工具来感受下并发

‍

并发机制

‍

不并发

‍

package main

import (
	"fmt"
	"net"
)

func porter() {
	for port := 0; port < 65535; port++ {

		address := fmt.Sprintf("192.168.0.128:%d", port)
		connect, connect_error := net.Dial("tcp", address) 
//这行代码创建了一个TCP连接到指定的address。net.Dial函数尝试去连接一个网络端点，并返回一个Conn接口和一个error
//net.Dial是Go语言标准库net包中的一个函数，用于创建一个到指定网络和地址的连接。第一个参数是网络类型（如"tcp"、"udp"、"ip"等），第二个参数是地址（如"localhost:8080"）
		if connect_error != nil {
			fmt.Printf("[-] %d --> close\n", port)
			continue
		} else {
			connect.Close()
			fmt.Printf("[+] %d -->opening \n", port)
		}
		fmt.Println(address)
	}
}

func main() {
	porter()
}

‍

可以说是龟速

‍

goroutine并发

‍

package main

import (
	"fmt"
	"net"
	"sync"
	"time"
)

func porter() {
	var wait_group sync.WaitGroup //声明一个类型为sync.WaitGroup的变量wait_group，用于等待所有的goroutine完成
	time_start := time.Now()
	for port := 0; port < 65535; port++ {
		wait_group.Add(1)// 每次循环时，将等待组的计数器增加1
		go func(f_port int) {
			defer wait_group.Done() //当goroutine完成时，将等待组的计数器减1
			address := fmt.Sprintf("192.168.0.128:%d", f_port)
			connect, connect_error := net.Dial("tcp", address)
			if connect_error != nil {
				//fmt.Printf("[-] %d --> close\n", f_port)
				return
			}
			connect.Close()
			fmt.Printf("[+] %d -->opening \n", f_port)
		}(port) // 结束goroutine函数，并传入当前的端口号
	}
	wait_group.Wait() //等待所有的goroutine完成 
	time_stop := time.Now()
	time_def := time_stop.Sub(time_start)
	fmt.Printf("[*] 1-65535端口扫描完毕，共用时：%v。\n", time_def)
}

func main() {
	porter()
}