41. Go 进程执行

• 在上面的例子中，我们演示了一下如何去触发执行一个外部的进程。我们这样做的原因是我们希望从Go进程里面可以访问外部进程的信息。但有的时候，我们仅仅希望执行一个外部进程来替代当前的Go进程。这个时候，我们需要使用Go提供的 exec 函数。

package main
import "syscall"
import "os"
import "os/exec"
func main() {
// 本例中，我们使用`ls`来演示。Go需要一个该命令
// 的完整路径，所以我们使用`exec.LookPath`函数来
// 找到它
binary, lookErr := exec.LookPath("ls")
if lookErr != nil {
panic(lookErr)
}
// `Exec`函数需要一个切片参数，我们给ls命令一些
// 常见的参数。注意，第一个参数必须是程序名称
args := []string{"ls", "-a", "-l", "-h"}
// `Exec`还需要一些环境变量，这里我们提供当前的
// 系统环境
env := os.Environ()
// 这里是`os.Exec`调用。如果一切顺利，我们的原
// 进程将终止，然后启动一个新的ls进程。如果有
// 错误发生，我们将获得一个返回值
execErr := syscall.Exec(binary, args, env)
if execErr != nil {
panic(execErr)
}
}

42. Go 经典hello world

• 我们的第一个例子是打印经典的“hello world”信息，我们先看下代码。

package main
import "fmt"
func main() {
fmt.Println("hello world")
}

43. Go 可变长参数列表

• 我支持可变长参数列表的函数可以支持任意个传入参数，比如fmt.Println函数就是一个支持可变长参数列表的函数。

package main
import "fmt"
// 这个函数可以传入任意数量的整型参数
func sum(nums ...int) {
fmt.Print(nums, " ")
total := 0
for _, num := range nums {
total += num
}
fmt.Println(total)
}
func main() {
// 支持可变长参数的函数调用方法和普通函数一样
// 也支持只有一个参数的情况
sum(1, 2)
sum(1, 2, 3)
// 如果你需要传入的参数在一个切片中，像下面一样
// "func(slice...)"把切片打散传入
nums := []int{1, 2, 3, 4}
sum(nums...)
}

44. Go 命令行参数

• 命令行参数是一种指定程序运行初始参数的常用方式。比如 go run hello.go 使用 run 和 hello.go 参数
  来执行程序。

package main
import "os"
import "fmt"
func main() {
// `os.Args`提供了对命令行参数的访问，注意该
// 切片的第一个元素是该程序的运行路径，而
// `os.Args[1:]`则包含了该程序的所有参数
argsWithProg := os.Args
argsWithoutProg := os.Args[1:]
// 你可以使用索引的方式来获取单个参数
arg := os.Args[3]
fmt.Println(argsWithProg)
fmt.Println(argsWithoutProg)
fmt.Println(arg)
}

45. Go 命令行参数标记

• 命令行参数标记是为命令行程序指定选项参数的常用方法。例如，在命令 wc -l 中， -l 就是一个命令行参
  数标记。

package main
import "flag"
import "fmt"
func main() {
// 基础的标记声明适用于string，integer和bool型选项。
// 这里我们定义了一个标记`word`，默认值为`foo`和一
// 个简短的描述。`flag.String`函数返回一个字符串指
// 针（而不是一个字符串值），我们下面将演示如何使
// 用这个指针
wordPtr := flag.String("word", "foo", "a string")
// 这里定义了两个标记，一个`numb`，另一个是`fork`，
// 使用和上面定义`word`标记相似的方法
numbPtr := flag.Int("numb", 42, "an int")
boolPtr := flag.Bool("fork", false, "a bool")
// 你也可以程序中任意地方定义的变量来定义选项，只
// 需要把该变量的地址传递给flag声明函数即可
var svar string
flag.StringVar(&svar, "svar", "bar", "a string var")
// 当所有的flag声明完成后，使用`flag.Parse()`来分
// 解命令行选项
flag.Parse()
// 这里我们仅仅输出解析后的选项和任何紧跟着的位置
// 参数，注意我们需要使用`*wordPtr`的方式来获取最
// 后的选项值
fmt.Println("word:", *wordPtr)
fmt.Println("numb:", *numbPtr)
fmt.Println("fork:", *boolPtr)
fmt.Println("svar:", svar)
fmt.Println("tail:", flag.Args())
}

46. Go 排序

• Go的sort包实现了内置数据类型和用户自定义数据类型的排序功能。我们先看看内置数据类型的排序。

