Redis 连载(四) : 主从复制,读写分离,java-Jedis

# redis.conf位置,/etc/redis/redis.conf
redis-server /pathxxx/redis.conf

# 打开复制的redis.conf
sudo vim /pathxxx/redis

# 通过/port找到修改port的地方,把端口修改成一个其他任意端口,只要不冲突就可以.
port 6380

# 通过 /.pid 找到修改 pip 的地方.
pidfile /var/run/redis/redis-server-80.pid

# 通过 /logfile 找到修改log名的地方,进行文件名修改.
logfile /var/log/redis/redis-server-80.log

# 通过/dbfilename 找到修改 pip 的地方.
dbfilename dump-80.rdb

键盘按下esc键
键盘按下shift+ZZ

redis-server /pathxxx/redis.conf

info replication

slaveof 127.0.0.1 6379 [slaveof 主机IP 主机Port]

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>java-redis</groupId>
    <artifactId>jedis-study</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
        <!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>3.0.1</version>
        </dependency>
        <!-- 日志 -->
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.5</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-simple</artifactId>
            <version>1.7.5</version>
        </dependency>
    </dependencies>
</project>

package com.jedis;

import redis.clients.jedis.Jedis;

public class JedisTest {

    public static void main(String[] args) {
        try {
            Jedis jedis = new Jedis("192.168.93.43",6380);
            System.out.println(jedis.ping());
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}

package com.api;

import redis.clients.jedis.Jedis;

import java.util.Set;

public class RedisAPITest {

    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.93.43",6381);
        // 获取全部的 Key
        Set<String> sets = jedis.keys("k*");
        for (String key : sets) {
            System.out.println(key);
        }
        // 添加一个 key
        jedis.set("j_k1","这是一个 jedis value");
        System.out.println(jedis.get("j_k1"));
    }
}

package com.trans;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;

/**
 * 事务测试类
 */
public class RedisTransTest {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.93.43",6381);
        // 开启事务
        Transaction multi = jedis.multi();
        // 执行操作
        multi.set("tk1","tv1");
        multi.set("tk2","tv2");
        multi.set("tk3","tv3");
        // 提交操作
        multi.exec();
        // 放弃本次操作
//      multi.discard();
    }
}

package com.mands;

import redis.clients.jedis.Jedis;

/**
 * 主从复制
 */
public class RedisMAS {
    public static void main(String[] args) {
        Jedis jedis80 = new Jedis("192.168.93.43",6380);
        Jedis jedis81 = new Jedis("192.168.93.43",6381);

        // 将6381修改为6380的从机
        jedis81.slaveof("192.168.93.43",6380);
        // 主机写值
        jedis80.set("k3", "v3");
        // 从机读值
        System.out.println(jedis81.get("k3"));

    }
}

package com.pool;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
 * redis 连接池
 */
public class JedisPoolTools {


    private static volatile JedisPool jedisPool = null;

    private JedisPoolTools(){};

    public static JedisPool getJedisInstance(){
        if (jedisPool == null){
            synchronized (JedisPoolTools.class){
                if (jedisPool == null){
                    JedisPoolConfig poolConfig = new JedisPoolConfig();
                    // 最多有多少个空闲状态的实例.
                    poolConfig.setMaxIdle(20);
                    poolConfig.setMaxWaitMillis(100*1000);
                    // 获取一个jedis实例的时候是否检查连接可用性.如果为true.得到jedis实例均是可用的.
                    poolConfig.setTestOnBorrow(true);
                    jedisPool = new JedisPool(poolConfig, "192.168.93.43",6380);
                }
            }
        }

        return jedisPool;
    }

    public static void close(JedisPool jedisPool, Jedis jedis){
        if (jedis != null){
            jedis.close();
        }
    }
}

package com.pool;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

/**
 * 测试类
 */
public class JedisPoolTest {
    public static void main(String[] args) {
        try {

            JedisPool jedisPool = JedisPoolTools.getJedisInstance();
            Jedis jedis = jedisPool.getResource();
            jedis.set("k4","v4");
            jedis.close();
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}