码迷,mamicode.com
首页 > 其他好文 > 详细

corosync+pacemaker 双节点脑裂问题

时间:2015-10-10 10:47:14      阅读:276      评论:0      收藏:0      [点我收藏+]

标签:

0.引入

   corosync作为HA方案中成员管理层(membership layer),负责集群成员管理、通信方式(单播、广播、组播)等功能,pacemaker作为CRM层。在利用corosync+pacemaker 主备模式实践中,遇到一个问题,即脑裂问题。何谓脑裂: 在HA集群中,节点间通过心跳线进行网络通信,一旦心跳网络异常。导致成员互不相认,各自作为集群中的DC,这样资源同时会在主、备两节点启动。脑裂是corosync还是pacemaker导致的呢?一开始我认为是corosync,原因在于心跳端导致corosync不能正常通信。后来发现在pacemaker官网有找到脑裂(split-brain)的方案。pacemaker作为crm,主责是管理资源,还有一个作用是选择leader。

1.方案

  在[1](http://drbd.linbit.com/users-guide-emb/s-configure-split-brain-behavior.html)文中给出了一种解决方法。本文中讨论另一种方法,即为pacemaker配置抢占资源。原理在于,pacemaker 可以定义资源的执行顺序。如果将独占资源放在最前面,后面的资源的启动则依赖与它,成也独占资源,败也独占资源。当心跳网络故障时候,谁先抢占到该资源,该节点就接管服务资源,提供服务。这种方案必须解决两个问题,一是必须定义一个抢占资源,二是自定义pacemaker RA,去抢夺资源。

2. 定义抢占资源

   本文利用互斥锁来实现独占资源。具体由python实现一个简单的web服务,提供lock,unlock,updatelock服务。

__author__ = ‘ZHANGTIANJIONG629‘
import BaseHTTPServer
import threading
import time
lock_timeout_seconds = 8
lock = threading.Lock()
lock_client_ip = ""
lock_time = 0
class LockService(BaseHTTPServer.BaseHTTPRequestHandler):
    def do_GET(self):
        ‘‘‘define url route‘‘‘
        pass
    def lock(self, client_ip):
        global lock_client_ip
        global lock_time
        # if lock is free
        if lock.acquire():
            lock_client_ip = client_ip
            lock_time = time.time()
            self.send_response(200, ‘ok‘)
            self.close_connection
            return
            # if current client hold lock,updte lock time
        elif lock_client_ip == client_ip:
            lock_time = time.time()
            self.send_response(200, ‘ok,update‘)
            self.close_connection
            return
        else:
            # lock timeout,grab lock
            if time.time() - lock_time > lock_timeout_seconds:
                lock_client_ip = client_ip;
                lock_time = time.time()
                self.send_response(200, ‘ok,grab lock‘)
                self.close_connection
                return
            else:
                self.send_response(403, ‘lock is hold by other‘)
                self.close_connection
    def update_lock(self, client_ip):
        global lock_client_ip
        global lock_time
        if lock_client_ip == client_ip:
            lock_time = time.time()
            self.send_response(200, ‘ok,update‘)
            self.close_connection
            return
        else:
            self.send_response(403, ‘lock is hold by other‘)
            self.close_connection
            return
    def unlock(self, client_ip):
        global lock_client_ip
        global lock_time
        if lock.acquire():
            lock.release()
            self.send_response(200, ‘ok,unlock‘)
            self.close_connection
            return
        elif lock_client_ip == client_ip:
            lock.release()
            lock_time = 0
            lock_client_ip = ‘‘
            self.send_response(200, ‘ok,unlock‘)
            self.close_connection
            return
        else:
            self.send_response(403, ‘lock is hold by other‘)
            self.close_connection
            return
if __name__ == ‘__main__‘:
    http_server = BaseHTTPServer.HTTPServer((‘127.0.0.1‘, ‘88888‘), LockService)
    http_server.serve_forever()

下一篇介绍自定义RA脚本。

corosync+pacemaker 双节点脑裂问题

标签:

原文地址:http://my.oschina.net/hanhanztj/blog/515065

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!