网站用户行为数据统计与分析之三：数据写入redis缓存队列

接着上一篇来探讨redis。

先来认识一下redis：

redis是一个key-value存储系统。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)、zset(sorted
set --有序集合)和hash（哈希类型）。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。在此基础上，redis支持各种不同方式的排序。与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步。

Redis 是一个高性能的key-value数据库。 redis的出现，很大程度补偿了memcached这类key/value存储的不足，在部 分场合可以对关系数据库起到很好的补充作用。它提供了Python，Ruby，Erlang，PHP客户端，使用很方便。[1]

Redis支持主从同步。数据可以从主服务器向任意数量的从服务器上同步，从服务器可以是关联其他从服务器的主服务器。这使得Redis可执行单层树复制。从盘可以有意无意的对数据进行写操作。由于完全实现了发布/订阅机制，使得从数据库在任何地方同步树时，可订阅一个频道并接收主服务器完整的消息发布记录。同步对读取操作的可扩展性和数据冗余很有帮助。

<!--以上内容解释权归百度所有-->

redis也提供了Java api

第一步，导包

jedis-2.4.2.jar

common-pool.jar

第二步，如果使用maven管理项目，记住在pom.xml中配置依赖关系

第三步，实现代码

为了数据的安全，稳定，不丢失，先还是来写个连接池：

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class JedisPoolTest {
private static JedisPool jedisPool;

private static JedisPoolConfig initPoolConfig() {
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
// 控制一个pool最多有多少个状态为idle的jedis实例
jedisPoolConfig.setMaxActive(1000);
// 最大能够保持空闲状态的对象数
jedisPoolConfig.setMaxIdle(300);
// 超时时间
jedisPoolConfig.setMaxWait(1000);
// 在borrow一个jedis实例时，是否提前进行alidate操作；如果为true，则得到的jedis实例均是可用的；
jedisPoolConfig.setTestOnBorrow(true);
// 在还会给pool时，是否提前进行validate操作
jedisPoolConfig.setTestOnReturn(true);
return jedisPoolConfig;
}
public static void before() {
JedisPoolConfig jedisPoolConfig = initPoolConfig();
// 属性文件读取参数信息
ResourceBundle bundle = ResourceBundle.getBundle("redis_config");
String host = bundle.getString("redis.host");
int port = Integer.valueOf(bundle.getString("redis.port"));
int timeout = Integer.valueOf(bundle.getString("redis.timeout"));
String password = bundle.getString("redis.password");
// 构造连接池
jedisPool = new JedisPool(jedisPoolConfig, host, port, timeout, password);
}
}

第四步，测试

public void testSet() {
Jedis jedis = null;
// 从池中获取一个jedis实例
try {
jedis = jedisPool.getResource();
//jedis.set("blog_pool", "java2000_wl");
jedis.rpush("mylogstash","kk");//至于为什么是mylogstash，请见我下一篇博文
} catch (Exception e) {
// 销毁对象
jedisPool.returnBrokenResource(jedis);
Assert.fail(e.getMessage());
} finally {
// 还会到连接池
jedisPool.returnResource(jedis);
}
}
public void testGet() {
Jedis jedis = null;
try {
// 从池中获取一个jedis实例
jedis = jedisPool.getResource();
System.out.println(jedis.rpop("mylogstash"));//至于为什么是mylogstash，请见我下一篇博文
} catch (Exception e) {
// 销毁对象
jedisPool.returnBrokenResource(jedis);
Assert.fail(e.getMessage());
} finally {
// 用完了，还回去
jedisPool.returnResource(jedis);
}
}
}

如果大家对redis有更深层次的认识需要，我这里有个超详细的redis中文帮助文档下载地址：
http://download.csdn.net/detail/u013339851/7120455