名词解释： QPS（Query per second 每秒处理完的请求数）     什么是wrk    看下他GitHub上的介绍：https://github.com/wg/wrk wrk is a modern HTTP benchmarking tool capable of generating significant load when run on a single multi-core CPU. It combines a multithreaded design with sca…

上一篇说了以命令行方式执行了pprof，这次我们学习以web方式运行pprof. 下面看个例子： var datas []string func main() { go func() { for { log.Printf("len:%d",Add("gwyy")) time.Sleep(time.Second) } }() go func() { for { Get() time.Sleep(time.Second) } }() _ = http.ListenAndServe(":6060",nil) } func…

pprof是go语言内置 的分析性能，分析数据的工具，pprof开启后，每隔一段时间（10ms）就会收集下当前的堆栈信息，获取格格函数占用的CPU以及内存资源；最后通过对这些采样数据进行分析，形成一个性能分析报告。pprof用 profile.proto 读取分析样本的集合，并声称可视化报告，以帮助分析数据 （支持文本和图形报告） profile.proto 是一个 Protobuf v3的描述文件，它描述了一组 callstack和 symbolization 信息，它的作用是统计分析一组采样的调用栈，配置文件格…

    最近一直在写go, switch说实话用的不算多。但是今天用了下发现go的switch可真不太一样啊。 func main() { i := 0 switch i { case 0: fmt.Println("0000000000") fmt.Println("0") case 1: fmt.Println("1111111111") fmt.Println("1") case 2: fmt.Println("2222222222") fmt.Println("2") default: fmt.Printl…

golang中的select语句格式如下 select { case <-ch1: // 如果从 ch1 信道成功接收数据，则执行该分支代码 case ch2 <- 1: // 如果成功向 ch2 信道成功发送数据，则执行该分支代码 default: // 如果上面都没有成功，则进入 default 分支处理流程 }   可以看到select的语法结构有点类似于switch，但又有些不同。 select里的case后面并不带判断条件，而是一个信道的操作，不同于switch里的case，对于从其…

阅读 NSQ 源码时，看到NSQ使用了 go-svc 来启动nsq的相关程序,使得在程序退出的时候可以做一些释放资源等收尾工作。 使用起来非常简单,定义一个Service,实现其 svc.Service中的接口即可。  简单使用： func main() { prg := &program{} //运行程序 if err := svc.Run(prg, syscall.SIGINT, syscall.SIGTERM); err != nil { log.Fatal(err) } } //初始化方法 func…

简介 　　json格式可以算我们日常最常用的序列化格式之一了，Go语言作为一个由Google开发，号称互联网的C语言的语言，自然也对JSON格式支持很好。但是Go语言是个强类型语言，对格式要求极其严格而JSON格式虽然也有类型，但是并不稳定，Go语言在解析来源为非强类型语言时比如PHP等序列化的JSON时，经常遇到一些问题诸如字段类型变化导致无法正常解析的情况，导致服务不稳定。下面我们就一起来看看。 　　下面看看一个正常的结构体转json是什么样子： package main import ( "encoding/…

简介： 　es包地址：https://github.com/olivere/elastic/ 这个版本被广泛使用，我们也用这个。 　　注意：es版本不同，要导入不同的包。6.0版本导入“github.com/olivere/elastic” 连接es: var host = "http://xxx.com:9201" func es_init() { client, err := elastic.NewClient( elastic.SetURL(host), elastic.SetSniff(false), el…

import "github.com/Shopify/sarama" 　　saram 使用纯go语言编写。用于处理Apache Kafka（0.8及更高版本）的纯Go客户端库. 它包括一个易于生成和使用消息的高级API，以及一个在高级API不足时控制线路上字节的低级API. 内嵌提供了高级API的用法示例及其完整文档. 生产者： 有几种类型的生产者: 　　sarama.NewSyncProducer() //同步发送者 　　sarama.NewAsyncProducer() //异步发送者 同步模式： func m…