"Java 程序使用 Redis 添加依赖包 Maven 依赖方式 redis.clients jedis 2.9.0 下载 Jar 包方式下载地址： [链接] 代码使用示例 [链接] package com.louis.test; import java.util.HashMap; impor ...."

someone1
AI专业者开发社区 1 号成员
AI开发者社区 • 0 回帖 • 0 浏览 • 5 个月前

Redis笔记（六）：Java中使用Redis

Java 程序使用 Redis

添加依赖包

Maven 依赖方式

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.9.0</version>
</dependency>

下载 Jar 包方式

下载地址： http://central.maven.org/maven2/redis/clients/jedis/2.9.0/jedis-2.9.0.jar

代码使用示例

package com.louis.test;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import org.junit.Test;
import redis.clients.jedis.Jedis;
public class TestRedis {
</span><span style="color: rgba(0, 0, 255, 1)">private</span> <span style="color: rgba(0, 0, 255, 1)">static</span><span style="color: rgba(0, 0, 0, 1)">  Jedis jedis;

</span><span style="color: rgba(0, 0, 255, 1)">static</span><span style="color: rgba(0, 0, 0, 1)"> {
    </span><span style="color: rgba(0, 128, 0, 1)">// </span><span style="color: rgba(0, 128, 0, 1)">连接服务器，这里是本地</span>
    jedis = <span style="color: rgba(0, 0, 255, 1)">new</span> Jedis("127.0.0.1", 6379<span style="color: rgba(0, 0, 0, 1)">);
    </span><span style="color: rgba(0, 128, 0, 1)">// 如果需要，进行</span><span style="color: rgba(0, 128, 0, 1)">权限认证

//      jedis.auth("");
}
</span><span style="color: rgba(0, 128, 0, 1)">// </span><span style="color: rgba(0, 128, 0, 1)">字符串操作</span>

    @Test
public void testString() {
jedis.set("name", "张扬");
System.out.println( jedis.get("name") );
// 追加操作
jedis.append("name", "林语谣");
System.out.println( jedis.get("name") );
// 删除键
Long result = jedis.del("name");
System.out.println(result); //返回 Long 型  1 表示成功 0 失败
// 设置多个键值对
jedis.mset("name","敏敏", "city","上海");
// 获取多个键, 返回一个列表类型
System.out.println( jedis.mget("name", "city"));
}

</span><span style="color: rgba(0, 128, 0, 1)">// </span><span style="color: rgba(0, 128, 0, 1)">哈希操作Hash</span>

    @Test
public void testHash() {
Map<String,String> map = new HashMap<String,String>();
map.put("name", "张扬");
map.put("age", "20");
// 存储数据
jedis.hmset("user", map);
// 读取数据  返回一个列表类型 [张扬, 20]
System.out.println( jedis.hmget("user", "name","age") );
// HKEYS key 获取所有哈希表中的字段，返回一个列表 [name, age]
System.out.println( jedis.hkeys("user") );
// HVALS key，获取哈希表中所有值
System.out.println( jedis.hvals("user") );
// HLEN key，获取哈希表中字段的数量
System.out.println( jedis.hlen("user") );
// 获取所有的键，迭代操作
Iterator<String> iter = jedis.hkeys("user").iterator();
while(iter.hasNext()) {
String key = iter.next();
System.out.println( key+"--"+jedis.hmget("user", key) );
}
}

</span><span style="color: rgba(0, 128, 0, 1)">// </span><span style="color: rgba(0, 128, 0, 1)">List操作</span>

