Menggunakan java untuk mengoperasikan Redis membutuhkan jedis-2.1.0.jar, alamat unduh: jedis-2.1.0.jar
Jika Anda perlu menggunakan kumpulan koneksi Redis, Anda juga memerlukan commons-pool-1.5.4.jar. Alamat unduhan: commons-pool-1.5.4.jar
Paket com.test; import java.util.hashmap; import java.util.iterator; impor java.util.list; import java.util.map; org.junit.beFore; impor org.junit.test; impor redis.clients.jedis.jedis; Kelas Publik Testredis.test; @Before public void setup () {// Sambungkan server redis, 192.168.0.100:6379 jedis = new jedis ("192.168.0.100", 6379); // otentikasi izin jedis.auth ("admin"); } / *** string penyimpanan redis* / @test public void testString () { // ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- // hapus kunci system.out.println (jedis.get ("name")); // atur beberapa pasangan nilai kunci jedis.mset ("nama", "liuling", "usia", "23", "qq", "4767777xxx"); jedis.incr ("usia"); // Silakan tambahkan 1 System.out.println (jedis.get ("name") + "-" + jedis.get ("usia") + "-" + jedis.get ("qq")); } /** * Redis Operation Map * /@test public void testMap () {// ---------------- Peta <String, String> Map = New HashMap <String, String> (); peta.put ("name", "xinxin"); peta.put ("usia", "22"); peta.put ("qq", "123456"); jedis.hmset ("pengguna", peta); // Ambil nama di pengguna dan jalankan hasilnya: [Minxr]-> Perhatikan bahwa hasilnya adalah daftar generik // Parameter pertama adalah kunci yang disimpan dalam objek peta di redis, diikuti oleh kunci objek yang ditempatkan di peta, dan kunci di balik kunci dapat berupa beberapa, yang merupakan daftar parameter variabel <string> rsmap = jedis.hmget ");" System.out.println (RSMAP); // hapus nilai kunci dalam peta jedis.hdel ("pengguna", "usia"); System.out.println (jedis.hmget ("user", "usia")); // Karena dihapus, pengembalian adalah null system.out.println (jedis.hlen ("user")); // Kembalikan jumlah nilai yang disimpan dalam kunci dengan kunci dari pengguna 2 system.out.println (jedis.exists ("user")); // Kembalikan true jika ada catatan dengan pengguna. System.out.println (jedis.hkeys ("user")); // Kembalikan semua tombol di peta objek System.out.println (jedis.hvals ("user")); // kembalikan semua nilai dalam objek peta iterator <string> iter = jedis.hkeys ("user"). Iterator (); while (iter.hasnext ()) {string key = iter.next (); System.out.println (key+":"+jedis.hmget ("user", key)); }} /** * Daftar operasi jedis * /@test public void testList () {// Hapus semua konten sebelum memulai jedis.del ("java framework"); System.out.println (jedis.lrange ("Java Framework", 0, -1)); // Pertama menyimpan tiga potong data dalam kerangka kerja Java kunci jedis.lpush ("Java Framework", "Spring"); jedis.lpush ("Java Framework", "Struts"); jedis.lpush ("Java Framework", "Hibernate"); // Ambil semua data jedis.lrange dan ambil kisaran, // Yang pertama adalah kuncinya, yang kedua adalah posisi awal, dan yang ketiga adalah posisi akhir, dan jedis.llen mendapatkan panjang -1 untuk menunjukkan bahwa semua 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)); } /** * Set operasi jedis * /@test public void testset () {// tambahkan jedis.sadd ("user", "liuling"); jedis.sadd ("pengguna", "xinxin"); jedis.sadd ("pengguna", "ling"); jedis.sadd ("pengguna", "zhangxinxin"); jedis.sadd ("pengguna", "who"); // hapus noname jedis.srem ("pengguna", "who"); System.out.println (jedis.smembers ("user")); // Dapatkan semua nilai tambah System.out.println (jedis.sismember ("user", "who")); // menilai apakah siapa elemen dari sistem set pengguna.out.println (jedis.srandmember ("pengguna")); System.out.println (jedis.scrad ("user")); // Kembalikan jumlah elemen dalam koleksi} @test public void test () melempar InterruptedException {// Jedis Sort // Perhatikan bahwa RPush dan Lpush di sini adalah operasi daftar. adalah daftar ditautkan dua arah (tetapi dari perspektif kinerja) jedis.del ("a"); // hapus data terlebih dahulu, kemudian tambahkan data untuk menguji 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] // Masukkan hasilnya setelah penyortiran System.out.println (jedis.lrange ("a", 0, -1)); } @Test public void testredispool () {redisutil.getjedis (). Set ("newname", "test cina"); System.out.println (redisutil.getjedis (). Get ("newname")); }} Redis Connection Pool:
Paket com.test; import redis.clients.jedis.jedis; import redis.clients.jedis.jedispool; import redis.clients.jedis.jedispoolconfig; kelas akhir public redisutil {// redis server ip pribadi string statis addr = "192.168.0.100"; // Redis Port Number Private Static Int Port = 6379; // akses kata sandi private static string auth = "admin"; // Jumlah maksimum instance koneksi yang tersedia, nilai default adalah 8; // Jika nilainya -1, itu berarti tidak ada batasan; Jika kolam telah mengalokasikan contoh jedis maksimal, status kolam pada saat ini habis (exhaused). private static int max_active = 1024; // Kontak berapa banyak instance jedis dengan state idle (idle) di kumpulan, dan nilai default juga 8. private static int max_idle = 200; // Waktu maksimum untuk menunggu koneksi yang tersedia, dalam milidetik, nilai standarnya adalah -1, menunjukkan bahwa batas waktu tidak akan pernah tercapai. Jika waktu tunggu terlampaui, JedisconnectionException akan langsung dilemparkan; private static int max_wait = 10000; Timeout int statis pribadi = 10000; // Saat meminjam instance jedis, apakah akan melakukan operasi validasi terlebih dahulu; Jika benar, semua instance JEDIS yang diperoleh semuanya tersedia; private static boolean test_on_borrow = true; Private Static Jedispool Jedispool = NULL; / *** inisialisasi kumpulan koneksi redis*/ statis {coba {jedaispoolconfig config = new jedipispoolconfig (); config.setmaxactive (max_active); config.setmaxidle (max_idle); config.setmaxwait (max_wait); config.settestonborrow (test_on_borrow); jedispool = jedaispool baru (config, addr, port, timeout, auth); } catch (Exception e) {E.PrintStackTrace (); }} / *** Dapatkan instance jedis* @return* / public yang disinkronkan statis jedis getjedis () {coba {if (jedispool! = Null) {jedis resource = jedispool.getResource (); mengembalikan sumber daya; } else {return null; }} catch (Exception e) {e.printstacktrace (); kembali nol; }} / *** Lepaskan sumber daya jedis* @param jedis* / public static void returnResource (final jedis jedis) {if (jedis! = Null) {jedaispool.ReturnResource (jedis); }}}Di atas adalah semua konten artikel ini. Saya berharap ini akan membantu untuk pembelajaran semua orang dan saya harap semua orang akan lebih mendukung wulin.com.