mysql 슬레이브 연결 끊어졌을때 자동으로 마스터 연결시켜 주는 프로그램 > PHP
PHP

mysql 슬레이브 연결 끊어졌을때 자동으로 마스터 연결시켜 주는 프로그램

조회 1,346회 댓글 0건
  • 현재 페이지 주소 복사
  • 페이스북으로 공유
  • X 로  공유
  • 트위터로  공유
  • 네이버 블로그로 공유
  • 네이버 카페 공유하기
  • 네이버 라인 공유하기
  • 네이버 밴드 공유하기
  • 링크드인으로 공유하기

이 프로그램은 마스터를 하나를 두고 슬레이브를 여러개 둔 다음 분산 처리를 하는경우 간혹 마스터와 싱크가 끊어져서 슬레이브가 작동을 멈추는 경우 사용하는 프로그램 입니다.

마스터 락을 걸어주는 것 때문에 확인 및 테스트 충분히 한 다음 적용하는것이 중요합니다.


대략적인 흐름을 알고 있는 것이 중요합니다.

그래야 아래 프로그램이 왜? 있는지 이해를 하기 편하기 때문입니다.

순서는 다음과 같습니다.

1. 마스터에 락을 걸어 줍니다.

2. 마스터의 로그파일 위치 정보를 가져 옵니다.

3. 슬레이브 접속하여 로그를 가져오지 못하는 상태이면

4. 슬레이브를 멈춤니다. (이것이 안되면 아래 5번 실행 할때 오류발생)

5. 마스터의 로그파일 위치를 재 설정 합니다.

6. 슬레이브를 시작 합니다

7. 마스터 락 걸어 줬던것 풀어 줍니다..


위에서 더 추가 되어야할것은 슬레이브가 오류가 있었을때만 아래를 함수로 만들어 실행하는 기능이 추가 되면 되는데 응용해서 프로그램 약간만 수정하면 됩니다.


슬레이브에 대한 호스트명은 자신의 환경에 맞게 추가를 해줘야 합니다.

배열형태로 되어 넣고 싶은 만큼 넣을 수 있습니다.




  $db_id        = 'root';
  $db_pw        = '12354';
  $masterHost   = '';
  $aSlave['']   = '';

  # show status like '%Table_locks_immediate%' 횟수를 알 수 있고 이것을 기반으로 처리가 되었는지 알 수 있다.
  $oDbconM      = mysqli_connect($masterHost, $db_id, $db_pw, '', $port);

  # 마스터에서 갱신이 되지 않도록 락을 걸어 준다.
  $dbResult     = mysqli_db_query("FLUSH TABLES WITH READ LOCK", 'result', $oDbconM );

  # 마스터의 현재 상태를 가져온다. 포지션
  $Query_sql    = "SHOW MASTER STATUS";
  $aRs          = mysqli_db_query($Query_sql,'assoc',$oDbconM);
  $aTemp        = explode('.', $aRs['File']);
  $masterIdxNo  = (int)$aTemp[1];
  $masterFile   = $aRs['File'];
  $masterPos    = $aRs['Position'];
  // $masterFile   = 'binlog.000001';
  // $masterPos    = 0;

  # 슬레이브에 접속해서 마스터와 맞춰 준다.
  foreach( $aSlave as $slaveHost => $port )
  {
    $oDbconS      = mysqli_connect($slaveHost, $db_id, $db_pw, '', $port);
    $Query_sql    = "SHOW SLAVE STATUS";
    $aRs          = mysql_db_query($Query_sql, 'assoc', $oDbconS);
    if ( $aRs['Slave_IO_Running'] == 'No' )
    {
      $dbResult     = mysqli_db_query("stop slave", 'result', $oDbconS);
      $dbResult     = mysqli_db_query("CHANGE MASTER TO MASTER_LOG_FILE='$masterFile', MASTER_LOG_POS=$masterPos", 'result', $oDbconS);
      $dbResult     = mysqli_db_query("start slave", 'result', $oDbconS);
    }
  }

  $dbResult     = mysqli_db_query("UNLOCK tables", 'result', $oDbconM );
 


필요한 경우 디비쿼리용 사용자 함수는 아래 보시면 됩니다.

공통으로 사용하는 php Mysql 함수 > PHP (pabburi.co.kr) 


  • 현재 페이지 주소 복사
  • 페이스북으로 공유
  • X 로  공유
  • 트위터로  공유
  • 네이버 블로그로 공유
  • 네이버 카페 공유하기
  • 네이버 라인 공유하기
  • 네이버 밴드 공유하기
  • 링크드인으로 공유하기
