+ "\t");
}
//HDEL key field [field ...]删除哈希表key中的一个或多个指定域。
//HLEN key 返回哈希表key中域的数量。
//HEXISTS key field查看哈希表key中,给定域field是否存在。
//HINCRBY key field increment为哈希表key中的域field的值加上增量increment。
//HKEYS key返回哈希表key中的所有域。
//HVALS key返回哈希表key中的所有值。
System.out.println("\n" + "==================== LIST 操作 =====================");
//LPUSH key value [value ...]将值value插入到列表key的表头。//LPUSH puts the new value at the start of the list
jedis.lpush("mylist", "abc");
jedis.lpush("mylist", "xzc");
jedis.lpush("mylist", "erf");
jedis.lpush("mylist", "bnh");
//LRANGE key start stop返回列表key中指定区间内的元素,区间以偏移量start和stop指定。下标(index)参数start和stop都以0为底,
//也就是说,以0表示列表的第一个元素,以1表示列表的第二个元素,以此类推。
//你也可以使用负数下标,以-1表示列表的最后一个元素,-2表示列表的倒数第二个元素,以此类推。
List listy = jedis.lrange("mylist", 0, -1);//LRANGE mylist 0 -1 ==> 其中 -1 返回所有的值.
for(int i=0;i" + jedis.llen("mylist"));
//LLEN key返回列表key的长度。
//LREM key count value根据参数count的值,移除列表中与参数value相等的元素。
System.out.println("\n" + "=========== SET 操作 =====================");
//SADD key member [member ...]将member元素加入到集合key当中。
jedis.sadd("testSet", "s1");
jedis.sadd("testSet", "s2");
jedis.sadd("testSet", "s3");
jedis.sadd("testSet", "s4");
jedis.sadd("testSet", "s5");
//SREM key member移除集合中的member元素。
jedis.srem("testSet", "s5");
//SMEMBERS key返回集合key中的所有成员。
Set set = jedis.smembers("testSet");
Iterator ite=set.iterator() ;
while(ite.hasNext()){
Object obj1=ite.next();
System.out.println(obj1);
}
//SISMEMBER key member判断member元素是否是集合key的成员。是(true),否则(false)
boolean isInSet = jedis.sismember("testSet", "s4");
System.out.println("sismember()判断member元素是否是集合key的成员==>" + isInSet);
//SCARD key返回集合key的基数(集合中元素的数量)。
//SMOVE source destination member将member元素从source集合移动到destination集合。
//SINTER key [key ...]返回一个集合的全部成员,该集合是所有给定集合的交集。
//SINTERSTORE destination key [key ...]此命令等同于SINTER,但它将结果保存到destination集合,而不是简单地返回结果集
//SUNION key [key ...]返回一个集合的全部成员,该集合是所有给定集合的并集。
//SUNIONSTORE destination key [key ...]此命令等同于SUNION,但它将结果保存到destination集合,而不是简单地返回结果集。
//SDIFF key [key ...]返回一个集合的全部成员,该集合是所有给定集合的差集 。
//SDIFFSTORE destination key [key ...]此命令等同于SDIFF,但它将结果保存到destination集合,而不是简单地返回结果集。
}
}
=====================================================================================
序列化:
Person.java
package com.jiangge.jrtest;
import java.io.Serializable;
@SuppressWarnings("serial")
public class Person implements Serializable {
private int id;
private String name;
public Person() {
}
public Person(int id, String name) {
super();
this.id = id;
this.name = name;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
PersonRedisSerializeTest.java
package com.jiangge.jrtest;
import redis.clients.jedis.Jedis;
public class PersonRedisSerializeTest {
public static void main(String[] args) {
PersonRedisSerializeTest test = new PersonRedisSerializeTest();
test.setObject(); //序列化
test.getObject(); //反序列化
}
/**
* 序列化写对象, 将Person对象写入Redis中
*
* 我们到命令行窗口中读取该对象,看看有没有写入成功:
* redis 127.0.0.1:6379> get person:100
* "\xac\xed\x00\x05sr\x00\x19com.jiangge.jrtest.Person\xfa\x13\xad$\x8e$\xfc\x80\x
* 02\x00\x02I\x00\x02idL\x00\x04namet\x00\x12Ljava/lang/String;xp\x00\x00\x00dt\x0
* 0\tyixiaohan"
* 可以取到序列化之后的值。
*/
public void setObject() {
Jedis jedis=new Jedis("localhost");
jedis.set("person:100".getBytes(), SerializeUtil.serialize(new Person(100, "yixiaohan")));
jedis.set("person:101".getBytes(), SerializeUtil.serialize(new Person(101, "xiaowei")));
}
/** 反序列化取对象 */
public void getObject() {
Jedis jedis=new Jedis("localhost");
byte[] data100= jedis.get(("person:100").getBytes());
Person person100 = (Person) SerializeUtil.unserialize(data100);
System.out.println(String.format("person:100->id=%s,name=%s", person100.getId(), person100.getName()));
byte[] data101= jedis.get(("person:101").getBytes());
Person person101 = (Person) SerializeUtil.unserialize(data101);
System.out.println(String.format("person:101->id=%s,name=%s", person101.getId(), person101.getName()));
}
}
SerializeUtil.java
package com.jiangge.jrtest;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
public class SerializeUtil {
/**
* 序列化
* @