使用Jedis连接Redis
Posted 邵鸿鑫
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了使用Jedis连接Redis相关的知识,希望对你有一定的参考价值。
使用Jedis连接redis跟我们使用jdbc连接数据库特别向,话不多说,直接上代码。
需要引入的jar包
这里我建的是maven工程,pom坐标配置如下
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.7.0</version>
</dependency>
代码
package com.taotao.rest.jedis;
import java.util.HashSet;
import javax.swing.Spring;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.taotao.rest.dao.JedisClient;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPool;
public class JedisTest
//单实例链接测试
@Test
public void testJedisSingel()
//创建jedis对象
Jedis jedis=new Jedis("192.168.154.128",6379);
//调用jedis对象方法,方法名和Jedis命令一致
jedis.set("key1", "jedis test");
String string=jedis.get("key1");
System.out.println(string);
//使用连接池连接测试
@Test
public void testJedisPool()
//创建Jedis链接池
JedisPool pool=new JedisPool("192.168.154.128",6379);
//从连接池中获得Jedis对象
Jedis jedis=pool.getResource();
String string=jedis.get("key1");
System.out.println(string);
jedis.close();
pool.close();
//集群版链接测试
@Test
public void testJedisCluster()
HashSet<HostAndPort> nodes=new HashSet<>();
nodes.add(new HostAndPort("192.168.154.128",6379));
nodes.add(new HostAndPort("192.168.154.128",6380));
nodes.add(new HostAndPort("192.168.154.128",6381));
nodes.add(new HostAndPort("192.168.154.128",6382));
nodes.add(new HostAndPort("192.168.154.128",6383));
nodes.add(new HostAndPort("192.168.154.128",6384));
JedisCluster cluster=new JedisCluster(nodes);
cluster.set("key1", "test");
String string=cluster.get("key1");
System.out.println(string);
cluster.close();
//spring整合单机版测试
@Test
public void testSpringJedisSingle()
ApplicationContext applicationContext=new ClassPathXmlApplicationContext("classpath:/spring/applicationContext-*.xml");
JedisPool pool=(JedisPool) applicationContext.getBean("redisClient");
Jedis jedis=pool.getResource();
String string=jedis.get("key1");
System.out.println(string);
jedis.close();
pool.close();
//spring整合集群版测试
@Test
public void testSpringJedisCluster()
ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-*.xml");
JedisCluster jedisCluster = (JedisCluster) applicationContext.getBean("redisClient");
String string = jedisCluster.get("key1");
System.out.println(string);
jedisCluster.close();
以上是关于使用Jedis连接Redis的主要内容,如果未能解决你的问题,请参考以下文章