전체 237건 1 페이지
  • profile_image PHP 설치 되어 있지 아니하여 윈도우PC에 최신버전으로 설치버전은 설치 할 때마다 다르기 때문에 본인이 사용하려는버전을 선택 하면 됩니다.     > 현대적인? 방법으로 설치함.       예전에 압축해 놓은것 풀고 path 설정하고 했던 그런 방법을 쓰지 않고 간단하게 설치가 되었다.      winget install PHP.PHP.8.5    > 아래 명령으로 설치된 위치를 찾음      where php    > php.ini-production…
  • profile_image OP캐쉬 사용하면 괜찮아 보다는 저 같은 경우는 사용하지 않아도 괜찮아를 더 좋아 합니다.▷ 솔리드 캐시(SOLID CACHE)란?솔리드 캐시는 간단히 말해 "비싼 RAM(REDIS) 대신 저렴하고 넉넉한 디스크(DB)에 캐시를 저장하는 전략"으로 원래 루비 온 레일즈(RUBY ON RAILS) 커뮤니티에서 제안된 방식이지만 본질은 어떤 언어에서든 적용 가능한 실용적인 캐싱 철학임.▷ 핵심 철학: "ssd는 생각보다 훨씬 빠르다"과거에는 디스크가 너무 느려서 무조건 데이터를 ram(REDIS MEMCACHED)에 올려야 했지만 지금은 nvme ssd 같은 초고속 저장 장치가 보편화되었습니다. 굳이 복잡하게 별도의 메모리…
  • profile_image MyISAM은 SELECT가 빠르고 InnoDB는 느리다그런 경우도 있고 아닌 경우도 있기 때문에 어떤 용도로 사용하느냐에 따라서 다를 수 있습니다.그리고 처음 데이터 넣은 다음 select만 90% 이상이고 테이블 사용이 업데이트나 인서트는 적은 경우인지 불특정 다수에게 서비스 하기 때문에 불특정한 row를 가져와서 보여줘야 하는것인지에 다를 수 있는 것입니다. 가장 큰 차이: 데이터와 인덱스 구조→ MyISAM  - 데이터 파일(.MYD) 과 인덱스 파일(.MYI) 이 분리됨  - 인덱스 → 데이터 파일을 다시 읽는 구조  - 동작흐름: PK 인덱스 탐색 (.MYI) -> 데이터 위치…
  • profile_image 데이터베이스를 사용하다 보면 이미 존재하는 데이터인지 확인한 후 INSERT 또는 UPDATE를 해야 하는 상황을 자주 만나게 됩니다.이때 매우 유용한 문법이 바로 INSERT ... ON DUPLICATE KEY UPDATE입니다.즉, 쿼리 한번으로 해결 된다는 의미 인데 아무곳에서나 사용 가능한것은 아니고 키 중복이 발생하는 부분에서만 사용 하는 것입니다.그렇기 때문에 unique의 특성을 모르시는 분은 사용 하면 안되겠지요.  장점- 쿼리 수 감소: SELECT → INSERT/UPDATE 두 번 쿼리 날릴 필요 없음- 동시성 문제 감소: SELECT 후 INSERT 방식보다 Race Condition 발…
  • profile_image 웹서버에 접근하는 X-Forwarded-For란?X-Forwarded-For(XFF)는 HTTP 헤더로 클라이언트가 프록시나 로드 밸런서를 거쳐 웹 서버에 접속할 때 원래 클라이언트의 IP 주소를 식별하기 위해 사용 됩니다.로그밸런스도 프록시서버의 변형된 형태가 있기 때문에 쉽게 프록시 서버라고 생각을 하면 쉽습니다.일반적으로 웹 서버는 직접 연결된 IP만 볼 수 있는데 프록시 뒤에 있으면 프록시 서버의 IP만 보이게 되는데 이런 경우 XFF 헤더가 실제 사용자 IP를 전달하는 역할을 합니다. ▷ 헤더 형식X-Forwarded-For: 클라이언트IP 프록시1 프록시2 ...여러 프록시를 거치면 쉼표로 구분되어 …
  • profile_image ifconfig는 초기 한번 정도만 사용하고 interface configuration의 약자로 리눅스/유닉스 시스템에서 네트워크 인터페이스를 설정하고 확인하는 명령어입니다.▷ ifconfig 주요 용도1. 네트워크 인터페이스 정보 조회  - 현재 활성화된 네트워크 인터페이스 목록 확인  - 각 인터페이스의 IP 주소, MAC 주소, 서브넷 마스크 확인  - 네트워크 통계 정보 (전송/수신 패킷 수, 에러 등) 확인2. 네트워크 인터페이스 설정  - IP 주소 할당 및 변경  - 서브넷 마스크 설정  - 브로드캐스트 주소 설정  - MTU(Maximum Tr…
  • profile_image 결론부터 말하면 느리게 다운로드 처리 하는 방식에 대한 것입니다.왜? 느리게 다운로드가 필요한가 하면 지연을 시키면 트래픽이 평탄화 되는 효과가 있는데 갑자기 순간적으로 팍 튀는 그런 현상을 없애기 위해서 필욯나 방법중 하나 입니다. 원리는 간단하며 읽은 만큼 내보내고 약간 지연 시키는 방식 입니다.    /**     * 청크 단위로 지연시키면서 파일 다운로드 (대용량 파일용)     *     * @param string $filePath 다운로드할 파일 경로     * @param …

상업적 이용 금지. 컨텐츠는 개인 용도로만 사용이 가능 합니다.