예제로 보는 아카(akka) - 18. 서비스로 설치 ( Deploying )

- Scala 2.11.8 기반 

- Akka 2.4.11 기반 

- Java 8  (akka 2.4 부터는 java 8 요구함. scala 2.11 은 java 7도 괜찮지만~) 

서비스로 설치 ( Deploying )

이전 포스팅에 이어서 이번에는 서비스로 만드는 방식을 알아보겠습니다. 즉 서버가 시작하면 자동으로 시작되게 하고 , 이전까지는 ./helloakka 로 시작한 후에는 Ctrl+C 나 kill -9  pid 를 이용하여 적절한 리소스해제 없이 강제로 죽였어야 했는데요. 좀 더 우아하게 stop 시켜 봅시다. 

이전 포스팅에서 만든 프로젝트에서  이어서 해봅니다.

* 이전 포스팅과 마찬가지로 더 좋은 방법이 있을 수 있으며 적극적인 공유가 필요합니다.

이번 포스팅에서는 2가지를 합니다.

1. 서비스로 실행하기 ( 서버 내렸다가 다시 실행했을때 우리 서비스도 자동으로 실행되게) 

2. 시작,종료를 우아하게 처리하기  (이 부분은 정리가 좀 덜 됬습니다)

서비스로 실행하기

방법1.우분투에서 서비스로 등록하기 (nohup & 및 pkill 및 init.d 활용)

 프로젝트 폴더에 run 파일을 만들고 내용은 아래와 같이 합니다. 

#!/bin/sh

USERNAME=$USER

COMMAND="/home/hama/work/helloakka/stage/bin/helloakka"

KILL_COMMAND = "java -cp /home/hama/work/helloakka"

if [ "$1" = "start" ]; then

#check process

        # /dev/null 로 redirection 을 통해 화면 출력을 하지 않는것은 '표준출력' 에 한해서 해당된다. 

        #2>&1 는 표준에러를 표준출력으로 redirection 하라는 의미다.

pgrep -f  "java -cp /home/hama/work/helloakka"  > /dev/null 2>&1 # 0 이면 성공. 다른거면 실패 

if [$? -ne 0] ; then

#if not exists

echo "not exists"

else

#if exists

#pkill -f  "java -cp /home/hama/work/helloakka"

#echo "helloakka killed.."

echo "..exits.."

sleep 1

fi

nohup $COMMAND &

echo "helloakka Starting OK.."

elif [ "$1" = "stop" ]; then

pgrep -f  "java -cp /home/hama/work/helloakka"  > /dev/null 2>&1

if [ $? -ne 0 ] ; then

#if not exists

echo "helloakka process not found.."

else 

#if exists

pkill -f  "java -cp /home/hama/work/helloakka"

echo "helloakka killed.."

fi 

elif [ "$1" = "log" ]; then

tail -f logs/*.log

else

echo "usage run [start/stop/log]"

fi

run 을 실행하기 위해  .profile 파일에 export PATH=$PATH:.  추가

source .profile 

/etc/init.d 아래 스크립트 작성 (helloakka 이름) 

#! /bin/sh

# /etc/init.d/helloakka

### BEGIN INIT INFO

# Provides:          helloakka

# Required-Start:

# Required-Stop:

# Should-Start:

# Default-Start:     2 3 4 5

# Default-Stop:

# Short-Description: helloakka

### END INIT INFO

USERNAME=who??

COMMAND_HELLOAKKA="/home/$USERNAME/helloakka/run"

case "$1" in

  start)

    echo "Starting helloakka Script.."

    sudo -u $USERNAME $COMMAND_HELLOAKKA start

    echo "Done!!"

    ;;

  stop)

    echo "Stopping helloakka Script.."

    sudo -u $USERNAME $COMMAND_HELLOAKKA stop

    echo "Done!!"

    ;;

  *)

    echo "Usage: /etc/init.d/helloakka{start|stop}"

    exit 1

    ;;

esac

exit 0

권한설정 

* sudo chmod 755 helloakka  (누구든지 실행하도록 권한)

* update-rc.d 로 부팅되면 시작하기 업데이트해줌 ( sudo update-rc.d helloakka defaults) 

우아하게 시작,종료 처리하기

1. apache daemon 의존성 추가 

libraryDependencies += "commons-daemon" % "commons-daemon" % "1.0.15"

2. daemon 구현  (우아하게 종료하기 구현) 

trait ApplicationLifecycle {
  def start(): Unit
  def stop(): Unit
}

abstract class AbstractApplicationDaemon extends Daemon {
  def application: ApplicationLifecycle  // 추상메소드
  def init(daemonContext: DaemonContext) {}
  def start() = application.start()
  def stop() = application.stop()
  def destroy() = application.stop()
}

class ApplicationDaemon() extends AbstractApplicationDaemon {
  def application = new HelloAkkaApplication
}

class HelloAkkaApplication() extends ApplicationLifecycle with LazyLogging  {
  private[this] var started: Boolean = false
  private val applicationName = "hellokernel"

  val actorSystem = ActorSystem(applicationName)
  val actor = actorSystem.actorOf(Props[HelloWorld])
  val config = actorSystem.settings.config
  val timer = config.getInt("helloWorld.timer")

  def start() {
    logger.info(s"Starting $applicationName Service")
    if (!started) {
      started = true
      actorSystem.actorOf(Props(
        new HelloWorldCaller(
          timer millis,
          actor)))
    }
  }

  def stop() {
    logger.info(s"Stopping $applicationName Service")
    if (started) {
      started = false
      actorSystem.shutdown()
    }
  }
}

object maintest extends App {
  val application = createApplication()
  def createApplication() = new ApplicationDaemon
  private[this] var cleanupAlreadyRun: Boolean = false

  def cleanup(){
    val previouslyRun = cleanupAlreadyRun
    cleanupAlreadyRun = true
    if (!previouslyRun) application.stop()
  }

  Runtime.getRuntime.addShutdownHook(new Thread(new Runnable {
    def run() {
      cleanup()
    }
  }))

  application.start()
}

-  보통 아파치 데몬은 JSVC 를 사용하여 시작하고 종료합니다. 하지만 JSVC 를 사용하지 않고 실행 시켰을 경우는 셧다운 후크를 이용해서 종료됩니다. 

JVM은 다음과 같은 상황인 경우 셧다운 이벤트를 발생시킨다.

• 정상적으로 종료될 때. 예) 마지막 논데몬 쓰레드가 종료되었거나 System.exit()가 호출될 때.
• JVM이 강제적으로 종료될 때. 예) 시스템 셧다운, 사용자 로그아웃, Ctrl+C 누름

---

참고:

http://flurdy.com/docs/scalainit/startscala.html