Home  >  Article  >  Database  >  golang利用http模块构建redis读写查api

golang利用http模块构建redis读写查api

WBOY
WBOYOriginal
2016-06-07 16:39:331757browse

前沿: 这两天试着用golang做一些高性能的api,不想把压力到聚合在平台的接口上。平台因为要做很多耗时间的操作,uwsgi下会出现少许错误,找了一圈不知道如何解决该问题。 暂时先绕道而行,先拿简单的接口来做测试,慢慢的把复杂的操作也迁移到golang上。 话

前沿:

        这两天试着用golang做一些高性能的api,不想把压力到聚合在平台的接口上。平台因为要做很多耗时间的操作,uwsgi下会出现少许错误,找了一圈不知道如何解决该问题。 暂时先绕道而行,先拿简单的接口来做测试,慢慢的把复杂的操作也迁移到golang上。

          话说以前高性能的接口,我用的最多的方案还是nginx lua的组合,超强,大家可以看看我以前写的nginx lua的文章,各方面没得说。只是这段时间正在看golang 的,就试着用golang实现redis的api,先来个简单的试试手。

先搞下golang的redis模块

cd $GOPATH/src
git clone git://github.com/alphazero/Go-Redis.git redis
cd redis
go install

简单说下golang操作redis的例子

//xiaorui.cc
package main
import (
    "os";
    "bufio";
    "log";
    "fmt";
    "redis";
)
/*
    hello world, redis style.
*/
func main () {
    // create the client.  Here we are using a synchronous client.
    // Using the default ConnectionSpec, we are specifying the client to connect
    // to db 13 (e.g. SELECT 13), and a password of go-redis (e.g. AUTH go-redis)
    spec := redis.DefaultSpec().Db(13).Password("go-redis");
    client, e := redis.NewSynchClientWithSpec (spec);
    if e != nil { log.Println ("failed to create the client", e); return }
    key := "examples/hello/user.name";
    value, e := client.Get(key);
    if e!= nil { log.Println ("error on Get", e); return }
    if value == nil {
        fmt.Printf("\nHello, don't believe we've met before!\nYour name? ");
        reader:= bufio.NewReader(os.Stdin);
        user, _ := reader.ReadString(byte('\n'));
        if len(user) > 1 {
            user = user[0:len(user)-1];
            value = []byte(user);
            client.Set(key, value);
        } else {
            fmt.Printf ("vafanculo!\n");
            return;
        }
    }
    fmt.Printf ("Hey, ciao %s!\n", fmt.Sprintf("%s", value));
}

我写的实例,大家看懂了后,完全可以做更多的扩展。


其实golang自带的http很有mvc的感觉,三者做了一些分离,很像python里面的web.py tornado。。。

测试结果:

服务端的启动

wKioL1Mrmi3Qj3nVAAHGNMEWAPA108.jpg

客户端的测试

wKiom1MrmkSg8_TGAATqDvHKzoA311.jpg

//xiaorui.cc
package main
import(
    "fmt"
    "net/http"
    "io/ioutil"
    "log"
    "time"
    "redis"
)
//xiaorui.cc
const AddForm = `
Name: 
Age: 
`
const setform = `
key: 
value: 
`
func Handler( w http.ResponseWriter,r *http.Request ){
    path := r.URL.Path[1:]
    if path == "favicon.ico"  {
        http.NotFound(w, r)
        return
    }
    if path == ""{
        path = "index.html"
    }
    contents,err:= ioutil.ReadFile( path )
    if err !=nil{
        fmt.Fprintf( w,"404" )
        return
    }
    fmt.Fprintf( w,"%s\n",contents )
}
func Add( w http.ResponseWriter,r *http.Request ){
    name := r.FormValue("name")
    age := r.FormValue("age")
    if name == "" || age == "" {
        fmt.Fprint(w, AddForm)
        return
    }
    fmt.Fprintf(w, "Save : Your name is  %s , You age is %s",name,age)
}
func redisset( w http.ResponseWriter,r *http.Request ){
    key := r.FormValue("key")
    value := r.FormValue("value")
    if key == "" || value == "" {
        fmt.Fprint(w, setform)
        return
    }
    spec := redis.DefaultSpec().Db(0).Password("");
    client, e := redis.NewSynchClientWithSpec (spec);
    if e != nil { log.Println ("服务器连接有异常", e); return }
    inva := []byte(value)
    client.Set(key, inva);
    fmt.Fprintf(w, "哥们,你输入的key  %s 和value  %s 已经插入到redis里面了",key,key)
}
func redisget( w http.ResponseWriter,r *http.Request ){
    key := r.FormValue("key")
    if key == "" {
        fmt.Fprint(w, setform)
        return
    }
    spec := redis.DefaultSpec().Db(0).Password("");
    client, e := redis.NewSynchClientWithSpec (spec);
    if e != nil { log.Println ("服务器连接有异常", e); return }
    value, e := client.Get(key);
    fmt.Fprintf(w, "哥们,你要查询的key  %s 和value  %s ",key,value)
}
func valueget(w http.ResponseWriter, r *http.Request) {
    params := r.URL.Query()
    user := params.Get("user")
    fmt.Fprintf(w, "you are get user %s", user)
}
func main(){
    http.HandleFunc( "/",Handler)
    http.HandleFunc( "/add",Add)
    http.HandleFunc( "/redisset",redisset)
    http.HandleFunc( "/redisget",redisget)
    http.HandleFunc( "/valueget",valueget)
    s := &http.Server{
        Addr:           ":80",
        ReadTimeout:    30 * time.Second,
        WriteTimeout:   30 * time.Second,
        MaxHeaderBytes: 1 <p>
		</p>

<p style="color:#555555;font-family:宋体, 'Arial Narrow', arial, serif;font-size:14px;background-color:#FFFFFF;">
		<span style="font-family:微软雅黑, 'microsoft yahei';font-size:20px;"><br>
</span>
	</p>
<p style="color:#555555;font-family:宋体, 'Arial Narrow', arial, serif;font-size:14px;background-color:#FFFFFF;">
		<span style="font-family:微软雅黑, 'microsoft yahei';font-size:20px;"><br>
</span>
	</p>
<p>

</p>
<p style="color:#555555;font-family:宋体, 'Arial Narrow', arial, serif;font-size:14px;background-color:#FFFFFF;">
	<span style="font-family:微软雅黑, 'microsoft yahei';font-size:20px;"><br>
</span>
</p>
<p style="color:#555555;font-family:宋体, 'Arial Narrow', arial, serif;font-size:14px;background-color:#FFFFFF;">
	<span style="font-family:微软雅黑, 'microsoft yahei';font-size:20px;"><br>
</span>
</p>
<p style="color:#555555;font-family:宋体, 'Arial Narrow', arial, serif;font-size:14px;background-color:#FFFFFF;">
	<span style="font-family:微软雅黑, 'microsoft yahei';font-size:20px;"><br>
</span></p>
    <p class="copyright">
        原文地址:golang利用http模块构建redis读写查api, 感谢原作者分享。
    </p>
    
    


Statement:
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn