Personal Notes

Appearance

Go 语言从入门到实战 ​

Go 语言简介 ​

概述 ​

Go 语言诞生于 2007 年，主要是为了解决 Google 内部所发现的问题。

  • 多核硬件架构
  • 超大规模分布式计算集群
  • Web 模式导致的前所未有的开发规模和更新速度

大多数互联网公司都会面临上述问题，Go 语言本身就是用来解决上述问题的，所以越来越多公司和组织都在使用 Go。

除了构建大规模互联网系统之外，在业界大家熟知的一些软件，例如 Docker、Kubernets，都是使用 Go 来编写的，所以 Go 也被称为云端开发语言。著名的区块链项目，像以太坊、HYPERLEDGER 这些都可以用 Go 来开发，所以说 Go 也是当之无愧的区块链开发语言。传统的企业应用，物联网应用，也都有 Go 的身影 ，Go 语言的应用范围也在不断扩展。

Go 语言创始人：

  • Rob Pike：Unix 的早期开发者，UTF-8 创始人
  • Ken Thompson：Unix 创始人，C 语言创始人，1983 年获图灵奖
  • Robert Griesemer：Google V8 JS Engineer、Hot Spot 开发者

特性：

  • 简单
    • C 37 关键字、C++ 84 关键字、Go 25 关键字
  • 高效
    • 编译的强类型语言
    • 支持垃圾回收的同时，也支持指针直接进行内存访问
  • 生产力
    • 语法简洁
    • 存在编程约束，只支持复合，不支持继承

第一个 Go 程序 ​

简单案例 ​

go
// src/ch1/main/hello_world.go

package main

import "fmt"

func main() {
	fmt.Println("hello world")
}
// src/ch1/main/hello_world.go

package main

import "fmt"

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

直接运行

go run hello_world.go
go run hello_world.go

编译后运行

go build hello_world.go 
./hello_world
go build hello_world.go 
./hello_world

Go 在默认情况下都会使用静态链接，编译完的 Go 程序都会指示一个独立的二进制文件，具有良好的便携性，可以拷贝到不到的机器上运行。安装部署时，尤其是通过容器安装部署，便携能力很强。

案例分析 ​

应用程序入口

  • 必须是 main 包：package main
  • 必须是 main 方法：func main()
  • 文件名不一定是 main.go

退出返回值

  • Go 中 main 函数不支持任何返回值
  • 通过 os.Exit 返回状态
go
// ...

func main() {
	fmt.Println("hello world")
	os.Exit(0)
}
// ...

func main() {
	fmt.Println("hello world")
	os.Exit(0)
}
  • 在程序中直接通过 os.Args 获取命令行参数
go
func main() {
	if len(os.Args) > 1 {
		fmt.Println("hello world", os.Args[1])
	}
}
func main() {
	if len(os.Args) > 1 {
		fmt.Println("hello world", os.Args[1])
	}
}
go run hello_world.go heora
go run hello_world.go heora

01. 基础程序结构 ​

变量、常量 ​

The master has failed more times than the beginner has tried.

编写测试程序 ​

  • 源码文件以 _test 结尾：xxx_test.go
  • 测试方法名以 Test 开头：func TestXXX(t *testing.T) {...}
go
// src/ch2/test/first_test.go

package try_test

import "testing"

func TestTry(t *testing.T) {
	t.Log("my first try!")
}
// src/ch2/test/first_test.go

package try_test

import "testing"

func TestTry(t *testing.T) {
	t.Log("my first try!")
}

变量定义 ​

go
// src/ch2/fib/fib_test.go

package fib

import (
	"testing"
)

func TestFibList(t *testing.T) {
	// 1. 第一种方式
	// var a int = 1
	// var b int = 1

	// 2. 第二种方式
	// var (
	// 	a int = 1
	// 	b     = 1
	// )

	// 3. 第三种方式
	a := 1
	b := 1

	t.Log(a)

	for i := 0; i < 5; i++ {
		t.Log(" ", b)
		tmp := a
		a = b
		b = tmp + a
	}
}
// src/ch2/fib/fib_test.go

package fib

import (
	"testing"
)

func TestFibList(t *testing.T) {
	// 1. 第一种方式
	// var a int = 1
	// var b int = 1

	// 2. 第二种方式
	// var (
	// 	a int = 1
	// 	b     = 1
	// )

	// 3. 第三种方式
	a := 1
	b := 1

	t.Log(a)

	for i := 0; i < 5; i++ {
		t.Log(" ", b)
		tmp := a
		a = b
		b = tmp + a
	}
}
  • 赋值支持自动类型推断
  • 在一个赋值语句中可以对多个变量同时赋值
go
func TestExchange(t *testing.T) {
	// a := 1
	// b := 2
	// tmp := a
	// a = b
	// b = tmp

	a := 1
	b := 2

	a, b = b, a

	t.Log(a, b)
}
func TestExchange(t *testing.T) {
	// a := 1
	// b := 2
	// tmp := a
	// a = b
	// b = tmp

	a := 1
	b := 2

	a, b = b, a

	t.Log(a, b)
}

常量定义 ​

支持快速设置连续值

go
package constant_test

import "testing"

const (
	Monday = iota + 1
	Tuesday
	Wednesday
	Thursday
	Friday
	Saturday
	Sunday
)

const (
	Readable = 1 << iota
	Writable
	Executable
)

func TestConstant(t *testing.T) {
	t.Log(Monday, Tuesday) // 1 2

	a := 7 // 0111

	t.Log(a&Readable == Readable, a&Writable == Writable, a&Executable == Executable) 
  // true true true
}
package constant_test

import "testing"

const (
	Monday = iota + 1
	Tuesday
	Wednesday
	Thursday
	Friday
	Saturday
	Sunday
)

const (
	Readable = 1 << iota
	Writable
	Executable
)

func TestConstant(t *testing.T) {
	t.Log(Monday, Tuesday) // 1 2

	a := 7 // 0111

	t.Log(a&Readable == Readable, a&Writable == Writable, a&Executable == Executable) 
  // true true true
}

数据类型 ​

基本数据类型 ​

数据类型
bool
string
int init8 int16 int32 int64
uint uint8 uint16 uint32 uint64 uintptr
byte // alias for uint8
rune // alias for int32, represents a Unicode code point
float32 float64
complex64 complex128

类型转化

  • Go 语言不支持隐式类型转换
  • 别名和原有类型也不能进行隐式类型转换
go
package type_test

import "testing"

type MyInt int64

func TestType(t *testing.T) {
	var a int = 1

	var b int64
	var c int32

	// b = a // cannot use a (variable of type int) as int64 value in assignmentcompiler
	// c = a // cannot use a (variable of type int) as int64 value in assignmentcompiler

	b = int64(a)
	c = int32(a)

	var d MyInt
	d = MyInt(a)

	t.Log(a, b, c, d)
}
package type_test

import "testing"

type MyInt int64

func TestType(t *testing.T) {
	var a int = 1

	var b int64
	var c int32

	// b = a // cannot use a (variable of type int) as int64 value in assignmentcompiler
	// c = a // cannot use a (variable of type int) as int64 value in assignmentcompiler

	b = int64(a)
	c = int32(a)

	var d MyInt
	d = MyInt(a)

	t.Log(a, b, c, d)
}

