1. 程式人生 > >redis的使用和安裝,redis基礎和高階部分

redis的使用和安裝,redis基礎和高階部分

在後端開發中,為了提高效能,對於一些經常查詢但是又不太變化的內容會使用redis,比如前端的列表展示項等,如果資料有變化也可以清空快取,讓前端查一次資料庫,所以使用redis相對高效和靈活.本文主要對於redis在linux上的使用和安裝進行說明。

1.redis的安裝
2.redis常用的命令
3.在阿里雲上面安裝redis
4.在vwmare上安裝redis
5.利用jedis連線redis進行存入和輸出
6.redis的高可用,哨兵機制,主從複製(安裝三臺redis伺服器,一臺主redis)
7.redis常見錯誤
8.redis持久化(AOF與RDB區別)

1.首先通過shell連線到阿里雲伺服器。

image.png

2.輸入 yum -y install gcc 進行安裝redis

image.png
4.輸入命令:

tar xzf redis-3.2.9.tar.gz
 cd redis-3.2.9
make MALLOC=libc

image.png
5.啟動Redis服務
在redis安裝目錄下的redis.conf檔案中的如下內容:預設安裝路徑是在/root/redis-3.2.9 下面

1、註釋掉redis安裝目錄下的redis.conf檔案中的如下資料:bind 127.0.0.1,修改後為#bind 127.0.0.1
2、修改保護模式為非:預設為protected-mode
yes ,修改後為protected-mode no 3、設定redis連線密碼:找到#requirepass foobared ,在下面新增requirepass 123456 然後啟動redis server:輸入指令src/redis-server redis.conf

image.png
還需要把阿里雲上的redis的6379的埠開啟
image.png

常用指令
在以上過程中可能會需要重啟redis server,終止和重啟的命令如下:
1、終止,通過殺死redis的程序
kill -9 程序ID (解釋:-9的含義是強制殺死)
程序ID可以通過如下命令查詢:
ps -ef | grep 'redis'
ps aux | grep '6379'
--- 查詢埠 kill -15 9886 --- 殺死重置 kill -9 9886 --- 強制殺死

在伺服器開啟後可以開啟客戶端進行測試

啟動客戶端並測試
src/redis-cli
帶密碼的啟動方式
./redis-cli -h 127.0.0.1 -p 6379 -a 123456
-h 是主機IP地址
-p 是埠號
-a 是密碼
也可以直接通過程式碼進行測試

6.通過jedis連線redis,通過java程式碼實現儲存redis,並從redis當中取值

需要在marven當中加入
 <dependency>
     <groupId>redis.clients</groupId>
     <artifactId>jedis</artifactId>
     <version>2.9.0</version>
 </dependency>

然後直接寫個測試類測試一下
image.png

測試程式碼

package com.winter.utils.redis;

import org.junit.Test;
import redis.clients.jedis.Jedis;

import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

