Javaを使用してRedisを操作するにはJedis-2.1.0.jar、ダウンロードアドレス:Jedis-2.1.0.jar
Redis Connection Poolを使用する必要がある場合は、Commons-Pool-1.5.4.jarも必要です。住所をダウンロード:Commons-Pool-1.5.4.jar
パッケージcom.test; import java.util.hashmap; import java.util.iterator; import java.util.list; import java.util.map; import org.junit.before; import org.junit.test; import redis.clients.clients.jedis.jedis;公開クラス{private jedis jedis; @before public void setup(){// Redis Server、192.168.0.100:6379 Jedis = new Jedis( "192.168.0.100"、6379); //許可認証jedis.auth( "admin"); } / *** RedisストレージString* / @Test public void testString(){ //---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- //キーシステムを削除します。Out.println(jedis.get( "name")); //複数のキー値ペアJedis.mset( "name"、 "liuling"、 "age"、 "23"、 "qq"、 "476777xxx"); jedis.incr( "age"); // 1つのSystem.out.println(jedis.get( "name") + " - " + jedis.get( "age") + " - " + jedis.get( "qq"))を追加してください。 } /** * redis操作Map * /@test public void testmap(){// -------------------------- <string、string> map = new hashmap <string、string>(); map.put( "name"、 "xinxin"); map.put( "age"、 "22"); map.put( "qq"、 "123456"); jedis.hmset( "user"、map); //ユーザーの名前を取り出して結果を実行します:[minxr] - >結果は汎用リストであることに注意してください//最初のパラメーターはRedisのマップオブジェクトに保存され、その後、マップに配置されたオブジェクトのキーが続き、キーの背後にあるキーが複数になります。 System.out.println(rsmap); //マップのキー値を削除しますjedis.hdel( "user"、 "age"); System.out.println(jedis.hmget( "user"、 "age")); //削除されているため、リターンはnull system.out.println(jedis.hlen( "user")); //ユーザー2 system.out.println(jedis.exists( "user"))のキーでキーに保存されている値の数を返します。 //ユーザーにレコードがある場合はtrueを返します。 system.out.println(jedis.hkeys( "user")); //マップオブジェクトSystem.out.println(jedis.hvals( "user"))にすべてのキーを返します。 while(iter.hasnext()){string key = iter.next(); System.out.println(key+":"+jedis.hmget( "user"、key)); }} /** * jedis操作リスト * /@test public void testlist(){// Jedis.del( "Java Framework"); System.out.println(jedis.lrange( "Java Framework"、0、-1)); //キーJavaフレームワークに3つのデータを最初に保存しますjedis.lpush( "Java Framework"、 "Spring"); jedis.lpush( "Java Framework"、 "Struts"); jedis.lpush( "Java Framework"、 "Hibernate"); //すべてのデータを取得してjedis.lrangeと範囲を取り出します。// 1つ目はキー、2番目はスタート位置、3番目はエンド位置であり、jedis.llenは長さ-1を取得してすべてのsystem.out.lange( "javaフレームワーク"、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操作セット * /@test public void testset(){// add 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")); //すべての付加価値system.out.println(jedis.sismember( "user"、 "who"))を取得します); //ユーザーセットシステムの要素であるかどうかを判断します。 system.out.println(jedis.scrad( "user")); //コレクション内の要素の数を返します} @test public void test()throws arturtedexception {// jedis sort //ここにあるrpushとlpushはリスト操作であることに注意してください。は双方向リンクリスト(ただし、パフォーマンスの観点から)jedis.del( "a"); 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 void testredispool(){redisutil.getjedis()。set( "newname"、 "中国のテスト"); system.out.println(redisutil.getjedis()。get( "newName")); }} Redis接続プール:
パッケージcom.test; import redis.clients.jedis.jedis; import redis.clients.jedis.jedispool; import redis.clients.jedis.jedispoolconfig; public final class redisutil {// redis server ip private static string addr = "192.168.0.0.0.0.0; // redisポート番号プライベート静的intポート= 6379; //パスワードにアクセスプライベート静的文字列auth = "admin"; //利用可能な接続インスタンスの最大数、デフォルト値は8です。 //値が-1の場合、それは制限がないことを意味します。プールが既にMaxactive Jedisインスタンスを割り当てている場合、この時点でのプールのステータスは使い果たされています(吐き出されます)。 private static int max_active = 1024; //プール内の状態アイドル(アイドル)を含むJedisインスタンスの数とデフォルト値も8。プライベートStatic Int Max_idle = 200です。 //利用可能な接続を待つ最大時間、ミリ秒単位で、デフォルト値は-1であり、タイムアウトに到達しないことを示します。待機時間を超えた場合、JedisconnectionExceptionが直接スローされます。 private static int max_wait = 10000; Private Static Int Timeout = 10000; // Jedisインスタンスを借りるとき、事前に検証操作を実行するかどうか。真実の場合、取得したJedisインスタンスはすべて利用可能です。 private static boolean test_on_borrow = true; Private Static Jedispool jedispool = null; / *** Redis接続プールを初期化*/ static {try {jedispoolconfig config = new jedispoolconfig(); config.setmaxactive(max_active); config.setmaxidle(max_idle); config.setmaxwait(max_wait); config.settestonborrow(test_on_borrow); jedispool = new Jedispool(config、addr、port、timeout、auth); } catch(Exception e){e.printstacktrace(); }} / ** get jedis instance* @return* / public synchronized static jedis getjedis(){try {if(jedispool!= null){jedis resource = jedispool.getResource();返品リソース。 } else {return null; }} catch(例外e){e.printstacktrace(); nullを返します。 }} / *** jedis resource* @param jedis* / public static void return Resource(final jedis jedis){if(jedis!= null){jedispool.returnresource(jedis); }}}上記はこの記事のすべての内容です。みんなの学習に役立つことを願っています。誰もがwulin.comをもっとサポートすることを願っています。