Go 语言对于类型转换非常严格， 不支持隐式类型转换。

go
type MyInt int64    // 类型再定义，支持强制类型转换，不支持判等操作
type MyInt = int64  // 类型别名，支持直接判等操作
type MyInt int64    // 类型再定义，支持强制类型转换，不支持判等操作
type MyInt = int64  // 类型别名，支持直接判等操作

类型的预定义值 ​

  • math.MaxInt64
  • math.MaxFloat64
  • math.MaxUnit32

指针类型 ​

Go 支持垃圾回收机制 ，同时作为一种非常高效的语言，也支持使用指针直接访问内存空间。

不过 Go 语言指针使用也有一些限制：

  • 不支持指针运算
  • string 是值类型，默认值是空字符串，而不是 nil
go
func TestPoint(t *testing.T) {
	a := 1
	aPtr := &a

	// aPtr = aPtr + 1 // cannot convert 1 (untyped int constant) to *int

	t.Log(a, aPtr)           // 1 0x140000a41c8
	t.Logf("%T %T", a, aPtr) // int *int
}
func TestPoint(t *testing.T) {
	a := 1
	aPtr := &a

	// aPtr = aPtr + 1 // cannot convert 1 (untyped int constant) to *int

	t.Log(a, aPtr)           // 1 0x140000a41c8
	t.Logf("%T %T", a, aPtr) // int *int
}
go
func TestStrng(t *testing.T) {
	var s string

	t.Log("*" + s + "*") // **
	t.Log(len(s))        // 0
}
func TestStrng(t *testing.T) {
	var s string

	t.Log("*" + s + "*") // **
	t.Log(len(s))        // 0
}

运算符 ​

算数运算符 ​

A = 10, B = 20

运算符描述实例
+相加A + B = 30
-相减A - B = -10
*相乘A * B = 200
/相除B / A = 2
%取余B % A = 0
++自增A++ = 11
--自减A-- = 9

Go 语言没有前置 ++，前置 -- 。

比较运算符 ​

A = 10, B = 20

运算符描述实例
==检查两个值是否相等，如果相等返回 true，否则返回 falseA == B false
!=检查两个值是否相等，如果不想等返回 true，否则返回 falseA != B true
>检查左边值是否大于右边值，如果是返回 true，否则返回 falseA > B false
<检查左边值是否小于右边值，如果是返回 true，否则返回 falseA < B true
>=检查左边值是否大于等于右边值，如果是返回 true，否则返回 falseA >= B false
<=检查左边值是否小于等于右边值，，如果是返回 true，否则返回 falseA <= B true

用 == 比较数组

很多主流语言中，数组是引用类型，使用 == 比较时，实际上是比较两个数组的引用，而不是比较值，在 Go 中则完全不同。

  • 相同维数且含有相同个数元素的数组才可以比较；
  • 每个元素都相同的才相等。
go
func TestCompareArray(t *testing.T) {
	a := [...]int{1, 2, 3, 4}
	b := [...]int{1, 3, 4, 5}
	c := [...]int{1, 2, 3, 4, 5}
	d := [...]int{1, 2, 3, 4}

	t.Log(a == b) // false
	// t.Log(a == c) // cannot compare a == c (mismatched types [4]int and
	t.Log(a == d) // true

	t.Log(a, b, c, d)
}
func TestCompareArray(t *testing.T) {
	a := [...]int{1, 2, 3, 4}
	b := [...]int{1, 3, 4, 5}
	c := [...]int{1, 2, 3, 4, 5}
	d := [...]int{1, 2, 3, 4}

	t.Log(a == b) // false
	// t.Log(a == c) // cannot compare a == c (mismatched types [4]int and
	t.Log(a == d) // true

	t.Log(a, b, c, d)
}

逻辑运算符 ​

A = 10, B = 20

运算符描述实例
&&逻辑 AND 运算符。如果两边的操作数都是 true，则条件为 true，否则为 falseA && B false
||逻辑 OR 运算符。如果两边的操作数有一个 true，则条件为 true，否则为 falseA || B true
!逻辑 NOT 运算符。如果条件为 true，则逻辑 NOT 条件为 false，否则为 true!(A && B) true

位运算符 ​

和主流语言基本一致，差异如下。

&^ 按位置零

  • 1 &^ 0 -- 1
  • 1 &^ 1 -- 0
  • 0 &^ 1 -- 0
  • 0 &^ 0 -- 0

条件和循环 ​

循环 ​

Go 语言仅支持循环关键字 for

go
for j := 7; j <= 9; j++
for j := 7; j <= 9; j++
go
// while 条件循环
// while <= 5

func TestWhileLoop(t *testing.T) {
	n := 0

	for n < 5 {
		n++
		t.Log(n)
	}
}
// while 条件循环
// while <= 5

func TestWhileLoop(t *testing.T) {
	n := 0

	for n < 5 {
		n++
		t.Log(n)
	}
}
go
// 无限循环
// while(true)

n := 0
for {
  ...
}
// 无限循环
// while(true)

n := 0
for {
  ...
}

条件语句 - if 条件 ​

go
if condition {
  // code to be executed if condition is true
} else {
	// code to be executed if condition is false  
}
if condition {
  // code to be executed if condition is true
} else {
	// code to be executed if condition is false  
}
go
if condition-1 {
  // code to be executed if condition-1 is true
} else if condition-2 {
  // code to be executed if condition-2 is true
} else {
	// code to be executed if both condition1 and condition2 are false  
}
if condition-1 {
  // code to be executed if condition-1 is true
} else if condition-2 {
  // code to be executed if condition-2 is true
} else {
	// code to be executed if both condition1 and condition2 are false  
}
  • condition 表达式结果必须为布尔值
  • 支持变量赋值
    • 由于 go 支持多返回值，配合使用比较便捷
go
if var decleartion; condition {
  // code to be exectuted if condition is true
}
if var decleartion; condition {
  // code to be exectuted if condition is true
}
go
func TestIfMulitSec(t *testing.T) {
	if a := 1 == 1; a {
		t.Log("1 == 1")
	}
}
func TestIfMulitSec(t *testing.T) {
	if a := 1 == 1; a {
		t.Log("1 == 1")
	}
}
go
func TestIfMulitSec(t *testing.T) {
  if v, err := someFun(); err == nil {
  } else {
  }
}
func TestIfMulitSec(t *testing.T) {
  if v, err := someFun(); err == nil {
  } else {
  }
}

条件语句 - switch 条件 ​

go
switch os := runtime.GOOS; os {
  case "darwin":
  	fmt.Println("OS X.")
  case "linux":
  	fmt.Println("Linux.")
	default:
  fmt.Printf("%s.", os)
}
switch os := runtime.GOOS; os {
  case "darwin":
  	fmt.Println("OS X.")
  case "linux":
  	fmt.Println("Linux.")
	default:
  fmt.Printf("%s.", os)
}
go
switch {
  case 0 <= Num && Num <= 3
  	fmt.Printf("0-3")
 	case 4 <= Num && Num <= 6
  	fmt.Printf("4-6")
  case 7 <= Num && Num <= 9
  	fmt.Printf("7-9")
}
switch {
  case 0 <= Num && Num <= 3
  	fmt.Printf("0-3")
 	case 4 <= Num && Num <= 6
  	fmt.Printf("4-6")
  case 7 <= Num && Num <= 9
  	fmt.Printf("7-9")
}
  • 条件表达式不限制为常量或者整数；
  • 单个 case 中，可以出现多个结果选项，使用逗号分隔；
  • 与 C 语言等规则相反，Go 语言不需要使用 break 来明确退出一个 case；
  • 可以不设定 switch 之后的条件表达式，在此种情况下，整个 switch 结构与多个 if...else... 的逻辑作用等同。
