Utilisation de Java pour faire fonctionner Redis nécessite Jedis-2.1.0.jar, Adresse de téléchargement: Jedis-2.1.0.jar
Si vous avez besoin d'utiliser Redis Connection Pool, vous avez également besoin de Commons-Pool-1.5.4.jar. Adresse de téléchargement: Commons-Pool-1.5.4.jar
Package 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.cligies.Jedis.Jedis; classe publique testredis {private jedis jedis; @Before public void setup () {// Connectez le serveur Redis, 192.168.0.100:6379 Jedis = New Jedis ("192.168.0.100", 6379); // Authentification d'authentification Jedis.Auth ("admin"); } / ** * Redis Storage String * / @Test public void testString () { // --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- // Supprimer un système clé.out.println (jedis.get ("name")); // définir plusieurs paires de valeurs de clé Jedis.mset ("nom", "liuling", "age", "23", "qq", "47677xxx"); Jedis.incr ("âge"); // Veuillez ajouter 1 System.out.println (Jedis.get ("Name") + "-" + Jedis.get ("Age") + "-" + Jedis.get ("qq")); } / ** * Redis Operation Map * / @Test public void testmap () {// ---------------- Map <String, String> map = new Hashmap <String, String> (); map.put ("name", "xinxin"); map.put ("Âge", "22"); map.put ("qq", "123456"); jedis.hmset ("utilisateur", map); // Sortez le nom dans l'utilisateur et exécutez le résultat: [MINXR] -> Notez que le résultat est une liste générique // Le premier paramètre est la clé stockée dans l'objet de carte dans Redis, suivie de la clé de l'objet placé dans la carte, et la clé derrière la clé peut être multiple, qui est une liste de paramètres variables <string> RSMAP = Jedis.hmget ("user" "", "nom", ""); "); System.out.println (RSMAP); // Supprimer une valeur clé dans la carte jedis.hdel ("utilisateur", "âge"); System.out.println (jedis.hmget ("utilisateur", "âge")); // Parce qu'il est supprimé, le retour est null System.out.println (Jedis.hlen ("utilisateur")); // renvoie le nombre de valeurs stockées dans la clé avec la clé de l'utilisateur 2 System.out.println (Jedis.exists ("utilisateur")); // Renvoie True s'il y a un enregistrement avec l'utilisateur. System.out.println (jedis.hkeys ("utilisateur")); // Renvoie toutes les touches dans le système d'objet MAP.out.println (Jedis.hvals ("utilisateur")); // renvoie toutes les valeurs dans l'objet Map Iterator <string> iter = jedis.hkeys ("user"). Iterator (); while (iter.hasnext ()) {string key = iter.next (); System.out.println (clé + ":" + jedis.hmget ("utilisateur", key)); }} / ** * Liste des opérations de Jedis * / @Test public void testList () {// Supprime tous les contenus avant de démarrer Jedis.del ("framework Java"); System.out.println (Jedis.lRange ("Framework Java", 0, -1)); // Stockez d'abord trois données dans le cadre Java clé Jedis.lpush ("Java Framework", "Spring"); Jedis.lpush ("framework Java", "Struts"); Jedis.lpush ("framework Java", "hibernate"); // récupérer toutes les données jedis.lrange et éliminer la plage, // la première est la clé, la seconde est la position de début, et la troisième est la position finale, et Jedis.llen obtient la longueur -1 pour indiquer que tous les System.out.println (Jedis.lrange ("Java Framework", 0, -1)); Jedis.del ("framework Java"); Jedis.rpush ("framework Java", "printemps"); Jedis.rpush ("framework Java", "Struts"); jedis.rpush ("framework java", "hibernate"); System.out.println (Jedis.lRange ("Framework Java", 0, -1)); } / ** * Jedis Operation Set * / @Test public void testSet () {// ajouter jedis.sadd ("user", "liuling"); jedis.sadd ("utilisateur", "xinxin"); jedis.sadd ("utilisateur", "ling"); jedis.sadd ("utilisateur", "zhangxinxin"); Jedis.sadd ("utilisateur", "OMS"); // supprimer noname jedis.srem ("utilisateur", "who"); System.out.println (Jedis.smembers ("utilisateur")); // Obtenez tous les valeurs ajoutées System.out.println (Jedis.SismEmber ("utilisateur", "OMS")); // juger si qui est un élément du System System.out.out.println (Jedis.srandMember ("utilisateur")); System.out.println (Jedis.scrad ("User")); // Renvoie le nombre d'éléments dans la collection} @Test public void test () lance InterruptedException {// Jedis Sort // Notez que RPUSH et LPUSH Voici des opérations de liste. est une liste liée bidirectionnelle (mais du point de vue de la performance) jedis.del ("a"); // efface d'abord les données, puis ajoutez les données pour tester 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] // Entrez le résultat après le tri System.out.println (Jedis.lRange ("A", 0, -1)); } @Test public void testRedispool () {redisutil.getJedis (). Set ("newname", "test chinois"); System.out.println (redisutil.getjedis (). Get ("newname")); }} Pool de connexion Redis:
package com.test; import redis.clients.jedis.jedis; import redis.clients.jedis.jedispool; importer redis.clients.jedis.jedispoolconfig; public final class redisutil {// redis server ip static string addr = "192.168.0.100"; // Redis Port Number Private Static int port = 6379; // accéder à mot de passe privé statique statique auth = "admin"; // Le nombre maximum d'instances de connexion disponibles, la valeur par défaut est de 8; // Si la valeur est -1, cela signifie aucune limite; Si la piscine a déjà alloué les instances de Jedis maxactives, le statut de la piscine en ce moment est épuisé (exhaué). private static int max_active = 1024; // Contacts le nombre d'instances Jedis avec l'état inactif (inactif) dans un pool, et la valeur par défaut est également 8. private static int max_idle = 200; // Le temps maximum pour attendre les connexions disponibles, en millisecondes, la valeur par défaut est -1, indiquant que le délai d'expiration ne sera jamais atteint. Si le temps d'attente est dépassé, une conception de jedisconnection sera directement lancée; private static int max_wait = 10000; Timeout statique privé = 10000; // lors de l'emprunt d'une instance Jedis, s'il faut effectuer à l'avance des opérations de validation; Si cela est vrai, les instances Jedis obtenues sont toutes disponibles; Boolean statique privé Test_on_borrow = true; Jedispool statique privé Jedispool = null; / ** * Initialiser le pool de connexion redis * / statique {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 synchronisé statique jedis getjedis () {try {if (jedispool! = Null) {jedis ressource = jedispool.getResource (); RETOUR RESSOURCE; } else {return null; }} catch (exception e) {e.printStackTrace (); retourner null; }} / ** * Libérez la ressource Jedis * @param jedis * / public static void returnResource (final jedis jedis) {if (Jedis! = Null) {jedispool.returnResource (Jedis); }}}Ce qui précède est tout le contenu de cet article. J'espère que cela sera utile à l'apprentissage de tous et j'espère que tout le monde soutiendra davantage Wulin.com.