package main import ( "fmt" "time" "log" "github.com/garyburd/redigo/redis" ) func main(){ fmt.Println("Redis:") conn,err := redisConn("","","6"); if err != nil { log.Fatal("Error: ", err) } test(conn) } func test(conn *RedisConn) { conn.Do("SET","xxx",1) if xxx,err :=redis.Int(conn.Do("GET","xxx")); err == nil { fmt.Println("xxx:",xxx) } conn.Flus...阅读全文
要理解并灵活运用一个语言，我觉得有必要了解其构建应用程序的内部机制。经过这段时间对GO的接触，个人对GO构建程序的方式挺满意：简单、直接、灵活。下面就对GO语言构建应用程序的方法进行一个浅显的分析。 构建一个GO项目，我们只需设置好工程工作目录，并在该目录下新建名为src的文件夹，然后将你的源文件放到src下就行了。为便于理解，这里给出一个简单项目的例子进行具体说明。 环境变量：GOPATH =path/to/GoPro:$GOPATH GoPro/ bin/ hello pkg/ linux_amd64/ example/ mymath.a src/ example/ mymath/ sqrt.go //package mymath hello/ test.go //package mai...阅读全文
package main import ( "fmt" "database/sql" _ "github.com/go-sql-driver/mysql" ) type TestMysql struct { db * sql.DB } func Init()(*TestMysql, error) { test := new (TestMysql) db, err := sql.Open("mysql","root:@tcp(172.16.3.8:3306)/jackma?charset=utf8") if err != nil { fmt.Println(err.Error()) return test,nil } test.db = db return test, nil } func (...阅读全文
前言 运行环境在ubuntu,按照官方网站说明简单安装，在这就不具体说明了，安装过错中没有任何错误。下面我就按照光放网站照这写一个hello.go。 代码如下： package main import "fmt" func main(){ fmt.Printf("你好，世界") } 运行命令： 6g hello.go 6l hello.6 ./6.out 输出结果：你好，世界 运行一下命令会生成64 位的exe程序： 6l -o hello.exe hello.6 生成的文件大小有1.1MB,在window 7 32 位下运行会报如下错误： Program too big to fit memory. 下面想办法在64位操作系统下生成32程序。 找了，好久没找到，不过，除了6g,还有gccg...阅读全文
第二章 序 在计算机底层，一切都是比特位。然而计算机一般操作的都是固定大小的值，称之为字(word)。字会被解释为整数、浮点数、比特位数组、内存地址等，这些字又可以进一步聚合成数据包(packet)、像素点、作品集、诗歌或者其它任何对象。Go语言提供了多样化的数据组织方式，这些数据类型既有硬件层面的兼容性，又能让程序员方便的组合成更复杂的数据类型。 Go语言的数据类型分为四大类：基本类型，复合类型，引用类型及接口类型。本章将介绍基本类型：数字，字符串，布尔值。 一、整数 Go语言的数值数据类型包括以下几种：整数，浮点数，复数，每一种都包含了大小(size)不同的数值类型，例如有符号整数包含int8,int16,int32,int64,int。每一种数值类型都会决定值的大小和符号(正负)，我们...阅读全文
图1 图2 从图1和图2的对比中可以 看到，图2少了第15行的读取操作，然后图2代码运行的结果，就是全部的hello worldABCDEFG，图1的代码就只有从read之后算起的ABCDEFG。原因是什么呢？读写指针在其中作怪！每次的读写操作都是从指针位置开始的。图1中，第一次read之后，读写指针已经跑到hello word这个地方了，不是在0处，所以第二次read的结果是从这个非零指针之后开始往后读的，所以结果就只有后面的ABCDEFG。图2中，刚开始没有进行read操作，所以读写指针一直保持在零处，所以下一次read是从零处开始读取的。结果为全部的hello worldABCDEFG。 图3 从图3可以看到，用buf.string()这种方式可以看到并没有进行读指针的移动。 图4 从...阅读全文
package main import ( "encoding/json" "fmt" "os" ) type ConfigStruct struct { Host string `json:"host"` Port int `json:"port"` AnalyticsFile string `json:"analytics_file"` StaticFileVersion int `json:"static_file_version"` StaticDir string `json:"static_dir"` TemplatesDir string `json:"templates_dir"` SerTcpSocketHost string `json:"serTcpSocketHost...阅读全文
package main import ( "encoding/json" "fmt" "os" ) type ConfigStruct struct { Host string `json:"host"` Port int `json:"port"` AnalyticsFile string `json:"analytics_file"` StaticFileVersion int `json:"static_file_version"` StaticDir string `json:"static_dir"` TemplatesDir string `json:"templates_dir"` SerTcpSocketHost string `json:"serTcpSocketHost...阅读全文
我想定义一个 ``` type mytype []string var arr mytype =mytype([]string{"123","abc"}) ``` 当然，为的就是增加一些方法。 但是问题来了，如果又来了一些元素要加入我自己定义的这个arr，应该怎么加？只靠强转...阅读全文
载于公众号：灰子学技术原文链接：https://mp.weixin.qq.com/s/nJRVbhRQCgWHR1eHSfBpFA一、前言介绍：对于Go语言并发通讯，是使用的协程goroutine，而协程之间的通讯采用的是channel。但是channel不管是有缓存的，还是无缓存的都会有阻塞的情况出现，只不过无缓存的阻塞会更加频繁。而协程长时间阻塞了之后，Go语言本身又没有提供这种超时的解决机制，所以开发者需要自己考虑实现这种超时机制。这种超时机制在Go语言中则是使用select来解决的。相关的背景知识：1.Go语言并发篇（一）：之go语句篇：https://mp.weixin.qq.com/s/FD-MP9r5sEn1QYRAYZE_4g2.Go语言之goroutine的调度原理： ht...阅读全文
```go package main import ( "encoding/csv" "fmt" "io" "log" "os" ) func main() { //准备读取文件 fileName := "D:\\gotest\\src\\source\\test.csv" fs, err := os.Open(fileName) if err != nil { log.Fatalf("can not open the file, err is %+v", err) } defer fs.Close() r := csv.NewReader(fs) //针对大文件，一行一行的读取文件 for { row, err := r.Read() if err != nil && err != io....阅读全文
位运算 Bitwise operation 前言 日常提出疑问，然后引出今天的下文： 如何在代码里不用 “+” 、“-” 实现加减法的操作？ 接下来我就介绍一项一招制敌的技能 —— 位运算 正文 什么是位运算 程序中的所有数在计算机内存中都是以二进制的形式存储的。位运算（Bitwise operation）就是直接对整数在内存中的二进制位进行操作，因此其执行效率非常高。 在程序中使用位运算进行操作，会大大提高程序的性能。 位运算的本质 位运算是在二进制之间操作，粗略地说就是 0 和 1 之间的转换 位运算的基本操作 与运算 & 两个位都是 1 时，结果才为 1 1 & 1 = 1 1 & 0 = 0 100 & 001 = 0 100 & 101 = 100 或运算 | 两个位都是 0 时，...阅读全文
目录 结构 概念 创建结构 使用结构 值传递 匿名结构 结构的组合 概念 定义一个组合 使用组合 摘要 定义结构，使用结构，值传递与指针传递，匿名结构，结构的组合 结构 概念 Go 中没有 class 的概念，结构可以完成类似功能 支持指向自身的指针类型成员 支持匿名结构 支持 == 和 != 运算符 创建结构 格式 type
package mainimport ( "database/sql" "fmt" _ "github.com/mattn/go-sqlite3" "log" "os")type Users struct { UserId int Uname string}func main() { os.Remove("./foo.db") db, err := sql.Open("sqlite3", "./foo.db") if err != nil { log.Fatal(err) } defer db.Close() sql := `create table users (userId integer, uname text);` db.Exec(sql) sql = `insert into us...阅读全文
我的流程是这样的： 从文件hash.log中读取infohash到一个map[string]int变量hashlist中，读取格式为：hashlist["infohash值"]=1，infohash是有重复值的，在读取的时候，如果遇到重复值，hashlist["infohash"]的值就会自动加1，就编程了hashlist["infohash"]=2，如果没有重复值，则默认为1 当全部读取完成后，使用range来处理map变量，将其中的每一条infohash写入数据库，使用go来并发处理，但是实际操作时却发现，虽然map变量中没有重复值，但实际操作时，却发现循环一旦开始，每次都只会重复一条数据 我的代码如下： ```go for { //e := os.Chdir...阅读全文
以下摘自The Go Programming Language： The &^ operator is bit clear (AND NOT): in the expression z = x &^ y, each bit of z is 0 if the corresponding bit of y is 1; otherwise it equals the corresponding bit of x. 即z = x &^ y运算相当于先把y取反（针对y的每个bit：0变成1，1变成0），然后再和x进行&运算。参考下例： package main import "fmt" func main(){ var x uint8 = 1 var y uint8 = 1 << 2 fmt.Prin...阅读全文
最近在看go语言，只是体验一下传说中的强大。 这个的代码例子是 go语言操作文件：file.go package main import ( "bytes" "fmt" "os" ) func main() { file, err := os.Open("file.go") if err != nil { defer file.Close() fmt.Println(err.Error()) }else{ fileinfo, _ := file.Stat() fmt.Println(fileinfo.Size(), fileinfo.Name()) filesize := fileinfo.Size() buffer := make([]byte, filesize) file.Read(b...阅读全文
第二章 序 在计算机底层，一切都是比特位。然而计算机一般操作的都是固定大小的值，称之为字(word)。字会被解释为整数、浮点数、比特位数组、内存地址等，这些字又可以进一步聚合成数据包(packet)、像素点、作品集、诗歌或者其它任何对象。Go语言提供了多样化的数据组织方式，这些数据类型既有硬件层面的兼容性，又能让程序员方便的组合成更复杂的数据类型。 Go语言的数据类型分为四大类：基本类型，复合类型，引用类型及接口类型。本章将介绍基本类型：数字，字符串，布尔值。 一、整数 Go语言的数值数据类型包括以下几种：整数，浮点数，复数，每一种都包含了大小(size)不同的数值类型，例如有符号整数包含int8,int16,int32,int64,int。每一种数值类型都会决定值的大小和符号(正负)，我们...阅读全文
To read all file content(in bytes) to memory, ioutil.ReadAll package main import ( "fmt" "io/ioutil" "os" "log" ) func main() { file, err := os.Open("file.txt") if err != nil { log.Fatal(err) } defer file.Close() b, err := ioutil.ReadAll(file) fmt.Print(b) } But sometimes, if the file size is big, it might be more memory-efficient to just read in c...阅读全文
package main import ( "fmt" "net/http" "os" ) func main() { Client := &http.Client{} url := "http://www.baidu.com" req, err := http.NewRequest("GET", url, nil) if err != nil { panic("failure to get info from baidu") } response, err := Client.Do(req) if err != nil { panic("fail") } str := make([]byte, 2048) size, err := response.Body.Read(str) if si...阅读全文
版权声明：本文为Sunface(孙飞)原创文章，转载请注明出处 https://blog.csdn.net/abv123456789/article/details/50902368 第二章 序 在计算机底层，一切都是比特位。然而计算机一般操作的都是固定大小的值，称之为字(word)。字会被解释为整数、浮点数、比特位数组、内存地址等，这些字又可以进一步聚合成数据包(packet)、像素点、作品集、诗歌或者其它任何对象。Go语言提供了多样化的数据组织方式，这些数据类型既有硬件层面的兼容性，又能让程序员方便的组合成更复杂的数据类型。 Go语言的数据类型分为四大类：基本类型，复合类型，引用类型及接口类型。本章将介绍基本类型：数字，字符串，布尔值。 一、整数 Go语言的数值数据类型包括以下几种：整数...阅读全文
#### 【题目】 编写一个结构体，用两个栈实现队列，支持队列的基本操作（push、poll、peek） #### 【难度】 ★★☆☆ #### 【解答】 ```go package main import ( "container/list" "errors" "fmt" ) func main() { q := NewQueue() q.Push(1) fmt.Println(q.Peek()) q.Push(2) fmt.Println(q.Peek()) fmt.Println(q.Poll()) fmt.Println(q.Peek()) fmt.Println(q.Poll()) fmt.Println(q.Poll()) fmt.Println(q.Peek()) } type...阅读全文
代码如下： package main import ( "container/list" "fmt" "time" ) var Ch = make(chan int) var DataList = list.New() func ReadChan() { for { data := <-Ch fmt.Println(data) } } func WriteChan() { for { if size := DataList.Len(); size > 0 { data := DataList.Front() if data.Value != nil { Ch <- data.Value.(in...阅读全文
// 通过封装atomic.Value原子值类型，可以实现安全存储不会引发panic type atomicValue struct { v atomic.Value t reflect.Type } func NewAtomicValue(example interface{}) (*atomicValue, error) { if example == nil { return nil, errors.New("atomic value: nil example") } return &atomicValue{ t: reflect.TypeOf(example), }, nil } func (av *atomicValue) Store(v interface{}) error { ...阅读全文
http://tonybai.com/2012/09/26/interoperability-between-go-and-c/ // foo.h int count; void foo(); //foo.c #include "foo.h" int count = 6; void foo() { printf("I am foo!\n"); } //foo.go package main // #cgo LDFLAGS: -L ./ -lfoo // #include
很多人喜欢Go语言，其实是因为Go语言有其独特的语言属性在支撑着其在编程语言界的发展，今天兄弟连Go语言+区块链培训老师给大家介绍一下关于Go语言并发技术3：管道通信，下面我们一起来看一下吧。（ http://bt.itxdl.cn/ ）channel 介绍channel 提供了一种通信机制，通过它，一个 goroutine 可以想另一 goroutine 发送消息。channel 本身还需关联了一个类型，也就是 channel 可以发送数据的类型。例如: 发送 int 类型消息的 channel 写作 chan int 。channel 创建channel 使用内置的 make 函数创建，下面声明了一个 chan int 类型的 channel:ch := make(chan int)· ...阅读全文
前言 前期误操作，导致数据库表删除，虽然数据量不多，但是通过binlog恢复比较麻烦，通过备份文件来恢复，备份文件达36个G打开都是问题； 使用备份文件恢复 大文件编辑器，glogg-latest-x86_64-setup通过该文件打开备份文件，虽然过程稍慢，但是能够打开，且正常读取编辑信息，要恢复的数据量不大时采取是没问题的，但是如果表几十万行，操作起来就比较麻烦了； Golang读取备份文件 采用Golang读取，借助编程语言的优势来读取备份，经过测试读取指定备份文件（约36GB）表，大约需要12min，其实主要就是读取遍历备份文件的过程； ** * @Author: ws * @File: main * @Date: 2019/11/16 0016 14:35 * @Remark: *...阅读全文
搭建fabric网络环境需要准备如下环境，后面会详细介绍安装过程。 环境 Linux：Ubuntu 16.04 Golang:1.9+ docker:1.12+ Fabric:1.1.0 工具 git curl vim golang (goroot,gopath) docker docker-compose 实现docker的自动化操作 简化docker容器操作命令 一条命令即可启动docker容器 相关的操作命令是被集成在一个配置文件中 node npm 安装 fabric 下载 docker镜...阅读全文
redis 基础数据类型Sting类型 :Redis 的字符串是动态字符串，是可以修改的字符串，内部结构实现上类似于 Java 的 ArrayList，采用预分配冗余空间的方式来减少内存的频繁分配，如图中所示，内部为当前字符串实际分配的空间 capacity 一般要高于实际字符串长度 len。当字符串长度小于 1M 时，扩容都是加倍现有的空间，如果超过 1M，扩容时一次只会多扩 1M 的空间。需要注意的是字符串最大长度为 512M。操作命令：set key valueget keyexists keydel key批量设置mset key1 value1 key2 value2 key3 value3mget key1 key2 key3过期设置expire key1 5 5秒后过期sete...阅读全文
go语言中 想要对字符串 hello做插入操作，（如变成 h11ello）都没提供这个公共的方法...阅读全文
所需包engine import ( "fmt" "sync" "engine/mgo" "engine/mgo/bson" ) var ( session *mgo.Session db *mgo.Database c *mgo.Collection mux sync.Mutex ) func init() { mux.Lock() defer mux.Unlock() if session != nil { return } // new session session, err := mgo.Dial("192.168.0.229:27017") checkErr("dial fail", err) session.SetMode(mgo.Monotonic, true) // new...阅读全文
定义连贯操作的结构体方法 package toy type Toy struct { nick string shape string color string height int } func (t *Toy) SetNick(nick string) *Toy { t.nick = nick return t } func (t *Toy) SetShape(shape string) *Toy { t.shape = shape return t } func (t *Toy) SetColor(color string) *Toy { t.color = color return t } func (t *Toy) SetHeight(height int) *Toy { t.he...阅读全文
项目见：???? kafka cluster example 这个实例做了些什么？ 搭建了拥有 3 节点 kafka、 3 节点 zookeeper 的 docker 集群服务； 分别创建了 1 个消息发布者和 2 个相同消费组的消息订阅者的 docker 应用； 使用 ab 进行并发测试，验证该实例消息的订阅 / 发布功能； 通过这个实例，能够了解些什么？ 使用 Docker Compose 构建 Kafka 集群 使用 Golang 创建 Kafka Pub/Sub 实例 使用 ApacheBench 进行并发测试 使用 Makefile 简化构建操作命令 如果这个实例，对你了解 kakfa 有所帮助，请为项目添加 star ，非常感谢...阅读全文
package main import "database/sql" import _ "github.com/Go-SQL-Driver/MySQL" import "fmt" func checkErr(err error){ if err != nil{ fmt.Println(err) panic(err) } } func main(){ db, err := sql.Open("mysql", "root:dumx@/test?charset=utf8") checkErr(err) stmt, err := db.Prepare("INSERT test.latlng SET lat=?, lng=?") checkErr(err) res, err := stmt.Exec(...阅读全文
各位sql 中datetime类型值2016-07-31,go打印出来是 2016-0 这种形式，显示不全是什么原...阅读全文
读写操作： // hello project main.go /* 从文件中读取数据，然后进行排序，再把排序后的数据写入到新文件中 */ package main import ( "fmt" //使用fmt包中的Println()函数 "bufio" "io" "os" "strconv" "sort" ) func readValues(infile string) (values []int,err error){ file,err := os.Open(infile) if err != nil { fmt.Println("打开文件失败！",infile) } defer file.Close() br := bufio.NewReader(file) values = make(...阅读全文
下面是Golang常用的一些操作，获取环境变量、操作文件等等；package main import ( "fmt" "os" "path/filepath" "io/ioutil" ) func main () { //将当前路径和给定的路径连接成绝对路径 absPath,_ := filepath.Abs("test") fmt.Println(absPath) //返回路径中最后的那个路径（通常是目录名或者文件名） basePath := filepath.Base(absPath) fmt.Println(basePath) //返回除最后的目录之外的路径（即最后的目录之前的路径） dirPath := filepath.Dir(absPath) fmt.Println(dirPat...阅读全文
package main import ( "bytes" "fmt" "io" "os" ) func main() { file, err := os.OpenFile("./a.png", os.O_RDONLY, os.ModePerm) defer file.Close() if err != nil { fmt.Println("open file err:", err.Error()) os.Exit(1) } fmt.Println("open file ./a.png success!") fileinfo, err := file.Stat() if err != nil { fmt.Println("stat err:", err.Error()) os.Exit(1)...阅读全文
package main import ( "encoding/json" "fmt" "os" ) type ConfigStruct struct { Host string `json:"host"` Port int `json:"port"` AnalyticsFile string `json:"analytics_file"` StaticFileVersion int `json:"static_file_version"` StaticDir string `json:"static_dir"` TemplatesDir string `json:"templates_dir"` SerTcpSocketHost string `json:"serTcpSocketHost...阅读全文
可以通过time.LoadLocation的方式避免时区的变化 func TestStatsMsg(t *testing.T) { assert := assert.New(t) assert.NotNil(QQGroupMMgr) ti, _ := time.Parse("2006-01-02 15:04:05", "2016-10-08 00:00:00") persons := QQGroupMMgr.StatsMsg("茅", ti) assert.NotNil(persons) tz, _ := time.LoadLocation("UTC") for _, value := range persons { fmt.Println("StatsMsg---:", value.ID....阅读全文
在关系型数据库领域，为人津津乐道的一个特性，便是数据库的锁设计及事务隔离级别。 本文通过golang系统库sync，来实现简单的数据库数据读写操作。 场景说明 小明经营一家水果店，创业初始资金为100000元，所有的收入以及支出通过2个银行账户进行往来。 因交易频繁，可能存在并发更新账户数据及查账的需求，需要保障账户数据针对所有操作的一致性。 此处需要引入读写锁，保障读写的安全性及高效性。 需求分析 在MySQL中，使用InnoDB存储引擎，配合合适的事务隔离级别，可以做到数据行级锁定，也就是: 操作类型 查账户A 查账户B 写账户A 写账户B 查账户A 可并发 可并发 互斥 可并发 查账户B 可并发 可并发 可并发 互斥 写账户A 互斥 可并发 互斥 可并发 写账户B 可并发 互斥 可并发...阅读全文
为什么slice不支持==操作？书上描述的不是很清楚...阅读全文
package main import ( "fmt" "gopkg.in/mgo.v2" "gopkg.in/mgo.v2/bson" "log" ) type Student struct { //Id_ bson.ObjectId `bson:"_id"` Name string `bson:"name"` Phone string `bson:"phone"` Email string `bson:"email"` Sex string `bson:"sex"` } //数据库连接主要用到了mgo中的Dial()函数,连接形式如mgo.Dial(url1,url2,url3) func ConnecToDB() *mgo.Collection { session, err := mg...阅读全文
有一个map,只对其进行新增，更新操作，现在写一个定时任务，定时检测map中的key是否被更新，若没被更新将其删掉，怎么检测是否被更新？？？...阅读全文
为什么要用nginx? 在网上搜索负载均衡的时候，总会跳出nginx这个字眼，对于我这样只关注开发功能却从未关心过架构的人来说，还是比较陌生的，印象中用了nginx好像可以扛更多的访问量。 过完年后开发工作告一段落，正好有时间，就决定从一个初学者的角度来描述一下，为什么要用nginx。 经查阅各种资料，nginx的主要功能和使用方式包括 nginx反向代理 nginx负载均衡 nginx配置https nginx静态资源服务器 整合keepalive、lvs等 以上5点主要作为后续实践内容的大纲。 nginx反向代理 这个名称和概念有点让人懵逼，从数据的流向方面来说一下我的理解。 nginx反向代理.jpg 通过时序图可以看出，相当于nginx就是个方案公司的FAE，你的所有需求和沟通交流，...阅读全文
因为golang的map和列表切片都是引用类型，且非线程安全的，所以在多个go routine中进行读写操作的时候，会产生“map read and map write“的panic错误。 某一些类型的对象，会有这种类似的set方法来写数据，或者get方法来返回一个map: func (this *object) Set(name, val) { this.Lock() defer this.Unlock() this.m[name] = val } func (this *object) Get() map[string]string { this.Lock() defer this.Unlock() return this.m } 如果会在多个go routine中通过该对象的Get()...阅读全文