go
func TestSWitchMultiCase(t *testing.T) {
	for i := 0; i < 5; i++ {
		switch i {
		case 0, 2:
			t.Log("even")
		case 1, 3:
			t.Log("odd")
		default:
			t.Log("it is not 0-3")
		}
	}
}
func TestSWitchMultiCase(t *testing.T) {
	for i := 0; i < 5; i++ {
		switch i {
		case 0, 2:
			t.Log("even")
		case 1, 3:
			t.Log("odd")
		default:
			t.Log("it is not 0-3")
		}
	}
}
go
func TestSwitchCaseCondition(t *testing.T) {
	for i := 0; i < 5; i++ {
		switch {
		case i%2 == 0:
			t.Log("even")
		case i%2 == 1:
			t.Log("odd")
		default:
			t.Log("it is not 0-3")
		}
	}
}
func TestSwitchCaseCondition(t *testing.T) {
	for i := 0; i < 5; i++ {
		switch {
		case i%2 == 0:
			t.Log("even")
		case i%2 == 1:
			t.Log("odd")
		default:
			t.Log("it is not 0-3")
		}
	}
}

02. 常用集合 ​

数据和切片 ​

数组声明 ​

go
func TestArrayInit(t *testing.T) {
	var arr [3]int
	arr1 := [4]int{1, 2, 3, 4}
	arr3 := [...]int{1, 2, 3, 4, 5}

	arr1[1] = 6

	t.Log(arr[1], arr[2]) // 0 0
	t.Log(arr1)           // [1, 6, 3, 4]
	t.Log(arr3)           // [1, 2, 3, 4, 5]
}
func TestArrayInit(t *testing.T) {
	var arr [3]int
	arr1 := [4]int{1, 2, 3, 4}
	arr3 := [...]int{1, 2, 3, 4, 5}

	arr1[1] = 6

	t.Log(arr[1], arr[2]) // 0 0
	t.Log(arr1)           // [1, 6, 3, 4]
	t.Log(arr3)           // [1, 2, 3, 4, 5]
}

数组元素遍历 ​

go
func TestArrayTravel(t *testing.T) {
	arr := [...]int{1, 3, 4, 5}

	// 1. method1
	for i := 0; i < len(arr); i++ {
		t.Log((arr[i]))
	}

	// 2. method2
	for idx, e := range arr {
		t.Log(idx, e)
	}

	// 3. method3
	for _, e := range arr {
		t.Log(e)
	}
}
func TestArrayTravel(t *testing.T) {
	arr := [...]int{1, 3, 4, 5}

	// 1. method1
	for i := 0; i < len(arr); i++ {
		t.Log((arr[i]))
	}

	// 2. method2
	for idx, e := range arr {
		t.Log(idx, e)
	}

	// 3. method3
	for _, e := range arr {
		t.Log(e)
	}
}

数组截取 ​

a[开始索引(包含), 结束索引(不包含)]
a[开始索引(包含), 结束索引(不包含)]
go
func TestArraySection(t *testing.T) {
	arr := [...]int{1, 2, 3, 4, 5}

	t.Log(arr[:3]) // [1 2 3]
	t.Log(arr[3:]) // [4 5]
	t.Log(arr[:])  // [1 2 3 4 5]
}
func TestArraySection(t *testing.T) {
	arr := [...]int{1, 2, 3, 4, 5}

	t.Log(arr[:3]) // [1 2 3]
	t.Log(arr[3:]) // [4 5]
	t.Log(arr[:])  // [1 2 3 4 5]
}

数组截取之后，其实就是一个 slice。

切片声明 ​

go
func TestSliceInit(t *testing.T) {
	var s0 []int
	t.Log(len(s0), cap(s0)) // 0 0

	s0 = append(s0, 1)
	t.Log(len(s0), cap(s0)) // 1 1

	s1 := []int{1, 2, 3, 4}
	t.Log(len(s1), cap(s1)) // 4 4

	s2 := make([]int, 3, 5)
	t.Log(len(s2), cap(s2)) // 3 5
	// cap 容量，len 可访问元素个数
	// t.Log(s2[0], s2[1], s2[2], s2[3], s2[4]) // index out of range [3] with length 3 [recovered]
	t.Log(s2[0], s2[1], s2[2]) // 0 0 0

	s2 = append(s2, 5)
	t.Log(len(s2), cap(s2))           // 4 5
	t.Log(s2[0], s2[1], s2[2], s2[3]) // 0 0 0 5
}
func TestSliceInit(t *testing.T) {
	var s0 []int
	t.Log(len(s0), cap(s0)) // 0 0

	s0 = append(s0, 1)
	t.Log(len(s0), cap(s0)) // 1 1

	s1 := []int{1, 2, 3, 4}
	t.Log(len(s1), cap(s1)) // 4 4

	s2 := make([]int, 3, 5)
	t.Log(len(s2), cap(s2)) // 3 5
	// cap 容量，len 可访问元素个数
	// t.Log(s2[0], s2[1], s2[2], s2[3], s2[4]) // index out of range [3] with length 3 [recovered]
	t.Log(s2[0], s2[1], s2[2]) // 0 0 0

	s2 = append(s2, 5)
	t.Log(len(s2), cap(s2))           // 4 5
	t.Log(s2[0], s2[1], s2[2], s2[3]) // 0 0 0 5
}

切片共享存储结构 ​

go
func TestSliceGrowing(t *testing.T) {
	s := []int{}

	for i := 0; i < 10; i++ {
		s = append(s, i)
		t.Log(len(s), cap(s))
	}
	// 当容量不够时，会乘 2 倍的方式进行扩展
	// 当扩展时，会开启新的存储空间，并将原有空间的元素拷贝到新空间中间
	// 1 1
	// 2 2
	// 3 4
	// 4 4
	// 5 8
	// 6 8
	// 7 8
	// 8 8
	// 9 16
	// 10 16
}
func TestSliceGrowing(t *testing.T) {
	s := []int{}

	for i := 0; i < 10; i++ {
		s = append(s, i)
		t.Log(len(s), cap(s))
	}
	// 当容量不够时，会乘 2 倍的方式进行扩展
	// 当扩展时，会开启新的存储空间，并将原有空间的元素拷贝到新空间中间
	// 1 1
	// 2 2
	// 3 4
	// 4 4
	// 5 8
	// 6 8
	// 7 8
	// 8 8
	// 9 16
	// 10 16
}
go
func TestSliceShareMemory(t *testing.T) {
	year := []string{"Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"}

	Q2 := year[3:6]
	t.Log(Q2, len(Q2), cap(Q2)) // [Apr May Jun] 3 9

	summer := year[5:8]
	t.Log(summer, len(summer), cap(summer)) // [Jun Jul Aug] 3 7

	summer[0] = "Unknow"
	t.Log(Q2)   // [Apr May Unknow]
	t.Log(year) // [Jan Feb Mar Apr May Unknow Jul Aug Sep Oct Nov Dec]
}
func TestSliceShareMemory(t *testing.T) {
	year := []string{"Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"}

	Q2 := year[3:6]
	t.Log(Q2, len(Q2), cap(Q2)) // [Apr May Jun] 3 9

	summer := year[5:8]
	t.Log(summer, len(summer), cap(summer)) // [Jun Jul Aug] 3 7

	summer[0] = "Unknow"
	t.Log(Q2)   // [Apr May Unknow]
	t.Log(year) // [Jan Feb Mar Apr May Unknow Jul Aug Sep Oct Nov Dec]
}

