Tcp编程

公司主营业务：成都网站制作、成都网站设计、移动网站开发等业务。帮助企业客户真正实现互联网宣传，提高企业的竞争能力。创新互联公司是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化，感谢他们对我们的高要求，感谢他们从不同领域给我们带来的挑战，让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。创新互联公司推出涿鹿免费做网站回馈大家。

.....

redis

使⽤第三⽅开源的redis库: github.com/garyburd/redigo/redis
import(

“github.com/garyburd/redigo/redis"
)
9. 链接redis
    

redis
package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
    c, err := redis.Dial("tcp", "localhost:6379")
    if err != nil {
    fmt.Println("conn redis failed,", err)
    return
    }
    defer c.Close()
}

10. Set 接⼝

package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
    c, err := redis.Dial("tcp", "localhost:6379")
    if err != nil {
    fmt.Println("conn redis failed,", err)
    return
    }
    defer c.Close()
    _, err = c.Do("Set", "abc", 100)
    if err != nil {
    fmt.Println(err)
    return
    }
    r, err := redis.Int(c.Do("Get", "abc"))
    if err != nil {
    fmt.Println("get abc failed,", err)
    return
    }
    fmt.Println(r)
}

11. Hash表
    

package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
    c, err := redis.Dial("tcp", "localhost:6379")
    if err != nil {
    fmt.Println("conn redis failed,", err)
    return
    }
    defer c.Close()
    _, err = c.Do("HSet", "books", "abc", 100)
    if err != nil {
    fmt.Println(err)
    return
    }
    r, err := redis.Int(c.Do("HGet", "books", "abc"))
    if err != nil {
    fmt.Println("get abc failed,", err)
    return
    }
    fmt.Println(r)
}

11. 批量Set
    

package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
    c, err := redis.Dial("tcp", "localhost:6379")
    if err != nil {
    fmt.Println("conn redis failed,", err)
    return
    }
    defer c.Close()
    _, err = c.Do("MSet", "abc", 100, "efg", 300)
    if err != nil {
    fmt.Println(err)
    return
    }
    r, err := redis.Ints(c.Do("MGet", "abc", "efg"))
    if err != nil {
    fmt.Println("get abc failed,", err)
    return
    }
    for _, v := range r {
    fmt.Println(v)
    }
}

11. 过期时间
    

package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
    c, err := redis.Dial("tcp", "localhost:6379")
    if err != nil {
    fmt.Println("conn redis failed,", err)
    return
    }
    defer c.Close()
    _, err = c.Do("expire", "abc", 10)
    if err != nil {
    fmt.Println(err)
    return
    }
}

12. 队列操作
    

package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
)
func main() {
    c, err := redis.Dial("tcp", "localhost:6379")
    if err != nil {
    fmt.Println("conn redis failed,", err)
    return
    }
    defer c.Close()
    _, err = c.Do("lpush", "book_list", "abc", "ceg", 300)
    if err != nil {
    fmt.Println(err)
    return
    }
r, err := redis.String(c.Do("lpop", "book_list"))
    if err != nil {
    fmt.Println("get abc failed,", err)
    return
    }
fmt.Println(r)

网页标题：GO(9[TCP/Redis/原子操作])
文章出自：http://csdahua.cn/article/ppscgc.html