zoukankan      html  css  js  c++  java
  • 使用redis实现程序或者服务的高可用

    使用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"
    RUNNING = False #标识任务是否在跑 def use_redis(option=REDIS_DB): pool = redis.ConnectionPool(**option) r = redis.Redis(connection_pool=pool) return r def main(): client = use_redis() flag = client.exists(KEY)
    global RUNNING
    if not flag: client.setex(KEY, SERVER_IP, EXPIRATION_TIME) t = threading.Thread(target=work) t.start()
    RUNNING = True
    else: value = client.get(KEY) if value == SERVER_IP: client.expire(KEY, EXPIRATION_TIME)
    if not RUNNING:
    t = threading.Thread(target=work)
    t.start()
    RUNNING = True
    # 模拟业务逻辑
    def work(): while True: .......... time.sleep(8) if __name__ == "__main__": while True:
    try: main()
    except Exception, err:
    print(err)
    finally: time.sleep(LOOP_TIME)

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

  • 相关阅读:
    委托与事件的关系
    分布式存储ceph——(1)部署ceph
    neutron二
    openstack第五章:cinder
    openstack第六章:dashboard
    openstack第一章:keystone
    openstack第二章:glance
    openstack第三章:nova
    openstack第四章:neutron— 网络服务
    openstack安装
  • 原文地址:https://www.cnblogs.com/lucky-heng/p/11135410.html
Copyright © 2011-2022 走看看