锐客网

  1. 首页 > 睿知 > it技术 > >

redis支持go语言 redis gc

IT技术连接

go语言能做什么？很多朋友可能知道Go语言的优势在哪 ， 却不知道Go语言适合用于哪些地方 。
1、 Go语言作为服务器编程语言，很适合处理日志、数据打包、虚拟机处理、文件系统、分布式系统、数据库代理等；网络编程方面 。Go语言广泛应用于Web应用、API应用、下载应用等；除此之外 ， Go语言还可用于内存数据库和云平台领域 ， 目前国外很多云平台都是采用Go开发 。
2、 其实Go语言主要用作服务器端开发 。其定位是用来开发"大型软件"的，适合于很多程序员一起开发大型软件，并且开发周期长，支持云计算的网络服务 。Go语言能够让程序员快速开发 ， 并且在软件不断的增长过程中，它能让程序员更容易地进行维护和修改 。它融合了传统编译型语言的高效性和脚本语言的易用性和富于表达性 。
3、 Go语言成功案例 。Nsq：Nsq是由Go语言开发的高性能、高可用消息队列系统，性能非常高 ， 每天能处理数十亿条的消息；
4、 Docker：基于lxc的一个虚拟打包工具 ， 能够实现PAAS平台的组建 。
5、 Packer：用来生成不同平台的镜像文件，例如VM、vbox、AWS等，作者是vagrant的作者
6、 Skynet：分布式调度框架 。
7、 Doozer：分布式同步工具，类似ZooKeeper 。
8、 Heka：mazila开源的日志处理系统 。
9、 Cbfs：couchbase开源的分布式文件系统 。
10、 Tsuru：开源的PAAS平台 ， 和SAE实现的功能一模一样 。
11、 Groupcache：memcahe作者写的用于Google下载系统的缓存系统 。
12、 God：类似redis的缓存系统，但是支持分布式和扩展性 。
13、 Gor：网络流量抓包和重放工具 。
以上的就是关于go语言能做什么的内容介绍了 。
如何在 Go 语言中使用 Redis 连接池一、关于连接池
一个数据库服务器只拥有有限redis支持go语言的资源redis支持go语言，并且如果你没有充分使用这些资源 ， 你可以通过使用更多的连接来提高吞吐量 。一旦所有的资源都在使用，那么你就不 能通过增加更多的连接来提高吞吐量 。事实上，吞吐量在连接负载较大时就开始下降了 。通常可以通过限制与可用的资源相匹配的数据库连接的数量来提高延迟和吞 吐量 。
如何在Go语言中使用Redis连接池
如果不使用连接池，那么，每次传输数据，我们都需要进行创建连接，收发数据，关闭连接 。在并发量不高的场景，基本上不会有什么问题，一旦并发量上去了，那么，一般就会遇到下面几个常见问题redis支持go语言：
性能普遍上不去
CPU 大量资源被系统消耗
网络一旦抖动，会有大量 TIME_WAIT 产生，不得不定期重启服务或定期重启机器
服务器工作不稳定，QPS 忽高忽低
要想解决这些问题，我们就要用到连接池了 。连接池的思路很简单，在初始化时，创建一定数量的连接，先把所有长连接存起来，然后，谁需要使用，从这里取走，干完活立马放回来 。如果请求数超出连接池容量，那么就排队等待、退化成短连接或者直接丢弃掉 。
二、使用连接池遇到的坑
最近在一个项目中，需要实现一个简单的 Web Server 提供 Redis 的 HTTP interface，提供 JSON 形式的返回结果 。考虑用 Go 来实现 。
首先，去看一下 Redis 官方推荐的 Go Redis driver 。官方 Star 的项目有两个：Radix.v2 和 Redigo 。经过简单的比较后，选择了更加轻量级和实现更加优雅的 Radix.v2 。
Radix.v2 包是根据功能划分成一个个的 sub package，每一个 sub package 在一个独立的子目录中，结构非常清晰 。我的项目中会用到的 sub package 有 redis 和 pool 。
由于我想让这种被 fork 的进程最好简单点，做的事情单一一些，所以，在没有深入去看 Radix.v2 的 pool 的实现之前，我选择了自己实现一个 Redis pool 。(这里，就不贴代码了 。后来发现自己实现的 Redis pool 与 Radix.v2 实现的 Redis pool 的原理是一样的，都是基于 channel 实现的, 遇到的问题也是一样的 。)
不过在测试过程中 ， 发现了一个诡异的问题 。在请求过程中经常会报 EOF 错误 。而且是概率性出现 ， 一会有问题 ， 一会又好了 。通过反复的测试 ， 发现 bug 是有规律的 ， 当程序空闲一会后，再进行连续请求，会发生3次失败，然后之后的请求都能成功，而我的连接池大小设置的是3 。再进一步分析，程序空闲300秒 后，再请求就会失败，发现我的 Redis server 配置了 timeout 300，至此，问题就清楚了 。是连接超时 Redis server 主动断开了连接 。客户端这边从一个超时的连接请求就会得到 EOF 错误 。
【redis支持go语言 redis gc】然后我看了一下 Radix.v2 的 pool 包的源码，发现这个库本身并没有检测坏的连接，并替换为新server{location/pool{content_by_lua_block{localredis=require"resty.redis"localred=redis:new()localok,err=red:connect("127.0.0.1",6379)ifnotokthenngx.say("failedtoconnect:",err)returnendok,err=red:set("hello","world")ifnotokthenreturnendred:set_keepalive(10000,100)}}}
发现有个 set_keepalive 的方法，查了一下官方文档，方法的原型是 syntax: ok, err = red:set_keepalive(max_idle_timeout, pool_size) 貌似 max_idle_timeout 这个参数，就是我们所缺少的东西，然后进一步跟踪源码，看看里面是怎么保证连接有效的 。
function_M.set_keepalive(self,...)localsock=self.sockifnotsockthenreturnnil,"notinitialized"endifself.subscribedthenreturnnil,"subscribedstate"endreturnsock:setkeepalive(...)end
至此，已经清楚了，使用了 tcp 的 keepalive 心跳机制 。
于是，通过与 Radix.v2 的作者一些讨论，选择自己在 redis 这层使用心跳机制，来解决这个问题 。
四、最后的解决方案
在创建连接池之后，起一个 goroutine，每隔一段 idleTime 发送一个 PING 到 Redis server 。其中，idleTime 略小于 Redis server 的 timeout 配置 。连接池初始化部分代码如下：
p,err:=pool.New("tcp",u.Host,concurrency)errHndlr(err)gofunc(){for{p.Cmd("PING")time.Sleep(idelTime*time.Second)}}()
使用 redis 传输数据部分代码如下：
funcredisDo(p*pool.Pool,cmdstring,args...interface{})(reply*redis.Resp,errerror){reply=p.Cmd(cmd,args...)iferr=reply.Err;err!=nil{iferr!=io.EOF{Fatal.Println("redis",cmd,args,"erris",err)}}return}
其中 ， Radix.v2 连接池内部进行了连接池内连接的获取和放回，代码如下：
//Cmdautomaticallygetsoneclientfromthepool,executesthegivencommand//(returningitsresult),andputstheclientbackinthepoolfunc(p*Pool)Cmd(cmdstring,args...interface{})*redis.Resp{c,err:=p.Get()iferr!=nil{returnredis.NewResp(err)}deferp.Put(c)returnc.Cmd(cmd,args...)}
这样，我们就有了 keepalive 的机制，不会出现 timeout 的连接了，从 redis 连接池里面取出的连接都是可用的连接了 。看似简单的代码 ， 却完美的解决了连接池里面超时连接的问题 。同时，就算 Redis server 重启等情况 ， 也能保证连接自动重连 。
redis都支持哪些语言，java，php以外还有吗？支持Android，C#吗？对于Android怎么用？Java连接redisredis支持go语言的使用示例
Redis是开源的key-value存储工具redis支持go语言，redis通常用来存储结构化的数据redis支持go语言，因为redis的key可以包含String、hash、listset和sorted list 。
Redisclient支持多种语言，包括redis支持go语言：c、C、C#、php、java、python、go等语言，根据自己的开发语言，选择合适的redis client版本类型即可 。我是使用java语言开发的，针对java语言，redis client也提供redis支持go语言了多种客户端支持，按照推荐类型依次是：Jedis、Redisson、JRedis、JDBC-Redis、RJC、redis-protocol、aredis、lettuce 。前两种类型是比较推荐的，我们采用了Redisson类型版本作为redisclient的使用 。
Redisson版的redis可发工程搭建
1.新建maven工程
2.在pom.xml文件的dependencies节点下增加如下内容：
dependency
groupIdorg.redisson/groupId
artifactIdredisson/artifactId
version1.0.2/version
/dependency
dependency
groupIdorg.slf4j/groupId
artifactIdslf4j-log4j12/artifactId
version1.7.7/version
/dependency
3.保存pom.xml后，等eclispe工程构建完成后即可进行开发了
开发示例
下面是演示连接redis服务器、保存读取concurrentMap对象、保存读取set对象和保存读取Queue对象的示例代码，代码比较简单，这里就不再详细讲解了 ， 代码如下：
[java] view plaincopy
package com.my.test.redis;
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.ConcurrentMap;
import org.redisson.Config;
import org.redisson.Redisson;
public class RedisExample {
/**
* @param args
*/
public static void main(String[] args) {
// 1.初始化
Config config = new Config();
config.setConnectionPoolSize(10);
config.addAddress("127.0.0.1:6379");
Redisson redisson = Redisson.create(config);
System.out.println("reids连接成功...");
// 2.测试concurrentMap,put方法的时候就会同步到redis中
ConcurrentMapString, Object map = redisson.getMap("FirstMap");
map.put("wuguowei", "男");
map.put("zhangsan", "nan");
map.put("lisi", "女");
ConcurrentMap resultMap = redisson.getMap("FirstMap");
System.out.println("resultMap=="resultMap.keySet());
// 2.测试Set集合
Set mySet = redisson.getSet("MySet");
mySet.add("wuguowei");
mySet.add("lisi");
Set resultSet = redisson.getSet("MySet");
System.out.println("resultSet==="resultSet.size());
//3.测试Queue队列
Queue myQueue = redisson.getQueue("FirstQueue");
myQueue.add("wuguowei");
myQueue.add("lili");
myQueue.add("zhangsan");
myQueue.peek();
myQueue.poll();
Queue resultQueue=redisson.getQueue("FirstQueue");
System.out.println("resultQueue===" resultQueue);
// 关闭连接
redisson.shutdown();
}
}
如何在go语言中使用redis连接池1.在创建连接池之后，起一个 go routine，每隔一段 idleTime 发送一个 PING 到 Redis server 。其中，idleTime 略小于 Redis server 的 timeout 配置 。
2.连接池初始化部分代码如下：
p, err := pool.New("tcp", u.Host, concurrency) errHndlr(err) go func() {for {p.Cmd("PING")time.Sleep(idelTime * time.Second)} }()
3.使用 redis 传输数据部分代码如下：
func redisDo(p *pool.Pool, cmd string, args ...interface{}) (reply *redis.Resp, err error) {reply = p.Cmd(cmd, args...)if err = reply.Err; err != nil {if err != io.EOF {Fatal.Println("redis", cmd, args, "err is", err)}}return }
4.其中，Radix.v2 连接池内部进行了连接池内连接的获取和放回，代码如下：
// Cmd automatically gets one client from the pool, executes the given command // (returning its result), and puts the client back in the pool func (p *Pool) Cmd(cmd string, args ...interface{}) *redis.Resp {c, err := p.Get()if err != nil {return redis.NewResp(err)}defer p.Put(c)return c.Cmd(cmd, args...) }
这样，就有了系统 keep alive 的机制，不会出现 time out 的连接了，从 redis 连接池里面取出的连接都是可用的连接了 。看似简单的代码 ， 却完美的解决了连接池里面超时连接的问题 。同时 ， 就算 Redis server 重启等情况，也能保证连接自动重连 。
Go语言与Docker操作Redis首?。?如果之前使用过redis容器，我们需要先remove掉之前的容器
然后创建redis容器，并运行
进入redis容器中
接着我们通过 redis-cli 连接测试使用 redis 服务
setex指令 可以设置数据存在的时间， setex key second value
MSET一次设置多个key-value
MGET一次获取多个key-value
HGET
HGETALL
Hlen和hexist
Lpush 和 Lrange
Lpop和Rpop 从链表取出并移走数据
删除链表所有数据 DEL
字符串无序 不能重复
从连接池中Get出一个conn连接
GO语言使用 Redis数据库可以参考： windows环境下redis的安装
启动redis服务器：redis-server.exe redis.windows.conf
获取包：
导入包
访问：
redis支持go语言的介绍就聊到这里吧，感谢你花时间阅读本站内容 ， 更多关于redis gc、redis支持go语言的信息别忘了在本站进行查找喔 。

    推荐阅读


    上一篇：gis差值检验方法，两组差值的检验方法

    下一篇：模仿动作接龙团建游戏，动作接龙游戏串词