前言:
初识go语言不到半年,我是一次偶然的机会认识了golang这门语言,看到他简洁的语法风格和强大的语言特性,瞬间有了学习他的兴趣。我是很看好go这样的语言的,一方面因为他有谷歌主推,另一方面他确实有用武之地,高并发就是他的长处。现在的国内完全使用go开发的项目还不是很多,从这个上面可以看到:链接https://github.com/qiniu/go/issues/15,据我了解七牛云存储应该是第一个完全使用go开发的大型项目,其中七牛云的CEO许世伟是公认的go专家,同时也是《go语言编程》的作者,另外美团、小米、360、新浪等公司或多或少都有go语言的使用。
在我看来go是一门值得去学习去学习的语言。我本来是学习php的,有人会第一时间反驳我,php学习的咋样啊,就慌着去学习其他语言,我想说的是这不冲突,作为一个后端开发者,只会php一门脚本式的弱类型语言是远远不够的,这里不是说php语言不好。php有php的好,编译语言,强类型语言也自有他的优势所在,而服务器端开发者需要在并发,多线程上有所涉猎,总不能5年8年之后还写php吧,你要知道好多的架构师是没有语言的限制的。我就是一个不安分的人,不喜欢按部就班的生活,趁现在还年轻,喜欢啥就会全力去学习,好了,扯淡的话就说这么多。
这篇博客写的是go语言中的channel,之所以写他是因为我感觉channel很重要,同时channel也是go并发的重要支撑点,因为go是使用消息传递共享内存而不是使用共享内存来通信。并发编程是非常好的,但是并发是非常复杂的,难点在于协调,怎样处理各个程序间的通信是非常重要的。写channel的使用和特性之前我们需要回顾操作系统中的进程间的通信。
进程间的通信
在工程上一般通信模型有两种:共享数据和消息。进程通信顾名思义是指进程间的信息交换,因为进程的互斥和同步就需要进程间交换信息,学过操作系统的人都知道进程通信大致上可以分为低级进程通信和高级进程通信,现在基本上都是高级进程通信。其中高级通信机制又可以分为:消息传递系统、共享存储器系统、管道通信系统和客户机服务器系统。
1、消息传递系统
他不借助任何共享存储区或着某一种数据结构,他是以格式化的消息为单位利用系统提供的通信原语完成数据交换,感觉效率底下。
2、共享存储器系统
通信的进程共享存储区或者数据结构,进程通过这些空间进行通信,这种方式比较常见,比如某一个文件作为载体。
3、客户机服务器系统
其他几种通信机制基本上都是在同一个计算机上(可以说是同一环境),当然在一些情况下可以实现跨计算机通信。而客户机-服务器系统是不一样的,我的理解是可以当做ip请求,一个客户机请求连接到一台服务器。这种方式在网络上是现在比较流行的,现在比较常用的远程调度,如不RPC(听着很高大上,其实在操作系统上早就有了)还有套接字、socket,这种还是比较常用的,与我们编程紧密相关的,因为你会发现好多的服务需要使用RPC调用。
4、管道通信系
最后详细说一下管道通信的机制,在操作系统级别管道是指用于链接一个读进程和一个写进程来实现他们之间通信的文件。系统上叫pipe文件。实现的机制如:管道提供了下面的二个功能,1、互斥性,当一个进程正在对一个pipe文件执行读或者写操作时,其他的进程必须等待或阻塞或睡眠。2、同步性,当写(输入)进程写入pipe文件后会等待或者阻塞或者睡眠,直到读(输出)进程取走数据后把他唤醒,同理,当读进程去读一个空的pipe文件时也会等待或阻塞或睡眠,直到写进程写入pipe后把他唤醒。
channel的使用
好了,上面花了不少的篇幅写了进程间通信的几种方式,我们再回过来看看channel,对应到go中的channel应该是第四种,go语言的channel是在语言级别提供的goroutine间通信的方式。单独说channel是没有任何意义的,因为他和goroutine一起才有效果,我们先看看一般语言解决程序间共享内存的方法,下面是一段我们熟悉的程序,什么也不会输出,我刚学习的时候认为会输出东西,但是实际不是这样,当是感到一脸懵逼。
1 package main
2
3 import "fmt"
4
5 var counts int = 0
6
7 func Count() {
8 counts++
9 fmt.Println(counts)
10 }
11 func main() {
12
13 for i := 0; i < 3; i++ {
14 go Count()
15 }
16 }
学过go的人都应该知道原因,因为:Go程序从初始化main() 方法和package,然后执行main()函数,但是当main()函数返回时,程序就会退出,主程序并不等待其他goroutine的,导致没有任何输出。我们看看常规语言是怎样解决这种并发的问题的:
1 package main
2
3 import "fmt"
4 import "sync"
5 import "runtime"
6
7 var counts int = 0
8
9 func Count(lock *sync.Mutex) {
10 lock.Lock()
11 counts++
12 fmt.Println(counts)
13 lock.Unlock()
14 }
15 func main() {
16 lock := &sync.Mutex{}
17
18 for i := 0; i < 3; i++ {
19 go Count(lock)
20 }
21
22 for {
23 lock.Lock()
24 c := counts
25 lock.Unlock()
26
27 runtime.Gosched()
28
29 if c >= 3 {
30 break
31 }
32
33 }
34 }
解决方式有点逗比,加了一堆的锁,因为他的执行是这样的:代码中的lock变量,每次对counts的操作,都要先将他锁住,操作完成后,再将锁打开,在主函数中,使用for循环来不断检查counter的值当然同样也要加锁。当其值达到3时,说明所有goroutine都执行完毕了,这时主函数返回,然后程序退出。这种方式是大众语言解决并发的首选方式,可以看到为了解决并发,多写了好多的东西,如果一个初具规模的项目,不知道要加多少锁。
我们看看channel是如何解决这种问题的:
1 package main
2
3 import "fmt"
4
5 var counts int = 0
6
7 func Count(i int, ch chan int) {
8 fmt.Println(i, "WriteStart")
9 ch <- 1
10 fmt.Println(i, "WriteEnd")
11 fmt.Println(i, "end", "and echo", i)
12 counts++
13 }
14
15 func main() {
16 chs := make([]chan int, 3)
17 for i := 0; i &