public class TestRedis {
    private Jedis jedis;
//
    @Before
    public void setup() {
       jedis = new Jedis("192.168.184.128", 6379);//連線伺服器
        jedis.auth("123456");//密碼
//    }
    @Test
    public void test哨兵機制(){
        Jedis jedis = new Jedis("192.168.184.128", 6379);
//        //許可權認證,密碼設定的是123456
        jedis.auth("123456");
        jedis.set("name","我是192.168.184.128存在主伺服器");
        Jedis jedis1 = new Jedis("192.168.184.136", 6379);
//        //許可權認證,密碼設定的是123456
        jedis1.auth("123456");
        String name1 = jedis1.get("name");
        System.out.println("我是136從機"+name1);
        Jedis jedis2 = new Jedis("192.168.184.135", 6379);
//        //許可權認證,密碼設定的是123456
        jedis2.auth("123456");
        String name2 = jedis2.get("name");
        System.out.println("我是135從機"+name2);
        System.out.println("測試從機是否可寫");
        try {
            jedis1.set("name2","測試從機是否可寫");
            jedis2.set("name2","測試從機是否可寫");
            System.out.println("測試不成功,135從機可以寫");
        }catch (Exception e){
            System.out.println("說明從機沒有寫的許可權");
            System.out.println("輸出結果"+e.getMessage());
        }

    }




    /**
     * redis儲存字串
     */
    @Test
    public void testString() {
        jedis.set("name", "xinxin");//向key-->name中放入了value-->xinxin
        System.out.println(jedis.get("name"));//執行結果:xinxin

        jedis.append("name", " is my lover"); //拼接
        System.out.println(jedis.get("name"));

        jedis.del("name");  //刪除某個鍵
        System.out.println(jedis.get("name"));
        //設定多個鍵值對
        jedis.mset("name", "liuling", "age", "23", "qq", "476777XXX");
        jedis.incr("age"); //進行加1操作
        System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq"));

    }

    /**
     * redis操作Map
     */
    @Test
    public void testMap() {
        //-----新增資料----------
        Map<String, String> map = new HashMap<String, String>();
        map.put("name", "xinxin");
        map.put("age", "22");
        map.put("qq", "123456");
        jedis.hmset("user", map);
        //取出user中的name,執行結果:[minxr]-->注意結果是一個泛型的List
        //第一個引數是存入redis中map物件的key,後面跟的是放入map中的物件的key,後面的key可以跟多個,是可變引數
        List<String> rsmap = jedis.hmget("user", "name", "age", "qq");
        System.out.println(rsmap);

        //刪除map中的某個鍵值
        jedis.hdel("user", "age");
        System.out.println(jedis.hmget("user", "age")); //因為刪除了,所以返回的是null
        System.out.println(jedis.hlen("user")); //返回key為user的鍵中存放的值的個數2
        System.out.println(jedis.exists("user"));//是否存在key為user的記錄 返回true
        System.out.println(jedis.hkeys("user"));//返回map物件中的所有key
        System.out.println(jedis.hvals("user"));//返回map物件中的所有value

        Iterator<String> iter = jedis.hkeys("user").iterator();
        while (iter.hasNext()) {
            String key = iter.next();
            System.out.println(key + ":" + jedis.hmget("user", key));
        }
    }

    /**
     * jedis操作List
     */
    @Test
    public void testList() {
        //開始前,先移除所有的內容
        jedis.del("java framework");
        System.out.println(jedis.lrange("java framework", 0, -1));
        //先向key java framework中存放三條資料
        jedis.lpush("java framework", "spring");
        jedis.lpush("java framework", "struts");
        jedis.lpush("java framework", "hibernate");
        //再取出所有資料jedis.lrange是按範圍取出,
        // 第一個是key,第二個是起始位置,第三個是結束位置,jedis.llen獲取長度 -1表示取得所有
        System.out.println(jedis.lrange("java framework", 0, -1));

        jedis.del("java framework");
        jedis.rpush("java framework", "spring");
        jedis.rpush("java framework", "struts");
        jedis.rpush("java framework", "hibernate");
        System.out.println(jedis.lrange("java framework", 0, -1));
    }

    /**
     * jedis操作Set
     */
    @Test
    public void testSet() {
        //新增
        jedis.sadd("user", "liuling");
        jedis.sadd("user", "xinxin");
        jedis.sadd("user", "ling");
        jedis.sadd("user", "zhangxinxin");
        jedis.sadd("user", "who");
        //移除noname
        jedis.srem("user", "who");
        System.out.println(jedis.smembers("user"));//獲取所有加入的value
        System.out.println(jedis.sismember("user", "who"));//判斷 who 是否是user集合的元素
        System.out.println(jedis.srandmember("user"));
        System.out.println(jedis.scard("user"));//返回集合的元素個數
    }

    @Test
    public void test() throws InterruptedException {
        //jedis 排序
        //注意,此處的rpush和lpush是List的操作。是一個雙向連結串列(但從表現來看的)
        jedis.del("a");//先清除資料,再加入資料進行測試
        jedis.rpush("a", "1");
        jedis.lpush("a", "6");
        jedis.lpush("a", "3");
        jedis.lpush("a", "9");
        System.out.println(jedis.lrange("a", 0, -1));// [9, 3, 6, 1]
        System.out.println(jedis.sort("a")); //[1, 3, 6, 9]  //輸入排序後結果
        System.out.println(jedis.lrange("a", 0, -1));
    }

//    @Test
//    public void testRedisPool() {
//        RedisUtil.getJedis().set("newname", "中文測試");
//        System.out.println(RedisUtil.getJedis().get("newname"));
//    }
}

application.yml

server:
  port: 8081

spring:
    datasource:
        name: test
        url: jdbc:mysql://127.0.0.1:3306/mytest?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
        username: root
        password: root
        # 使用druid資料來源
#        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.jdbc.Driver
        filters: stat
        maxActive: 20
        initialSize: 1
        maxWait: 60000
        minIdle: 1
        timeBetweenEvictionRunsMillis: 60000
        minEvictableIdleTimeMillis: 300000
        validationQuery: select 'x'
        testWhileIdle: true
        testOnBorrow: false
        testOnReturn: false
        poolPreparedStatements: true
        maxOpenPreparedStatements: 20
    redis:
      database: 0
      host: 101.132.191.77
      port: 6379
      password: 123456
      pool:
        max-idle: 8
        min-idle: 0
        max-active: 8
        max-wait: -1
      timeout: 5000
mybatis:
  mapper-locations: classpath:mapping/*.xml
  type-aliases-package: com.winter.model

#pagehelper
pagehelper:
    helperDialect: mysql
    reasonable: true
    supportMethodsArguments: true
    params: count=countSql
########################################################
###Redis (RedisConfiguration)
########################################################


###spring.redis.database=0
###spring.redis.host=127.0.0.1
###spring.redis.port=6379
###spring.redis.password=123456
###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
redis的主從複製是什麼?
redis的主從複製主要還是讀寫分離,一臺主redis有讀和寫的許可權,其他從機redis只有讀的許可權,這樣做的好處是為了減輕redis主機的壓力。
redis的哨兵機制?
例:有3臺redis,一臺是主redis,2臺是從機,開啟哨兵機制後,3臺redis開啟後會傳送心跳包到哨兵這裡。如果主機掛了,那麼哨兵會從另外2臺從機這裡選出一臺作為主機(從原來只有讀許可權升級為讀寫許可權)
那如果3臺都掛了怎麼辦呢,一般企業會有備用機,或者利用keepalive的監聽重啟伺服器。
哨兵的功能+keepalive重啟伺服器功能=redis的高可用

image.png

為了進行redis的叢集操作,需要安裝vwmare,然後安裝linux 64位系統進行測試。
這個安裝就不詳說了。安裝vwmare以後下載linux 64位映象,然後匯入映象即可。說下我遇到的坑以及看到的有幫助網址。

主要問題可能為兩個:(1)sshd伺服器沒有啟動;(2)防火牆問題 並且需要永久開啟sshd和關閉防火牆

步驟一:啟動sshd伺服器
1,sshd服務安裝
2,[root@localhost /]# vi /etc/ssh/sshd_config
Port 22
Protocol 2
PermitRootLogin yes
去掉這三行的註釋
最後一個重要!因為它是允許root使用者直接使用sshd服務登入伺服器的!
3,重新啟動sshd服務
[root@localhost /]# service sshd restart
4,設定sshd為系統自動啟動

chkconfig iptables off 永久性生效
chkconfig ip6tables off 防火牆還需要關閉ipv6的防火牆:

步驟二:關閉防火牆
chkconfig iptables off 永久性生效
image.png

虛擬機器安裝以後可以進行克隆(需要先把伺服器給關掉後才可以克隆)
image.png

image.png
原理就是主redis開啟以後儲存記憶體快照發送到從伺服器,因此從伺服器裡面就會有主伺服器的資料
image.png

7.如何設定主redis和從redis?

修改從伺服器redis中的 redis.conf檔案
slaveof 192.168.33.130 6379  這個是主伺服器的地址和埠,就是把從的和主的進行關聯
masterauth 123456---redis伺服器配置了密碼,則需要配置
通過redis-cli連線後輸入info命令檢視role:master,role:slave可以檢視主伺服器和從伺服器

到redis目錄下修改sentinel.conf(這個是哨兵的配置檔案)

1.修改sentinel monitor mymaster 192.168.184.128 6379 1   這裡的128是主redis,6379是埠號,1是投票,哨兵根據投票數選取一個從redis作為主伺服器,一般都是設定為1. 不需要在主redis當中配置哨兵
2.sentinel down-after-milliseconds mymaster 5000  心跳檢測,5秒鐘沒訪問到就換伺服器
3.sentinel parallel-syncs mymaster 2   最多有2個子節點,就是備份伺服器
4.啟動的時候src/redis-server redis.conf 
然後開啟客戶端sentinel.conf --sentinel &    要將redis,redis配置檔案還有哨兵都開開來

image.png

8.redis事務

redis也有事務,就是主redis要提交以後,才能從從機上查到redis,redis事務平時用的極少

9.Redis持久化

什麼是Redis持久化
什麼是Redis持久化,就是將記憶體資料儲存到硬碟。
Redis 持久化儲存 (AOF 與 RDB 兩種模式)
RDB 預設開啟,redis.conf 中的具體配置引數如下;主要是修改save這裡

#dbfilename:持久化資料儲存在本地的檔案
dbfilename dump.rdb
#dir:持久化資料儲存在本地的路徑,如果是在/redis/redis-3.0.6/src下啟動的redis-cli,則資料會儲存在當前src目錄下
dir ./
##snapshot觸發的時機,save   
##如下為900秒後,至少有一個變更操作,才會snapshot 
##對於此值的設定,需要謹慎,評估系統的變更操作密集程度 
##可以通過“save “””來關閉snapshot功能 
#save時間,以下分別表示更改了1個key時間隔900s進行持久化儲存;更改了10個key300s進行儲存;更改10000個key60s進行儲存。
save 900 1
save 300 10
save 60 10000
##當snapshot時出現錯誤無法繼續時,是否阻塞客戶端“變更操作”,“錯誤”可能因為磁碟已滿/磁碟故障/OS級別異常等 
stop-writes-on-bgsave-error yes 
##是否啟用rdb檔案壓縮,預設為“yes”,壓縮往往意味著“額外的cpu消耗”,同時也意味這較小的檔案尺寸以及較短的網路傳輸時間 
rdbcompression yes 

AOF持久化

AOF 預設關閉,開啟方法,修改配置檔案 reds.conf:appendonly yes

##此選項為aof功能的開關,預設為“no”,可以通過“yes”來開啟aof功能 
##只有在“yes”下,aof重寫/檔案同步等特性才會生效 
appendonly yes 
##指定aof檔名稱 
appendfilename appendonly.aof 
##指定aof操作中檔案同步策略,有三個合法值:always everysec no,預設為everysec 
appendfsync everysec 
##在aof-rewrite期間,appendfsync是否暫緩檔案同步,"no"表示“不暫緩”,“yes”表示“暫緩”,預設為“no” 
no-appendfsync-on-rewrite no 
##aof檔案rewrite觸發的最小檔案尺寸(mb,gb),只有大於此aof檔案大於此尺寸是才會觸發rewrite,預設“64mb”,建議“512mb” 
auto-aof-rewrite-min-size 64mb 
##相對於“上一次”rewrite,本次rewrite觸發時aof檔案應該增長的百分比。 
##每一次rewrite之後,redis都會記錄下此時“新aof”檔案的大小(例如A),那麼當aof檔案增長到A*(1 + p)之後 
##觸發下一次rewrite,每一次aof記錄的新增,都會檢測當前aof檔案的尺寸。 
auto-aof-rewrite-percentage 100 

AOF與RDB區別
RDB是要輸入一定次數時間才會儲存,速度快,但是可能會有漏的,不安全,AOF屬於String的append,每次儲存都會存在本地,不會漏,但是效率慢,安全

10.redis訂閱頻道

redis訂閱頻道的原理與我之前做的極光推送比較類似,原理就是前端有個頻道號和後端的頻道後一一匹配,然後後端把訊息傳送給極光伺服器,告訴極光要傳送訊息給哪些有訂閱的手機。像極光的話還會把後端傳給他的訊息推送到蘋果推送伺服器上,再由蘋果伺服器將訊息推送給使用者。
image.png

原文地址
孫堅.gif