【五】、Jedis

导读:本篇文章讲解 【五】、Jedis,希望对大家有帮助,欢迎收藏,转发!站点地址:www.bmabk.com

五、Jedis

1.使用Java来操作Redis,Jedis是官方推荐的操作Redis的中间件
2.SpringBoot已经有整合RedisTemplate

必要步骤

  • 导入相关包
  • 建立连接
  • 操作
  • 可关闭连接,或者直接使用jedis连接池

1. 导入依赖

在maven官网搜索Jedis,选择你所要使用的Jedis的版本并导入
搜索Jedis版本

<!--导入jredis的包-->
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.2.0</version>
</dependency>
<!--fastjson-->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>fastjson</artifactId>
    <version>1.2.70</version>
</dependency>

2.编码测试

连接数据库

  1. 修改redis的配置文件

    [root@czlfirst ~]# cd /usr/local/bin/czlconfig/
    [root@czlfirst czlconfig]# ls
    redis.conf
    [root@czlfirst czlconfig]# vim redis.conf 
    
  2. 将只绑定本地注释
    (注:由于redis本身默认处于保护模式,redis.conf注释掉bind 127.0.0.1,会产生安全问题
    注释掉bind 127.0.0.1意味着所有客户端都可以访问,相当于bind 0.0.0.0
    将只绑定本地注释

  3. 关闭安全模式
    protected-mode yes将yes改为no

    从官方说明我们可以知道,当保护模式开启时,如果没有设置密码,并且设置允许任意ip可以访问时,你是连接不上 Redis 的!

    将yes改为no

  4. 开启防火墙,开放Redis端口(6379)

    • 查看防火墙状态

      systemctl status firewalld
      

      若防火墙已经打开则会显示runnning
      在这里插入图片描述
      若未打开防火墙则进行第二个步骤

    • 打开防火墙

      systemctl start firewalld  //打开防火墙
      systemctl stop firewalld //关闭防火墙
      
    • 查看防火墙某个端口是否开放

      firewall-cmd --query-port=6379/tcp
      

      查看防火墙某个端口是否开放

    • 如果端口没有开放则要开放防火墙端口6379

      firewall-cmd --zone=public --add-port=6379/tcp --permanent
      
    • 重新启动防火墙

      firewall-cmd --reload
      
    • 关闭Redis服务

      redis-cli shutdown
      
    • 再用配置完成之后的配置文件启动Redis服务

      redis-server czlconfig/redis.conf
      
    • 在阿里云服务器控制台配置安全组
      在阿里云服务器控制台配置安全组

使用Java操作Redis

package com.czl;

import redis.clients.jedis.Jedis;

public class TestPing {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("xxxxxx",6379);
        System.out.println(jedis.ping());
    }
}

显示Pong则连接成功

3.基于Jedis的事务控制

package com.czl;

import com.alibaba.fastjson.JSONObject;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;

public class TestTx {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("xx.xxx.xx.xx", 6379);

        JSONObject jsonObject = new JSONObject();
        jsonObject.put("hello","world");
        jsonObject.put("name","ASuLe");
        jedis.flushDB();
        //开启事务
        Transaction multi = jedis.multi();
        String result = jsonObject.toJSONString();
        //jedis.watch();//乐观锁一定要在事务之前添加,但是一定要监控已经存在的key
        try {
            multi.set("user1",result);
            multi.set("user2",result);
            /**
             * 对Java来说这是运行时异常,可以正常编译,但是运行时抛出了异常也就导致事务没有执行
             * **/
            int i = 1 / 0;
            //执行事务
            multi.exec();
        } catch (Exception e) {
            //出现异常则放弃事务
            e.printStackTrace();
            multi.discard();
        } finally {
            //完成之后关闭jedis的连接
            System.out.println(jedis.get("user1"));
            System.out.println(jedis.get("user2"));
            jedis.close();
        }
    }
}

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/81919.html

(0)
小半的头像小半

相关推荐

极客之音——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!