redis for java api_redis java api

小咪咪 2022-11-08 14:29 289阅读 0赞

packagebhz.redis01;importjava.util.HashMap;importjava.util.Iterator;importjava.util.List;importjava.util.Map;importorg.junit.BeforeClass;importorg.junit.Test;importredis.clients.jedis.Jedis;importredis.clients.jedis.Pipeline;importredis.clients.jedis.ShardedJedis;importredis.clients.jedis.ShardedJedisPipeline;importredis.clients.jedis.ShardedJedisPool;importredis.clients.jedis.Transaction;public classTestSingleRedis \{private staticJedis jedis;private staticShardedJedis shard;private staticShardedJedisPool pool;

@BeforeClasspublic static void setUpBeforeClass() throwsException \{//单个节点

jedis = new Jedis("139.196.123.218", 6379);//分片//List shards = Arrays.asList(new JedisShardInfo(//"139.196.123.218", 6379));//shard = new ShardedJedis(shards);//

//GenericObjectPoolConfig goConfig = new GenericObjectPoolConfig();//goConfig.setMaxTotal(100);//goConfig.setMaxIdle(20);//goConfig.setMaxWaitMillis(-1);//goConfig.setTestOnBorrow(true);//pool = new ShardedJedisPool(goConfig, shards);

\}//@AfterClass

public static void tearDownAfterClass() throwsException \{

jedis.disconnect();

shard.disconnect();

pool.destroy();

@Testpublic voidtestString() \{//-----添加数据----------

jedis.set("name", "bhz");//向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", "bhz", "age", "27", "qq", "174754613");

jedis.incr("age"); //进行加1操作

System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-"

\+ jedis.get("qq"));

\}/\*\*\* redis操作Map\*/@Testpublic voidtestMap() \{//-----添加数据----------

Map map = new HashMap();

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 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 iter = jedis.hkeys("user").iterator();while(iter.hasNext()) \{

String key=iter.next();

System.out.println(key+ ":" + jedis.hmget("user", key));

\}/\*\*\* jedis操作List\*/@Testpublic voidtestList() \{//开始前，先移除所有的内容

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));

\}/\*\*\* jedis操作Set\*/@Testpublic voidtestSet() \{//添加

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", "who"));//判断 who//是否是user集合的元素

System.out.println(jedis.srandmember("user"));

System.out.println(jedis.scard("user"));//返回集合的元素个数

@Testpublic void testRLpush() throwsInterruptedException \{//jedis 排序//注意，此处的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));

\}//@Test

public voidtestTrans() \{long start =System.currentTimeMillis();

Transaction tx=jedis.multi();for (int i = 0; i < 1000; i++) \{

tx.set("t" + i, "t" +i);

\}//System.out.println(tx.get("t1000").get());

List results =tx.exec();long end =System.currentTimeMillis();

System.out.println("Transaction SET: " + ((end - start) / 1000.0)+ " seconds");

\}//@Test

public voidtestPipelined() \{

Pipeline pipeline=jedis.pipelined();long start =System.currentTimeMillis();for (int i = 0; i < 1000; i++) \{

pipeline.set("p" + i, "p" +i);

\}//System.out.println(pipeline.get("p1000").get());

List results =pipeline.syncAndReturnAll();long end =System.currentTimeMillis();

System.out.println("Pipelined SET: " + ((end - start) / 1000.0)+ " seconds");

\}//@Test

public voidtestPipelineTrans() \{long start =System.currentTimeMillis();

Pipeline pipeline=jedis.pipelined();

pipeline.multi();for (int i = 0; i < 100000; i++) \{

pipeline.set("" + i, "" +i);

pipeline.exec();

List results =pipeline.syncAndReturnAll();long end =System.currentTimeMillis();

System.out.println("Pipelined transaction SET: "

\+ ((end - start) / 1000.0) + " seconds");

\}//@Test

public voidtestShard() \{long start =System.currentTimeMillis();for (int i = 0; i < 100000; i++) \{

String result= shard.set("shard" + i, "n" +i);

\}long end =System.currentTimeMillis();

System.out.println("shard SET: " + ((end - start) / 1000.0)+ " seconds");

\}//@Test

public voidtestShardpipelined() \{

ShardedJedisPipeline pipeline=shard.pipelined();long start =System.currentTimeMillis();for (int i = 0; i < 100000; i++) \{

pipeline.set("sp" + i, "p" +i);

List results =pipeline.syncAndReturnAll();long end =System.currentTimeMillis();

System.out.println("shardPipelined SET: " + ((end - start) / 1000.0)+ " seconds");

\}//@Test

public voidtestShardPool() \{

ShardedJedis sj=pool.getResource();long start =System.currentTimeMillis();for (int i = 0; i < 100000; i++) \{

String result= sj.set("spn" + i, "n" +i);

\}long end =System.currentTimeMillis();

pool.returnResource(sj);

System.out.println("shardPool SET: " + ((end - start) / 1000.0)+ " seconds");

redis for java api_redis java api

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 Java使用RedisTemplate操作Redis常用API

相关 redis for java api_redis java api

相关 java与sharepoint_Sharepoint API for Java

相关 j2ee java websocket_Java API For WebSocket（七）Java EE环境

相关 Redis高级项目实战！java串口api

相关 Java Code Examples for redis.clients.jedis.Jedis

相关 java api

相关 Java API for Mac

相关 java for

相关 java Compiler API (java编译api)