使用redis实现程序或者服务的高可用

Posted 2022-03-15 lucky-heng

使用redis实现程序或者服务的高可用，就是将某一程序或服务部署在不同服务器上，或者是跨机房部署，当运行服务的服务器挂了之后，其他服务器上的该服务能立马顶上，这里我简单的使用redis实现这一目的。

思路是： 部署在不同服务器上的相同服务，隔段时间去redis上查下某一个键（自己定义），如果该键不存在，则设置该键的值，可以是自己本服务器的IP，并设置的一个过期时间，然后执行服务的业务逻辑，如果该键存在，查看该键的值是不是自己的IP，如果是，更新该键的过期时间。代码如下：

# coding:utf8
import time
import redis
import threading


REDIS_DB = 
    ‘host‘: ‘*********‘,
    ‘port‘: *****,
    ‘password‘: None,

KEY = "********"
EXPIRATION_TIME = 12
LOOP_TIME = 10
SERVER_IP = "1.1.1.1"


def use_redis(option=REDIS_DB):
    pool = redis.ConnectionPool(**option)
    r = redis.Redis(connection_pool=pool)
    return r


def get_key_from_redis():
    client = use_redis()
    flag = client.exists(KEY)
    if not flag:
        client.setex(KEY, SERVER_IP, EXPIRATION_TIME)
        t = threading.Thread(target=work)
        t.start()
    else:
        value = client.get(KEY)
        if value == SERVER_IP:
            client.expire(KEY, EXPIRATION_TIME)


# 模拟业务逻辑
def work():
    while True:
        ..........
        time.sleep(8)


if __name__ == "__main__":
    while True:
        get_key_from_redis()
        time.sleep(LOOP_TIME)

当然，隔段时间去查一下redis，这个时间要比key的过期时间短一些。