使用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的主要内容,如果未能解决你的问题,请参考以下文章

使用Jedis连接Redis

阿里云-Redis-Help-连接实例-Redis客户端连接:Jedis客户端

用jedis连接Redis集群

Jedis/JedisPool和Redis数据类型与特性

Redis连接池Lettuce Jedis 区别

Redis实战-Jedis连接池的使用方法