time包中包括两类时间：时间点（某一时刻）和时常（某一段时间） １时间常量（时间格式化） const ( ANSIC = "Mon Jan _2 15:04:05 2006" UnixDate = "Mon Jan _2 15:04:05 MST 2006" RubyDate = "Mon Jan 02 15:04:05 -0700 2006" RFC822 = "02 Jan 06 15:04 MST" RFC822Z = "02 Jan 06 15:04 -0700" // RFC822 with numeric zone RFC850 = "Monday, 02-Jan-06 15:04:05 MST" RFC1123 = "Mon, 02 Jan 2006 15:04:05 MST...阅读全文
golang面试题整理 １、go的调度 ２、go struct能不能比较 因为是强类型语言，所以不同类型的结构不能作比较，但是同一类型的实例值是可以比较的，实例不可以比较，因为是指针类型 ３、go defer（for defer），先进后出，后进先出 func b() { for i := 0; i < 4; i++ { defer fmt.Print(i) } } ４、select可以用于什么，常用语gorotine的完美退出 golang 的 select 就是监听 IO 操作，当 IO 操作发生时，触发相应的动作 每个case语句里必须是一个IO操作，确切的说，应该是一个面向channel的IO操作 ５、context包的用途 Context通常被译作上下文，它是一个比较抽象的概念，其...阅读全文
核心代码：smtp.SendMail(host, auth, user, send_to, msg)，auth := smtp.PlainAuth("", user, password, hp[0]) 可行方案：使用企业邮箱的SMTP发送邮件，host :="smtp.exmail.qq.com:25"，因此需要一个企业邮箱的账号和密码 直接上代码： main.go package main import ( "fmt" "net/smtp" "strings" ) func SendToMail(user, password, host, to, subject, body, mailtype string) error { hp := strings.Split(host, ":") a...阅读全文
golang中实现并发非常简单，只需在需要并发的函数前面添加关键字＂go"，但是如何处理go并发机制中不同goroutine之间的同步与通信，golang 中提供了sync包和channel机制来解决这一问题． sync 包提供了互斥锁这类的基本的同步原语.除 Once 和 WaitGroup 之外的类型大多用于底层库的例程。更高级的同步操作通过信道与通信进行。 type Cond func NewCond(l Locker) *Cond func (c *Cond) Broadcast() func (c *Cond) Signal() func (c *Cond) Wait()type Lockertype Mutex func (m *Mutex) Lock() func (m *Mu...阅读全文
redis的client有好多好多，go语言的client在redis官方有两个推荐，radix和redigo。选择哪一个好呢？确实很纠结，后来掷硬币决定选择redigo了。 redis、go、redigo的安装就不需要提了，不能强行增加篇幅。 redigo使用起来很人性化，api设计的符合直觉，我对redis了解较少，使用过程中基本没有遇到障碍。 redigo的使用入门可以去查godoc：http://godoc.org/github.com/garyburd/redigo/redis 接下来就是毫无技术含量的贴代码了： 连接redis我一般是这样写的： 1 c, err := redis.Dial("tcp", "127.0.0.1:6379") 2 if err != nil { 3 ...阅读全文
GoLang之协程 目前，WebServer几种主流的并发模型： 多线程，每个线程一次处理一个请求，在当前请求处理完成之前不会接收其它请求；但在高并发环境下，多线程的开销比较大； 基于回调的异步IO，如Nginx服务器使用的epoll模型，这种模式通过事件驱动的方式使用异步IO，使服务器持续运转，但人的思维模式是串行的，大量回调函数会把流程分割，对于问题本身的反应不够自然； 协程，不需要抢占式调度，可以有效提高线程的任务并发性，而避免多线程的缺点；但原生支持协程的语言还很少。 协程（coroutine）是Go语言中的轻量级线程实现，由Go运行时（runtime）管理。 在一个函数调用前加上go关键字，这次调用就会在一个新的goroutine中并发执行。当被调用的函数返回时，这个gorouti...阅读全文
本文主要基于官方文档Go Concurrency Patterns: Context以及视频Advanced Go Concurrency Patterns的学习而得。 背景 在go服务器中，对于每个请求的request都是在单独的goroutine中进行的，处理一个request也可能设计多个goroutine之间的交互， 使用context可以使开发者方便的在这些goroutine里传递request相关的数据、取消goroutine的signal或截止日期。 Context结构 // A Context carries a deadline, cancelation signal, and request-scoped values // across API boundaries. ...阅读全文
我们总是会使用Timer去执行一些定时任务，最近在Go语言的定时器使用上面不小心踩到一点问题，这里记录一下。 go demo(input) func demo(input chan interface{}) { for { select { case msg <- input: println(msg) case <-time.After(time.Second * 5): println("5s timer") case <-time.After(time.Second * 10): println("10s timer") } } } 写出上面这段程序的目的是从 input channel 持续接收消息加以处理，同时希望每过5秒钟和每过10秒钟就分别执行一个定时任务。但是当你执行这段程序...阅读全文
背景 在最近开发的项目中，后端需要编写许多提供HTTP接口的API，另外技术选型相对宽松，因此选择Golang + Beego框架进行开发。之所以选择Golang，主要是考虑到开发的模块，都需要接受瞬时大并发、请求需要经历多个步骤、处理时间较长、无法同步立即返回结果的场景，Golang的goroutine以及channel所提供的语言层级的特性，正好可以满足这方面的需要。 goroutine不同于thread，threads是操作系统中的对于一个独立运行实例的描述，不同操作系统，对于thread的实现也不尽相同；但是，操作系统并不知道goroutine的存在，goroutine的调度是有Golang运行时进行管理的。启动thread虽然比process所需的资源要少，但是多个thread之间...阅读全文
本文是看了文章之后的心得。 在此感谢。 概述 Go 语言中的 new 和 make 一直是新手比较容易混淆的东西，咋一看很相似。不过解释两者之间的不同也非常容易。 他们所做的事情，和应用的类型也不相同。 二者都是用来分配空间。 new 函数 new 是内建函数，函数原型为 func new(Type) *Type 官方文档描述为： The new build-in function allocates memory（仅仅分配空间）. The first argument is a type, not a value, and the value returned is a pointer to a newly allocated zero value of that type. 翻译如下： ...阅读全文
 Go 中的 context 包在与 API 和慢处理交互时可以派上用场，特别是在生产级的 Web 服务中。在这些场景中，您可能想要通知所有的 goroutine 停止运行并返回。这是一个基本教程，介绍如何在项目中使用它以及一些最佳实践和陷阱。 要理解 context 包，您应该熟悉两个概念。 在转到 context 之前，我将简要介绍这些内容，如果您已经熟悉，则可以直接转到 context 部分。 ## Goroutine...阅读全文
for循环是Go语言唯一的循环结构。这里有三个基本的for循环类型。 package main import "fmt" func main() { // 最基本的一种，单一条件循环 // 这个可以代替其他语言的while循环 i := 1 for i <= 3 { fmt.Println(i) i = i + 1 } // 经典的循环条件初始化/条件判断/循环后条件变化 for j := 7; j <= 9; j++ { fmt.Println(j) } // 无条件的for循环是死循环，除非你使用break跳出循环或者 // 使用return从函数返回 for { fmt.Println("loop") break } } 输出结果 1 2 3 7 8 9 loop 在后面的例子中，你将...阅读全文
如果不是我对真正并行的线程的追求，就不会认识到Go有多么的迷人。 Go语言从语言层面上就支持了并发，这与其他语言大不一样，不像以前我们要用Thread库 来新建线程，还要用线程安全的队列库来共享数据。 以下是我入门的学习笔记。 Go语言的goroutines、信道和死锁 goroutine Go语言中有个概念叫做goroutine, 这类似我们熟知的线程，但是更轻。 以下的程序，我们串行地去执行两次loop函数: func loop() { for i := 0; i < 10; i++ { fmt.Printf("%d ", i) } } func main() { loop() loop() } 毫无疑问，输出会是这样的: 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 ...阅读全文
欢迎来到 [Golang 系列教程](https://studygolang.com/subject/2)的第 22 篇。 在[上一教程](https://studygolang.com/articles/12342)里，我们探讨了如何使用 Go 协程（Goroutine）来实现并发。我们接着在本教程里学习信道（Channel），学习如何通过信道来实现 Go 协程间的通信。 ## 什么是信道？ 信道可以想像成 Go 协程之间通信的管道。如同管道中的水会从一端流到另一端，通过使用信道，数据也可以从一端发送，在另一端接收。 ## 信道的声明 所有信道都关联了一个类型。信道只能运输这种类型的数据，而运输其他类型的数据都是非法的。 `chan T` 表示 `T` 类型的信道。 信道的零值为 `nil...阅读全文
管道(Channel)是Go语言中比较重要的部分，经常在Go中的并发中使用。今天尝试对Go语言的管道来做以下总结。总结的形式采用问答式的方法，让答案更有目的性。 Q1.管道是什么？ 管道是Go语言在语言级别上提供的goroutine间的**通讯方式**，我们可以使用channel在多个goroutine之间传递消息。channel是**进程内**的通讯方式，是不支持跨进程通信的，如果需要进程间通讯的话，可以使用Socket等网络方式。 以上是管道的概念，下面我们就看下管道的语法。 Q2.管道的语法? 整个Go语言的语法都比较简洁，管道也不例外，其语法如下所示： 在此应当注意，管道是类型相关的，即一个管道只能传递一种类型的值。管道中的数据是先进先出的。 1 // 声明方式，在此ElemType...阅读全文
什么是channel？ channel是Go语言在语言级别提供的goroutine间的通信方式。我们可以使用channel在两个或 多个goroutine之间传递消息。channel是进程内的通信方式，因此通过channel传递对象的过程和调用函数时的参数传递行为比较一致，比如也可以传递指针等。如果需要跨进程通信，我们建议用 分布式系统的方法来解决，比如使用Socket或者HTTP等通信协议。Go语言对于网络方面也有非常完善的支持。 channel是类型相关的。也就是说，一个channel只能传递一种类型的值，这个类型需要在声明channel时指定。如果对Unix管道有所了解的话，就不难理解channel，可以将其认为是一种类 型安全的管道。 （我复制pdf上的。个人理解即是并发编程中各线程...阅读全文
关于在goroutine中使用time.After的理解， 新手在学习过程中的“此时此刻”的理解，错误还请指正。 先线上代码： package main import ( "fmt" "time" ) func main() { //closeChannel() c := make(chan int) timeout := time.After(time.Second * 2) // t1 := time.NewTimer(time.Second * 3) // 效果相同 只执行一次 var i int go func() { for { select { case <-c: fmt.Println("channel sign") return case <-t1.C: // 代码段2 fm...阅读全文
首先我们来看线程,在golang里面也叫goroutine 在读这篇文章之前，我们需要了解一下并发与并行。golang的线程是一种并发机制，而不是并行。它们之间的区别大家可以上网搜一下，网上有很多的介绍。 下面我们先来看一个例子吧 import( "fmt" ) funcmain(){ go fmt.Println("1") fmt.Println("2") } 在golang里面，使用go这个关键字，后面再跟上一个函数就可以创建一个线程。后面的这个函数可以是已经写好的函数，也可以是一个匿名函数 funcmain(){ vari=3 go func(a int) { fmt.Println(a) fmt.Println("1") }(i) fmt.Println("2") } 上面的代码就创...阅读全文
var和const ：变量和常量的声明 var varName type 或者 varName : = value package and import: 导入 func： 用于定义函数和方法 return ：用于从函数返回 defer someCode ：在函数退出之前执行 go : 用于并行 select 用于选择不同类型的通讯 interface 用于定义接口 struct 用于定义抽象数据类型 break、case、continue、for、fallthrough、else、if、switch、goto、default 流程控制 chan用于channel通讯 type用于声明自定义类型 map用于声明map类型数据 range用于读取slice、map、channel数...阅读全文
教程制作： IT无崖子(刘丹冰) 教程简介：本教程主要针对具有一定编程基础的学员，懂得基本的编程语法。 使用Go语言实现并发的协程调度池阉割版，本文主要介绍协程池的基本设计思路，目的为深入浅出快速了解协程池工作原理，与真实的企业协程池还有很大差距，本文仅供学习参考。 一、何为并发，Go又是如何实现并发？ gopool1.jpeg gopool2.jpeg 并行的好处： 同一时刻可以处理多个事务 更加节省时间，效率更高 具有并行处理能力的程序我们称之为“并发程序” 并发程序的处理能力优势体现在哪里？ goPool3.jpeg 二、Go语言如何实现并发？ package main import "fmt" import "time" func go_worker(name string) { f...阅读全文
Golang最大的特色可以说是协程(goroutine)了, 协程让本来很复杂的异步编程变得简单, 让程序员不再需要面对回调地狱, 虽然现在引入了协程的语言越来越多, 但go中的协程仍然是实现的是最彻底的. 这篇文章将通过分析golang的源代码来讲解协程的实现原理. 这个系列分析的golang源代码是Google官方的实现的1.9.2版本, 不适用于其他版本和gccgo等其他实现, 运行环境是Ubuntu 16.04 LTS 64bit. 核心概念 要理解协程的实现, 首先需要了解go中的三个非常重要的概念, 它们分别是G, M和P, 没有看过golang源代码的可能会对它们感到陌生, 这三项是协程最主要的组成部分, 它们在golang的源代码中无处不在. G (goroutine) G是...阅读全文
channels 是 goroutines之间通信的工具， 可以理解为管道， 虽然go也提供共享变量的方式， 但是更加推荐使用channel func TestChan(t *testing.T) { c := make(chan int) go func() { c <- 48 }() fmt.Println(<- c) // 保持持续运行 holdRun() } func holdRun() { time.Sleep(1 * time.Hour) } c := make(chan int) 声明一个 传输整形 的unbuffer chan,（接收消息和发送消息者将会阻塞，直到channel ”可用“） <- 操作符用来接受和发送消息 chan <- 48 发送“48“ 进入管道， <-c...阅读全文
golang判断短chan channel是否关闭 群里有朋友问,怎么判断chan是否关闭,因为close的channel不会阻塞,并返回类型的nil值,会导致死循环.在这里写个例子记录一下,并且分享给大家 如果不判断chan是否关闭 Notice: 以下代码会产生死循环 package main import ( "fmt" ) func main() { c := make(chan int, 10) c <- 1 c <- 2 c <- 3 close(c) for { fmt.Println(<-c) } } 判断短chan是否关闭 package main import ( "fmt" ) func main() { c := make(chan int, 10) c <- 1 c...阅读全文
``` package main import ( "fmt" "log" "math/rand" "sync" "time" "github.com/go-redis/redis" ) var redisdb *redis.Client var wg sync.WaitGroup func main() { wg.Add(1) go testRedisBase() wg.Wait() } func testRedisBase() { defer wg.Done() //连接服务器 redisdb = redis.NewClient(&redis.Options{ Addr: "localhost:6379", // use default Addr Password: "", // no ...阅读全文
你很可能从某种途径听说过 Go 语言。它越来越受欢迎，并且有充分的理由可以证明。 Go 快速、简单，有强大的社区支持。学习这门语言最令人兴奋的一点是它的并发模型。 Go 的并发原语使创建多线程并发程序变得简单而有趣。我将通过插图介绍 Go 的并发原语，希望能点透相关概念以方便后续学习。本文是写给 Go 语言编程新手以及准备开始学习 Go 并发原语 (goroutines 和 channels) 的同学。 ## 单线程程序 vs. 多线程程序 你可能已经写过一些单线程程序。一个常用的编程模式是组合多个函数来执行一个特定任务，并且只有前一个函数准备好数据，后面的才会被调用。  欢迎来到 [Golang 系列教程](https://studygolang.com/subject/2)的第 36 篇。 在这一章我们将学习如何使用 Go 语言将数据写到文件里面。并且还要学习如何同步的写到文件里面。 这章教程包括如下几个部分： - 将字符串写入文件 - 将字节写入文件 - 将数据一行一行的写入文件 - 追加到文件里 - 并发写文件 请在本地运行所有本教程的程序，因为 playground 对文件的操作支持的并不好。 ## 将字符串写入文件 ...阅读全文
前瞻 context 包困扰我好久，之前在 watch etcd 的时候首次上手使用这个包，当时并不理解这个包的作用，只知道可以用来关闭 watch ， 后来被大牛吐槽了，决定深入探究一番。 简介 golang 中的创建一个新的 goroutine , 并不会返回像c语言类似的pid，所有我们不能从外部杀死某个goroutine，所有我就得让它自己结束，之前我们用 channel ＋ select 的方式，来解决这个问题，但是有些场景实现起来比较麻烦，例如由一个请求衍生出的各个 goroutine 之间需要满足一定的约束关系，以实现一些诸如有效期，中止routine树，传递请求全局变量之类的功能。于是google 就为我们提供一个解决方案，开源了 context 包。使用 context 实...阅读全文
并发语言俨然是应大规模应用架构的需要而提出，有其现实所需。前后了解了Scala和Golang，深深体会到现代并发语言与旧有的Java、C++等语言在风格及理念上的巨大差异。本文主要针对Scala和Golang这两个我喜爱的并发语言在并发特性上的不同实现，做个比较和阐述，以进一步加深理解。 一. Scala与Golang的并发实现思路Scala语言并发设计采用Actor模型，借鉴了Erlang的Actor实现，并且在Scala 2.10之后，Scala采用的是Akka Actor模型库。Actor模型主要特征如下： “一切皆是参与者”，且各个actor间是独立的； 发送者与已发送消息间解耦，这是Actor模型显著特点，据此实现异步通信； actor是封装状态和行为的对象，通过消息交换进行相互通...阅读全文
1 func pointer_test() { 2 //空指针，输出为nil 3 var p *int 4 fmt.Printf("p: %v\n", p) 5 //指向局部变量，变量值初始为0 6 var i int 7 p = &i 8 fmt.Printf("p: %v,%v\n", p, *p) 9 //通过指针修改变量数值 10 *p = 8 11 fmt.Printf("p: %v,%v\n", p, *p) 12 //数组的初始化及输出 13 m := [3]int{3, 4, 5} 14 fmt.Printf("m:%v--%v,%v,%v\n", m, m[0], m[1], m[2]) 15 //指针数组的初始化及输出 16 //j, k, l := 3, 4, 5 17...阅读全文
http://m.oschina.net/blog/125853 如果是命令行程序需要退出, CTRL+C是最直接的方法. C语言如何处理CTRL+C CTRL+C会向命令行进程发送中断信号, 在C语言的
Channel是Go中的一个核心类型，你可以把它看成一个管道，通过它并发核心单元就可以发送或者接收数据进行通讯(communication)。它的操作符是箭头 <- 。[plain] view plain copy print?ch <- v // 发送值v到Channel ch中 v := <-ch // 从Channel ch中接收数据，并将数据赋值给v ch <- v // 发送值v到Channel ch中 v := <-ch // 从Channel ch中接收数据，并将数据赋值给v (箭头的指向就是数据的流向)就像 map 和 slice 数据类型一样, channel必须先创建再使用:[plain] view plain copy print?ch := make(chan int...阅读全文
计时器用来定时执行任务，分享一段代码： package main import "time" import "fmt" func main() { //新建计时器，两秒以后触发，go触发计时器的方法比较特别，就是在计时器的channel中发送值 timer1 := time.NewTimer(time.Second * 2) //此处在等待channel中的信号，执行此段代码时会阻塞两秒 <-timer1.C fmt.Println("Timer 1 expired") //新建计时器，一秒后触发 timer2 := time.NewTimer(time.Second) //新开启一个线程来处理触发后的事件 go func() { //等触发时的信号 <-timer2.C fmt.Print...阅读全文
channel 是 golang 里相当有趣的一个功能，大部分时候 channel 都是和 goroutine 一起配合使用。本文主要介绍 channel 的一些有趣的用法。 通道（channel），像是通道（管道），可以通过它们发送类型化的数据在协程之间通信，可以避开所有内存共享导致的坑；通道的通信方式保证了同步性。数据通过通道：同一时间只有一个协程可以访问数据：所以不会出现数据竞争，设计如此。数据的归属（可以读写数据的能力）被传递。 通道实际上是类型化消息的队列：使数据得以传输。它是先进先出（FIFO）结构的所以可以保证发送给他们的元素的顺序（有些人知道，通道可以比作 Unix shells 中的双向管道（tw-way pipe））。通道也是引用类型，所以我们使用 make() 函数来给...阅读全文
make用于内建类型（map、slice 和channel）的内存分配。new用于各种类型的内存分配。 内建函数new本质上说跟其它语言中的同名函数功能一样：new(T)分配了零值填充的T类型的内存空间，并且返回其地址，即一个*T类型的值。用Go的术语说，它返回了一个指针，指向新分配的类型T的零值。有一点非常重要：new返回指针。 内建函数make(T, args)与new(T)有着不同的功能，make只能创建slice、map和channel，并且返回一个有初始值(非零)的T类型，而不是*T。 本质来讲，导致这三个类型有所不同的原因是指向数据结构的引用在使用前必须被初始化。例如，一个slice，是一个包含指向数据（内部array）的指针、长度和容量的三项描述符；在这些项目被初始化之前，sl...阅读全文
golang 的 select 的功能和 select, poll, epoll 相似， 就是监听 IO 操作，当 IO 操作发生时，触发相应的动作。 示例： ch1 := make (chan int, 1) ch2 := make (chan int, 1) ... select { case <-ch1: fmt.Println("ch1 pop one element") case <-ch2: fmt.Println("ch2 pop one element") } 注意到 select 的代码形式和 switch 非常相似， 不过 select 的 case 里的操作语句只能是【IO 操作】 。 此示例里面 select 会一直等待等到某个 case 语句完成， 也就是等到成功从...阅读全文
安装在线教程 由于墙，golang.org 国内无法访问，其在线教程也一样 tutorial.golang.org http://go-tour-zh.appspot.com/ 可以在本机运行， 先安装Go 编译器 http://code.google.com/p/go/downloads/list 然后安装教程 go get code.google.com/p/go-tour/gotour 或者中文的 go get bitbucket.org/mikespook/go-tour-zh/gotour 最后执行安装产生的 gotour 执行文件，即可在http://localhost:3999 打开教程。 一些练习的答案 #46 练习：斐波纳契闭包 package main import "f...阅读全文
file 技术一面 基础面试 一面是通过电话直接沟通 go的调度 go struct能不能比较 go defer（for defer） select可以用于什么 context包的用途 client如何实现长连接 主协程如何等其余协程完再操作 slice，len，cap，共享，扩容 map如何顺序读取 实现set 实现消息队列（多生产者，多消费者） 大文件排序 基本排序，哪些是稳定的 http get跟head http 401,403 http keep-alive http能不能一次连接多次请求，不等后端返回 tcp与udp区别，udp优点，适用场景 time-wait的作用 数据库如何建索引 孤儿进程，僵尸进程 死锁条件，如何避免 linux命令，查看端口占用，cpu负载，内存占用，如...阅读全文
在上一篇moonmq的介绍中（这里），我只简短的罗列了一些moonmq的设计想法，可是对于怎样使用并没有具体说明，公司同事无法非常好的使用。 对于moonmq的使用，事实上非常easy，例子代码在这里，我们仅仅须要处理好broker，consumer以及publisher的关系就能够了。 首先，我们须要启动一个broker，由于moonmq如今仅仅支持tcp的自己定义协议，所以broker启动的时候须要指定一个listen address。 #启动broker ./simple_broker -addr=127.0.0.1:11182 启动了broker之后，我们就能够向该broker发送消息 #向test这个queue发送 hello msg ./simple_publisher -add...阅读全文
最近在油管上面看了一个视频：Understanding nil，挺有意思，这篇文章就对视频做一个归纳总结，代码示例都是来自于视频。 nil是什么 相信写过Golang的程序员对下面一段代码是非常非常熟悉的了： if err != nil { // do something.... } 当出现不等于nil的时候，说明出现某些错误了，需要我们对这个错误进行一些处理，而如果等于nil说明运行正常。那什么是nil呢？查一下词典可以知道，nil的意思是无，或者是零值。零值，zero value，是不是有点熟悉？在Go语言中，如果你声明了一个变量但是没有对它进行赋值操作，那么这个变量就会有一个类型的默认零值。这是每种类型对应的零值： bool -> false numbers -> 0 string -...阅读全文
自：https://golang.org/doc/effective_go.html Effective Go IntroductionExamplesFormattingCommentaryNamesPackage namesGettersInterface namesMixedCapsSemicolonsControl structuresIfRedeclaration and reassignmentForSwitchType switchFunctionsMultiple return valuesNamed result parametersDeferDataAllocation with newConstructors and composite literalsAllocati...阅读全文
channel 是 golang 里相当有趣的一个功能，在我使用 golang 编码的经验里，大部分事件都会是在享受 channel 和 goroutine 配合的乐趣。所以本文主要介绍 channel 的一些有趣的用法。 这里有 Oling Cat 翻译的Go编程语言规范里关于 channel（信道）的描述： 信道提供了一种机制，它在两个并发执行的函数之间进行同步，并通过传递（与该信道元素类型相符的）值来进行通信。 这个个描述又乏味、又枯燥。在我第一次阅读的时候，完全不明白这到底是个什么玩意。事实上，可以认为 channel 是一个管道或者先进先出队列，非常简单且轻量。channel 并不是 Golang 首创的。它同样作为内置功能出现在其他语言中。在大多数情况下，它是一个又大、又笨、又复...阅读全文
1. Error: error getting endorser client for channel: endorser client failed to connect to orderer.rabbit.com:8051: failed to create new connection: context deadline exceeded 原因：CORE_PEER_ADDRESS=orderer.rabbit.com:8051 地址不对或peer节点未启动 2. Error: proposal failed (err: bad proposal response 500: access denied for [JoinChain][testc2]: [Failed verifying ...阅读全文
channel 是 golang 里相当有趣的一个功能，在我使用 golang 编码的经验里，大部分事件都会是在享受 channel 和 goroutine 配合的乐趣。所以本文主要介绍 channel 的一些有趣的用法。这里有 Oling Cat 翻译的Go编程语言规范里关于 channel（信道）的描述：信道提供了一种机制，它在两个并发执行的函数之间进行同步，并通过传递（与该信道元素类型相符的）值来进行通信。这个个描述又乏味、又枯燥。在我第一次阅读的时候，完全不明白这到底是个什么玩意。事实上，可以认为 channel 是一个管道或者先进先出队列，非常简单且轻量。channel 并不是 Golang 首创的。它同样作为内置功能出现在其他语言中。在大多数情况下，它是一个又大、又笨、又复杂的消...阅读全文
最近需要实现一个自增序列的增长功能，原来的做法是从数据库中实现自增长就可以了，可是最近用的sequel pro死活找不到从指定值开始自增长的设置，只能自己通过代码查找数据库最后一项然后加一，这样每次需要增加数据的时候都要去查找以便，很是不方便，最近看到这篇文章，获益匪浅，作者提供的程序还能直接用，哈哈哈，赶紧mark了，谢谢作者。 原文出处：https://mikespook.com/2012/06/golang-channel-%E6%9C%89%E8%B6%A3%E7%9A%84%E5%BA%94%E7%94%A8/ 查看原文后会有很多意外收获呢 package main import ( "fmt" "time" "strconv" "reflect" ) type AutoInc s...阅读全文
Golang 中make与new 区别 转载：https://medium.com/d-d-mag/golang-%E7%AD%86%E8%A8%98-make-%E8%88%87-new-%E7%9A%84%E5%B7%AE%E5%88%A5-68b05c7ce016 在 golang 有兩個保留字 make 與 new，也是剛開始學習 golang 的時候容易搞混的地方，這邊做個簡單的筆記。 new new 可以用來初始化泛型，並且返回儲存位址。所以通常我們會用指標變數來接 new 過後的型別。特別要注意的是，new 會自動用 zeroed value 來初始化型別，也就是字串會是""，number 會是 0，channel, func, map, slice 等等則會是 nil。 因為...阅读全文
生命不止，继续 go go go !!! 今天，跟大家分享的是在golang中执行定时任务，主要介绍两个github上的开源库的使用。 Linux下crontab crontab 命令常见于Unix和类Unix的操作系统之中，用于设置周期性被执行的指令。 该命令从标准输入设备读取指令，并将其存放于“crontab”文件中，以供之后读取和执行。 该词来源于希腊语chronos（χρόνος），原意是时间。 通常，crontab储存的指令被守护进程激活，crond常常在后台运行，每一分钟检查是否有预定的作业需要执行。这类作业一般称为cron jobs。 crontab文件包含送交cron守护进程的一系列作业和指令。每个用户可以拥有自己的crontab文件；同时，操作系统保存一个针对整个系统的cr...阅读全文
1:驱动 本来打算自己写一个驱动的，后来发现github上面已经有了，那我就直接拿现成的了， 驱动采用 github.com/streadway/amqp ，直接import就可以啦！ 2:exchange and queue 在上一篇文章中，我们已经创建好virtualhost 、exchange and queue，所以我们先定义这些常量 const ( queueName = "push.msg.q" exchange = "t.msg.ex" mqurl ="amqp://shi:123@192.168.232.130:5672/test" ) var conn *amqp.Connectionvar channel *amqp.Channel 3：错误处理 func failOnE...阅读全文
golang的select与channel配合使用。它用于等待一个或者多个channel的输出。 应用场景：主goroutine等待子goroutine完成，但是子goroutine无限运行，导致主goroutine会一直等待下去。而主线程想假如超过了一定的时没有返回的话，进行超时判断然后继续运行下去。 package main import ( "time" "fmt" ) var chs chan int = make(chan int,1) func write(){ time.Sleep(3*time.Second) chs<-1 } func read(){ select { case ch1:=<-chs: fmt.Println(ch1) return case <-time....阅读全文
前言 如何实现一个爬虫系统或则简单的小脚本?一般是定义一个入口页面，然后一个页面会有其他页面的URL，于是从当前页面获取到这些URL加入到爬虫的抓取队列中，然后进入到新页面后再递归的进行上述的操作，其实说来就跟深度遍历或广度遍历一样。 golang由于其编译速度很快，而且对并发(goroutine)的天然支持,配合chan的协程处理,可以很好地实现一个稳定高效的爬虫系统. 用到的包 完全不借助第三方的框架,通过go sdk的标准库来实现一个爬虫应用,主要用到的包 net/http 标准库里内建了对http协议的支持,实现了一个http client,可以直接通过其进行get,post等请求 strings 不像java的String是一个引用类型,go语言中的字符串类型是一个内建的基础类型,...阅读全文