数组 vs 切片 ​

  • 容量是否可伸缩
    • 数组定长
    • 切片不定长
  • 是否可以进行比较
    • 相同维数、相同长度的数组是可以比较的
    • 切片不能比较
go
func TestSliceComparing(t *testing.T) {
	a := []int{1, 2, 3, 4}
	b := []int{1, 2, 3, 4}

	if a == b { // cannot compare a == b (slice can only be compared to nil)
		t.Log("equal")
	}
}
func TestSliceComparing(t *testing.T) {
	a := []int{1, 2, 3, 4}
	b := []int{1, 2, 3, 4}

	if a == b { // cannot compare a == b (slice can only be compared to nil)
		t.Log("equal")
	}
}

Map ​

Map 声明 ​

go
m := map[string]int{"one": 1, "two": 2, "three": 3}

m1 := map[string]int{}
m1["one"] = 1

m2 := make(map[string]int, 10 /**Initial Capacity*/)
// 为什么不初始化 len ?
// 切片中 len 都会赋值为零值，map 没有办法确认零值
m := map[string]int{"one": 1, "two": 2, "three": 3}

m1 := map[string]int{}
m1["one"] = 1

m2 := make(map[string]int, 10 /**Initial Capacity*/)
// 为什么不初始化 len ?
// 切片中 len 都会赋值为零值，map 没有办法确认零值
go
func TestInitMap(t *testing.T) {
	m1 := map[int]int{1: 1, 2: 4, 3: 9}
	t.Log(m1[2])                 // 4
	t.Logf("len m1=%d", len(m1)) // len m1=3

	m2 := map[int]int{}
	m2[4] = 16
	t.Logf("len m2=%d", len(m2)) // len m2=1

	m3 := make(map[int]int, 10)
	t.Logf("len m3=%d", len(m3)) // len m3=0
}
func TestInitMap(t *testing.T) {
	m1 := map[int]int{1: 1, 2: 4, 3: 9}
	t.Log(m1[2])                 // 4
	t.Logf("len m1=%d", len(m1)) // len m1=3

	m2 := map[int]int{}
	m2[4] = 16
	t.Logf("len m2=%d", len(m2)) // len m2=1

	m3 := make(map[int]int, 10)
	t.Logf("len m3=%d", len(m3)) // len m3=0
}

Map 元素访问 ​

在访问的 key 不存在时，会返回零值，不能通过返回 nil 来判断元素是否存在。

go
func TestAccessNotExistingKey(t *testing.T) {
	m1 := map[int]int{}
	t.Log(m1[1]) // 0

	m1[2] = 0
	t.Log(m1[1]) // 0

	// 无法区分不存在值或实际值为 0
	// 需要自主判断

	// m1[3] = 0

	if _, ok := m1[3]; ok {
		t.Logf("key 3 value is %d", m1[3])
	} else {
		t.Log("key 3 is not existing.")
	}
}
func TestAccessNotExistingKey(t *testing.T) {
	m1 := map[int]int{}
	t.Log(m1[1]) // 0

	m1[2] = 0
	t.Log(m1[1]) // 0

	// 无法区分不存在值或实际值为 0
	// 需要自主判断

	// m1[3] = 0

	if _, ok := m1[3]; ok {
		t.Logf("key 3 value is %d", m1[3])
	} else {
		t.Log("key 3 is not existing.")
	}
}

Map 遍历 ​

go
m := map[string]int{"one": 1, "two": 2, "three": 3}
for k, v := range m {
  t.Log(k, v)
}
m := map[string]int{"one": 1, "two": 2, "three": 3}
for k, v := range m {
  t.Log(k, v)
}
go
func TestTravelMap(t *testing.T) {
	m1 := map[int]int{1: 1, 2: 4, 3: 9}

	for k, v := range m1 {
		t.Log(k, v)
		// 1 1
		// 2 4
		// 3 9
	}
}
func TestTravelMap(t *testing.T) {
	m1 := map[int]int{1: 1, 2: 4, 3: 9}

	for k, v := range m1 {
		t.Log(k, v)
		// 1 1
		// 2 4
		// 3 9
	}
}

Map 底层使用使用 hash 表机制，所以遍历结果并不总是有序的。

Map 与工厂模式 ​

  • Map 的 value 可以是一个方法
    • Go 语言中，函数是一等公民
  • 与 Go 的 Dock type 接口方式一起，可以方便的实现单一方法对象的工厂模式
go
package map_test

import "testing"

func TestMapWithFunValue(t *testing.T) {
	m := map[int]func(op int) int{}

	m[1] = func(op int) int { return op }
	m[2] = func(op int) int { return op * op }
	m[3] = func(op int) int { return op * op * op }

	t.Log(m[1](2), m[2](2), m[3](2)) // 2 4 8 
}
package map_test

import "testing"

func TestMapWithFunValue(t *testing.T) {
	m := map[int]func(op int) int{}

	m[1] = func(op int) int { return op }
	m[2] = func(op int) int { return op * op }
	m[3] = func(op int) int { return op * op * op }

	t.Log(m[1](2), m[2](2), m[3](2)) // 2 4 8 
}

实现 Set ​

Go 语言没有提供内置的 Set，我们可以使用 Map 实现一个 Set。

  • 元素唯一性
  • 基本操作
    • 添加元素
    • 判断元素是否存在
    • 删除元素
    • 元素个数
go
func TestMapForSet(t *testing.T) {
	set := map[int]bool{}

	set[1] = true

	n := 1

	if set[n] {
		t.Logf("%d is existing", n)
	} else {
		t.Logf("%d is not existing", n)
	}

	set[2] = true
	t.Log(len(set)) // 2

	delete(set, 2)
	t.Log(len(set)) // 1
}
func TestMapForSet(t *testing.T) {
	set := map[int]bool{}

	set[1] = true

	n := 1

	if set[n] {
		t.Logf("%d is existing", n)
	} else {
		t.Logf("%d is not existing", n)
	}

	set[2] = true
	t.Log(len(set)) // 2

	delete(set, 2)
	t.Log(len(set)) // 1
}

03. 字符串 ​

基本使用 ​

  • string 是数据类型，不是引用或指针类型
  • string 是只读的 byte slice，len 函数可以获取它所包含的 byte 数
  • string 的 byte 数组可以存放任何数据
