commit the test code

Coder0yang · Coder0yang · commit 0259d3ab32b4 · 2016-08-25T23:03:35.000+08:00
diff --git a/README.md b/README.md
@@ -0,0 +1,2 @@
+## The way to learn Golang
+### this is the code I practiced
diff --git a/redis_test/conn.go b/redis_test/conn.go
@@ -1,28 +1,49 @@
 package redistest
 
 import (
-    "github.com/garyburd/redigo/redis"
+	"github.com/garyburd/redigo/redis"
 )
 
-var conn redis.Conn
+//var conn redis.Conn
+func newPool() *redis.Pool {
+	return &redis.Pool{
+		MaxIdle:   80,
+		MaxActive: 20000,
+		Dial: func() (redis.Conn, error) {
+			c, err := redis.Dial("tcp", "localhost:6379")
+			if err != nil {
+				panic(err.Error())
+			}
+			return c, err
+		},
+	}
+}
+
+var pool = newPool()
 
-func Init(redisIp string,redisPort string)error{
-    var err error
-    conn,err = redis.Dial(redisIp,redisPort)
-    return err
+/*
+func Init()error{
+    pool = newPool()
 }
+*/
 
-func DoGet(userId string)string{
-    str,_ := redis.String(conn.Do("HGET",userId,"ad1"))
-    return str
+func getConn() redis.Conn {
+	c := pool.Get()
+	return c
 }
 
-func PipeGet(userId string)string{
-    conn.Send("HGET",userId,"ad1")
-    conn.Flush()
-    str,_ := redis.String(conn.Receive())
-    return str
+func releaseConn(c *redis.Conn) {
+	(*c).Close()
 }
-func Release(){
-    conn.Close()
+
+func DoGet(userId string) {
+	c := getConn()
+    c.Do("INCR",userId)
+    c.Close()
+}
+
+func PipeGet(userId string) {
+    c := getConn()
+    c.Send("INCR",userId)
+    c.Close()
 }
diff --git a/redis_test/conn_test.go b/redis_test/conn_test.go
@@ -5,39 +5,21 @@ import(
 )
 
 func TestDoGet(t *testing.T){
-    Init("tcp","127.0.0.1:6379")
-    str := DoGet("test")
-    if str != "1"{
-        t.Errorf("DoGet() is faild")
-    }
-    defer Release()
+    DoGet("test")
 }
 
 func TestPipeGet(t *testing.T){
-    Init("tcp","127.0.0.1:6379")
-    str := PipeGet("test")
-    if str != "1"{
-        t.Errorf("DoGet() is faild")
-    }
-    defer Release()
+    PipeGet("test")
 }
 
 func BenchmarkDoGet(b *testing.B){
-    b.StopTimer()
-    Init("tcp","127.0.0.1:6379")
-    b.StartTimer()
     for i:=0;i<b.N;i++ {
         DoGet("test")
     }
-    defer Release()
 }
 
 func BenchmarkPipeGet(b *testing.B){
-    b.StopTimer()
-    Init("tcp","127.0.0.1:6379")
-    b.StartTimer()
     for i:=0;i<b.N;i++ {
         PipeGet("test")
     }
-    defer Release()
 }
diff --git a/redispipeline/pipeline.go b/redispipeline/pipeline.go
@@ -0,0 +1,18 @@
+package RedisCtrl
+
+import (
+	"fmt"
+
+	"github.com/garyburd/redigo/redis"
+)
+
+func DoRedis(c redis.Conn) {
+	c.Send("MULTI")
+	c.Send("INCR", "foo0")
+	c.Send("INCR", "foo1")
+	c.Send("INCR", "foo2")
+	c.Send("INCR", "foo3")
+	c.Send("HINCRBY", "map", "key1", "1")
+	r, _ := c.Do("EXEC")
+	fmt.Println(r)
+}
diff --git a/redispipeline/redispool.go b/redispipeline/redispool.go
@@ -0,0 +1,9 @@
+package RedisCtrl
+
+import(
+    "fmt"
+
+    "github.com/garyburd/redigo/redis"
+)
+
+func 
diff --git a/redispool_demo.go b/redispool_demo.go
@@ -0,0 +1,45 @@
+package main
+import (
+    "net/http"
+    "runtime"
+    "io"
+    "fmt"
+    "log"
+    "time"
+    "github.com/garyburd/redigo/redis"
+)
+// 重写生成连接池方法
+func newPool() *redis.Pool {
+    return &redis.Pool{
+        MaxIdle: 80,
+        MaxActive: 1200, // max number of connections
+        Dial: func() (redis.Conn, error) {
+            c, err := redis.Dial("tcp", "localhost:6379")
+            if err != nil {
+                panic(err.Error())
+            }
+            return c, err
+        },
+    }
+}
+// 生成连接池
+var pool = newPool()
+func redisServer(w http.ResponseWriter, r *http.Request) {
+    startTime := time.Now()
+    // 从连接池里面获得一个连接
+    c := pool.Get()
+    // 连接完关闭，其实没有关闭，是放回池里，也就是队列里面，等待下一个重用
+    defer c.Close()
+    dbkey := "netgame:info"
+    if ok, err := redis.Bool(c.Do("LPUSH", dbkey, "yangzetao")); ok {
+    } else {
+        log.Print(err)
+    }
+    msg := fmt.Sprintf("用时：%s", time.Now().Sub(startTime));
+    io.WriteString(w, msg+"\n\n");
+}
+func main() {
+    runtime.GOMAXPROCS(runtime.NumCPU());
+    http.HandleFunc("/", redisServer);
+    http.ListenAndServe(":9527", nil);
+}

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,2 @@`
	`1`	`+## The way to learn Golang`
	`2`	`+### this is the code I practiced`
Original file line number	Diff line number	Diff line change
`@@ -5,39 +5,21 @@ import(`
`5`	`5`	`)`
`6`	`6`
`7`	`7`	`func TestDoGet(t *testing.T){`
`8`		`- Init("tcp","127.0.0.1:6379")`
`9`		`- str := DoGet("test")`
`10`		`- if str != "1"{`
`11`		`- t.Errorf("DoGet() is faild")`
`12`		`- }`
`13`		`- defer Release()`
	`8`	`+ DoGet("test")`
`14`	`9`	`}`
`15`	`10`
`16`	`11`	`func TestPipeGet(t *testing.T){`
`17`		`- Init("tcp","127.0.0.1:6379")`
`18`		`- str := PipeGet("test")`
`19`		`- if str != "1"{`
`20`		`- t.Errorf("DoGet() is faild")`
`21`		`- }`
`22`		`- defer Release()`
	`12`	`+ PipeGet("test")`
`23`	`13`	`}`
`24`	`14`
`25`	`15`	`func BenchmarkDoGet(b *testing.B){`
`26`		`- b.StopTimer()`
`27`		`- Init("tcp","127.0.0.1:6379")`
`28`		`- b.StartTimer()`
`29`	`16`	`for i:=0;i<b.N;i++ {`
`30`	`17`	`DoGet("test")`
`31`	`18`	`}`
`32`		`- defer Release()`
`33`	`19`	`}`
`34`	`20`
`35`	`21`	`func BenchmarkPipeGet(b *testing.B){`
`36`		`- b.StopTimer()`
`37`		`- Init("tcp","127.0.0.1:6379")`
`38`		`- b.StartTimer()`
`39`	`22`	`for i:=0;i<b.N;i++ {`
`40`	`23`	`PipeGet("test")`
`41`	`24`	`}`
`42`		`- defer Release()`
`43`	`25`	`}`
-Original file line number
+Diff line change
@@ @@ -0,0 +1,9 @@ @@
 +package RedisCtrl
++
 +import(
 +    "fmt"
++
 +    "github.com/garyburd/redigo/redis"
 +)
++
 +func