在閱讀kafka的golang 客戶端代碼sarama-cluster時，遇到了如下一段代碼：
// Messages returns the read channel for the messages that are returned by
// the broker.
//
// This channel will only return if Config.Group.Mode option is set to
// ConsumerModeMultiplex (default).
func (c *Consumer) Messages() -chan *sarama.ConsumerMessage { return c.messages }
對于代碼中的-chan *sarama.ConsumerMessage產(chǎn)生了疑問，這個是什么意思呢？
經(jīng)查閱資料，得知上面返回的是一個read-only類型的channel，即只讀的管道。
驗證：
package main
import (
"fmt"
)
type C struct {
Name string
}
type D struct {
Id chan C
}
func (d *D)A() chan C {
return d.Id
}
func main() {
c := C{
Name: "test",
}
ch := make(chan C, 10)
ch - c
d := D{
Id: ch,
}
r := d.A()
r - c
for i:=0;i=len(r);i++ {
fmt.Printf("%v", -r)
}
}
創(chuàng)建func A() chan C {}, 在調(diào)用A()后，返回值r為channel， 其仍可以寫入對象c，輸出結(jié)果為：
{test}{test}
Process finished with exit code 0
package main
import (
"fmt"
)
type C struct {
Name string
}
type D struct {
Id chan C
}
func (d *D)A() -chan C {
return d.Id
}
func main() {
c := C{
Name: "test",
}
ch := make(chan C, 10)
ch - c
d := D{
Id: ch,
}
r := d.A()
r - c
for i:=0;i=len(r);i++ {
fmt.Printf("%v", -r)
}
}
創(chuàng)建func A() -chan C {}, 在調(diào)用A()后，返回值r為channel， 但無法向r中寫入對象c，會報語法錯誤，輸出結(jié)果為：
# command-line-arguments
.\test2.go:29:7: invalid operation: r - c (send to receive-only type -chan C)
Compilation finished with exit code 2
同理， 如果返回類型為 chan- type，則返回的是write-only類型的channel，即只能寫不能讀。
如何聲明和初始化單向channel
var ch1 chan- int // 聲明ch1，只用于寫int數(shù)據(jù)
var ch2 -chan int // 聲明ch2，只用于讀int數(shù)據(jù)
ch3 := make(chan- int, 10) // 初始化一個只寫的channel
ch4 := make(-chan int, 10) // 初始化一個只讀的chaannel
補充：golang chan- 和 -chan，作為函數(shù)參數(shù)時
開始時看到這個實在沒明白怎么回事
測試了下才知道原來
-chan int 像這樣的只能接收值
chan- int 像這樣的只能發(fā)送值
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方，望不吝賜教。
您可能感興趣的文章:- Golang 空map和未初始化map的注意事項說明
- Golang 如何判斷數(shù)組某個元素是否存在 (isset)
- Go語言的Channel遍歷方法詳解
- Golang 拷貝Array或Slice的操作
- 基于Go Int轉(zhuǎn)string幾種方式性能測試
- Go語言中break label與goto label的區(qū)別
- Go 實現(xiàn)英尺和米的簡單單位換算方式