go
func TestString(t *testing.T) {
	var s string
	t.Log(s) // 初始化为默认零值

	s = "hello"
	t.Log(len(s)) // 5

	// string 是不可变的 byte 切片
	// s[1] = '3' // cannot assign to s[1] (value of type byte)

	s = "\xE4\xB8\xA5" // 可以存储二进制数据
	t.Log(s)           // 严

	s = "中"
	t.Log(len(s)) // 3 存储的是 byte 数

	c := []rune(s)
	t.Log(len(c)) // 1
	// t.Log("run size:", unsafe.Sizeof(c[0])) // run size: 4

	t.Logf("中 unicode %x", c[0]) // 中 unicode 4e2d
	t.Logf("中 utf8 %x", s)       // 中 utf8 e4b8ad
}
func TestString(t *testing.T) {
	var s string
	t.Log(s) // 初始化为默认零值

	s = "hello"
	t.Log(len(s)) // 5

	// string 是不可变的 byte 切片
	// s[1] = '3' // cannot assign to s[1] (value of type byte)

	s = "\xE4\xB8\xA5" // 可以存储二进制数据
	t.Log(s)           // 严

	s = "中"
	t.Log(len(s)) // 3 存储的是 byte 数

	c := []rune(s)
	t.Log(len(c)) // 1
	// t.Log("run size:", unsafe.Sizeof(c[0])) // run size: 4

	t.Logf("中 unicode %x", c[0]) // 中 unicode 4e2d
	t.Logf("中 utf8 %x", s)       // 中 utf8 e4b8ad
}

Unicode UTF8

  • Unicode 是一种字符集（code point）
  • UTF8 是 unicode 的存储实现（转换为字节序列的规则）

编码与存储 ​

字符“中”
Unicode0x4E2D
UTF-80xE4B8AD
string/[]byte[0xE4, 0xB8, 0xAD]
go
func TestStringToRune(t *testing.T) {
	s := "中华人民共和国"

	for _, c := range s {
		t.Logf("%[1]c %[1]d", c)
		// 中 20013
		// 华 21326
		// 人 20154
		// 民 27665
		// 共 20849
		// 和 21644
		// 国 22269
	}
}
func TestStringToRune(t *testing.T) {
	s := "中华人民共和国"

	for _, c := range s {
		t.Logf("%[1]c %[1]d", c)
		// 中 20013
		// 华 21326
		// 人 20154
		// 民 27665
		// 共 20849
		// 和 21644
		// 国 22269
	}
}

阮一峰博客-字符串编码

常用字符串处理函数 ​

go
func TestStringFn(t *testing.T) {
	s := "A,B,C"

	parts := strings.Split(s, ",")
	for _, part := range parts {
		t.Log(part)
		// A
		// B
		// C
	}

	t.Log(strings.Join(parts, "-")) // A-B-C
}

func TestStringConv(t *testing.T) {
	s := strconv.Itoa(10)

	t.Log("str" + s) // str10

	if i, err := strconv.Atoi("10"); err == nil {
		t.Log(10 + i) // 20
	}
}
func TestStringFn(t *testing.T) {
	s := "A,B,C"

	parts := strings.Split(s, ",")
	for _, part := range parts {
		t.Log(part)
		// A
		// B
		// C
	}

	t.Log(strings.Join(parts, "-")) // A-B-C
}

func TestStringConv(t *testing.T) {
	s := strconv.Itoa(10)

	t.Log("str" + s) // str10

	if i, err := strconv.Atoi("10"); err == nil {
		t.Log(10 + i) // 20
	}
}

04. 函数 ​

Go 语言中的函数 ​

函数是一等公民。

  • 可以多有多个返回值；
  • 所有参数都是值传递；
    • slice、map、channel 也是值传递
  • 函数可以作为变量的值；
  • 函数可以作为参数和返回值。
go

func returnMultiValues() (int, int) {
	return rand.Intn(10), rand.Intn(20)
}

func timeSpent(inner func(op int) int) func(op int) int {
	return func(n int) int {
		start := time.Now()
		ret := inner(n)
		fmt.Println("time spent:", time.Slice(start).Seconds())
		return ret
	}
}

func slowFn(op int) int {
	time.Sleep(time.Second * 1)
	return op
}

func TestFn(t *testing.T) {
	a, _ := returnMultiValues()
	t.Log(a) // 1

	tsSF := timeSpent(slowFn)
	t.Log(tsSF(10))
}

func returnMultiValues() (int, int) {
	return rand.Intn(10), rand.Intn(20)
}

func timeSpent(inner func(op int) int) func(op int) int {
	return func(n int) int {
		start := time.Now()
		ret := inner(n)
		fmt.Println("time spent:", time.Slice(start).Seconds())
		return ret
	}
}

func slowFn(op int) int {
	time.Sleep(time.Second * 1)
	return op
}

func TestFn(t *testing.T) {
	a, _ := returnMultiValues()
	t.Log(a) // 1

	tsSF := timeSpent(slowFn)
	t.Log(tsSF(10))
}

推荐书籍：《计算器程序的构造和解释》。

可变参数和defer ​

可变参数

go
func Sum(ops ...int) int {
	ret := 0

	for _, op := range ops {
		ret += op
	}

	return ret
}

func TestVarParam(t *testing.T) {
	t.Log(Sum(1, 2, 3, 4))    // 10
	t.Log(Sum(1, 2, 3, 4, 5)) // 15
}
func Sum(ops ...int) int {
	ret := 0

	for _, op := range ops {
		ret += op
	}

	return ret
}

func TestVarParam(t *testing.T) {
	t.Log(Sum(1, 2, 3, 4))    // 10
	t.Log(Sum(1, 2, 3, 4, 5)) // 15
}

defer

go
func Clear() {
	fmt.Println("Clear resources.")
}

func TestDefer(t *testing.T) {
	defer Clear()
	fmt.Println("Start")
	panic("err")
}

// Star
// Clear resources
func Clear() {
	fmt.Println("Clear resources.")
}

func TestDefer(t *testing.T) {
	defer Clear()
	fmt.Println("Start")
	panic("err")
}

// Star
// Clear resources

05. 面向对象编程 ​

https://golang.org/doc/faq

行为定义和实现 ​

结构体定义

go
type Employee struct {
	Id   string
	Name string
	Age  int
}
type Employee struct {
	Id   string
	Name string
	Age  int
}

实例创建及初始化

go
func TestCreateEmployeeObj(t *testing.T) {
	e1 := Employee{"0", "Bob", 20}
	e2 := Employee{Name: "Mike", Age: 25}
	e3 := new(Employee) // 返回指针

	e3.Id = "3"
	e3.Age = 22
	e3.Name = "Rose"

	t.Log(e1)              // {0 Bob 20}
	t.Log(e2)              // { Mike 25}
	t.Log(e2.Id)           //
	t.Log(e3)              // &{3 Rose 22}
	t.Logf("e2 is %T", e2) // e2 is encap.Employee
	t.Logf("e3 is %T", e3) // e3 is *encap.Employee
}
func TestCreateEmployeeObj(t *testing.T) {
	e1 := Employee{"0", "Bob", 20}
	e2 := Employee{Name: "Mike", Age: 25}
	e3 := new(Employee) // 返回指针

	e3.Id = "3"
	e3.Age = 22
	e3.Name = "Rose"

	t.Log(e1)              // {0 Bob 20}
	t.Log(e2)              // { Mike 25}
	t.Log(e2.Id)           //
	t.Log(e3)              // &{3 Rose 22}
	t.Logf("e2 is %T", e2) // e2 is encap.Employee
	t.Logf("e3 is %T", e3) // e3 is *encap.Employee
}

