JAVA - Redis的连接
java 连接 linux Redis 遇到的问题#
昨天在 Linux 搭建了 Redis 服务,今天使用 java 连接测试了一下。要想使用 java 连接 redis 服务,就离不开 jedis-2.6.1.jar。使用 jedis 连接 redis 十分方便。下面我们测试一下是否连接上 redis 服务:
package com.coinvs.redis.util;
import redis.clients.jedis.Jedis;
//import redis.clients.jedis.Jedis;
public class RadisDemo {
public static void main(String[] args) {
// 连接本地的 Redis 服务
Jedis jedis = new Jedis("192.168.1.66",6379);
System.out.println("Connection to server sucessfully");
// 查看服务是否运行
System.out.println("Server is running:"+jedis.ping());
}
}
import redis.clients.jedis.Jedis;
//import redis.clients.jedis.Jedis;
public class RadisDemo {
public static void main(String[] args) {
// 连接本地的 Redis 服务
Jedis jedis = new Jedis("192.168.1.66",6379);
System.out.println("Connection to server sucessfully");
// 查看服务是否运行
System.out.println("Server is running:"+jedis.ping());
}
}
如果出现下图,这说明没有连接成功,不过不用担心,这很好解决。
出现这种错误的原因有以下几种:
- redis 服务没有开启;
- 没有正确输入,ip、端口;
- Linux 系统防火墙没有关闭;
- 防火墙关闭了,但是访问者 ip,在 redis.conf 文件的 bind 之外。
简单设置一下,应该就可以连接上了!
下面我们简单说一下,jedis API 的使用:#
1.redis 存储字符串
// @Test
public void testString() {
//----- 添加数据 ----------
jedis.set("name","往往");// 向 key-->name 中放入了 value--xinxin
System.out.println(jedis.get("name"));// 执行结果:xinxin
jedis.append("name", "is my lover"); // 拼接
System.out.println(jedis.get("name"));
jedis.del("name"); // 删除某个键
System.out.println(jedis.get("name"));
// 设置多个键值对
jedis.mset("name","liuling","age","23","qq","476777XXX");
System.out.println(jedis.get("age"));
jedis.incr("age"); // 进行加 1 操作
System.out.println(jedis.get("age"));
System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq"));
}
public void testString() {
//----- 添加数据 ----------
jedis.set("name","往往");// 向 key-->name 中放入了 value--xinxin
System.out.println(jedis.get("name"));// 执行结果:xinxin
jedis.append("name", "is my lover"); // 拼接
System.out.println(jedis.get("name"));
jedis.del("name"); // 删除某个键
System.out.println(jedis.get("name"));
// 设置多个键值对
jedis.mset("name","liuling","age","23","qq","476777XXX");
System.out.println(jedis.get("age"));
jedis.incr("age"); // 进行加 1 操作
System.out.println(jedis.get("age"));
System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq"));
}
2.redis 操作 Map
// @Test
public void testMap() {
//----- 添加数据 ----------
Map<String, String> map = new HashMap<String, String>();
map.put("name", "xinxin");
map.put("age", "22");
map.put("qq", "123456");
jedis.hmset("user",map);
// 取出 user 中的 name,执行结果:[minxr]--> 注意结果是一个泛型的 List
// 第一个参数是存入 redis 中 map 对象的 key,后面跟的是放入 map 中的对象的 key,后面的 key 可以跟多个,是可变参数
List<String> rsmap = jedis.hmget("user", "name", "age", "qq");
System.out.println(rsmap);
// 删除 map 中的某个键值
jedis.hdel("user","age");
System.out.println(jedis.hmget("user", "age")); // 因为删除了,所以返回的是 null
System.out.println(jedis.hlen("user")); // 返回 key 为 user 的键中存放的值的个数 2
System.out.println(jedis.exists("user"));// 是否存在 key 为 user 的记录 返回 true
System.out.println(jedis.hkeys("user"));// 返回 map 对象中的所有 key
System.out.println(jedis.hvals("user"));// 返回 map 对象中的所有 value
Iterator<String> iter=jedis.hkeys("user").iterator();
while (iter.hasNext()){
String key = iter.next();
System.out.println(key+":"+jedis.hmget("user",key));
}
}
public void testMap() {
//----- 添加数据 ----------
Map<String, String> map = new HashMap<String, String>();
map.put("name", "xinxin");
map.put("age", "22");
map.put("qq", "123456");
jedis.hmset("user",map);
// 取出 user 中的 name,执行结果:[minxr]--> 注意结果是一个泛型的 List
// 第一个参数是存入 redis 中 map 对象的 key,后面跟的是放入 map 中的对象的 key,后面的 key 可以跟多个,是可变参数
List<String> rsmap = jedis.hmget("user", "name", "age", "qq");
System.out.println(rsmap);
// 删除 map 中的某个键值
jedis.hdel("user","age");
System.out.println(jedis.hmget("user", "age")); // 因为删除了,所以返回的是 null
System.out.println(jedis.hlen("user")); // 返回 key 为 user 的键中存放的值的个数 2
System.out.println(jedis.exists("user"));// 是否存在 key 为 user 的记录 返回 true
System.out.println(jedis.hkeys("user"));// 返回 map 对象中的所有 key
System.out.println(jedis.hvals("user"));// 返回 map 对象中的所有 value
Iterator<String> iter=jedis.hkeys("user").iterator();
while (iter.hasNext()){
String key = iter.next();
System.out.println(key+":"+jedis.hmget("user",key));
}
}
3.jedis 操作 List
// @Test
public void testList(){
// 开始前,先移除所有的内容
jedis.del("java framework");
System.out.println(jedis.lrange("java framework",0,-1));
// 先向 key java framework 中存放三条数据
jedis.lpush("java framework","spring");
jedis.lpush("java framework","struts");
jedis.lpush("java framework","hibernate");
// 再取出所有数据 jedis.lrange 是按范围取出,
// 第一个是 key,第二个是起始位置,第三个是结束位置,jedis.llen 获取长度 -1 表示取得所有
System.out.println(jedis.lrange("java framework",0,-1));
jedis.del("java framework");
jedis.rpush("java framework","spring");
jedis.rpush("java framework","struts");
jedis.rpush("java framework","hibernate");
System.out.println(jedis.lrange("java framework",0,-1));
}
public void testList(){
// 开始前,先移除所有的内容
jedis.del("java framework");
System.out.println(jedis.lrange("java framework",0,-1));
// 先向 key java framework 中存放三条数据
jedis.lpush("java framework","spring");
jedis.lpush("java framework","struts");
jedis.lpush("java framework","hibernate");
// 再取出所有数据 jedis.lrange 是按范围取出,
// 第一个是 key,第二个是起始位置,第三个是结束位置,jedis.llen 获取长度 -1 表示取得所有
System.out.println(jedis.lrange("java framework",0,-1));
jedis.del("java framework");
jedis.rpush("java framework","spring");
jedis.rpush("java framework","struts");
jedis.rpush("java framework","hibernate");
System.out.println(jedis.lrange("java framework",0,-1));
}
4. jedis 操作 Set
// @Test
public void testSet(){
jedis.del("user");
// 添加
jedis.sadd("user","liuling");
jedis.sadd("user","xinxin");
jedis.sadd("user","ling");
jedis.sadd("user","zhangxinxin");
jedis.sadd("user","who");
// 移除 noname
jedis.srem("user","who");
System.out.println(jedis.smembers("user"));// 获取所有加入的 value
System.out.println(jedis.sismember("user", "xinxin"));// 判断 who 是否是 user 集合的元素
System.out.println(jedis.srandmember("user")); // 随机返回一个 user 中元素的 value
System.out.println(jedis.scard("user"));// 返回集合的元素个数
}
public void testSet(){
jedis.del("user");
// 添加
jedis.sadd("user","liuling");
jedis.sadd("user","xinxin");
jedis.sadd("user","ling");
jedis.sadd("user","zhangxinxin");
jedis.sadd("user","who");
// 移除 noname
jedis.srem("user","who");
System.out.println(jedis.smembers("user"));// 获取所有加入的 value
System.out.println(jedis.sismember("user", "xinxin"));// 判断 who 是否是 user 集合的元素
System.out.println(jedis.srandmember("user")); // 随机返回一个 user 中元素的 value
System.out.println(jedis.scard("user"));// 返回集合的元素个数
}
5.jedis 排序#
@Test
public void test() throws InterruptedException {
//
// 注意,此处的 rpush 和 lpush 是 List 的操作。是一个双向链表(但从表现来看的)
jedis.del("a");// 先清除数据,再加入数据进行测试
jedis.rpush("a", "1");
jedis.lpush("a","6");
jedis.lpush("a","3");
jedis.lpush("a","9");
System.out.println(jedis.lrange("a",0,-1));// [9, 3, 6, 1]
System.out.println(jedis.sort("a")); //[1, 3, 6, 9] // 输入排序后结果
System.out.println(jedis.lrange("a",0,-1));
}
public void test() throws InterruptedException {
//
// 注意,此处的 rpush 和 lpush 是 List 的操作。是一个双向链表(但从表现来看的)
jedis.del("a");// 先清除数据,再加入数据进行测试
jedis.rpush("a", "1");
jedis.lpush("a","6");
jedis.lpush("a","3");
jedis.lpush("a","9");
System.out.println(jedis.lrange("a",0,-1));// [9, 3, 6, 1]
System.out.println(jedis.sort("a")); //[1, 3, 6, 9] // 输入排序后结果
System.out.println(jedis.lrange("a",0,-1));
}
简单的学习一下 jedis 的 API,后续还会补充!