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 BaseHTTPServerimport threadingimport timelock_timeout_seconds = 8lock = threading.Lock()lock_client_ip = ""lock_time = 0class 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            returnif __name__ == '__main__':    http_server = BaseHTTPServer.HTTPServer(('127.0.0.1', '88888'), LockService)    http_server.serve_forever()

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