1.下载并导入数据库驱动包 官方不提供实现，先下载第三方的实现，点击这里查看各种各样的实现版本。这里选择了Go-MySQL-Driver这个实现。地址是：https://github.com/go-sql-driver/mysql/。 然后按照里面的说明下载驱动包： $ go get github.com/go-sql-driver/mysql 最后导入包即可： import "database/sql" import _ "github.com/go-sql-driver/mysql" 2.连接至数据库 db, err := sql.Open("mysql", "root:root@/uestcbook") 3.执行查询 （1）Exec result, err := db.Exec( "I...阅读全文
各主流的golang orm介绍 当前较为主流/活跃的orm有gorm、xorm、gorose等 xorm 文档 github document godoc 支持的数据库有：mysql、mymysql、postgres、tidb、sqlite、mssql、oracle 事务性支持 链式api has, err := engine.Where("name = ?", name).Desc("id").Get(&user) err := engine.Where(builder.NotIn("a", 1, 2).And(builder.In("b", "c", "d", "e"))).Find(&users) 支持原生sql操作 查询缓存 可根据数据库反转生成代码 级联加载 提供sql语句日志输...阅读全文
最近被日志是折腾得死去活来，写文件无疑效率是最高的，但是分布式又成问题，虽然稍微折腾一下配合NFS，还是可以搞一搞的，但是始终语言设计没有那么方便。 最终决定用redis，换了redis以为就好了，因为内存运行嘛，谁知道tcp连接开销大得一塌糊涂，服务器负载一下子高了许多，使用netstat -an 查看发现一堆的 TIME_WAIT，连ssh到服务器都巨慢无比，所谓天下武功唯快不破，这么慢80岁老太太跳一支广场舞都能给灭了吧。 既然 tcp连接开销这么大，当然首要任务就是解决连接问题，明显一个请求一次连接是很不靠谱的，还不如直接往硬盘写日志呢，当然写日志第一段也说了，不支持分布式，业务分配没那么好。 那么，能不能先定只用一个连接呢，这显然是不行的，一个连接多个php-fpm互掐也会造成瓶颈...阅读全文
已经使用golang有一段时间，go的协程和gc垃圾回收特性的确会提高程序的开发效率。但是毕竟是一门新语言，如果对于它的机制不了解，用起来可能会蹦出各种潘多拉盒子。今天就讲讲我在项目中用到的sync包的Pool类的使用，以免大家混淆使用。 众所周知，go是自动垃圾回收的(garbage collector)，这大大减少了程序编程负担。但gc是一把双刃剑，带来了编程的方便但同时也增加了运行时开销，使用不当甚至会严重影响程序的性能。因此性能要求高的场景不能任意产生太多的垃圾（有gc但又不能完全依赖它挺恶心的），如何解决呢？那就是要重用对象了，我们可以简单的使用一个chan把这些可重用的对象缓存起来，但如果很多goroutine竞争一个chan性能肯定是问题.....由于golang团队认识到这个...阅读全文
基于GF(Go Frame)的后台管理系统 前端采用ruoyi-ui 、Vue、Element UI。 后端采用GO语言 框架 GF(Go Frame)。 本项目由奇讯科技团队开发。 内置功能 - 用户管理：用户是系统操作者，该功能主要完成系统用户配置。 - 部门管理：配置系统组织机构（公司、部门、小组），树结构展现支持数据权限。 - 岗位管理：配置系统用户所属担任职务。 - 菜单管理：配置系统菜单，操作权限，按钮权限标识等。 - 角色管理：角色菜单权限分配、设置角色按机构进行数据范围权限划分。 - 字典管理：对系统中经常使用的一些较为固定的数据进行维护。 - 参数管理：对系统动态配置常用参数。 - 操作日志：系统正常操作日志记录和查询；系统异常信...阅读全文
Golang支持DB操作位于database包下,支持基本CRUD操作、事务和Prepared Statement,本文以MySQL为例。 MySQL驱动安装 使用数据库之前,必须安装相关MySQL数据驱动[1],如果未安装驱动或者没有引入驱动库会报以下错误： failed to open database: sql: unknown driver "mysql" (forgotten import?) 安装golang mysql driver go get github.com/go-sql-driver/mysql 代码中还需注册数据库驱动,通过引入空白倒入[2]mysql包来完成 import("database/sql"// 引入数据库驱动注册及初始化_ "github.com/g...阅读全文
在golang的项目中，若要频繁的用redis（或者其他类似的NoSQL）来存取数据，最好用redigo自带的池来管理连接。 不然的话，每当要操作redis时，建立连接，用完后再关闭，会导致大量的连接处于TIME_WAIT状态（redis连接本质上就是tcp）。 注：TIME_WAIT，也叫TCP半连接状态，会继续占用本地端口。 以下为redis连接池的golang实现： import ( "github.com/garyburd/redigo/redis" "github.com/astaxie/beego" "time" ) var ( // 定义常量 RedisClient *redis.Pool REDIS_HOST string REDIS_DB int ) func init()...阅读全文
sql.DB 通过数据库驱动为我们提供管理底层数据库连接的打开和关闭操作. sql.DB 为我们管理数据库连接池 需要注意的是，sql.DB表示操作数据库的抽象访问接口,而非一个数据库连接对象;它可以根据driver打开关闭数据库连接，管理连接池。正在使用的连接被标记为繁忙，用完后回到连接池等待下次使用。所以，如果你没有把连接释放回连接池，会导致过多连接使系统资源耗尽。 操作mysql 1.导入mysql数据库驱动 1 2 3 4 import ( "database/sql" _ "github.com/go-sql-driver/mysql" ) 通常来说, 不应该直接使用驱动所提供的方法, 而是应该使用 sql.DB, 因此在导入 mysql 驱动时, 这里使用了匿名导入的方式(在包路...阅读全文
相传，创业C星球里存在一支神秘的创业护卫队，自组建以来的770天里他们奇迹般攻占超100个孵化基地，成功赋能超5000支创业团队，为平台上的团队实现超10亿元融资额。 C星球的创业勇士们，这个既低调又华丽的创业护卫队~~~现~~~身~~~了~~（看完全篇有惊喜） 这支创业护卫队正是阿里巴巴创新中心，它有个洋气的英文名：Alibaba Innovation Center。它诞生于2015年3月29日，当时还叫阿里云“创客+”。而2016年8月在云栖大会·北京峰会上“创客+”华丽升级为阿里巴巴创新中心。 阿里巴巴创新中心专注服务基于互联网、云计算、大数据等科技类“双创”团队，强大的阿里巴巴星球内外部资源整合能力是护卫队的主要技能之一，包括创业场地、指导、资本...阅读全文
````golang package main import ( "encoding/json" "errors" "fmt" "time" "github.com/garyburd/redigo/redis" ) const ( RedisURL = "redis://*****:6379" redisMaxIdle = 3 //最大空闲连接数 redisIdleTimeoutSec = 240 //最大空闲连接时间 RedisPassword = "*****" ) // NewRedisPool 返回redis连接池 func NewRedisPool(redisURL string) *redis.Pool { return &redis.Pool{ MaxIdle: redisMa...阅读全文
GO中调用redis时，实始化一个连接池，做法也是一般的用户： ```go &redis.Pool{ MaxIdle: beego.AppConfig.DefaultInt("redis::maxidle", 1), MaxActive: beego.AppConfig.DefaultInt("redis::maxactive", 10), IdleTimeout: time.Duration(beego.AppConfig.DefaultInt64("redis::idle_time_out", 180)) * time.Second, Dial: func() (redis.Conn, error) { log.Println("func dia...阅读全文
```/* * @Descripttion: golang 连接mysql demo * @version: * @Author: weilin * @Date: 2019-10-19 11:31:23 * @LastEditors: weilin * @LastEditTime: 2019-10-19 22:49:53 */package mainimport ( // database/sql是golang的标准库之一，它提供了一系列接口方法，用于访问关系数据库。 //它并不会提供数据库特有的方法，那些特有的方法交给数据库驱动去实现。我们这里使用到的是mysql驱动 "database/sql" "fmt" "time" // 导入mysql驱动 _ "github.com/go-sql...阅读全文
go net/http Client使用总结 Client数据结构 // A Client is an HTTP client. Its zero value (DefaultClient) is a // usable client that uses DefaultTransport. // // The Client's Transport typically has internal state (cached TCP // connections), so Clients should be reused instead of created as // needed. Clients are safe for concurrent use by multiple goroutin...阅读全文
准备知识：MySQL事务 1 基本操作 sql.Tx tx会从连接池中取一个空闲的连接，直至调用commit或者rollback才会释放 tx, err := db.Begin() // 创建tx对象 tx.Query(command1) tx.Exec(command2) tx.Commit() 2 并发 事务只有一个连接，事务内的操作是串行的 db, _ := sql.Open(...) rows, _ := db.Query("SELECT id FROM tt_users") for rows.Next(){ var ( user_id int openid string ) rows.Scan(&user_id) db.QueryRow("SELECT openid FROM tt...阅读全文
在上篇用纯go在本机模拟了下分布式队列的东西。这里补上Redis队列部份。 用Redis做队列有下面三个问题需解决： 1. 队列构建 使用Redis的RPUSH/LPOP来解决 2. 参数传递/解析 客户端将JOSN参数存入Redis,Server端取出后解析还原。 3. 连接池 redigo支持Redis连接池 下面代码就是具体解决实现: //Redis做后台任务队列 //author: Xiong Chuan Liang //date: 2015-3-25 package main import ( "bytes" "encoding/json" "errors" "fmt" "time" "github.com/garyburd/redigo/redis" ) func main() ...阅读全文
这几天用Go写了个简陋的服务器，连接Mysql数据库，提供api给其他程序调用来实现增删改产等服务。Go的版本是1.2，使用的驱动是go-sql-driver/mysql。但是在有一定量的查询结果以后，会出先too many connection的错误。 google了一下，很多文章都建议修改MySql的配置文件：my.ini。文章是这样解释的：MySql的默认连接数是100，当查询数过多时，就会出现这个错误。所以把配置修改： max_connections=1000 这个字段后面的数字就是MySql允许的连接数，改的大一些就会解决问题。于是在电脑上直接改成10000，重启MySql。然后电脑就卡的要崩溃了。看了相关的文档大约知道，这个参数是控制MySql建立的线程数的。改成10000就会有...阅读全文
关于什么是cassandra，可以参考： http://blog.csdn.net/zyz511919766/article/details/38683219 http://cassandra.apache.org/ 比较了HBASE、mongodb 和 cassandra 1）HBASE 和 cassandra 都是列式存储，但是 cassandra部署方便，扩展容易2） mongodb 并不是真正的列式存储，数据扩容比较麻烦，需要提前做好集群分区 casandra是 p2p(gossip)实现的bigtable, 数据一致性可以通过参数配置(R+W >N), 写操作完成是all node，还是指定的node个数，才进行返回。 数据模型： 尝试了cassandra的两个client。 1....阅读全文
熊猫TV的礼物系统使用了golang的 mongo库 mgo，中间踩了一些坑，总结下避免大家再踩坑 golang的mgo库说明里是说明了开启连接复用的，但观察实验发现，这并没有根本实现连接的控制，连接复用其实仅在当前操作 (session.Close 之前 )生效，最终还是需要程序员自行去限制连接才行。 废话不多说，开始上代码 GlobalMgoSession, err := mgo.Dial(host) func (m *MongoBaseDao) Get(tablename string, id string, result interface{}) interface{} { session := GlobalMgoSession.Clone() defer session.Close...阅读全文
Golang 数据库操作 Golang 数据库 MySQL Golang支持DB操作位于database包下,支持基本CRUD操作、事务和Prepared Statement,本文以MySQL为例。 MySQL驱动安装 使用数据库之前,必须安装相关MySQL数据驱动[1],如果未安装驱动或者没有引入驱动库会报以下错误： failed to open database: sql: unknown driver "mysql" (forgotten import?) 安装golang mysql driver go get github.com/go-sql-driver/mysql 代码中还需注册数据库驱动,通过引入空白倒入[2]mysql包来完成 import( "database/sql"...阅读全文
golang的channel除了goroutine通信之外还有很多其他的功能，本文将实现一种基于channel的通用连接池。 何为通用？ 连接池的实现不依赖具体的实例，而依赖某个接口，本文的连接池选用的是io.Closer接口，只要是实现了该接口的对象都可以被池管理。当然，你可以实现基于interface{}的连接池，这样任何对象都可以被管理。 实现原理 将连接句柄存入channel中，由于缓存channel的特性，获取连接时如果池中有连接，将直接返回，如果池中没有连接，将阻塞或者新建连接（没超过最大限制的情况下）。由于面向接口编程，所有创建连接的逻辑是不清楚的，这里需要传入一个函数，该函数返回一个io.Closer对象。 实现 由于并发问题，在需要操作池中互斥数据的时候需要加锁。 pack...阅读全文
GO src中自带了sql包和连接数据库的包。这里以连接MYsql为例子。 sql.Open 就是开启了一个数据库连接处。在执行EXEC 或者 QUERY的时候就会自己去建立连接。因此整个应用程序 只需要初始化一次sql.db指针。然后到处用就oK了。 // dbTest project main.go package main import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" "time" ) func IsErr(err error) { if err != nil { fmt.Printf("程晗错误:%s", err) } } func main() { //初始化数据库信息，此时就是一个数据库连接池 d...阅读全文
golang 高性能异步工作池。并发限制goroutine池，限制任务执行的并发性，而不是排队的任务数。无论排队多少任务，都不会阻止提交任务...阅读全文
func newPool(server, password string) *redis.Pool { return &redis.Pool{ MaxIdle: 3, IdleTimeout: 240 * time.Second, Dial: func () (redis.Conn, error) { c, err := redis.Dial("tcp", server) if err != nil { return nil, err } if _, err := c.Do("AUTH", password); err != nil { c.Close() return nil, err } return c, err }, TestOnBorrow: func(c redis.Conn, ...阅读全文
在中国，奇虎 360 是一个互联网和手机安全产品及服务的主要供应商，截止到 2014 年 6 月，奇虎拥有 5 亿的 PC 活跃用户以及超过 6.4 亿移动用户。奇虎还运营着中国最受欢迎的网络浏览器和 PC 搜索引擎(原文如此)。 我的团队，推送服务团队(Push Service Team)，为超过 50 个公司的产品提供服务（PC 和移动），包括成千上万放在我们的开放平台的应用程序。 我们对Go的青睐要从2012年第一次尝试为奇虎的一个产品提供推送功能开始。最初的nginx + lua + redis方案因为负载过大没能满足我们对实时性能的需求。在这种情况下，最新发布的1.0.3版Go引起了我们的注意，借助它提供的goroutine和channel特性，我们在几周之内开发完成了一个原型。我...阅读全文
Go中连接数据库的连接池：当你需要和数据库通信时，就会从连接池里面取出一个连接，和数据库交互。使用完的闲置的连接会回到连接池，等待下一次的调用。如果连接池里面没有闲置的连接，会自动创建一个新的连接出来。其中有一段： An sql.Row returns the connection when Scan() is called, sql.Rows returns either when Close() is called or all rows have been iterated over with Next(), and sql.Tx will return when Commit or Rollback() are called. If you forget to completely ...阅读全文
导读 大家好我是平也，今天跟大家介绍一款用来发送邮件的Go语言库email，目前星星1.3k，非常好用。 极速上手 准备工作 初始化项目 go get github.com/jordan-wright/email复制代码 本示例项目结构 . ├── go.mod ├── go.sum └── main.go复制代码 开启邮箱SMTP服务，以163邮箱为例，需要先登录到邮箱后台点击开启按钮，在发送完短信之后，会获取到一个授权码，将授权码保存，后面需要用到。 代码示例 首先配置好邮件内容 e := email.NewEmail() e.From = "平也
导读 大家好我是平也，今天跟大家介绍一款用来发送邮件的Go语言库email，目前星星1.3k，非常好用。 极速上手 准备工作 初始化项目 go get github.com/jordan-wright/email 本示例项目结构 . ├── go.mod ├── go.sum └── main.go 开启邮箱SMTP服务，以163邮箱为例，需要先登录到邮箱后台点击开启按钮，在发送完短信之后，会获取到一个授权码，将授权码保存，后面需要用到。 file file 代码示例 首先配置好邮件内容 e := email.NewEmail() e.From = "平也
导读 大家好我是平也，今天跟大家介绍一款用来发送邮件的Go语言库email，目前星星1.3k，非常好用。 极速上手 准备工作 初始化项目 go get github.com/jordan-wright/email 本示例项目结构 . ├── go.mod ├── go.sum └── main.go 开启邮箱SMTP服务，以163邮箱为例，需要先登录到邮箱后台点击开启按钮，在发送完短信之后，会获取到一个授权码，将授权码保存，后面需要用到。 代码示例 首先配置好邮件内容 e := email.NewEmail() e.From = "平也
《PostgreSQL Documentation》 介绍：PostgreSQL官方文档主页 《PG技术沙龙ppt》 介绍：2013年4月PG技术沙龙PPT 《PG9.3中文翻译文档》 介绍：PG9.3中文翻译文档 谢谢@skykiker提供 《PostgreSQL从菜鸟到专家(中译稿 by 洞庭湖的泥鳅)》 介绍：这篇文档是国内的一线postgreSQL专家所翻译。很经典 《PostgreSQL vs. MS SQL Server》 介绍：PostgreSQL与 MS SQL Server的对比,中文版 《PostgreSQL 30天 培训视频》 介绍：作者德哥@Digoal从事pg截止目前大概有7-8年，长期活跃在国内的pg社区。这套PostgreSQL 30天 培训视频包含了SQL基础...阅读全文
golang本身没有提供连接mysql的驱动，但是定义了标准接口供第三方开发驱动。这里连接mysql可以使用第三方库，第三方库推荐使用https://github.com/Go-SQL-Driver/MySQL这个驱动，更新维护都比较好。下面演示下具体的使用，完整代码示例可以参考最后。 下载驱动 sudo go get github.com/go-sql-driver/mysql 数据库连接 db, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/dbname?charset=utf8") 其中连接参数可以有如下几种形式：通常我们都用第二种。 user@unix(/path/to/socket)/dbname?chars...阅读全文
简介 Golang 提供了 database/sql 包用于对 SQL 的数据库的访问, 在这个包中, 最重要的自然就是 sql.DB 了.对于 sql.DB, 我们需要强调的是, 它并不代表一个数据库连接, 它是一个已存在的数据库的抽象访问接口. sql.DB 为我们提供了两个重要的功能: sql.DB 通过数据库驱动为我们管理底层数据库连接的打开和关闭操作. sql.DB 为我们管理数据库连接池 有一点需要注意的是, 正因为 sql.DB 是以连接池的方式管理数据库连接, 我们每次进行数据库操作时, 都需要从连接池中取出一个连接, 当操作任务完成时, 我们需要将此连接返回到连接池中, 因此如果我们没有正确地将连接返回给连接池, 那么会造成 db.SQL 打开过多的数据库连接, 使数据库连...阅读全文
1、前言 Go语言的渗透率越来越高，同时大家对Go语言实战经验的关注度也越来越高。Go语言在高并发、通信交互复杂、重业务逻辑的分布式系统中非常适用，具有开发体验好、一定量级下服务稳定、性能满足需要等优势。 本文内容整理自奇虎360公司的周洋在 Gopher China 2015 大会上的分享（演讲PPT下载：《Go语言构建高并发消息推送系统实践PPT(来自奇虎360)[附件下载] 》），该次分享以360海量在线的消息推送系统为例，来探讨使用Go语言构建高并发消息推送系统时所遇到的问题以及总结出的各种实践技巧。 2、Go语言在基础服务开发领域的优势 Go语言在高并发、通信交互复杂、重业务逻辑的分布式系统中非常适用，具有开发体验好、一定量级下服务稳定、性能满足需要等优势。以360消息推送系统为例...阅读全文
21天精品区块链课程免费学习，深入实战行家带路，助力开发者轻松玩转区块链！ >>> sqlx使用指南 这边文章主要基于Illustrated guide to SQLX翻译而成。 sqlx是一个go语言包，在内置database／sql包之上增加了很多扩展，简化数据库操作代码的书写。 资源 如果对于go语言的sql用法不熟悉，可以到下面网站学习： database/sql documentation go-database-sql tutorial 如果对于golang语言不熟悉，可以到下面网站学习： The Go tour How to write Go code Effective Go CSDN 由于database/sql接口是sqlx的子集，当前文档中所有关于database/sq...阅读全文
作为一个phper,第一次听到连接池还有点蒙圈，转golang开发后连接池的概念会经常使用。 一、连接池是什么 连接池是什么？一个服务端资源的连接数量都是有限的，每次初始化时他建一定数量的连接，先把所有连接存起来，谁要用则从里面取，用完后放回去。如果超出连接池容量，要是排队等着或么直接丢弃。 比如我们做开发中常用的mysq,redis,php-fpm的配置 1，redis服务端设置 maxclients 最大连接数设置 2， mysql服务端设置 max_connections 最大连接数 3，PHP-FPM 服务端设置 max_children 最大子进程数 start_servers 起始进程数 我们golang开发时连接redis用到自己设计的连接池概念，想要达到的效果是什么？ 1，最...阅读全文
我使用了redigo包的连接池方法来请求建好的redis库。但是在请求过程中经常会报 EOF的错误，这就导致rs（redis.Conn）关闭。并且数据也没有请求到。想请教一下有没有其他人也有类似的问题。这个EOF是什么导致的错误呢。 * 我的redis是用docker容器跑的。 * go版本 1.4.2 * 不管是连接池还是直接请求，都会常出现EOF错误 * 之前在写http的stream方式请求的数据的时候，也经常出现 unexpected EOF错误，也没有找到原...阅读全文
golang post 上传文件 地址：https://github.com/FakerGit/go-tools/tree/master/http //注意client 本身是连接池，不要每次请求时创建client var ( HttpClient = &http.Client{ Timeout: 3 * time.Second, } ) // 上传文件 // url 请求地址 // params post form里数据 // nameField 请求地址上传文件对应field // fileName 文件名 // file 文件 func UploadFile(url string, params map[string]string, nameField, fileName string...阅读全文
概览： 为什么需要连接池 连接失效问题 database/sql 中的连接池 使用连接池管理Thrift链接 以下主要使用Golang作为编程语言 为什么需要连接池 我觉得使用连接池最大的一个好处就是减少连接的创建和关闭，增加系统负载能力，之前就有遇到一个问题：TCP TIME_WAIT连接数过多导致服务不可用，因为未开启数据库连接池，再加上mysql并发较大，导致需要频繁的创建链接，最终产生了上万的TIME_WAIT的tcp链接，影响了系统性能。 链接池中的的功能主要是管理一堆的链接，包括创建和关闭，所以自己在fatih/pool基础上，改造了一下：https://github.com/silenceper/pool ，使得更加通用一些，增加的一些功能点如下： 连接对象不单单是net.Co...阅读全文
Golang支持DB操作位于database包下,支持基本CRUD操作、事务和Prepared Statement,本文以MySQL为例。 MySQL驱动安装 使用数据库之前,必须安装相关MySQL数据驱动[1],如果未安装驱动或者没有引入驱动库会报以下错误： failed to open database: sql: unknown driver "mysql" (forgotten import?) 安装golang mysql driver go get github.com/go-sql-driver/mysql 代码中还需注册数据库驱动,通过引入空白倒入[2]mysql包来完成 import("database/sql"// 引入数据库驱动注册及初始化_ "github.com/g...阅读全文
用了一周的时间才最终找到了一个会在大并发（并发1000，mbp普通本）下可能会发生的空指针问题，现在经过多次测试，终于可以关闭这个bug了。哈哈，高兴啊。 现在的gossdb已经相对成熟了，而且用的人也越来越多了，希望在这里介绍给大家，如果有人用ssdb，不妨尝试一下，会有惊喜的。 下面简单的介绍一下gossdb https://github.com/seefan/gossdb 功能列表 1. 继承官方连接方式。已支持超过40个官方命令。 2. 支持连接池。 3. 已支持 set 相关方法 4. 已支持 hashmap 相关方法 5. 已支持 queue 相关方法 6. 已支持返回值类型转换，可以方便的把从ssdb中取到的内容转化为指定类型。 连接池已支...阅读全文
岗位要求： 1、熟悉linux命令基础操作； 2、有过相关服务器运维经验，含接口编写、数据库设计； 3、了解C/S架构； 4、熟悉Golang，有大型项目开发和部署经验； 5、熟练网络编程，对Tcp数据包有所了解； 6、使用过开发过一个或以上比较完善的服务端应用项目优先考虑； 公司是做互联网医疗软件开发行业的，目前所有的技术人员都向CTO汇报工作，内部氛围轻松和谐，并鼓励学习新技术，一起讨论一起解决问题~ 福利的话，超多零食，平时也会组织一些活动出去吃吃喝喝，上下班不打卡，国家法定节假日都是照放的~ 工资方面，老板自己也开口了，主要看面试后的评价，不会低于市场工资水平，如果是CTO非常认同的大神，那工资都好谈~~ 如果有兴趣的小伙伴，可以发送简历到我的邮箱，邮箱是...阅读全文
安装 我使用的是 https://github.com/go-redis/r... 这个 golang 客户端, 因此安装方式如下: go get gopkg.in/redis.v4 接着在代码中导入此包即可: import "gopkg.in/redis.v4" 基本操作 创建客户端 通过 redis.NewClient 函数即可创建一个 redis 客户端, 这个方法接收一个 redis.Options 对象参数, 通过这个参数, 我们可以配置 redis 相关的属性, 例如 redis 服务器地址, 数据库名, 数据库密码等.下面是一个连接的例子: // 创建 redis 客户端 func createClient() *redis.Client { client := redis.N...阅读全文
olang的”database/sql”是操作数据库时常用的包，这个包定义了一些sql操作的接口，具体的实现还需要不同数据库的实现，mysql比较优秀的一个驱动是：github.com/go-sql-driver/mysql，在接口、驱动的设计上”database/sql”的实现非常优秀，对于类似设计有很多值得我们借鉴的地方，比如beego框架cache的实现模式就是借鉴了这个包的实现；”database/sql”除了定义接口外还有一个重要的功能：连接池，我们在实现其他网络通信时也可以借鉴其实现。连接池的作用这里就不再多说了，我们先从一个简单的示例看下”database/sql”怎么用：package main import( "fmt" "database/sql" _ "github.c...阅读全文
一、关于连接池 一个数据库服务器只拥有有限的资源，并且如果你没有充分使用这些资源，你可以通过使用更多的连接来提高吞吐量。一旦所有的资源都在使用，那么你就不能通过增加更多的连接来提高吞吐量。事实上，吞吐量在连接负载较大时就开始下降了。通常可以通过限制与可用的资源相匹配的数据库连接的数量来提高延迟和吞吐量。 如果不使用连接池，那么，每次传输数据，我们都需要进行创建连接，收发数据，关闭连接。在并发量不高的场景，基本上不会有什么问题，一旦并发量上去了，那么，一般就会遇到下面几个常见问题： 性能普遍上不去CPU 大量资源被系统消耗网络一旦抖动，会有大量 TIME_WAIT 产生，不得不定期重启服务或定期重启机器服务器工作不稳定，QPS 忽高忽低 要想解决这些问题，我们就要用到连接池了。连接池的思路很简...阅读全文
文 http://peter.bourgon.org/go-kit/ The modern enterprise 当我们听到 企业（enterprise）这个词的时候，往往会联想到老派，缓慢， 繁文褥节等名词，就比如 IBM HP 甚至红帽这样的公司，他们已经在长达数十年的时间内成为科技行业的领导者。现在，一些如 Google Amazon Twitter，Netflix，Facebook，Spotify，乃至 SoundCloud 这些公司正成为互联网行业的主流，这些现代的企业通常有以下一些特质： 技术导向 专注用户产品和用户体验 成功的，爆炸式的增长 100-1000 数量级的工程师 采用面向服务的架构 （SOA） 最后一点尤其关键。 A service-oriented archite...阅读全文
建过网站的人都知道，网站备案真实性核验环节花费的时间比较长，为贯彻国务院“放管服”改革要求，工业和信息化部及各省通信管理局自2016年起指导境内接入服务企业开展了APP备案试点工作，旨在满足网站备案真实性的前提下，解决广大用户对网站备案时效性的要求。近日，阿里云APP就正式上线了“备案刷脸核验”功能，网站备案客户可直接在APP上传相关资料，极大的缩短了网站备案时间。  网站备案是指针对使用大陆节点服务器开办网站的用户，需要在服务器提供商处提交备案申请，阿里云作为工信部许可的接入服务企业，可以对有开办网站需求的用户提供备案支...阅读全文
gorm快速上手 Quick start 数据库连接 1.Sqlite数据库 package main import ( "github.com/jinzhu/gorm" _ "github.com/jinzhu/gorm/dialects/sqlite" ) func main() { //打开数据库连接 var db, _ = gorm.Open("sqlite3", "demo.db") //关闭数据库连接 defer db.Close() } 2.MySQL数据库 数据库连接字符串格式即DSN (Data Source Name)格式为： [username[:password]@][protocol[(address)]]/dbname[?param1=value1&...&par...阅读全文
因为需要减少数据库的查询次数，所以拼装的sql比较长，大概有13K，用这条sql在终端查的时候，是没问题的，项目中就一直报错，错误信息： 刚开始报 [mysql] 2017/12/08 18:35:23 packets.go:36: unexpected EOF 然后接下来的sql就全部报 driver: bad connection (invalid connection) [mysql] 2017/12/08 18:35:23 connection.go:354: invalid connection [mysql] 2017/12/08 18:35:23 connection.go:354: invalid connection 是连接池配置的...阅读全文
更新日志： 更新至2012.4.8的vitess代码 新的代码增加了同步用的条件变量，没有空闲资源时的排队不再使用channel来同步(使用其它编程语言的同学可以方便的移植这个代码了)，转而使用condition variable。不再使用mu.RLock，统一使用Lock，不再纠结。 整体代码清晰了许多。 为了进一步提高性能和代码复用，vitess还提供了通用的池管理，RoundRobin.go中实现了通用的资源池，方便管理池内资源总数，超时。 先上第一道菜：RoundRobin在整个vitess架构中扮演的什么角色？ 个人觉得RoundRobin的重要性在vitess中怎么着也能算个丐帮的几个长老之一吧，作为其它几个pool的核心基础 如cache_pool.go就是RoundRobin...阅读全文
mgo 是 MongoDB 的 Golang 驱动。 连接池 我们通过 Dial 函数创建一个新的 session： session, err := mgo.Dial(url) 创建的 session 能够和 MongoDB 集群中的所有服务器通讯。需要注意的是，对于一个集群只需要调用一次 Dial，通过此 Dial 返回的 session 的 New 和 Copy 方法能够创建更多的 session 出来，这些 session 共用底层的连接池（Dial 创建的多个 session 之间使用不同的连接池）。 更为具体的来看下 Strong session（Strong 为一种一致性模式，这里讨论 Strong session 是因为其相对简单，详见下文）。一个 Strong session...阅读全文
基本概念 Open() – creates a DB Close() - closes the DB Query() - 查询 QueryRow() -查询行 Exec() -执行操作，update，insert，delete Row - A row is not a hash map, but an abstraction of a cursor Next() Scan() 注意：DB并不是指的一个connection 连接到数据库 我们以mysql为例，使用github.com/go-sql-driver/mysql，首先我们需要导入我们需要的包 import ( "database/sql" _ "github.com/go-sql-driver/mysql" ) 注意我们导入gith...阅读全文