package main
import "fmt"
import "sort"
func main() {
// 这些排序方法都是针对内置数据类型的。
// 这里的排序方法都是就地排序，也就是说排序改变了
// 切片内容，而不是返回一个新的切片
strs := []string{"c", "a", "b"}
sort.Strings(strs)
fmt.Println("Strings:", strs)
// 对于整型的排序
ints := []int{7, 2, 4}
sort.Ints(ints)
fmt.Println("Ints: ", ints)
// 我们还可以检测切片是否已经排序好
s := sort.IntsAreSorted(ints)
fmt.Println("Sorted: ", s)
}

47. Go 切片

• 切片是Go语言的关键类型之一，它提供了比数组更多的功能。

package main
import "fmt"
func main() {
// 和数组不同的是，切片的长度是可变的。
// 我们可以使用内置函数make来创建一个长度不为零的切片
// 这里我们创建了一个长度为3，存储字符串的切片，切片元素
// 默认为零值，对于字符串就是""。
s := make([]string, 3)
fmt.Println("emp:", s)
// 可以使用和数组一样的方法来设置元素值或获取元素值
s[0] = "a"
s[1] = "b"
s[2] = "c"
fmt.Println("set:", s)
fmt.Println("get:", s[2])
// 可以用内置函数len获取切片的长度
fmt.Println("len:", len(s))
// 切片还拥有一些数组所没有的功能。
// 例如我们可以使用内置函数append给切片追加值，然后
// 返回一个拥有新切片元素的切片。
// 注意append函数不会改变原切片，而是生成了一个新切片，
// 我们需要用原来的切片来接收这个新切片
s = append(s, "d")
s = append(s, "e", "f")
fmt.Println("apd:", s)
// 另外我们还可以从一个切片拷贝元素到另一个切片
// 下面的例子就是创建了一个和切片s长度相同的新切片
// 然后使用内置的copy函数来拷贝s的元素到c中。
c := make([]string, len(s))
copy(c, s)
fmt.Println("cpy:", c)
// 切片还支持一个取切片的操作 "slice[low:high]"
// 获取的新切片包含元素"slice[low]"，但是不包含"slice[high]"
// 下面的例子就是取一个新切片，元素包括"s[2]"，"s[3]"，"s[4]"。
l := s[2:5]
fmt.Println("sl1:", l)
// 如果省略low，默认从0开始，不包括"slice[high]"元素
l = s[:5]
fmt.Println("sl2:", l)
// 如果省略high，默认为len(slice)，包括"slice[low]"元素
l = s[2:]
fmt.Println("sl3:", l)
// 我们可以同时声明和初始化一个切片
t := []string{"g", "h", "i"}
fmt.Println("dcl:", t)
// 我们也可以创建多维切片，和数组不同的是，切片元素的长度也是可变的。
twoD := make([][]int, 3)
for i := 0; i < 3; i++ {
innerLen := i + 1
twoD[i] = make([]int, innerLen)
for j := 0; j < innerLen; j++ {
twoD[i][j] = i + j
}
}
fmt.Println("2d: ", twoD)
}

}
package main
import "fmt"
func main() {
s1 := make([]int, 0)
test(s1)
fmt.Println(s1)
}
func test(s []int) {
s = append(s, 3)
//因为原来分配的空间不够，所以在另外一个地址又重新分配了空间，所以原始地址的数据没有变
}
package main
import "fmt"
func main() {
s1 := make([]int, 0)
s1 = test(s1)
fmt.Println(s1)
}
func test(s []int) []int {
s = append(s, 3)
return s
}
package main
import "fmt"
func main() {
s1 := make([]int, 3, 6)
fmt.Println("s1= ", s1, len(s1), cap(s1))
s2 := append(s1, 1, 2, 3)
fmt.Println("s1= ", s1, len(s1), cap(s1))
fmt.Println("s2= ", s2, len(s2), cap(s2))
s3 := append(s2, 4, 5, 6)
fmt.Println("s1= ", s1, len(s1), cap(s1))
fmt.Println("s2= ", s2, len(s2), cap(s2))
fmt.Println("s3= ", s3, len(s3), cap(s3))
}
package main
import "fmt"
func main() {
s1 := []int{0, 1, 2, 3, 4, 5, 6, 7, 8, 9}
s2 := make([]int, 3, 20)
var n int
n = copy(s2, s1)
fmt.Println(n, s2, len(s2), cap(s2))
s3 := s1[4:6]
fmt.Println(n, s3, len(s3), cap(s3))
n = copy(s3, s1[1:5])
fmt.Println(n, s3, len(s3), cap(s3))
}