    @Test
public void testList() {
　　　　 // LPUSH key value1 [value2] 将一个或多个值插入到列表头部
jedis.lpush("Programming language", "Java");
jedis.lpush("Programming language", "Python");
jedis.lpush("Programming language", "C++");
// 获取数据  返回一个 list [Python, Java]
// 第一个是 key，第二个是起始位置，第三个是结束位置
// 其中 0 表示列表的第一个元素， 1 表示列表的第二个元素，以此类推。
// 你也可以使用负数下标，以 -1 表示列表的最后一个元素，-2 表示列表的倒数第二个元素，以此类推。
System.out.println( jedis.lrange("Programming language",  0, -1) );
// LPUSHX key value 将一个值插入到已存在的列表头部
jedis.lpushx("Programming language", "php");
System.out.println( jedis.lrange("Programming language",  0, -1) );
// RPUSH key value1 [value2] 在列表中添加一个或多个值
jedis.rpush("Programming language", "C");
System.out.println( jedis.lrange("Programming language",  0, -1) );
// 输出情况
　　　　 // [C++, Python, Java]
　　　　 // [php, C++, Python, Java]
　　　　 // [php, C++, Python, Java, C]
    }
</span><span style="color: rgba(0, 128, 0, 1)">// </span><span style="color: rgba(0, 128, 0, 1)">Set操作</span>

    @Test
public void testSet() {
// 向集合添加一个或多个成员
jedis.sadd("webSite", "阿里巴巴","网易");
jedis.sadd("webSite", "腾讯");
// SCARD key 获取集合的成员数
System.out.println( jedis.scard("webSite") );
// SMEMBERS key 返回集合中的所有成员，返回类型列表 [阿里巴巴, 腾讯, 网易] 注意顺序不唯一
System.out.println( jedis.smembers("webSite") );
// SSCAN key cursor [MATCH pattern] [COUNT count] 迭代集合中的元素
System.out.println(jedis.sscan("webSite", "0") );
}

</span><span style="color: rgba(0, 128, 0, 1)">// </span><span style="color: rgba(0, 128, 0, 1)">sorted set有序Set</span>

    @Test
public void testSortSet() {
　　　　 // Redis 有序集合和集合一样也是 string 类型元素的集合, 且不允许重复的成员。
　　　　 // 不同的是每个元素都关联一个 double 类型的分数，redis 通过次分数来为集合中的成员进行从小到大的排序。
　　　　 // 有序集合的成员是唯一的, 但分数 (score) 却可以重复。
jedis.zadd("city", 0, "北京");
jedis.zadd("city", 1, "上海");
jedis.zadd("city", 2, "杭州");
    </span><span style="color: rgba(0, 128, 0, 1)">// </span><span style="color: rgba(0, 128, 0, 1)">ZCARD key 获取有序集合的成员数</span>
    System.out.println( jedis.zcard("city"<span style="color: rgba(0, 0, 0, 1)">) );
    </span><span style="color: rgba(0, 128, 0, 1)">// </span><span style="color: rgba(0, 128, 0, 1)">ZREVRANK key member 返回有序集合中指定成员的排名，有序集成员按分数值递减(从大到小)排序，<br>　　　　 // java中的方法是zrevrangeByScore</span>
    System.out.println( jedis.zrevrangeByScore("city", 5, 0<span style="color: rgba(0, 0, 0, 1)">) );
}

}

Spring Boot 集成 Redis

1. 新建 Spring Boot 项目

添加 spring-boot-starter-data-redis 依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

本文会根据 StringRedisTemplate、RedisTemplate 这两个模板来介绍，其中 StringRedisTemplate 继承自 RedisTemplate，只能操作键值都是 String 类型的数据。在实际开发中建议使用 RedisTemplate<K,V>。

查询源码可知 RedisTemplate 默认使用 JdkSerializationRedisSerializer 序列化，而 StringRedisTemplate 则使用 StringRedisSerializer。

2. 配置 redis

在 application.properties 中配置如下：

########################################################
###Redis (RedisConfiguration)
########################################################
spring.redis.database=1
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=
spring.redis.pool.max-idle=8
spring.redis.pool.min-idle=0
spring.redis.pool.max-active=8
spring.redis.pool.max-wait=-1
spring.redis.timeout=5000

3. 编写代码

1. 创建 model

