jedis入门教程
2024-08-24 14:05:16
1 jedis介绍
2 java连接Redis
1 导入jar包
2 连接实例
@Test
//获得单一的jedis对象操作数据库
public void test1(){ //1、获得连接对象 设置ip地址和端口
Jedis jedis = new Jedis("192.168.204.128", 6379); //2 、设置数据
jedis.set("name", "zhangsan"); //3 获得数据
String name = jedis.get("name");
System.out.println(name); //4 释放资源
jedis.close();
}
3 连接超时问题的处理
也可以直接使用下面的命令：开启端口的远程访问。
/sbin/iptables -I INPUT -p tcp --dport 6379 -j ACCEPT /etc/rc.d/init.d/iptables save
4 通过连接池获得连接
//通过jedis的pool获得jedis连接对象
@Test
public void test2(){
//0、创建池子的配置对象
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxIdle(30);//最大闲置个数
poolConfig.setMinIdle(10);//最小闲置个数
poolConfig.setMaxTotal(50);//最大连接数 //1、创建一个redis的连接池
JedisPool pool = new JedisPool(poolConfig, "192.168.186.131", 6379); //2、从池子中获取redis的连接资源
Jedis jedis = pool.getResource(); //3、操作数据库
jedis.set("xxx","yyyy");
System.out.println(jedis.get("xxx")); //4、关闭资源
jedis.close();
pool.close(); //实际开发中池子不要关闭，池子关闭了别人就没法使用了 }
4 连接池工具类
1 工具类代码
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties; import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig; public class JedisPoolUtils { private static JedisPool pool = null; static{ //加载配置文件
InputStream in = JedisPoolUtils.class.getClassLoader().getResourceAsStream("redis.properties");
Properties pro = new Properties();
try {
pro.load(in);
} catch (IOException e) {
e.printStackTrace();
} //获得池子对象
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxIdle(Integer.parseInt(pro.get("redis.maxIdle").toString()));//最大闲置个数
poolConfig.setMinIdle(Integer.parseInt(pro.get("redis.minIdle").toString()));//最小闲置个数
poolConfig.setMaxTotal(Integer.parseInt(pro.get("redis.maxTotal").toString()));//最大连接数
pool = new JedisPool(poolConfig,pro.getProperty("redis.url") , Integer.parseInt(pro.get("redis.port").toString()));
} //获得jedis资源的方法
public static Jedis getJedis(){
return pool.getResource();
}
}
2 配置文件
配置文件放在src目录下面：
redis.maxIdle=30
redis.minIdle=10
redis.maxTotal=100
redis.url=192.168.186.131
redis.port=6379
5 redis有密码的jedis连接方式
单机版
package cn.e3mall.jedis; import org.junit.Test; import redis.clients.jedis.Jedis; /**
*
* @title:JedisTest
* @description:
* @author jepson
* @date 2018年6月3日 下午4:20:19
* @version 1.0
*/
public class JedisTest { @Test
public void testJedis(){
// 第一步：创建一个Jedis对象。需要指定服务端的ip及端口。
Jedis jedis = new Jedis("192.168.25.128", 6379);
//设置密码
jedis.auth("123456");
// 第二步：使用Jedis对象操作数据库，每个redis命令对应一个方法。
jedis.set("name", "殷桃丸子");
String result = jedis.get("name");
// 第三步：打印结果。
System.out.println(result);
// 第四步：关闭Jedis
jedis.close();
}
}
如果redis有密码，这里不指定密码的话，会报下面的异常
单机版-从连接池获取连接
@Test
public void testJedispool(){
//0、创建池子的配置对象
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxIdle(30);//最大闲置个数
poolConfig.setMinIdle(10);//最小闲置个数
poolConfig.setMaxTotal(50);//最大连接数 //1、创建一个redis的连接池
JedisPool pool = new JedisPool(poolConfig, "192.168.25.128", 6379); //2、从池子中获取redis的连接资源
Jedis jedis = pool.getResource();
jedis.auth("123456");//设置密码 //3、操作数据库
jedis.set("user","王五");
System.out.println(jedis.get("user")); //4、关闭资源
jedis.close();
pool.close(); //实际开发中池子不要关闭，池子关闭了别人就没法使用了 }
6 jedis连接redis集群版
补充知识点：redis-cli客户端连接Redis集群的方法：
[root@admin redis01]# ./redis-cli -h 192.168.25.128 -p 7006 -c
@Test
public void testJedisCluster() throws Exception {
// 第一步：使用JedisCluster对象。需要一个Set<HostAndPort>参数。Redis节点的列表。
Set<HostAndPort> nodes = new HashSet<>();
nodes.add(new HostAndPort("192.168.25.128", 7001));
nodes.add(new HostAndPort("192.168.25.128", 7002));
nodes.add(new HostAndPort("192.168.25.128", 7003));
nodes.add(new HostAndPort("192.168.25.128", 7004));
nodes.add(new HostAndPort("192.168.25.128", 7005));
nodes.add(new HostAndPort("192.168.25.128", 7006));
JedisCluster jedisCluster = new JedisCluster(nodes);
// 第二步：直接使用JedisCluster对象操作redis。在系统中单例存在。
jedisCluster.set("hello", "100");
String result = jedisCluster.get("hello");
// 第三步：打印结果
System.out.println(result);
// 第四步：系统关闭前，关闭JedisCluster对象。
jedisCluster.close();
}
7 封装JedisClient接口实现单机版和集群版通用
将常用的操作redis的方法提取出来一个接口，分别对应单机版和集群版创建两个实现类。
1 JedisClient接口的定义
package cn.e3mall.common.jedis; import java.util.List;
import java.util.Map;
import java.util.Set; /**
* jedis操作redis的常用方法提取
* @title:JedisClient
* @description:
* @author jepson
* @date 2018年6月3日 下午7:52:31
* @version 1.0
*/
public interface JedisClient { //commons start
Boolean exists(String key);
Long expire(String key, int seconds);
Long ttl(String key);
Long persist(String key);
String type(String key);
Long del(String key);
String ping();
//commons end //String start
String set(String key, String value);
String get(String key);
String getSet(String key,String value);
Long incr(String key);
Long incrBy(String key,Long integer);
Double incrByFloat(String key,Double value);
Long decr(String key);
Long decrBy(String key,Long integer);
Long append(String key,String value);
//String类型的方法end //hash start;
Long hset(String key, String field, String value);
String hmset(String key,Map<String,String> map );
String hget(String key, String field);
List<String> hmget(String key, String... fields);
Map<String, String> hgetAll(String key);
Long hincrby(String key,String field,long value);
Long hlen(String key);
Set<String> hkeys(String key);
List<String> hvals(String key);
Long hdel(String key, String... fields);
Boolean hexists(String key, String field);
//hash end;
}
2 单机版的实现类
package cn.e3mall.common.jedis; import java.util.List;
import java.util.Map;
import java.util.Set; import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool; /**
* 单机版redis的方法
* @title:JedisClientPool
* @description:
* @author jepson
* @date 2018年6月3日 下午6:47:41
* @version 1.0
*/
public class JedisClientPool implements JedisClient { private JedisPool jedisPool; //连接池 private String password; //单机版密码 //get/set
public JedisPool getJedisPool() {
return jedisPool;
} public void setJedisPool(JedisPool jedisPool) {
this.jedisPool = jedisPool;
} public String getPassword() {
return password;
} public void setPassword(String password) {
this.password = password;
} @Override
public Boolean exists(String key) {
Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Boolean result = jedis.exists(key);
jedis.close();
return result;
} @Override
public Long expire(String key, int seconds) {
Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.expire(key, seconds);
jedis.close();
return result;
} @Override
public Long ttl(String key) {
Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.ttl(key);
jedis.close();
return result;
} @Override
public Long persist(String key) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.persist(key);
jedis.close();
return result;
} @Override
public String type(String key) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
String result = jedis.type(key);
jedis.close();
return result;
} @Override
public Long del(String key) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.del(key);
jedis.close();
return result;
} @Override
public String ping() { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
String result = jedis.ping();
jedis.close();
return result;
} @Override
public String set(String key, String value) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
String result = jedis.set(key, value);
jedis.close();
return result;
} @Override
public String get(String key) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
String result = jedis.get(key);
jedis.close();
return result;
} @Override
public String getSet(String key, String value) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
String result = jedis.getSet(key, value);
jedis.close();
return result;
} @Override
public Long incr(String key) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.incr(key);
jedis.close();
return result;
} @Override
public Long incrBy(String key, Long integer) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.incrBy(key, integer);
jedis.close();
return result;
} @Override
public Double incrByFloat(String key, Double value) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Double result = jedis.incrByFloat(key, value);
jedis.close();
return result;
} @Override
public Long decr(String key) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.decr(key);
jedis.close();
return result;
} @Override
public Long decrBy(String key, Long integer) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.decrBy(key, integer);
jedis.close();
return result;
} @Override
public Long append(String key, String value) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.append(key, value);
jedis.close();
return result;
} @Override
public Long hset(String key, String field, String value) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.hset(key, field, value);
jedis.close();
return result;
} @Override
public String hmset(String key, Map<String, String> map) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
String result = jedis.hmset(key, map);
jedis.close();
return result;
} @Override
public String hget(String key, String field) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
String result = jedis.hget(key, field);
jedis.close();
return result;
} @Override
public List<String> hmget(String key, String... fields) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
List<String> result = jedis.hmget(key, fields);
jedis.close();
return result;
} @Override
public Map<String, String> hgetAll(String key) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Map<String,String> result = jedis.hgetAll(key);
jedis.close();
return result;
} @Override
public Long hincrby(String key, String field, long value) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.hincrBy(key, field, value);
jedis.close();
return result;
} @Override
public Long hlen(String key) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.hlen(key);
jedis.close();
return result;
} @Override
public Set<String> hkeys(String key) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Set<String> result = jedis.hkeys(key);
jedis.close();
return result;
} @Override
public List<String> hvals(String key) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
List<String> result = jedis.hvals(key);
jedis.close();
return result;
} @Override
public Long hdel(String key, String... fields) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Long result = jedis.hdel(key, fields);
jedis.close();
return result;
} @Override
public Boolean hexists(String key, String field) { Jedis jedis = jedisPool.getResource();
jedis.auth(password);
Boolean result = jedis.hexists(key, field);
jedis.close();
return result;
} }
3 集群版实现类
package cn.e3mall.common.jedis; import java.util.List;
import java.util.Map;
import java.util.Set; import redis.clients.jedis.JedisCluster; /**
* redis集群redis客户端
* @title:JedisClientCluster
* @description:
* @author jepson
* @date 2018年6月3日 下午6:48:24
* @version 1.0
*/
public class JedisClientCluster implements JedisClient { private JedisCluster jedisCluster; public JedisCluster getJedisCluster() {
return jedisCluster;
} public void setJedisCluster(JedisCluster jedisCluster) {
this.jedisCluster = jedisCluster;
} @Override
public Boolean exists(String key) { return jedisCluster.exists(key);
} @Override
public Long expire(String key, int seconds) { return jedisCluster.expire(key, seconds);
} @Override
public Long ttl(String key) { return jedisCluster.ttl(key);
} @Override
public Long persist(String key) { return jedisCluster.persist(key);
} @Override
public String type(String key) { return jedisCluster.type(key);
} @Override
public Long del(String key) { return jedisCluster.del(key);
} @Override
public String ping() { return jedisCluster.ping();
} @Override
public String set(String key, String value) { return jedisCluster.set(key, value);
} @Override
public String get(String key) { return jedisCluster.get(key);
} @Override
public String getSet(String key, String value) { return jedisCluster.getSet(key, value);
} @Override
public Long incr(String key) { return jedisCluster.incr(key);
} @Override
public Long incrBy(String key, Long integer) { return jedisCluster.incrBy(key, integer);
} @Override
public Double incrByFloat(String key, Double value) { return jedisCluster.incrByFloat(key, value);
} @Override
public Long decr(String key) { return jedisCluster.decr(key);
} @Override
public Long decrBy(String key, Long integer) { return jedisCluster.decrBy(key, integer);
} @Override
public Long append(String key, String value) { return jedisCluster.append(key, value);
} @Override
public Long hset(String key, String field, String value) { return jedisCluster.hset(key, field, value);
} @Override
public String hmset(String key, Map<String, String> map) { return jedisCluster.hmset(key, map);
} @Override
public String hget(String key, String field) { return jedisCluster.hget(key, field);
} @Override
public List<String> hmget(String key, String... fields) { return jedisCluster.hmget(key, fields);
} @Override
public Map<String, String> hgetAll(String key) { return jedisCluster.hgetAll(key);
} @Override
public Long hincrby(String key, String field, long value) { return jedisCluster.hincrBy(key, field, value);
} @Override
public Long hlen(String key) { return jedisCluster.hlen(key);
} @Override
public Set<String> hkeys(String key) { return jedisCluster.hkeys(key);
} @Override
public List<String> hvals(String key) { return jedisCluster.hvals(key);
} @Override
public Long hdel(String key, String... field) { return jedisCluster.hdel(key, field);
} @Override
public Boolean hexists(String key, String field) { return jedisCluster.hexists(key, field);
} }
4 applicationContext-redis.xml配置
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.2.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.2.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-4.2.xsd
http://www.springframework.org/schema/util
http://www.springframework.org/schema/util/spring-util-4.2.xsd"> <!-- 加载配置文件 -->
<context:property-placeholder location="classpath:conf/db.properties" /> <!-- 连接redis单机版 -->
<bean id="jedisPool" class="redis.clients.jedis.JedisPool">
<constructor-arg name="host" value="${redis.host}"/>
<constructor-arg name="port" value="${redis.port}"/>
</bean>
<bean id="jedisClientPool" class="cn.e3mall.common.jedis.JedisClientPool">
<property name="jedisPool" ref="jedisPool"></property>
<property name="password" value="${redis.password}"></property>
</bean> <!-- 连接redis集群 -->
<!-- <bean id="jedisClientCluster" class="cn.e3mall.common.jedis.JedisClientCluster">
<property name="jedisCluster" ref="jedisCluster"/>
</bean>
<bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
<constructor-arg name="nodes">
<set>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="${redis.host1}"></constructor-arg>
<constructor-arg name="port" value="${redis.port1}"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="${redis.host2}"></constructor-arg>
<constructor-arg name="port" value="${redis.port2}"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="${redis.host3}"></constructor-arg>
<constructor-arg name="port" value="${redis.port3}"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="${redis.host4}"></constructor-arg>
<constructor-arg name="port" value="${redis.port4}"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="${redis.host5}"></constructor-arg>
<constructor-arg name="port" value="${redis.port5}"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="${redis.host6}"></constructor-arg>
<constructor-arg name="port" value="${redis.port6}"></constructor-arg>
</bean>
</set>
</constructor-arg>
</bean> -->
</beans>
注意：单机版和集群版不能共存，使用单机版时注释掉集群版的配置。
使用集群版时把单机版的配置注释掉。
5 db.properties配置
# mysql数据库
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/e3mall?characterEncoding=utf-8
jdbc.username=root
jdbc.password=root #redis单机版数据库
redis.password=123456
redis.host=192.168.25.128
redis.port=6379 #redis集群数据库
redis.host1=192.168.25.128
redis.port1=7001
redis.host2=192.168.25.128
redis.port2=7002
redis.host3=192.168.25.128
redis.port3=7003
redis.host4=192.168.25.128
redis.port4=7004
redis.host5=192.168.25.128
redis.port5=7005
redis.host6=192.168.25.128
redis.port6=7006
6 测试
package cn.e3mall.jedis; import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext; import cn.e3mall.common.jedis.JedisClient; /**
* 测试jedisclient
*
* @title:JedisClientTest
* @description:
* @author jepson
* @date 2018年6月3日 下午7:36:48
* @version 1.0
*/
public class JedisClientTest { @Test
public void testJedisClient() throws Exception {
// 初始化spring容器
ApplicationContext applicationContext = new ClassPathXmlApplicationContext(
"classpath:spring/applicationContext-redis.xml");
// 从容器中获得JedisClient对象
JedisClient jedisClient = applicationContext.getBean(JedisClient.class);
jedisClient.set("user", "lisi");
String string = jedisClient.get("user");
String ping = jedisClient.ping();
System.out.println(ping);
}
}
最新文章
- LeetCode 136. Single Number
- Node聊天程序实例01
- poj3660 floyd
- UVa 10330 Power Transmission / 最大流
- Union 与 Union all 区别
- 解决tomcat运行报错java.lang.UnsatisfiedLinkError: apache-tomcat-7.0.37\bin\tcnative-1.dll:Can load AMD 64
- 一篇文章让你搞懂 SSL 证书
- UWP 唤起应用商城，邮件
- Failed to load the JNI library "E:\JDK6.0\bin\client\jvm.dll"
- BZOJ 2463: [中山市选2009]谁能赢呢？[智慧]
- 剑指Offer--排序算法小结
- windows linux—unix 跨平台通信集成控制系统----系统硬件信息获取
- springMVC DispatcherServlet类关系图
- 解决y7000笔记本ubuntu下wifi无法连接问题
- python之对字符串类型的数组求平均值
- 简单实用的分页类-python
- kafka安装与简单使用
- sql语句语法
- 安装google 框架
- flask的变量和函数