Versions Compared

Old Version 4

changes.mady.by.user PSMON

Saved on

compared with

New Version Current

changes.mady.by.user PSMON

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

콘솔 APP 프로젝트 생성


실습은 콘솔 APP로 진행예정입니다.

SeviceA로 생성 ( 실습에서 ServiceB,C,D 등 여러가지 테스트 서비스 생성예정 )

Image Added


LIB 설치 

ServiceA  프로젝트에 nuget을 이용하여 라이브러리를 설정합니다.

Akka - Akka.Remote - Akka.Cluster

필요한것만 설치가능하지만, Cluster는 Remote와 Akka 기반 패키지를 모두 포함함으로

Cluster를 설치합니다.

nuget을 통한 라이브러리 설치: 

Image Added


패키지 관리자를 통한 설치

Code Block
PM> install-package Akka
PM> install-package Akka.Remote
PM> install-package Akka.Cluster


AkkaSystem을 사용하기 위한 최초 코드작성

Code Block
languagec#
themeDJango
titleProgram.cs
linenumberstrue
using System;
using Akka.Actor;

namespace ServiceA
{
    class Program
    {
        static void Main(string[] args)
        {
            ConsoleKeyInfo cki;

App.config ( .net의 어플리케이션 설정과 호환가능:  특이한 형태의 설정으로  JAVA와 설정방식호환  )

Code Block
linenumberstrue
<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <section name="akka" type="Akka.Configuration.Hocon.AkkaConfigurationSection, Akka" />
  </configSections>
    <startup> 
        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2" />
    </startup>
  <akka>    Console.CancelKeyPress += new ConsoleCancelEventHandler(myHandler);
            using (ActorSystem system = ActorSystem.Create("ServiceA"))
            {
    <hocon>
         <![CDATA[   //Actor의 시스템 준비 완료

              akka {  while (true)
            actor    {
             
       // 메인 어플리케이션 종료방지를 위한코드 (  provider = "Akka.Remote.RemoteActorRefProvider, Akka.Remote"
ctrl+x 종료 )
                    cki deployment {
= Console.ReadKey(true);
                     /some-group {
if (cki.Key == ConsoleKey.X) break;
                }
          router = broadcast-group}
        }

        protected static void myHandler(object sender, ConsoleCancelEventArgs args)
    routees.paths   = [{
            args.Cancel = true;
        }
    }
}


App.config

.net의 어플리케이션 설정과 호환가능:  특이한 형태의 설정으로  JAVA/AKKA 와 설정컨셉 동일  

Panel
<?xml version="1.0" encoding="utf-8" ?>
<configuration>"akka.tcp://ServiceB@127.0.0.1:8002/user/b1",
    <configSections>
      <section name="akka" type="Akka.Configuration.Hocon.AkkaConfigurationSection, Akka" />
    </configSections>
    <startup> 
        <supportedRuntime version="akka.tcp://ServiceB@127.0.0.1:8002/user/b2", v4.0" sku=".NETFramework,Version=v4.5.2" />
    </startup>
    <akka>
      <hocon>
        <![CDATA[     
            "akka.tcp://ServiceB@127.0.0.1:8002/user/b3"]
akka {
              actor {          }  
                provider = "Akka.Remote.RemoteActorRefProvider, Akka.Remote"
              }
               }
            
              remote {
                log-remote-lifecycle-events = DEBUG
                log-received-messages = on
               
                helios.tcp {
                    port = 8001 #bound to a specific port
                    hostname = 127.0.0.1
                }
              }           
  
          }         
 
       ]]>
      </hocon>
    </akka>
</configuration>

기본적인 설정 방법이며

서비스포트 (8001) , 라우터 정의및 로그등 기본적인 설정 방법입니다.

확장된 설정법(클러스터구성) 은 실습코드에서 다시 정리예정

...



var config = ConfigurationFactory.ParseString(@" akka.remote.dot-netty.tcp { transport-class = ""Akka.Remote.Transport.DotNetty.DotNettyTransport,
 Akka.Remote"" transport-protocol = tcp port = 8091 hostname = ""127.0.0.1"" }");

var system = ActorSystem.Create("MyActorSystem", config);

설정은 파일로 분리되는게 좋지만, 위와같은 형식으로 설정적용도 가능합니다.

실행확인

Image Added

로그의 의미:

자신이 설정한 포트(ex:8001)가  표시되면 정상이다.

 listens on a address : akka.tcp://ServiceA@127.0.0.1:8001 

( 차기버젼에서 JsonSerialzier가 Hyperion으로 기본 변경예정이니, 바꿀수있으면 바꾸란의미이며  -NewtonSoft에서 다른버젼의 JSON 라이브러리 충돌시 변경가능   )


Tip
titleAKKA 최초설정 소스

http://git.webnori.com/projects/AKKA/repos/akkastudy/browse?at=refs%2Fheads%2Ffeature%2Fakkafirst