行为（方法）定义

go
// 在实例对应方法被调用时，实例的成员会进行值复制
func (e Employee) String1() string {
	return fmt.Sprintf("ID:%s-Name:%s-Age:%d", e.Id, e.Name, e.Age)
}

// 为了避免内存拷贝，我们可以使用这种定义方式
func (e *Employee) String2() string {
	return fmt.Sprintf("ID:%s-Name:%s-Age:%d", e.Id, e.Name, e.Age)
}

func TestStructOperations(t *testing.T) {
	e1 := Employee{"0", "Bob", 20}
	t.Log(e1.String1()) // ID:0-Name:Bob-Age:20

	e2 := &Employee{"0", "Bob", 20}
	t.Log(e2.String2()) // D:0-Name:Bob-Age:20
}
// 在实例对应方法被调用时，实例的成员会进行值复制
func (e Employee) String1() string {
	return fmt.Sprintf("ID:%s-Name:%s-Age:%d", e.Id, e.Name, e.Age)
}

// 为了避免内存拷贝，我们可以使用这种定义方式
func (e *Employee) String2() string {
	return fmt.Sprintf("ID:%s-Name:%s-Age:%d", e.Id, e.Name, e.Age)
}

func TestStructOperations(t *testing.T) {
	e1 := Employee{"0", "Bob", 20}
	t.Log(e1.String1()) // ID:0-Name:Bob-Age:20

	e2 := &Employee{"0", "Bob", 20}
	t.Log(e2.String2()) // D:0-Name:Bob-Age:20
}

值接收者和指针接收者

值接收者声明的方法，调用时使用的时这个值的副本；

指针接收者声明的方法，调用时共享这个值。

接口定义和实现 ​

接口与依赖

go
// Duck Type 式接口实现
type Programmer interface {
	WriteHelloWorld() string
}

type GoProgrammer struct {
}

func (g *GoProgrammer) WriteHelloWorld() string {
	return "fmt.Println(\"Hello World\")"
}

func TestClient(t *testing.T) {
	p := new(GoProgrammer) // interface implement

	t.Log(p.WriteHelloWorld()) // fmt.Println("Hello World")
}
// Duck Type 式接口实现
type Programmer interface {
	WriteHelloWorld() string
}

type GoProgrammer struct {
}

func (g *GoProgrammer) WriteHelloWorld() string {
	return "fmt.Println(\"Hello World\")"
}

func TestClient(t *testing.T) {
	p := new(GoProgrammer) // interface implement

	t.Log(p.WriteHelloWorld()) // fmt.Println("Hello World")
}
  • 接口为非入侵性，实现不依赖于接口定义
  • 接口定义可以包含在接口使用者包内

接口变量

go
var prog Coder = &GoProgrammer{}

// prog 类型
type GoProgrammer struct {}

// prog 数据
type &GoProgrammer{}
var prog Coder = &GoProgrammer{}

// prog 类型
type GoProgrammer struct {}

// prog 数据
type &GoProgrammer{}

自定义类型

go
type IntConv func(op int) int

func timeSpent(inner IntConv) IntConv {
	return func(n int) int {
		start := time.Now()
		ret := inner(n)
		fmt.Println("time spent:", time.Slice(start).Seconds())
		return ret
	}
}
type IntConv func(op int) int

func timeSpent(inner IntConv) IntConv {
	return func(n int) int {
		start := time.Now()
		ret := inner(n)
		fmt.Println("time spent:", time.Slice(start).Seconds())
		return ret
	}
}

扩展与复用 ​

面向对象的扩展通常可以通过复合或者继承来实现，Go 不支持继承。

go
type Pet struct {
}

func (p *Pet) Speak() {
	fmt.Print(("..."))
}

func (p *Pet) SpeakTo(host string) {
	p.Speak()
	fmt.Println("", host)
}

type Dog struct {
	p *Pet
}

func (d *Dog) Speak() {
	d.p.Speak()
}

func (d *Dog) SpeakTo(host string) {
	d.p.SpeakTo(host)
}

func TestDod(t *testing.T) {
	dog := new(Dog)
	dog.SpeakTo("Wang Wang") // ... Wang Wang
}
type Pet struct {
}

func (p *Pet) Speak() {
	fmt.Print(("..."))
}

func (p *Pet) SpeakTo(host string) {
	p.Speak()
	fmt.Println("", host)
}

type Dog struct {
	p *Pet
}

func (d *Dog) Speak() {
	d.p.Speak()
}

func (d *Dog) SpeakTo(host string) {
	d.p.SpeakTo(host)
}

func TestDod(t *testing.T) {
	dog := new(Dog)
	dog.SpeakTo("Wang Wang") // ... Wang Wang
}

复合需要重新定义方法，这样看起来也比较自然。其次我们还可以使用匿名嵌套类型简化整个过程。

go
type Pet struct {
}

func (p *Pet) Speak() {
	fmt.Print(("..."))
}

func (p *Pet) SpeakTo(host string) {
	p.Speak()
	fmt.Println("", host)
}

type Dog struct {
	Pet
}

func TestDod(t *testing.T) {
	dog := new(Dog)
	dog.SpeakTo("Wang Wang") // ... Wang Wang
}
type Pet struct {
}

func (p *Pet) Speak() {
	fmt.Print(("..."))
}

func (p *Pet) SpeakTo(host string) {
	p.Speak()
	fmt.Println("", host)
}

type Dog struct {
	Pet
}

func TestDod(t *testing.T) {
	dog := new(Dog)
	dog.SpeakTo("Wang Wang") // ... Wang Wang
}

网上很多文章说 Go 的继承是这样实现的，其实这种说法并不准确。

go
// ...

type Dog struct {
	Pet
}

func (d *Dog) Speak() {
	fmt.Print("Wang!")
}

func TestGog(t *testing.T) {
	 var dog Pet := new(Dog)
	dog.SpeakTo("Wang Wang")	 
}
// ...

type Dog struct {
	Pet
}

func (d *Dog) Speak() {
	fmt.Print("Wang!")
}

func TestGog(t *testing.T) {
	 var dog Pet := new(Dog)
	dog.SpeakTo("Wang Wang")	 
}

在 Java 中上述代码是可以正常运行的，在 Go 中这样的写法并不正确，不能实现重载，且无法支持强制类型转换。

接口类型与多态 ​

空接口与断言

  • 空接口可以表示任何类型
  • 通过断言来将空接口转换为指定类型
go
v, ok := p.(int) // ok=true 时表示转换成功
v, ok := p.(int) // ok=true 时表示转换成功
go
func DoSometing(p interface{}) {
	if i, ok := p.(int); ok {
		fmt.Println("Integer", i)
		return
	}
	if s, ok := p.(string); ok {
		fmt.Println("String", s)
		return
	}
	fmt.Println("Unknow Type")
}

func TestEmptyInterfaceAssertion(t *testing.T) {
	DoSometing(10)   // Integer 10
	DoSometing("10") // String 10
}
func DoSometing(p interface{}) {
	if i, ok := p.(int); ok {
		fmt.Println("Integer", i)
		return
	}
	if s, ok := p.(string); ok {
		fmt.Println("String", s)
		return
	}
	fmt.Println("Unknow Type")
}

