文档章节

Redis笔记(六):Java中使用Redis

o
 osc_4nmshwhm
发布于 2018/08/06 16:05
字数 1480
阅读 9
收藏 0

精选30+云产品,助力企业轻松上云!>>>

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 {

    private static  Jedis jedis;

    static {
        // 连接服务器,这里是本地
        jedis = new Jedis("127.0.0.1", 6379);
        // 如果需要,进行权限认证
//      jedis.auth("");
    }

    // 字符串操作
    @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"));

    }

    // 哈希操作Hash
    @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) );
        }

    }

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

 

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

 


作者:朝雨忆轻尘
出处:https://www.cnblogs.com/xifengxiaoma/ 
版权所有,欢迎转载,转载请注明原文作者及出处。

 

o
粉丝 0
博文 500
码字总数 0
作品 0
私信 提问
加载中
请先登录后再评论。
Redis之上的分布式Java队列

最近学习的势头大涨,码了很多干货。分享给大家参考学习! 通过优锐课的java学习笔记中,了解到关于让我们使用Redisson Java框架讨论六种不同类型的基于Redis的分布式队列。 1、在Redis中使用...

osc_tiaoycd5
04/16
9
0
(๑•̀ㅂ•́)و✧文章总目录ヾ(≧▽≦*)o

SSM整合进阶篇 Spring+SpringMVC+MyBatis+easyUI整合进阶篇(一)设计一套好的RESTful API Spring+SpringMVC+MyBatis+easyUI整合进阶篇(二)RESTful API实战笔记(接口设计及Java后端实现) S...

涵s
2018/05/24
0
0
Carlosfu技术系列文章总目录

转载请注明出处哈:http://carlosfu.iteye.com/blog/2240426 刚看了一下这个账号是2009年注册的,当时可能是为了下载javaeye的周刊吧,后来12年开始工作时候,零零散散的转了几篇别人的。 为什...

付磊-起扬
2015/09/03
0
0
面试10家公司,终入阿里,感谢大佬的496页Java面试进阶解析笔记

面试就是大家身边总是存在各种各样的可能,而自身又具备这样的能力,就忍不住想试一试,尤其是到了年关,是一个好的蓄势并且认真积累的阶段。当然面试套路众多,但对于技术面试来说,主要是考察...

Java发财
05/23
0
0
Redis 学习笔记(篇一):字符串和链表

本次学习除了基本内容之外主要思考三个问题:why(为什么)、what(原理是什么)、which(同类中还有哪些类似的东西,相比有什么区别)。 由于我对 java 比较熟悉,并且 java 中也有字符串和...

osc_3xmkn220
04/16
4
0

没有更多内容

加载失败,请刷新页面

加载更多

使用amoeba实现mysql读写分离

转载马士兵连老师笔记 使用amoeba实现mysql读写分离 1、什么是amoeba? Amoeba(变形虫)项目,专注 分布式数据库 proxy 开发。座落与Client、DB Server(s)之间。对客户端透明。具有负载均衡、...

兵荒马乱的青春
19分钟前
0
0
学Vue,就要学会vue JSX(二)

学习JSX,先了解一下createElement 提到JSX,不可避免的就要提到createElement,当你看完本节,你会发现,奇怪的知识又增多了。ok,我们接着上一部分继续讲。这一次的准备工作是了解createEleme...

osc_kurqu050
19分钟前
17
0
学Vue,就要学会vue JSX(三)

是时候使用JSX代替createElement了 接着上面的讲,当我们看到上面用createElement去实现组件,太麻烦了,别说工作效率提高了,就是那些嵌套可以嵌套正确就很赞了,所以我们需要用JSX去简化整...

osc_tq5hz9vv
21分钟前
13
0
protocol buffer使用

protocol buffer使用例子 protocol buffer是什么 https://developers.google.com/protocol-buffers 这是protocol buffer的官方网站,上边有详细的使用方式。 一般常见的序列和反序列方式就是...

RandomObject
22分钟前
7
0
小白的前端之路-HTMl

HTML——超文本标记语言 HTMl里面有标签,标签又分为单标签和双标签,也分为行级元素和块级元素 标签是用<>包裹起来的,而且必须要有<>,否则会直接显示在浏览器上面哦 现在介绍一下常用标签...

osc_e45irv7l
22分钟前
9
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部