学步园

Redis的知识准备

redis的基础介绍:http://blog.csdn.net/Java2King/archive/2010/07/27/5769738.aspx

redis的安装：http://hanqunfeng.javaeye.com/blog/684108

JDBC—Redis的使用

redis的java-jdbc的下载地址 : http://code.google.com/p/jdbc-redis/

代码例子：插入10万的数据

package com.redis;<br /> import java.sql.Connection;<br /> import java.sql.DriverManager;<br /> import java.sql.ResultSet;<br /> import java.sql.SQLException;<br /> import java.sql.Statement;<br /> /**<br /> * @author zhujiadun.pt<br /> *<br /> */<br /> public class TestRedis {<br /> /**<br /> * @param args<br /> * @throws ClassNotFoundException<br /> * @throws SQLException<br /> */<br /> public static void main(String[] args) throws ClassNotFoundException, SQLException {<br /> //装载Redis数据库的驱动器<br /> Class.forName("br.com.svvs.jdbc.redis.RedisDriver");</p> <p> //连接数据库<br /> Connection conn = DriverManager.getConnection("jdbc:redis://localhost");</p> <p> //获取Statement<br /> Statement stmt = conn.createStatement();</p> <p> //执行SQL语句<br /> for(int i=0;i<100000;i++){<br /> stmt.execute("set my_first_key"+i+" my first value"+i);<br /> }</p> <p> stmt.execute("get my_first_key");<br /> ResultSet r = stmt.getResultSet();<br /> while (r.next()) {<br /> System.out.println(">" + r.getString(0) + "<");<br /> }<br /> }<br /> }<br />

另一段经典的jdbc代码

package com.Redis.Demo;<br /> import java.sql.Statement;<br /> import java.sql.Connection;<br /> import java.sql.DriverManager;<br /> import java.sql.ResultSet;<br /> import java.sql.SQLException;<br /> public class RedisDemo {<br /> private static Connection conn = null;<br /> private static Statement stm = null;<br /> private static ResultSet rs = null;<br /> /**<br /> * @param args<br /> * @throws SQLException<br /> */<br /> public static void main(String[] args) throws SQLException {<br /> init();<br /> oneKey();<br /> manyKey();<br /> }<br /> /*<br /> * 初始化<br /> */<br /> private static void init() {</p> <p> try {<br /> // 加载redis jdbc驱动<br /> Class.forName("br.com.svvs.jdbc.redis.RedisDriver");<br /> // 连接<br /> conn = DriverManager.getConnection("jdbc:redis://192.168.1.117");<br /> stm = conn.createStatement();<br /> } catch (ClassNotFoundException e) {<br /> System.out.println(e.toString());<br /> } catch (SQLException e) {<br /> System.out.println(e.toString());<br /> }<br /> }<br /> /*<br /> * 关闭stm,conn<br /> */<br /> private static void close() {<br /> try {<br /> // rs.close();<br /> stm.close();<br /> conn.close();<br /> } catch (SQLException e) {<br /> System.out.println(e.toString());<br /> }<br /> }<br /> /*<br /> * 一个键值的操作<br /> *<br /> */<br /> private static void oneKey() throws SQLException {<br /> String sql = "set my_first_key myfirstvalue";<br /> stm.execute(sql);<br /> stm.execute("get my_first_key");<br /> ResultSet rs = stm.getResultSet();<br /> while (rs.next()) {<br /> System.out.println(rs.getString("my_first_key"));<br /> }<br /> close();<br /> }<br /> /*<br /> * 一个key对多个value操作<br /> */<br /> private static void manyKey() throws SQLException {<br /> stm.execute("lpush mylist value1");<br /> stm.execute("lpush mylist value2");<br /> stm.execute("lpush mylist value3");</p> <p> stm.execute("lrange mylist 0 -1"); </p> <p> ResultSet rs=stm.getResultSet();</p> <p> while(rs.next()){<br /> System.out.println(rs.getString("mylist"));<br /> }<br /> }<br /> }