func TestEmptyInterfaceAssertion(t *testing.T) {
	DoSometing(10)   // Integer 10
	DoSometing("10") // String 10
}

我们可以使用 switch 语句简化上面的程序：

go
 func DoSometing(p interface{}) {
	// if i, ok := p.(int); ok {
	// 	fmt.Println("Integer", i)
	// 	return
	// }
	// if s, ok := p.(string); ok {
	// 	fmt.Println("String", s)
	// 	return
	// }
	// fmt.Println("Unknow Type")

	switch v := p.(type) {
	case int:
		fmt.Println("Integer", v)
	case string:
		fmt.Println("String", v)
	default:
		fmt.Println("Unknow Type")
	}
}

func TestEmptyInterfaceAssertion(t *testing.T) {
	DoSometing(10)   // Integer 10
	DoSometing("10") // String 10
}
 func DoSometing(p interface{}) {
	// if i, ok := p.(int); ok {
	// 	fmt.Println("Integer", i)
	// 	return
	// }
	// if s, ok := p.(string); ok {
	// 	fmt.Println("String", s)
	// 	return
	// }
	// fmt.Println("Unknow Type")

	switch v := p.(type) {
	case int:
		fmt.Println("Integer", v)
	case string:
		fmt.Println("String", v)
	default:
		fmt.Println("Unknow Type")
	}
}

func TestEmptyInterfaceAssertion(t *testing.T) {
	DoSometing(10)   // Integer 10
	DoSometing("10") // String 10
}

Go 接口最佳实践

倾向于使用小的接口定义，很多接口只包含一个方法。

go
type Reader interface {
  Read(p []byte)(n int, err error)
}
type Writer interface {
  write(p []byte)(n int, err error)
}
type Reader interface {
  Read(p []byte)(n int, err error)
}
type Writer interface {
  write(p []byte)(n int, err error)
}

较大的接口定义，可以由多个小接口定义组合而成。

go
type ReadWriter interface {
  Reader,
  Writer
}
type ReadWriter interface {
  Reader,
  Writer
}

只依赖于必要功能的最小接口。

go
func StoreData(reader Reader) error {
  ...
}
func StoreData(reader Reader) error {
  ...
}

06. 错误处理 ​

Go 的错误机制 ​

  • 没有异常机制；
  • error 类型实现 error 接口；
  • 可以通过 errors.New 来快速创建错误实例。
go
type error interface {
  Error() string
}

errors.New("n must be in the range [0, 10]")
type error interface {
  Error() string
}

errors.New("n must be in the range [0, 10]")

最佳实践 1 ​

go
func getFibonacci(n int) ([]int, error) {
	if n < 2  || n > 100 {
		return nil, errors.New("n should be in [2, 100]")
	}

	fibList := []int{1, 1}

	for i := 2; i < n; i++ {
		fibList = append(fibList, fibList[i-2]+fibList[i-1])
	}

	return fibList, nil
}

func TestFibonacci(t *testing.T) {
	t.Log(getFibonacci(10)) // [1 1 2 3 5 8 13 21 34 55]

	if v, err := getFibonacci(-10); err != nil {
		t.Error(err)
	} else {
		t.Log(v)
	}
}
func getFibonacci(n int) ([]int, error) {
	if n < 2  || n > 100 {
		return nil, errors.New("n should be in [2, 100]")
	}

	fibList := []int{1, 1}

	for i := 2; i < n; i++ {
		fibList = append(fibList, fibList[i-2]+fibList[i-1])
	}

	return fibList, nil
}

func TestFibonacci(t *testing.T) {
	t.Log(getFibonacci(10)) // [1 1 2 3 5 8 13 21 34 55]

	if v, err := getFibonacci(-10); err != nil {
		t.Error(err)
	} else {
		t.Log(v)
	}
}

代码优化

go
var LessThanTwoError = errors.New("n should be not less than 2")
var LargetThanHundredError = errors.New("n should be not larger than 100")

func getFibonacci(n int) ([]int, error) {
	if n < 2 {
		return nil, LessThanTwoError
	}
	if n > 100 {
		return nil, LargetThanHundredError
	}

	fibList := []int{1, 1}

	for i := 2; i < n; i++ {
		fibList = append(fibList, fibList[i-2]+fibList[i-1])
	}

	return fibList, nil
}

func TestFibonacci(t *testing.T) {
	t.Log(getFibonacci(10)) // [1 1 2 3 5 8 13 21 34 55]

	if v, err := getFibonacci(-10); err != nil {
		if err == LessThanTwoError {
			fmt.Println("It is less.") // It is less.
		}
	} else {
		t.Log(v)
	}
}
var LessThanTwoError = errors.New("n should be not less than 2")
var LargetThanHundredError = errors.New("n should be not larger than 100")

func getFibonacci(n int) ([]int, error) {
	if n < 2 {
		return nil, LessThanTwoError
	}
	if n > 100 {
		return nil, LargetThanHundredError
	}

	fibList := []int{1, 1}

	for i := 2; i < n; i++ {
		fibList = append(fibList, fibList[i-2]+fibList[i-1])
	}

	return fibList, nil
}

func TestFibonacci(t *testing.T) {
	t.Log(getFibonacci(10)) // [1 1 2 3 5 8 13 21 34 55]

	if v, err := getFibonacci(-10); err != nil {
		if err == LessThanTwoError {
			fmt.Println("It is less.") // It is less.
		}
	} else {
		t.Log(v)
	}
}

最佳实践2 ​

go
func getFibonacci2(str string) {
	var (
		i    int
		err  error
		list []int
	)

	if i, err = strconv.Atoi(str); err == nil {
		if list, err = getFibonacci(i); err == nil {
			fmt.Println(list)
		} else {
			fmt.Println("Error", err)
		}
	} else {
		fmt.Println("Error", err)
	}
}
func getFibonacci2(str string) {
	var (
		i    int
		err  error
		list []int
	)

	if i, err = strconv.Atoi(str); err == nil {
		if list, err = getFibonacci(i); err == nil {
			fmt.Println(list)
		} else {
			fmt.Println("Error", err)
		}
	} else {
		fmt.Println("Error", err)
	}
}

代码优化

go
func getFibonacci3(str string) {
	var (
		i    int
		err  error
		list []int
	)
	if i, err = strconv.Atoi(str); err != nil {
		fmt.Println("Error", err)
		return
	}
	if list, err = getFibonacci(i); err == nil {
		fmt.Println("Error", err)
		return
	}
	fmt.Println(list)
}
func getFibonacci3(str string) {
	var (
		i    int
		err  error
		list []int
	)
	if i, err = strconv.Atoi(str); err != nil {
		fmt.Println("Error", err)
		return
	}
	if list, err = getFibonacci(i); err == nil {
		fmt.Println("Error", err)
		return
	}
	fmt.Println(list)
}

错误优先机制，代码更易读。

panic 和 recover ​

panic ​

  • panic 用于不可恢复的错误；
  • panic 退出前会执行 defer 指定的内容。

panic vs os.Exit

  • os.Exit 退出时不会调用 defer 指定的函数；
  • os.Exit 退出时不输出当前调用栈信息。
