博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
redis多实例重启脚本
阅读量:7000 次
发布时间:2019-06-27

本文共 2304 字,大约阅读时间需要 7 分钟。

   redis属于单进程的服务,它主要受内存、CPU、磁盘IO(主要是做持久化),如果服务器配置比较高,多核CPU、高内存的服务器,可以考虑做redis多实例。做多实例之前,首先要考虑CPU和内存的利用,我在测试的时候发现,redis在QPS为6-8W左右的时候,这个redis所在的逻辑CPU核的负载就在100%左右,所以要优化CPU使用这块,目前一般是是做网卡软中断来实现平衡这种单进程使用CPU过高的情况,不过需要网卡支持网卡软中断,效果不错。

   多实例redis的管理,涉及到监控、服务的管理等,这里只说redis多实例的重启。以下是多实例的重启脚本,仅供交流参考:

#!/usr/bin/env python# -*- coding: utf-8 -*-import redis,threading,sys,socket,time,osfrom multiprocessing import Pooldef port_check(host,port):    POOL = redis.ConnectionPool(host=host, port=port)    my_server = redis.Redis(connection_pool=POOL)    try:        a = my_server.ping()        if a:            return 1        else:            return 0    except Exception,e:        return 0def shutdown_server(host,port):    flag = port_check(host,port)    if flag == 1:        POOL = redis.ConnectionPool(host=host, port=port)        my_server = redis.Redis(connection_pool=POOL)        my_server.shutdown()        while 1:            flag = port_check(host,port)            if flag == 0:                print "%s:%s is Shutdown OK" % (host,port)                break            else:                time.sleep(1)    else:        print "%s:%s is Shutdown alreaday" % (host,port)def start_server(host,port):    flag = port_check(host,port)    if flag == 0:        start_conm = "/usr/local/bin/redis-server /usr/local/redis/etc/redis_%s.conf" % port        os.popen(start_conm)        time.sleep(3)        i = 0        while 1:#每5s检测一次redis ping,持续一分钟,1分钟没有起来认为启动失败            flag = port_check(host,port)            if flag == 1:                print "%s:%s is Start OK" % (host,port)                break            else:                if i > 12:                    print "%s:%s is Start Error" % (host,port)                    break                else:                    time.sleep(5)                    i = i + 1    else:        print "%s:%s is Start alreaday" % (host,port)def restart(host,port):    shutdown_server(host,port)    start_server(host,port)def main():    server_list = ["127.0.0.1:6379","127.0.0.1:16379"]    pool = Pool(processes=3)    for i in server_list:        aa = i.split(':')        host = aa[0]        port = int(aa[1])        results = pool.apply_async(restart, (host,port))    pool.close()    pool.join()    if results.successful():        print 'successful'if __name__=="__main__":    main()

转载地址:http://zievl.baihongyu.com/

你可能感兴趣的文章
说说你生活中高颜值的程序员?
查看>>
从科学记数法到浮点数标准IEEE 754
查看>>
Netty杂记1—BIO网络编程
查看>>
Vue: Binding与Watcher
查看>>
高性能编码技巧
查看>>
Java中锁概念总结
查看>>
Swift泛型定义 同时限定T的类(class)和多协议(protocol)
查看>>
从闭包函数的变量自增的角度 - 解析js垃圾回收机制
查看>>
pip安装报错return _setlocale(category, locale)locale.Error: unsupported locale setti
查看>>
在 Create React App 项目中使用 Prettier
查看>>
那些年收藏的技术文章(二) 云笔记篇
查看>>
浏览器渲染原理
查看>>
TS+Nodejs+Express构建用于前端调试的WEB服务器
查看>>
ubuntu18.04下VSCode通过ssh连接github实操
查看>>
113. Path Sum II
查看>>
logstash常用插件介绍
查看>>
leetcode390.Elimination Game
查看>>
Stream流与Lambda表达式(二) Stream收集器 Collector接口
查看>>
HTTP代理ip的这些误区你知道吗?
查看>>
前端菜鸟笔记 Day-3 CSS基础
查看>>