sultudy / waterfall

message stream system
3 stars 0 forks source link

Feature/3 #5

Closed xgate closed 8 years ago

xgate commented 8 years ago

actor기반으로 N개 스트림을 처리하도록 구현. 기본 제공되는 서버를 계속 사용했습니다. (갈아치우고 싶지만 연습겸 ^^)

djkim005 commented 8 years ago

(먼저, akka 기반의 코드를 처음봐서, 아~~ 이런식으로 돌아가는 구나~ 라고 보게 해 주어서 감사감사~~ :+1: )

2가지 관점에서 화두를 던져봅니다~

  1. 기 언급한 akka stream 은 적합할지 모르겠으나, stream 서비스에서 현재의 akka 구조는 좀 불필요해 보입니다. 실제 클라이언트 쓰레드 30개를 돌려보면 알겠지만, 쓰레드가 24개 정도가 동시 실행하고 나머지는 wait 함. 쓰레드 갯수를 조정할 수 있겠지만, 여기서 생각해보면, 간단간단하게 처리해야하는 actor 구조에 적합해 보이지 이런 stream 서비스에서는 굳이... 라는 생각이 듦
  2. 코드를 보고나서 든 생각인데, 지난번 술먹을때 한 얘기... akka 를 사용하면 oop 적으로 프로그래밍할 필요가 없다? (다형성을 쓸 필요가 없다?) 관점에서,,, 여기서도 다형성을 필요로 하는 코드가 나올수 있다~ 예를 들어, StreamServer의 sendChunkedMessages 에서 하는 일 중, read 하는 부분이 여러개로 구현한다면~? file에서 읽을 수도 있고, db 또는 지난 번에 얘기한 kafka 에서 읽을 수도 있다는 것이지~ 그렇다면, 어떻게 클래스를 만들것인가? 다른 기능은 모두 같은데~^^

함 생각해보자는 차원에서~~^^