package com.haq.entity;
import java.io.Serializable;
/**


Created by on 2017/2/24.
*/
public class User implements Serializable {
private static final long serialVersionUId = 1L;
private String id;
private String name;
public User(){
super();
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
@Override
public String toString() {
return "User{" +
"id='"+ id +''' +
", name='"+ name +''' +
'}';
}
}

2. 创建 RedisService

package com.haq.common.redis;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
/**


Created by on 2017/3/1.
*/
@Service
public class RedisService {
@Autowired
StringRedisTemplate stringRedisTemplate;
@Resource(name = "stringRedisTemplate")
ValueOperations<String, String> valOpsStr;
@Autowired
RedisTemplate<Object, Object> redisTemplate;
@Resource(name = "redisTemplate")
ValueOperations<Object, Object> valOpsObj;
/**

根据指定 key 获取 String
@param key
@return
*/
public String getStr(String key){
return valOpsStr.get(key);
}

/**

设置 Str 缓存
@param key
@param val
*/
public void setStr(String key, String val){
valOpsStr.set(key,val);
}

/**

删除指定 key
@param key
*/
public void del(String key){
stringRedisTemplate.delete(key);
}

/**

根据指定 o 获取 Object
@param o
@return
*/
public Object getObj(Object o){
return valOpsObj.get(o);
}

/**

设置 obj 缓存
@param o1
@param o2
*/
public void setObj(Object o1, Object o2){
valOpsObj.set(o1, o2);
}

/**

删除 Obj 缓存
@param o
*/
public void delObj(Object o){
redisTemplate.delete(o);
}



}

3.创建 RedisController

package com.haq.web;
import com.haq.common.redis.RedisService;
import com.haq.entity.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**


Created by on 2017/3/1.
*/
@RestController
@RequestMapping("/redis")
public class RedisController {
@Autowired
RedisService redisService;
/**

设置 Str 缓存
@param key
@param val
@return
*/
@RequestMapping(value = "setStr")
public String setStr(String key, String val){
try {
redisService.setStr(key, val);
return "success";
} catch (Exception e){
e.printStackTrace();
return "error";
}
}

/**

根据 key 查询 Str 缓存
@param key
@return
*/
@RequestMapping(value = "getStr")
public String getStr(String key){
return redisService.getStr(key);
}

/**

根据 key 产出 Str 缓存
@param key
@return
*/
@RequestMapping(value = "delStr")
public String delStr(String key){
try {
redisService.del(key);
return "success";
} catch (Exception e){
return "error";
}
}

/**

设置 obj 缓存
@param key
@param user
@return
*/
@RequestMapping(value = "setObj")
public String setObj(String key, User user){
try {
redisService.setObj(key, user);
return "success";
} catch (Exception e){
e.printStackTrace();
return "error";
}
}

/**

获取 obj 缓存
@param key
@return
*/
@RequestMapping(value = "getObj")
public Object getObj(String key){
return redisService.getObj(key);
}

/**

删除 obj 缓存
@param key
@return
*/
@RequestMapping(value = "delObj")
public Object delObj(String key){
try {
redisService.delObj(key);
return "success";
} catch (Exception e){
e.printStackTrace();
return "error";
}
}



}

4.运行测试

1.StringRedisTemplate

http://127.0.0.1:8080/redis/setStr?key=aa&val=name

http://127.0.0.1:8080/redis/getStr?key=aa

http://127.0.0.1:8080/redis/delStr?key=aa

2.RedisTemplate

http://127.0.0.1:8080/redis/setObj?key=aa&id=1&name=test

http://127.0.0.1:8080/redis/getObj?key=aa

http://127.0.0.1:8080/redis/delObj?key=aa

以上地址都能通过测试，在这里就不一一截图了

参考资料

http://www.runoob.com/redis/redis-java.html

https://www.cnblogs.com/floay/p/6485742.html

https://blog.csdn.net/u012385190/article/details/53464621

Redis笔记（六）：Java中使用Redis

Java 程序使用 Redis

添加依赖包

Maven 依赖方式

下载 Jar 包方式

代码使用示例

Spring Boot 集成 Redis

1. 新建 Spring Boot 项目

2. 配置 redis

3. 编写代码

1. 创建 model

2. 创建 RedisService

1.StringRedisTemplate

2.RedisTemplate

参考资料

相关帖子

随便看看

Redis笔记（六）：Java中使用Redis