go
func TestPanicVxExit(t *testing.T) {
	defer func() {
		fmt.Println("Finally!")
	}()

	fmt.Println("Start")
	// os.Exit(-1)
	panic(errors.New("Something wrong!"))
}
func TestPanicVxExit(t *testing.T) {
	defer func() {
		fmt.Println("Finally!")
	}()

	fmt.Println("Start")
	// os.Exit(-1)
	panic(errors.New("Something wrong!"))
}

recover ​

通过 recover 可以接收错误，进行恢复处理。

go
func TestPanicVxExit(t *testing.T) {
	defer func() {
		fmt.Println("Finally!")

		if err := recover(); err != nil {
			fmt.Println("recovered from", err) // recovered from Something wrong!
		}
	}()

	fmt.Println("Start")
	// os.Exit(-1)
	panic(errors.New("Something wrong!"))
}
func TestPanicVxExit(t *testing.T) {
	defer func() {
		fmt.Println("Finally!")

		if err := recover(); err != nil {
			fmt.Println("recovered from", err) // recovered from Something wrong!
		}
	}()

	fmt.Println("Start")
	// os.Exit(-1)
	panic(errors.New("Something wrong!"))
}

上述这种方式只是将错误接收，并记录，其实这样的修复方式是非常危险的。

  • 容易形成僵尸服务进程，导致 health check 失效；
  • “Let it Crash！” 往往是我们恢复不确定错误的最好方法。

07. 包和依赖管理 ​

构建可复用模块（包） ​

package ​

  • 基本复用模块单元
    • 以首字母大写来表明可被包外代码访问
  • 代码的 package 可以和所在的目录不一致
  • 同一目录里的 Go 代码的 package 要保持一致

如何使用 ​

通过 go get 来获取远程依赖

  • go get -u 强制从网络更新远程依赖

注意代码在 GitHub 上的组织形式，以适应 go get

  • 直接以代码路径开始，不要有 src
go
// src/ch15/series/series.g

package series

// 大写的函数名才可以在包外被调用
func GetFibonacciSeries(n int) []int {
	ret := []int{1, 1}
	for i := 2; i < n; i++ {
		ret = append(ret, ret[i-2]+ret[i-1])
	}
	return ret
}
// src/ch15/series/series.g

package series

// 大写的函数名才可以在包外被调用
func GetFibonacciSeries(n int) []int {
	ret := []int{1, 1}
	for i := 2; i < n; i++ {
		ret = append(ret, ret[i-2]+ret[i-1])
	}
	return ret
}
go
// src/ch15/client/client_test.go

package client_test

import (
	"plus/src/ch15/series"
	"testing"
)

func TestPackage(t *testing.T) {
	t.Log(series.GetFibonacciSeries(5)) // [1 1 2 3 5]
}
// src/ch15/client/client_test.go

package client_test

import (
	"plus/src/ch15/series"
	"testing"
)

func TestPackage(t *testing.T) {
	t.Log(series.GetFibonacciSeries(5)) // [1 1 2 3 5]
}

init 方法 ​

  • 在 main 被执行前，所有依赖的 package 的 init 方法都会被执行；
  • 不同包的 init 函数按照包导入的依赖关系决定执行顺序；
  • 每个包可以有多个 init 函数；
  • 包的每个源文件也可以有多个 init 函数。

使用第三方包 ​

go
package remote_test

import (
	"testing"

	cm "github.com/easierway/concurrent_map"
)

func TestConcurrentMap(t *testing.T) {
	m := cm.CreateConcurrentMap(99)
	m.Set(cm.StrKey("key"), 10)

	t.Log(m.Get(cm.StrKey("key")))
}
package remote_test

import (
	"testing"

	cm "github.com/easierway/concurrent_map"
)

func TestConcurrentMap(t *testing.T) {
	m := cm.CreateConcurrentMap(99)
	m.Set(cm.StrKey("key"), 10)

	t.Log(m.Get(cm.StrKey("key")))
}

可以使用 go mod tidy 命令自动分析依赖并下载。

依赖管理 ​

未解决的依赖问题 ​

  • 同一环境下，不同项目使用同一包的不同版本
  • 无法管理对包的特定版本的依赖

vendor 路径 ​

随着 Go 1.5 release 版本的发布，vendor 目录被添加到除 GOPATH 和 GOROOT 之外的依赖目录查找的解决方案。在 Go 1.6 之前，你需要手动设置环境变量。

查找依赖包路径的解决方案如下：

  • 当前包下的 vendor 目录；
  • 向上级目录查找，直到找到 src 下的 vendor 目录；
  • 在 GOPATH 下面查找依赖包；
  • 在 GOROOT 目录下查找。

常见的依赖管理工具 ​

godep https://github.com/tools/godep

glide https://github.com/Masterminds/glide

dep https://github.com/golang/dep

08. 并发编程 ​

协程机制 ​

Thread vs Groutine ​

创建时默认的 stack 的大小

  • JDK 以后 Java Thread stack 默认为 1M；
  • Groutine 的 Stack 初始化大小为 2K。

和 KSE（Kernel Space Entity）的对应关系

  • Java Thread 时 1:1
  • Groutine 是 M:N

多对多关系简图，thread 与 kernel entity 一对一关系。

Processor 在不同的系统线程里，但是每个 Processor 都挂载一个准备运行的协程队列。Processor 会依次运行协程。

如果一个协程运行的时间特别长，那么在队列中的其他协程是不是就会延迟很久？

其实在 Go 启动的时候会有一个守护线程对 Processor 进行计数，记录每个 Processor 完成的数量。当一段时间守护线程发现 Processor 完成的协程数量没有变化，它就会往协程的任务栈中插入一个特殊的标记，当协程运行时遇到非内联函数 ，读到这个标记，就会中断下来，等候到协程队尾切换到别的协程继续运行。

当某一个协程被系统中断，例如 IO， 需要等待的时候。为了提高整体的并发，Processor 会把自己移动到另一个可使用的系统线程中继续执行它所挂载的其他协程。 当被中断的协程被唤醒完成之后，它会把自己加入到其中某一个 Processor 的队列中，后者加入到全局等待队列中。

当协程被中断后，它在寄存器中的运行状态也会保存到这个对象里，当协程被唤醒时，这些信息也会重新写入寄存器，继续运行。

代码案例 ​

go
func TestGroutine(t *testing.T) {
	for i := 0; i < 10; i++ {
		// 使用 go 关键词启动协程运行程序
		go func(i int) {
			fmt.Println(i)
		}(i)
	}
	time.Sleep(time.Microsecond * 50)
}
func TestGroutine(t *testing.T) {
	for i := 0; i < 10; i++ {
		// 使用 go 关键词启动协程运行程序
		go func(i int) {
			fmt.Println(i)
		}(i)
	}
	time.Sleep(time.Microsecond * 50)
}

每次运行的结果都是不一致的，因为协程运行并不是按照指定顺序执行的。

共享内存并发机制 ​

Lock ​

锁机制，对于 Java 和 C++ 程序员都很常见。

java
Lock lock = ...;
lock.lock()
try {
  
} catch (Exception ex) {
  
} finally {
  lock.unlock()
}
Lock lock = ...;
lock.lock()
try {
  
} catch (Exception ex) {
  
} finally {
  lock.unlock()
}

Copyright © 2023-月落 版权所有