使用Jedis连接Redis

时间:2021-01-16 17:25:10

使用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();	}}