登录  /  注册

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

php中文网
发布: 2016-06-07 16:39:33
原创
1587人浏览过

前沿: 这两天试着用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>
    
    
登录后复制
智能AI问答
PHP中文网智能助手能迅速回答你的编程问题,提供实时的代码和解决方案,帮助你解决各种难题。不仅如此,它还能提供编程资源和学习指导,帮助你快速提升编程技能。无论你是初学者还是专业人士,AI智能助手都能成为你的可靠助手,助力你在编程领域取得更大的成就。
相关标签:
来源:php中文网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
关于CSS思维导图的课件在哪? 课件
凡人来自于2024-04-16 10:10:18
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2024 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号