Go提供了一種稱為通道的機(jī)制，用于在goroutine之間共享數(shù)據(jù)。當(dāng)您作為goroutine執(zhí)行并發(fā)活動時(shí)，需要在goroutine之間共享資源或數(shù)據(jù)，通道充當(dāng)goroutine之間的管道（管道）并提供一種機(jī)制來保證同步交換。
創(chuàng)新互聯(lián)建站主要從事成都做網(wǎng)站、成都網(wǎng)站設(shè)計(jì)、網(wǎng)頁設(shè)計(jì)、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)上杭,10多年網(wǎng)站建設(shè)經(jīng)驗(yàn),價(jià)格優(yōu)惠、服務(wù)專業(yè),歡迎來電咨詢建站服務(wù):028-86922220
根據(jù)數(shù)據(jù)交換的行為，有兩種類型的通道：無緩沖通道和緩沖通道。無緩沖通道用于執(zhí)行g(shù)oroutine之間的同步通信，而緩沖通道用于執(zhí)行異步通信。無緩沖通道保證在發(fā)送和接收發(fā)生的瞬間兩個(gè)goroutine之間的交換。緩沖通道沒有這樣的保證。
通道由make函數(shù)創(chuàng)建，該函數(shù)指定chan關(guān)鍵字和通道的元素類型。
這是創(chuàng)建無緩沖和緩沖通道的代碼塊：
語法
使用內(nèi)置函數(shù)make創(chuàng)建無緩沖和緩沖通道。make的第一個(gè)參數(shù)需要關(guān)鍵字chan，然后是通道允許交換的數(shù)據(jù)類型。
這是將值發(fā)送到通道的代碼塊需要使用-運(yùn)算符：
語法
一個(gè)包含5個(gè)值的緩沖區(qū)的字符串類型的goroutine1通道。然后我們通過通道發(fā)送字符串“Australia”。
這是從通道接收值的代碼塊：
語法
- 運(yùn)算符附加到通道變量（goroutine1）的左側(cè)，以接收來自通道的值。
在無緩沖通道中，在接收到任何值之前沒有能力保存它。在這種類型的通道中，發(fā)送和接收goroutine在任何發(fā)送或接收操作完成之前的同一時(shí)刻都準(zhǔn)備就緒。如果兩個(gè)goroutine沒有在同一時(shí)刻準(zhǔn)備好，則通道會讓執(zhí)行其各自發(fā)送或接收操作的goroutine首先等待。同步是通道上發(fā)送和接收之間交互的基礎(chǔ)。沒有另一個(gè)就不可能發(fā)生。
在緩沖通道中，有能力在接收到一個(gè)或多個(gè)值之前保存它們。在這種類型的通道中，不要強(qiáng)制goroutine在同一時(shí)刻準(zhǔn)備好執(zhí)行發(fā)送和接收。當(dāng)發(fā)送和接收阻塞時(shí)也有不同的條件。只有當(dāng)通道中沒有要接收的值時(shí)，接收才會阻塞。僅當(dāng)沒有可用緩沖區(qū)來放置正在發(fā)送的值時(shí)，發(fā)送才會阻塞。
實(shí)例
運(yùn)行結(jié)果
摘要： 一、前言 go語言類似Java JUC包也提供了一些列用于多線程之間進(jìn)行同步的措施，比如低級的同步措施有 鎖、CAS、原子變量操作類。相比Java來說go提供了獨(dú)特的基于通道的同步措施。本節(jié)我們先來看看go中CAS操作 二、CAS操作 go中的Cas操作與java中類似，都是借用了CPU提供的原子性指令來實(shí)現(xiàn)。
go語言類似Java JUC包也提供了一些列用于多線程之間進(jìn)行同步的措施，比如低級的同步措施有 鎖、CAS、原子變量操作類。相比Java來說go提供了獨(dú)特的基于通道的同步措施。本節(jié)我們先來看看go中CAS操作
go中的Cas操作與java中類似，都是借用了CPU提供的原子性指令來實(shí)現(xiàn)。CAS操作修改共享變量時(shí)候不需要對共享變量加鎖，而是通過類似樂觀鎖的方式進(jìn)行檢查，本質(zhì)還是不斷的占用CPU 資源換取加鎖帶來的開銷（比如上下文切換開銷）。下面一個(gè)例子使用CAS來實(shí)現(xiàn)計(jì)數(shù)器
go中CAS操作具有原子性，在解決多線程操作共享變量安全上可以有效的減少使用鎖所帶來的開銷，但是這是使用cpu資源做交換的。
我簡單列舉了并發(fā)編程的大綱，需要詳細(xì)的私信“555”~~
智能合約調(diào)用是實(shí)現(xiàn)一個(gè) DApp 的關(guān)鍵，一個(gè)完整的 DApp 包括前端、后端、智能合約及區(qū)塊 鏈系統(tǒng)，智能合約的調(diào)用是連接區(qū)塊鏈與前后端的關(guān)鍵。
我們先來了解一下智能合約調(diào)用的基礎(chǔ)原理。智能合約運(yùn)行在以太坊節(jié)點(diǎn)的 EVM 中。因此要 想調(diào)用合約必須要訪問某個(gè)節(jié)點(diǎn)。
以后端程序?yàn)槔?，后端服?wù)若想連接節(jié)點(diǎn)有兩種可能，一種是雙 方在同一主機(jī)，此時(shí)后端連接節(jié)點(diǎn)可以采用 本地 IPC(Inter-Process Communication，進(jìn) 程間通信)機(jī)制，也可以采用 RPC(Remote Procedure Call，遠(yuǎn)程過程調(diào)用)機(jī)制;另 一種情況是雙方不在同一臺主機(jī)，此時(shí)只能采用 RPC 機(jī)制進(jìn)行通信。
提到 RPC， 讀者應(yīng)該對 Geth 啟動參數(shù)有點(diǎn)印象，Geth 啟動時(shí)可以選擇開啟 RPC 服務(wù)，對應(yīng)的 默認(rèn)服務(wù)端口是 8545。。
接著，我們來了解一下智能合約運(yùn)行的過程。
智能合約的運(yùn)行過程是后端服務(wù)連接某節(jié)點(diǎn)，將 智能合約的調(diào)用(交易)發(fā)送給節(jié)點(diǎn)，節(jié)點(diǎn)在驗(yàn)證了交易的合法性后進(jìn)行全網(wǎng)廣播，被礦工打包到 區(qū)塊中代表此交易得到確認(rèn)，至此交易才算完成。
就像數(shù)據(jù)庫一樣，每個(gè)區(qū)塊鏈平臺都會提供主流 開發(fā)語言的 SDK(Software Development Kit，軟件開發(fā)工具包)，由于 Geth 本身就是用 Go 語言 編寫的，因此若想使用 Go 語言連接節(jié)點(diǎn)、發(fā)交易，直接在工程內(nèi)導(dǎo)入 go-ethereum(Geth 源碼) 包就可以了，剩下的問題就是流程和 API 的事情了。
總結(jié)一下，智能合約被調(diào)用的兩個(gè)關(guān)鍵點(diǎn)是節(jié)點(diǎn)和 SDK。
由于 IPC 要求后端與節(jié)點(diǎn)必須在同一主機(jī)，所以很多時(shí)候開發(fā)者都會采用 RPC 模式。除了 RPC，以太坊也為開發(fā)者提供了 json- rpc 接口，本文就不展開討論了。
接下來介紹如何使用 Go 語言，借助 go-ethereum 源碼庫來實(shí)現(xiàn)智能合約的調(diào)用。這是有固定 步驟的，我們先來說一下總體步驟，以下面的合約為例。
步驟 01:編譯合約，獲取合約 ABI(Application Binary Interface，應(yīng)用二進(jìn)制接口)。 單擊【ABI】按鈕拷貝合約 ABI 信息，將其粘貼到文件 calldemo.abi 中(可使用 Go 語言IDE 創(chuàng)建該文件，文件名可自定義，后綴最好使用 abi)。
最好能將 calldemo.abi 單獨(dú)保存在一個(gè)目錄下，輸入“l(fā)s”命令只能看到 calldemo.abi 文件，參 考效果如下:
步驟 02:獲得合約地址。注意要將合約部署到 Geth 節(jié)點(diǎn)。因此 Environment 選擇為 Web3 Provider。
在【Environment】選項(xiàng)框中選擇“Web3 Provider”，然后單擊【Deploy】按鈕。
部署后，獲得合約地址為:0xa09209c28AEf59a4653b905792a9a910E78E7407。
步驟 03:利用 abigen 工具(Geth 工具包內(nèi)的可執(zhí)行程序)編譯智能合約為 Go 代碼。abigen 工具的作用是將 abi 文件轉(zhuǎn)換為 Go 代碼，命令如下:
其中各參數(shù)的含義如下。 (1)abi:是指定傳入的 abi 文件。 (2)type:是指定輸出文件中的基本結(jié)構(gòu)類型。 (3)pkg:指定輸出文件 package 名稱。 (4)out:指定輸出文件名。 執(zhí)行后，將在代碼目錄下看到 funcdemo.go 文件，讀者可以打開該文件欣賞一下，注意不要修改它。
步驟 04:創(chuàng)建 main.go，填入如下代碼。 注意代碼中 HexToAddress 函數(shù)內(nèi)要傳入該合約部署后的地址，此地址在步驟 01 中獲得。
步驟 04:設(shè)置 go mod，以便工程自動識別。
前面有所提及，若要使用 Go 語言調(diào)用智能合約，需要下載 go-ethereum 工程，可以使用下面 的指令:
該指令會自動將 go-ethereum 下載到“$GOPATH/src/github.com/ethereum/go-ethereum”，這樣還算 不錯(cuò)。不過，Go 語言自 1.11 版本后，增加了 module 管理工程的模式。只要設(shè)置好了 go mod，下載 依賴工程的事情就不必關(guān)心了。
接下來設(shè)置 module 生效和 GOPROXY，命令如下:
在項(xiàng)目工程內(nèi)，執(zhí)行初始化，calldemo 可以自定義名稱。
步驟 05:運(yùn)行代碼。執(zhí)行代碼，將看到下面的效果，以及最終輸出的 2020。
上述輸出信息中，可以看到 Go 語言會自動下載依賴文件，這就是 go mod 的神奇之處。看到 2020，相信讀者也知道運(yùn)行結(jié)果是正確的了。
1、下載go的zip文件。并且一定要把文件解壓到c:\go目錄下。
2、配置windows的高級環(huán)境變量。包括：GOROOT、GOOS、GOBIN、GOARCH。并且在path變量里面把c:\go\bin加入。以便可以在命令行直接運(yùn)行g(shù)o命令。
舉例：我的機(jī)器：
GOPATH= c:\go;c:\go\src;F:\workspace\goSample01;
GOBIN=c:\go\bin;F:\workspace\goSample01\bin;
其中，c:\go是go的安裝路徑；
F:\workspace\goSample01是我寫的go語言項(xiàng)目的工程目錄；
F:\workspace\goSample01\bin是go語言項(xiàng)目的工程目錄下的可執(zhí)行文件路徑;
3、在完成環(huán)境變量配置后，打開一個(gè)命令行窗口，直接輸入go，然后回車，看看是否出現(xiàn)go的幫助信息。如果出現(xiàn)，那么go的基本環(huán)境就OK了。
注意：這個(gè)基本環(huán)境不包含開發(fā)工具，也不能直接編譯帶C代碼的go程序。
4、(可選)為了支持Import遠(yuǎn)程包，最好裝個(gè)gomingw。下載地址：。如果下的是壓縮包，請把它解壓到C盤。例如，C:\gowin-env。里面有個(gè)Console.bat是以后使用go get的環(huán)境。舉例：有個(gè)文件a.go,里面import(
"fmt"
"github.com/astaxie/beedb"
_ "github.com/ziutek/mymysql/godrv"
為了編譯該a.go文件，需要啟動Console.bat，然后在該命令行窗口，進(jìn)入c:\go\src目錄下，執(zhí)行g(shù)o getgithub.com/astaxie/beedb
Go get github.com/ziutek/mymysql/godrv .
Go會自動下載該遠(yuǎn)程包并編譯和安裝這些包。
配置goclipse（可選）
（如果不喜歡eclipse開發(fā)工具，請?zhí)^這個(gè)配置。）
1、下載并安裝goclipse插件。Goclipse是go語言for eclipse的插件，下載地址：
2、啟動eclipse并創(chuàng)建go項(xiàng)目。然后寫個(gè)最簡單的helloworld.go文件，并運(yùn)行。代碼如下：
packagemainimport"fmt"func main(){ fmt.Printf("hello, world")}
配置gocode（可選）
如果不需要go語法輔助和eclipse里面的（按ALT+/）彈出go語言自動輔助功能，請?zhí)^這個(gè)配置。
1、下載gocode的zip文件，解壓后放在go的bin目錄下。
2、下載并安裝Git軟件。并且在path里面配置git的執(zhí)行路徑。例如c:\git\bin
3、在命令行執(zhí)行：go build .\gocode。如果一切正常，那么將會編譯生成一個(gè)gocode.exe文件在go的bin目錄下。如果編譯失敗，那么就轉(zhuǎn)第4步。
4、如果第3步直接編譯gocode源文件成功，那就直接到第5步。否則，就需要通過git下載gocode源文件，然后再編譯。在命令行執(zhí)行：go get -u github.com/nsf/gocode 。就會生成gocode.exe文件。
5、在goclipse插件里面指定gocode的路徑。就可以在elcipse里面調(diào)用gocode來幫助寫編碼了。
從開發(fā)工具這塊看，go語言還不夠成熟，開發(fā)工具都還不完善，有待改進(jìn)。
下載go-tour教程源代碼（可選）
Google有個(gè)在線運(yùn)行g(shù)o語言的教程（），很不錯(cuò)。支持在web上直接運(yùn)行大部分的go程序，想了解這個(gè)教程的源代碼的朋友可以通過以下方式獲取。如果沒興趣，可以跳過這個(gè)步驟。
一般命令
所謂一般命令，就是在一定時(shí)間內(nèi)會執(zhí)行完的命令。比如 grep, cat 等等。 執(zhí)行命令的步驟是：連接，執(zhí)行，獲取結(jié)果
連接
連接包含了認(rèn)證，可以使用 password 或者 sshkey 2種方式來認(rèn)證。下面的示例為了簡單，使用了密碼認(rèn)證的方式來完成連接。
import (
"fmt"
"time"
"golang.org/x/crypto/ssh"
)
func connect(user, password, host string, port int) (*ssh.Session, error) {
var (
auth []ssh.AuthMethod
addr string
clientConfig *ssh.ClientConfig
client *ssh.Client
session *ssh.Session
err error
)
// get auth method
auth = make([]ssh.AuthMethod, 0)
auth = append(auth, ssh.Password(password))
clientConfig = ssh.ClientConfig{
User: user,
Auth: auth,
Timeout: 30 * time.Second,
}
// connet to ssh
addr = fmt.Sprintf("%s:%d", host, port)
if client, err = ssh.Dial("tcp", addr, clientConfig); err != nil {
return nil, err
}
// create session
if session, err = client.NewSession(); err != nil {
return nil, err
}
return session, nil
}
連接的方法很簡單，只要提供登錄主機(jī)的 用戶*， *密碼*， *主機(jī)名或者IP*， *SSH端口
執(zhí)行，命令獲取結(jié)果
連接成功后，執(zhí)行命令很簡單
import (
"fmt"
"log"
"os"
"time"
"golang.org/x/crypto/ssh"
)
func main() {
session, err := connect("root", "xxxxx", "127.0.0.1", 22)
if err != nil {
log.Fatal(err)
}
defer session.Close()
session.Run("ls /; ls /abc")
}
上面代碼運(yùn)行之后，雖然命令正常執(zhí)行了，但是沒有正常輸出的結(jié)果，也沒有異常輸出的結(jié)果。 要想顯示結(jié)果，需要將 session 的 Stdout 和 Stderr 重定向 修改 func main 為如下：
func main() {
session, err := connect("root", "xxxxx", "127.0.0.1", 22)
if err != nil {
log.Fatal(err)
}
defer session.Close()
session.Stdout = os.Stdout
session.Stderr = os.Stderr
session.Run("ls /; ls /abc")
}
這樣就能在屏幕上顯示正常，異常的信息了。
交互式命令
上面的方式無法遠(yuǎn)程執(zhí)行交互式命令，比如 top ， 遠(yuǎn)程編輯一個(gè)文件，比如 vi /etc/nginx/nginx.conf 如果要支持交互式的命令，需要當(dāng)前的terminal來接管遠(yuǎn)程的 PTY。
func main() {
session, err := connect("root", "olordjesus", "dockers.iotalabs.io", 2210)
if err != nil {
log.Fatal(err)
}
defer session.Close()
fd := int(os.Stdin.Fd())
oldState, err := terminal.MakeRaw(fd)
if err != nil {
panic(err)
}
defer terminal.Restore(fd, oldState)
// excute command
session.Stdout = os.Stdout
session.Stderr = os.Stderr
session.Stdin = os.Stdin
termWidth, termHeight, err := terminal.GetSize(fd)
if err != nil {
panic(err)
}
// Set up terminal modes
modes := ssh.TerminalModes{
ssh.ECHO: 1, // enable echoing
ssh.TTY_OP_ISPEED: 14400, // input speed = 14.4kbaud
ssh.TTY_OP_OSPEED: 14400, // output speed = 14.4kbaud
}
// Request pseudo terminal
if err := session.RequestPty("xterm-256color", termHeight, termWidth, modes); err != nil {
log.Fatal(err)
}
session.Run("top")
}
重慶分公司
重慶分公司
