分类：Golang

2021
06-04

golang 函数返回chan类型的操作

在阅读kafka的golang客户端代码sarama-cluster时，遇到了如下一段代码：//Messagesreturnsthereadchannelforthemessagesthatarereturnedby//thebroker.////ThischannelwillonlyreturnifConfig.Group.Modeoptionissetto//ConsumerModeMultiplex(default).func(c*Consumer)Messages()<-chan*sarama.ConsumerMessage{returnc.messages}对于代码中的<-chan*sarama.ConsumerMessage产生了疑问，... 继续阅读 >
2021
06-04

Golang 拷贝Array或Slice的操作

Golang中Array是值类型而slice是引用类型。因此两者之间的赋值或拷贝有些差异，本文带你了解各自的差异。1.拷贝array前面提及数组是值类型，所以数组变量名不是指向第一个元素的指针。事实上它表示整个数组，下面两者情况将自动创建数组：数组变量赋值给另一个数组变量数组变量传递作为函数参数请看示例：packagemainimport"fmt"funcmain(){sample1:=[2]string{"a","b"}fmt.Printf("Sample1Before:%v\n",sample... 继续阅读 >
2021
06-04

golang 生成对应的数据表struct定义操作

在开发过程中，常常需要将数据库表对应到golang的一个struct，特别是使用一些ORM工具，sqlx库等，我是个懒人，即使数据表的字段不多，我也懒得去一个个对应的敲入代码，更别提数据表字段比较多的情况了，码农的时间，不能浪费在这啊，对吧？所以我在想，是不是有办法可以自动生成。我在工作时，用得最多的是mysql了，因此本文针对mysql的数据表来自动生成golang的struct定义mysql有个自带的数据库information_schema，里面的信息... 继续阅读 >
2021
06-03

golang 如何通过反射创建新对象

废话少说，直接贴代码~typeAstruct{Namestring}//测试unitfuncTestReflect(t*testing.T){reflectNew((*A)(nil))}//反射创建新对象。funcreflectNew(targetinterface{}){iftarget==nil{fmt.Println("参数不能未空")return}t:=reflect.TypeOf(target)ift.Kind()==reflect.Ptr{//指针类型获取真正type需要调用Elemt=t.Elem()}newStruc:=reflect.New(t)//调用反射创建对象newStruc.Ele... 继续阅读 >
2021
06-03

golang 实现两个结构体复制字段

实际工作中可能会有这样的场景：两个结构体(可能类型一样),字段名和类型都一样,想复制一个结构体的全部或者其中某几个字段的值到另一个(即merge操作),自然想到可以用反射实现packagemainimport"fmt"import"reflect"//用b的所有字段覆盖a的//如果fields不为空,表示用b的特定字段覆盖a的//a应该为结构体指针funcCopyFields(ainterface{},binterface{},fields...string)(errerror){at:=reflect.TypeOf(a)av:=... 继续阅读 >
2021
06-03

golang 实现对Map进行键值自定义排序

看代码吧~//自定义结构体,用来自定义排序typeRecentlyUpdateListMapSorter[]map[string]interface{}//根据MapSorter.Keys进行倒序排序func(ms*RecentlyUpdateListMapSorter)SortReverse(){sort.Sort(sort.Reverse(ms))}//自定义排序方法（Len(),Less(),Swap()）func(ms*RecentlyUpdateListMapSorter)Len()int{returnlen(*ms)}func(ms*RecentlyUpdateListMapSorter)Less(i,jint)bool{t1,_:=time.Parse(tim... 继续阅读 >
2021
05-29

Golang 的defer执行规则说明

defer介绍defer是golang的一个特色功能，被称为“延迟调用函数”。当外部函数返回后执行defer。类似于其他语言的try…catch…finally…中的finally，当然差别还是明显的。在使用defer之前我们应该多了解defer的特性，这样才能避免使用上的误区。1.最简单的deferfunctest(){deferfunc(){fmt.Println("defer")}()//todo//...return//defer执行时机}我们可以稍微改动一下上述代码再次确认defer的执行时... 继续阅读 >
2021
05-29

golang 的string与[]byte转换方式

相对于C语言，golang是类型安全的语言。但是安全的代价就是性能的妥协。下面我们看看Golang不想让我们看到的“秘密”——string的底层数据。通过reflect包，我们可以知道，在Golang底层，string和slice其实都是struct：typeSliceHeaderstruct{DatauintptrLenintCapint}typeStringHeaderstruct{DatauintptrLenint}其中Data是一个指针，指向实际的数据地址，Len表示数据长度。但是，在string和[]b... 继续阅读 >
2021
05-28

解决Golang中ResponseWriter的一个坑

解决Golang中ResponseWriter的一个坑 在使用Context.ResponseWriter中的Set/WriteHeader/Write这三个方法时，使用顺序必须如下所示，否则会出现某一设置不生效的情况。ctx.ResponseWriter.Header().Set("Content-type","application/text")ctx.ResponseWriter.WriteHeader(403)ctx.ResponseWriter.Write([]byte(resp))如1：ctx.ResponseWriter.Header().Set("Content-type","application/text")ctx.ResponseWriter.Write([]byte(resp))ctx.ResponseWriter.WriteH... 继续阅读 >
2021
05-28

golang在GRPC中设置client的超时时间

golang在GRPC中设置client的超时时间 超时建立连接主要就2函数Dail和DialContext。//Dialcreatesaclientconnectiontothegiventarget.funcDial(targetstring,opts...DialOption)(*ClientConn,error){returnDialContext(context.Background(),target,opts...)}funcDialContext(ctxcontext.Context,targetstring,opts...DialOption)(conn*ClientConn,errerror){...}DialContext太长了不帖了.看Dial实际上也是调用DialContext来实现的.... 继续阅读 >
2021
05-28

golang http使用踩过的坑与填坑指南

golang对http进行了很好的封装，使我们在开发基于http服务的时候，十分的方便，但是良好的封装，很容易是的我们忽略掉它们底层的实现细节。如下是我踩过的一些坑，以及相应的解决方法。调用http服务通常的实践如下：resp,err:=http.Get("http://example.com/")iferr!=nil{//handleerror}deferresp.Body.Close()body,err:=ioutil.ReadAll(resp.Body)//...陷阱一：Responsebody没有及时关闭网络... 继续阅读 >
2021
05-28

Golang 实现超大文件读取的两种方法

Golang 实现超大文件读取的两种方法 Golang超大文件读取的两个方案流处理方式分片处理去年的面试中我被问到超大文件你怎么处理，这个问题确实当时没多想，回来之后仔细研究和讨论了下这个问题，对大文件读取做了一个分析比如我们有一个log文件，运行了几年，有100G之大。按照我们之前的操作可能代码会这样写：funcReadFile(filePathstring)[]byte{content,err:=ioutil.ReadFile(filePath)iferr!=nil{log.Println("Readerror")}ret... 继续阅读 >
2021
05-28

golang实现mysql数据库事务的提交与回滚

MySQL事务主要用于处理操作量大，复杂度高的数据。在MySQL中只有使用了Innodb数据库引擎的数据库或表才支持事务。事务用来管理insert,update,delete语句，事务处理可以用来维护数据库的完整性，保证成批的SQL语句要么全部执行，要么全部不执行。一般来说，事务是必须满足4个条件（ACID）：：原子性（Atomicity，或称不可分割性）、一致性（Consistency）、隔离性（Isolation，又称独立性）、持久性（Durability）。本文主... 继续阅读 >
2021
05-28

解决Golang 中使用WaitGroup的那点坑

sync.WaitGroup对于Golang开发者来说并不陌生，其经常作为多协程之间同步的一种机制。用好它势必会让你事半功倍，但是一旦错用将引发问题。关于WaitGroup的使用网上有很多例子，在此就不做介绍了，我想说的是我在项目中使用WaitGroup遇到的坑。在项目中，因为服务器有同步需求，所以直接使用了WaitGroup，但是未考虑使用场景，结果在项目上线之后，高峰期的时候客户端经常出现卡顿，经过多方查找，才发现如果使用WaitGroup的时候... 继续阅读 >