48. Go 请求处理频率控制

• 频率控制是控制资源利用和保证服务高质量的重要机制。Go可以使用goroutine，channel和ticker来以优
  雅的方式支持频率控制。

package main
import "time"
import "fmt"
func main() {
// 首先我们看下基本的频率限制。假设我们得控制请求频率，
// 我们使用一个通道来处理所有的这些请求，这里向requests
// 发送5个数据，然后关闭requests通道
requests := make(chan int, 5)
for i := 1; i <= 5; i++ {
requests <- i
}
close(requests)
// 这个limiter的Ticker每隔200毫秒结束通道阻塞
// 这个limiter就是我们频率控制处理器
limiter := time.Tick(time.Millisecond * 200)
// 通过阻塞从limiter通道接受数据，我们将请求处理控制在每隔200毫秒
// 处理一个请求，注意`<-limiter`的阻塞作用。
for req := range requests {
<-limiter
fmt.Println("request", req, time.Now())
}
// 我们可以保持正常的请求频率限制，但也允许请求短时间内爆发
// 我们可以通过通道缓存来实现，比如下面的这个burstyLimiter
// 就允许同时处理3个事件。
burstyLimiter := make(chan time.Time, 3)
// 填充burstyLimiter，先发送3个数据
for i := 0; i < 3; i++ {
burstyLimiter <- time.Now()
}
 
// 然后每隔200毫秒再向burstyLimiter发送一个数据，这里是不断地
// 每隔200毫秒向burstyLimiter发送数据
go func() {
for t := range time.Tick(time.Millisecond * 200) {
burstyLimiter <- t
}
}()
// 这里模拟5个请求，burstyRequests的前面3个请求会连续被处理，
// 因为burstyLimiter被先连续发送3个数据的的缘故，而后面两个
// 则每隔200毫秒处理一次
burstyRequests := make(chan int, 5)
for i := 1; i <= 5; i++ {
burstyRequests <- i
}
close(burstyRequests)
for req := range burstyRequests {
<-burstyLimiter
fmt.Println("request", req, time.Now())
}
}

49. Go 时间

• Go提供了对时间和一段时间的支持。这里有一些例子。

package main
import "fmt"
import "time"
func main() {
p := fmt.Println
// 从获取当前时间开始
now := time.Now()
p(now)
// 你可以提供年，月，日等来创建一个时间。当然时间
// 总是会和地区联系在一起，也就是时区
then := time.Date(2009, 11, 17, 20, 34, 58, 651387237, time.UTC)
p(then)
// 你可以获取时间的各个组成部分
p(then.Year())
p(then.Month())
p(then.Day())
p(then.Hour())
p(then.Minute())
p(then.Second())
p(then.Nanosecond())
p(then.Location())
// 输出当天是周几，Monday-Sunday中的一个
p(then.Weekday())
// 下面的几个方法判断两个时间的顺序，精确到秒
p(then.Before(now))
p(then.After(now))
p(then.Equal(now))
// Sub方法返回两个时间的间隔(Duration)
diff := now.Sub(then)
p(diff)
// 可以以不同的单位来计算间隔的大小
p(diff.Hours())
p(diff.Minutes())
p(diff.Seconds())
p(diff.Nanoseconds())
// 你可以使用Add方法来为时间增加一个间隔
// 使用负号表示时间向前推移一个时间间隔
p(then.Add(diff))
p(then.Add(-diff))
}

50. Go 时间戳

• 程序的一个通常需求是计算从Unix起始时间开始到某个时刻的秒数，毫秒数，微秒数等。

package main
import "fmt"
import "time"
func main() {
// 使用Unix和UnixNano来分别获取从Unix起始时间
// 到现在所经过的秒数和微秒数
now := time.Now()
secs := now.Unix()
nanos := now.UnixNano()
fmt.Println(now)
// 注意这里没有UnixMillis方法，所以我们需要将
// 微秒手动除以一个数值来获取毫秒
millis := nanos / 1000000
fmt.Println(secs)
fmt.Println(millis)
fmt.Println(nanos)
// 反过来，你也可以将一个整数秒数或者微秒数转换
// 为对应的时间
fmt.Println(time.Unix(secs, 0))
fmt.Println(time.Unix(0, nanos))
}