서비스 코드에 등록된 서버 동작

[singsangssong]

🔍 Description

• Arcus 클러스터 운영에 필요한 기능을 추가하는 것을 목표로 합니다. 현재 memcached 서버를 서비스코드에 등록하고, 삭제하는 기능까지 추가된 상태입니다.
• 서비스 코드에 등록된 memcached 서버를 구동, 혹은 중지 시킬 수 있는 기능을 추가하고, 해당 명령은 기존 arcus.sh의 memcacehd start | stop 과 동일하게 동작하도록 합니다. 또 서비스 코드에 등록된 memcached 서버의 목록을 볼 수 있도록 memcached list기능을 지원합니다.

⏰ Implementation Idea

• memcached start <serviceCode>

  • serviceCode의 memcached 서버를 구동합니다.
  • 매핑된 서버의 주소를 통해서 해당 장비에 접속합니다.
  • 이때, /arcus/cache_list/serviceCode에 저장된 데이터를 통해서 구동 옵션을 추가해줍니다.

• memcached stop <serviceCode>

  • serviceCode의 memcached 서버를 중지합니다.
  • serviceCode에 속한 주소값을 가져와서, 해당 장비에 접속합니다. 이후 장비에서 구동중인 포트번호를 찾아서 이를 중지시킵니다.

• memcached list <serviceCode>

  • serviceCode의 memcached 서버의 주소를 모두 출력합니다.

• memcached listall (선택)

  • 현재 zookeeper에 있는 모든 정보를 간추려 출력합니다.
  • serviceCode, serviceCode의 총 서버수, 온라인 서버수 등을 보여줍니다.

[namsic]

서비스코드에 속한 모든 서버 일괄 구동하는 것 외에, 서버 하나씩 개별 구동/중지하는 기능도 있어야 합니다.

[singsangssong]

서비스코드에 속한 모든 서버 일괄 구동하는 것 외에, 서버 하나씩 개별 구동/중지하는 기능도 있어야 합니다.

코멘트주신대로 서버의 단일 동작에 관한 기능도 추가로 작성하겠습니다. 해당 동작은 가이드없이 작성한 주관적 설계임을 참고해주시길 바랍니다.

• memcached start <serviceCode> [ip:port...]: 서버 구동

  • serviceCode외에 인자가 있다면, 이때부터 선택적 구동으로 간주합니다. 이에 인자로 받은 주소값의 서버를 모두 구동합니다.
  • 인자로 받은 주소값 중, serviceCode내에 존재하지 않는 주소라면 무시합니다.(혹은 실패로 처리할 수 있습니다.)
  • serviceCode만 인자로 존재한다면, serviceCode내의 모든 서버를 구동합니다.

• memcached stop <serviceCode> [ip:port]: 서버 중지

  • '서버 중지' 또한 '서버 구동'과 방식은 동일하게 동작합니다. 만약 주소값중 serviceCode내에 존재하지 않는 주소라면 무시합니다.(혹은 실패로 처리할 수 있습니다.)

[singsangssong]

memcached start를 수행하는 python 레거시 코드에서는, 서버를 실행하기 위해서 아래 함수를 사용합니다. 아래의 함수처럼 수행할 지, 혹은 기본 수행옵션(./memcached -E .libs/default_engine.so)에서 전역 구동옵션만 추가하는게 좋을지 의견 여쭙고 싶습니다.

def mc_start_server(config, zkhosts):
  exe = '%s/bin/memcached -E %s/lib/default_engine.so -X %s/lib/syslog_logger.so -X %s/lib/ascii_scrub.so -d -v -r -R5 -U 0 -D: -b 8192 -m%s -p %s -c %s -t %s -z %s'%(
          ARCUS_PATH, ARCUS_PATH, ARCUS_PATH, ARCUS_PATH,
          config['memlimit'], config['port'], config['connections'], config['threads'], zkhosts
        )
  try:
    # memcached process would be blocked (I don't know why..) so just timeout it
    run_or_local(exe, warn_only=True, timeout=2)
  except Exception as e:
    print e
    pass

[namsic]

우선은 고정 옵션을 아래와 같이 하는 것이 좋겠습니다.
Dockerfile 참고하였고, 나머지 구동 옵션은 각 옵션 의미와 값이 적절한지 확인해 보아야 합니다.

%s/bin/memcached\
 -E %s/lib/default_engine.so
 -X %s/lib/syslog_logger.so
 -X %s/lib/ascii_scrub.so
 -D:
 -d

[singsangssong]

현재 PR올릴만큼 테스트를 수행해보지는 않았지만, 설계한대로 구현까지는 완료된 상태입니다.
링크의 내용을 간단하게만 리뷰 부탁드립니다.
세부적인 내용보다는 큰 흐름에서 해당 코드처럼 동작해도 될지 봐주시면 좋을 것 같습니다.

[namsic]

commit에 코멘트 남겨 두었습니다.

[singsangssong]

마지막 논의만 거친다면 PR을 올려도 될 것 같습니다.

memcached start의 종료문제

현재 memcached start를 수행하면 memcached서버가 실행되는 것까지 잘 동작함을 확인했습니다. 다만, 해당 명령이 종료되지 않은 채로 프로그램이 멈추는 현상이 있습니다.

이를 python 레거시 코드에서는 원인을 명확히 확인하지 못한 채로, 2초뒤 타임아웃 시키도록 구현했습니다. (주석으로 '왜이러는지 모르겠다. 그냥 타임아웃되면 종료한다'라고 작성되어있습니다.)

def mc_start_server(config, zkhosts):
  exe = '%s/bin/memcached -E %s/lib/default_engine.so -X %s/lib/syslog_logger.so -X %s/lib/ascii_scrub.so -d -v -r -R5 -U 0 -D: -b 8192 -m%s -p %s -c %s -t %s -z %s'%(
          ARCUS_PATH, ARCUS_PATH, ARCUS_PATH, ARCUS_PATH,
          config['memlimit'], config['port'], config['connections'], config['threads'], zkhosts
        )
  try:
    # memcached process would be blocked (I don't know why..) so just timeout it
    run_or_local(exe, warn_only=True, timeout=2)
  except Exception as e:
    print e
    pass

이에 python처럼 일정시간을 둔채로 반응이 없다면 타임아웃을 할지, 아니면 nohup을 이용해서 memcached 서버를 시작하라는 요청만 보내는게 좋을지 궁금합니다.

[namsic]

ssh로 memcached를 실행하면, 실행한 memcached process가 종료되어야 명령 실행이 완료된 것으로 판단합니다.
(ssh의 정확한 동작 매커니즘은 잘 모르지만, ssh로 실행 명령을 보내고 멈춰 있는 상태에서
다른 터미널로 해당 memcached를 kill하면 ssh 명령도 함께 완료 처리되는 것을 확인할 수 있습니다.)

nohup 사용해서 ssh를 즉시 완료 처리할 수 있으면 그렇게 하는 것이 좋겠습니다.
타임아웃 처리해도 무방합니다. 네트워크 문제가 없다는 전제 하에 타임아웃 발생하는 경우가 오히려 정상 실행된 상태일 가능성이 높습니다.

[singsangssong]

현재 memcached 명령어로 서비스코드에 등록된 서버를 시작 | 중지 | 출력할 수 있습니다.
#17 에서 머지되었음으로 이슈 닫습니다.

./arcus-cli memcached -h 명령으로 인터페이스 확인할 수 있습니다.