멀티 캐스트와 관련하여 질문 있습니다.

[penny]

네티 3.1.0 베타 버전을 살펴보니 UDP 및 멀티캐스트를 지원한다고 해서 이번 프로젝트에 적용할 수 있는지 살펴보고 있는 중
입니다. 그런데, 하다가 막히는 부분들이 있어 이렇게 질문을 올리게 되었습니다.

1. 다른 시스템으로 부터 전송되는 데이터는 UDP 기반의 브로드 캐스트이고, 제가 이를 받아서 처리한 후, 또 다른 시스템으
로 전송할 때에는 UDP 기반의 멀티캐스트 입니다.
이 때, 작성되는 핸들러의 messageReceived() 내에서 다음과 같이 작성해도 되는지 궁금합니다.

// 데이터 처리 (UDP 브로드캐스트 방식으로 받은 데이터)
ChannelBuffer buffer = (ChannelBuffer) e.getMessage();
ChannelBufferInputStream is = new ChannelBufferInputStream(buffer);

// 비즈니스 로직 수행
...

// 전송 (멀티캐스트 주소로 전송)
e.getChannel().write(buffer, new InetSocketAddress("239.0.0.3",
20002));

실행은 되는 것 같은데 이렇게 해도 되는 것인지요.
아, 그리고 QOTM 예를 보면 서버 측에서 오류가 발생했을 때 exceptionCaught() 내에서 주석으로 계속 서비스 해
야 하므로 커넥션을 닫지 않는다라고 되어 있는데, 네티를 사용한 UDP 기반의 프로그래밍에도 모두 적용되는 내용인지 궁금합니
다.

2. 예제를 흉내내가면서 멀티캐스트 기반의 클래스를 작성해 보려고 API를 살펴보니,
DatagramChannel의 joinGroup 메소드가 멀티캐스트와 연관이 있는 것 같아 아래처럼 작성해보았습니다.

channel.joinGroup(InetAddress.getByName("239.0.0.3")); // 바로 이 부분

그러고 난 후에 실행시키면 무엇이 문제인 것인지 아래와 같은 예외가 나더군요.

Exception in thread "main" org.jboss.netty.channel.ChannelException:
java.net.SocketException: error setting options
at org.jboss.netty.channel.socket.oio.OioDatagramChannel.joinGroup
(OioDatagramChannel.java:119)
at example.qotm.QuoteOfTheMomentClient.main
(QuoteOfTheMomentClient.java:34)
Caused by: java.net.SocketException: error setting options
at java.net.PlainDatagramSocketImpl.join(Native Method)
at java.net.PlainDatagramSocketImpl.join(PlainDatagramSocketImpl.java:
172)
at java.net.MulticastSocket.joinGroup(MulticastSocket.java:276)
at org.jboss.netty.channel.socket.oio.OioDatagramChannel.joinGroup
(OioDatagramChannel.java:117)
... 1 more

살펴보면 멀티캐스트 기반 소켓 옵션을 설정하다 나는 것 같은데 정확한 이유를 모르겠더군요.
네티 소스 코드를 열어봤는데 자바 MulticastSock을 설정하는 것 이외에는 아무 것도 없어 보이는데, 왜 이런 예외가 나
는걸까요?
제가 API를 잘못 이해해서 잘못 작성한 것인지, 아니면 멀티 캐스트를 사용하기 위해서 또 다른 별도의 작업을 해주어야 하는건가
요?

[Trustin Lee]

안녕하세요 페니님,

On 4월22일, 오후6시12분, penny <keuns...@gmail.com> wrote:
> 네티 3.1.0 베타 버전을 살펴보니 UDP 및 멀티캐스트를 지원한다고 해서 이번 프로젝트에 적용할 수 있는지 살펴보고 있는 중
> 입니다. 그런데, 하다가 막히는 부분들이 있어 이렇게 질문을 올리게 되었습니다.
>
> 1. 다른 시스템으로 부터 전송되는 데이터는 UDP 기반의 브로드 캐스트이고, 제가 이를 받아서 처리한 후, 또 다른 시스템으
> 로 전송할 때에는 UDP 기반의 멀티캐스트 입니다.
> 이 때, 작성되는 핸들러의 messageReceived() 내에서 다음과 같이 작성해도 되는지 궁금합니다.
>
> // 데이터 처리 (UDP 브로드캐스트 방식으로 받은 데이터)
> ChannelBuffer buffer = (ChannelBuffer) e.getMessage();
> ChannelBufferInputStream is = new ChannelBufferInputStream(buffer);
>
> // 비즈니스 로직 수행
> ...
>
> // 전송 (멀티캐스트 주소로 전송)
> e.getChannel().write(buffer, new InetSocketAddress("239.0.0.3",
> 20002));
>
> 실행은 되는 것 같은데 이렇게 해도 되는 것인지요.

네, 그렇게 하시면 됩니다.

> 아, 그리고 QOTM 예를 보면 서버 측에서 오류가 발생했을 때 exceptionCaught() 내에서 주석으로 계속 서비스 해
> 야 하므로 커넥션을 닫지 않는다라고 되어 있는데, 네티를 사용한 UDP 기반의 프로그래밍에도 모두 적용되는 내용인지 궁금합니
> 다.

네, 서버의 경우 소켓 하나로 여러 원격지에서 한 포트로 들어오는 패킷을 모두 처리하므로 예외가 발생했다고 해서 소켓을 닫으면
서버를 종료시키는 효과를 가지므로 예외가 나도 채널을 닫지 않아야 합니다. 다만 커넥트된 DatagramChannel의 경우에
는 하나의 원격지에서 하나의 포트로 들어오는 패킷만 처리하므로 닫아도 무방할 듯 하네요.

> 2. 예제를 흉내내가면서 멀티캐스트 기반의 클래스를 작성해 보려고 API를 살펴보니,
> DatagramChannel의 joinGroup 메소드가 멀티캐스트와 연관이 있는 것 같아 아래처럼 작성해보았습니다.
>
> channel.joinGroup(InetAddress.getByName("239.0.0.3")); // 바로 이 부분

제대로 하셨습니다.

> 그러고 난 후에 실행시키면 무엇이 문제인 것인지 아래와 같은 예외가 나더군요.
>
> Exception in thread "main" org.jboss.netty.channel.ChannelException:
> java.net.SocketException: error setting options
> at org.jboss.netty.channel.socket.oio.OioDatagramChannel.joinGroup
> (OioDatagramChannel.java:119)
> at example.qotm.QuoteOfTheMomentClient.main
> (QuoteOfTheMomentClient.java:34)
> Caused by: java.net.SocketException: error setting options
> at java.net.PlainDatagramSocketImpl.join(Native Method)
> at java.net.PlainDatagramSocketImpl.join(PlainDatagramSocketImpl.java:
> 172)
> at java.net.MulticastSocket.joinGroup(MulticastSocket.java:276)
> at org.jboss.netty.channel.socket.oio.OioDatagramChannel.joinGroup
> (OioDatagramChannel.java:117)
> ... 1 more
>
> 살펴보면 멀티캐스트 기반 소켓 옵션을 설정하다 나는 것 같은데 정확한 이유를 모르겠더군요.
> 네티 소스 코드를 열어봤는데 자바 MulticastSock을 설정하는 것 이외에는 아무 것도 없어 보이는데, 왜 이런 예외가 나
> 는걸까요?
> 제가 API를 잘못 이해해서 잘못 작성한 것인지, 아니면 멀티 캐스트를 사용하기 위해서 또 다른 별도의 작업을 해주어야 하는건가
> 요?

제 생각에는 운영체제 관련 이슈가 아닐까 하는데요. 제 리눅스 데스크탑에서 해 보니 잘 되는 것 같아서요. 한 번
MulticastSocket 을 직접 사용해서 joinGroup 해서 잘 되는지 확인해 주시겠어요? 그래도 되지 않는다면 운영
체제 설정에 문제가 있을 것 같습니다. 그럼 꼭 한 번 해 보시고 회신 주시면 감사하겠습니다. 곧 RC 들어가는데 멀티캐스
트 부분은 테스트하기가 어려워서요 ^^*

이희승 드림

[penny]

빠른 답변 정말 감사드립니다.

그런데, 답변하신 내용 중에서요...

> 네, 서버의 경우 소켓 하나로 여러 원격지에서 한 포트로 들어오는 패킷을 모두 처리하므로 예외가 발생했다고 해서 소켓을 닫으면
> 서버를 종료시키는 효과를 가지므로 예외가 나도 채널을 닫지 않아야 합니다.

라고 말씀하신 부분이 있는데, 한 원격지에서 멀티 캐스트로 뿌리거나 한 원격지에서 브로드캐스트로 뿌리는 경우에 해당되는 내용인
것이지요? 제가 하는 부분 중에 원격지로부터 멀티캐스트로 받아서 멀티캐스트로 뿌려야 하는 부분도 있거든요..

> 다만 커넥트된 DatagramChannel의 경우에는 하나의 원격지에서 하나의 포트로 들어오는 패킷만 처리하므로 닫아도 무방할 듯 하네요.

여기에서 커넥트된 DatagramChannel이라는 것은 UDP 기반의 Point to Point를 의미하시는 것인가요?

> 한 번 MulticastSocket 을 직접 사용해서 joinGroup 해서 잘 되는지 확인해 주시겠어요?

MulticastSocket을 직접 사용해서 joinGroup 하고 실행 시키면 잘 되네요;;;
참고로 제 운영체제는 윈도우 XP이고 SP 3 깔린 상태입니다.

귀찮게 해드려서 죄송합니다;;;

[Trustin Lee]

On 4월22일, 오후7시14분, penny <keuns...@gmail.com> wrote:
> 빠른 답변 정말 감사드립니다.
>
> 그런데, 답변하신 내용 중에서요...
>
> > 네, 서버의 경우 소켓 하나로 여러 원격지에서 한 포트로 들어오는 패킷을 모두 처리하므로 예외가 발생했다고 해서 소켓을 닫으면
> > 서버를 종료시키는 효과를 가지므로 예외가 나도 채널을 닫지 않아야 합니다.
>
> 라고 말씀하신 부분이 있는데, 한 원격지에서 멀티 캐스트로 뿌리거나 한 원격지에서 브로드캐스트로 뿌리는 경우에 해당되는 내용인
> 것이지요? 제가 하는 부분 중에 원격지로부터 멀티캐스트로 받아서 멀티캐스트로 뿌려야 하는 부분도 있거든요..

브로드캐스트를 받든 멀티캐스트를 받든 임의의 원격지로부터 받는 모든 경우를 이야기한 거에요^^

> > 다만 커넥트된 DatagramChannel의 경우에는 하나의 원격지에서 하나의 포트로 들어오는 패킷만 처리하므로 닫아도 무방할 듯 하네요.
>
> 여기에서 커넥트된 DatagramChannel이라는 것은 UDP 기반의 Point to Point를 의미하시는 것인가요?

넵

> > 한 번 MulticastSocket 을 직접 사용해서 joinGroup 해서 잘 되는지 확인해 주시겠어요?
>
> MulticastSocket을 직접 사용해서 joinGroup 하고 실행 시키면 잘 되네요;;;
> 참고로 제 운영체제는 윈도우 XP이고 SP 3 깔린 상태입니다.

혹시.. QOTM 예제에서 setBroadcast(false/true) 라인과 관련이 있을지 모르겠다는 생각이.. 한 번 해당
라인을 지우고 해 보면 어떻게 될까요?

> 귀찮게 해드려서 죄송합니다;;;

아닙니다. 제가 더 귀찮게 해 드리는 것 같네요. 문제를 후딱 해결하고 싶어서요 ^^

[Trustin Lee]

아.. 그리고 가능하다면 MulticastSocket 직접 사용해서 작성하신 코드를 회신에 넣어 주시면 동작을 비교해볼 수 있
을 것 같습니다. 부탁드리겠습니다.

[penny]

setBroadcast(false/true) 부분을 제외 했는데도 똑같은 오류가 발생하네요;;

다음은 간단하게 작성했던 코드입니다.

MulticastSocket을 사용한 코드

public class TsdUserListener1 {

public static void main(String[] args) throws Exception {
int port = 20002;
String group = "239.0.0.3";

MulticastSocket s = new MulticastSocket(port);
s.joinGroup(InetAddress.getByName(group));
byte buf[] = new byte[18];
DatagramPacket pack = new DatagramPacket(buf, buf.length);
s.receive(pack);

System.out.println("Received data from: " + pack.getAddress
().toString() +
": " + pack.getPort() + " with length: " +
pack.getLength());
System.out.write(pack.getData(), 0, pack.getLength());
System.out.println();
}
}

Netty를 사용한 경우

@ChannelPipelineCoverage("all")
public class TsdUserListener1 extends SimpleChannelHandler {

private static final String host = "239.0.0.3";
private static final int port = 20002;

@Override
public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent
e)
throws Exception {

e.getCause().printStackTrace();
e.getChannel().close();
}

@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent
e)
throws Exception {

ChannelBuffer buffer = (ChannelBuffer) e.getMessage();
ChannelBufferInputStream is = new ChannelBufferInputStream(buffer);

User user = new User();
user.setId(is.readInt());
user.setFirstName(buffer.toString(4, 4, "US-ASCII"));
user.setLastName(buffer.toString(8, 6, "US-ASCII"));
user.setHeight(is.readFloat());

System.out.println(user);
}

public static void main(String[] args) throws Exception {
DatagramChannelFactory factory = new OioDatagramChannelFactory(
Executors.newCachedThreadPool());

ChannelPipeline pipeline = Channels.pipeline();
pipeline.addLast("handler", new TsdUserListener1());

DatagramChannel channel = factory.newChannel(pipeline);
channel.joinGroup(InetAddress.getByName(host));

ChannelFuture future = channel.bind(new InetSocketAddress(port));
future.awaitUninterruptibly();
}

}

Netty 기반 실행 시 발생하는 예외 stack trace

Exception in thread "main" org.jboss.netty.channel.ChannelException:
java.net.SocketException: error setting options
at org.jboss.netty.channel.socket.oio.OioDatagramChannel.joinGroup
(OioDatagramChannel.java:119)

at example.kntds.TsdUserListener1.main(TsdUserListener1.java:80)

Caused by: java.net.SocketException: error setting options
at java.net.PlainDatagramSocketImpl.join(Native Method)
at java.net.PlainDatagramSocketImpl.join(PlainDatagramSocketImpl.java:
172)

at java.net.MulticastSocket.joinGroup(MulticastSocket.java:276)나는 상황
도.... 대기 중....

at org.jboss.netty.channel.socket.oio.OioDatagramChannel.joinGroup
(OioDatagramChannel.java:117)
... 1 more

at example.kntds.TsdUserListener1.main(TsdUserListener1.java:80) 여기가 가리
키는 라인이
channel.joinGroup(InetAddress.getByName(host)); 이 부분이예요;;

[Trustin Lee]

MulticastSocket 을 사용한 코드에서 아래 부분을:

MulticastSocket s = new MulticastSocket(port);

다음과 같이 바꾸면 어떻게 되는지 궁금합니다:

MulticastSocket s = new MulticastSocket(null);
s.bind(new InetSocketAddress(port));

또 이렇게도 바꾸면 어떻게 되는지도 궁금합니다:

MulticastSocket s= new MulticastSocket(new InetSocketAddress(port));

잘 부탁합니다 ^^

[Trustin Lee]

지금 보니 MulticastSocket 을 사용한 코드는 생성자에서 bind를 먼저 하고 joinGroup 을 하는 반면
Netty 를 사용한 코드는 joinGroup 을 먼저 하고 그 다음에 bind 를 한다는 차이가 있네요. Netty 를 사용
한 코드에서 bind 를 먼저 한 뒤에 joinGroup 해 보면 어떨까요?

[penny]

On 4월22일, 오후8시04분, Trustin Lee <trus...@gmail.com> wrote:
> MulticastSocket 을 사용한 코드에서 아래 부분을:
>
> MulticastSocket s = new MulticastSocket(port);
>
> 다음과 같이 바꾸면 어떻게 되는지 궁금합니다:
>
> MulticastSocket s = new MulticastSocket(null);
> s.bind(new InetSocketAddress(port));

정상적으로 실행되었습니다.

> 또 이렇게도 바꾸면 어떻게 되는지도 궁금합니다:
>
> MulticastSocket s= new MulticastSocket(new InetSocketAddress(port));
>
> 잘 부탁합니다 ^^

이 경우 마찬가지로 정상적으로 실행되었어요;;

[Trustin Lee]

바꿔 말하면 MulticastSocket 에서 new MulticastSocket(null) 로 바인드 안된 소켓을 만든뒤
joinGroup 후 bind 해서 동일 에러가 발생하는 지 확인하고 싶습니다 ^^;

[penny]

> 지금 보니 MulticastSocket 을 사용한 코드는 생성자에서 bind를 먼저 하고 joinGroup 을 하는 반면
> Netty 를 사용한 코드는 joinGroup 을 먼저 하고 그 다음에 bind 를 한다는 차이가 있네요. Netty 를 사용
> 한 코드에서 bind 를 먼저 한 뒤에 joinGroup 해 보면 어떨까요?

아... 그렇게 하니까 되었어요.
그런 순서의 차이가 있으리라고는 정말 상상도 못했는데, 왜 그걸 못 본 것인지;;;
정말 감사합니다..^^

마지막으로 딱 하나의 질문과 네티에게 바라는 점 하나만 적을께요^^

ChannelBuffer는 보니깐 이전 자바의 ByteBuffer나, 미나의 ByteBuffer에서처럼 putString이나
putInt 같은것이 없고, 대신 ChannelBufferOutputStream이나 ChannelBufferInputStream
을 사용해서 String 타입이나 float 타입을 접근하는 것 같은데, 이렇게 접근하는 방식이 맞는건가요?

음.. 네티에 바라는 점은 멀티캐스트 예제, 스프링과의 통합에 대한 구체적인 예제하고 POJO를 다룰 때 일반적인 자바 타입들
이 어떻게 다루어져 있는지에 대해 약간 보강되어졌으면 하는거예요^^

성실하게 답변해 주셔서 대단히 감사합니다.^^
나중에 기회 되면 멀티 캐스트 예제 간단하게나마 구성해서 올려보도록 할께요^^

[penny]

On 4월22일, 오후8시19분, Trustin Lee <trus...@gmail.com> wrote:
> 바꿔 말하면 MulticastSocket 에서 new MulticastSocket(null) 로 바인드 안된 소켓을 만든뒤
> joinGroup 후 bind 해서 동일 에러가 발생하는 지 확인하고 싶습니다 ^^;
>

한 가지 빼 먹었네요...
자바의 MulticastSocket에서도 다음과 같이 하니까 똑같이 옵션 설정에서 오류가 나네요.

바인딩 후에 joinGroup을 하면 오류가 안 났지만...

MulticastSocket s = new MulticastSocket(null);
s.bind(new InetSocketAddress(port));

s.joinGroup(InetAddress.getByName(group));

바인딩 전에 joinGroup을 수행하니 오류가 나네요.

MulticastSocket s = new MulticastSocket(null);

s.joinGroup(InetAddress.getByName(group));
s.bind(new InetSocketAddress(port));

[Trustin Lee]

On Apr 22, 8:29 pm, penny <keuns...@gmail.com> wrote:
> > 지금 보니 MulticastSocket 을 사용한 코드는 생성자에서 bind를 먼저 하고 joinGroup 을 하는 반면
> > Netty 를 사용한 코드는 joinGroup 을 먼저 하고 그 다음에 bind 를 한다는 차이가 있네요. Netty 를 사용
> > 한 코드에서 bind 를 먼저 한 뒤에 joinGroup 해 보면 어떨까요?
>
> 아... 그렇게 하니까 되었어요.
> 그런 순서의 차이가 있으리라고는 정말 상상도 못했는데, 왜 그걸 못 본 것인지;;;
> 정말 감사합니다..^^

그러게 말이에요. 그런데 VMware 에서 Windows Vista 로 테스트해 보면 순서에 관계 없이 잘 되는 것 같아
요. 운영체제마다 조금씩 차이가 있는 것 같네요.

> 마지막으로 딱 하나의 질문과 네티에게 바라는 점 하나만 적을께요^^
>
> ChannelBuffer는 보니깐 이전 자바의 ByteBuffer나, 미나의 ByteBuffer에서처럼 putString이나
> putInt 같은것이 없고, 대신 ChannelBufferOutputStream이나 ChannelBufferInputStream
> 을 사용해서 String 타입이나 float 타입을 접근하는 것 같은데, 이렇게 접근하는 방식이 맞는건가요?

ChannelBuffers.copiedBuffer(String str, String encoding) 메소드를 이용하면 버퍼로
변환이 되고, 그 버퍼를 인수로 주고 writeBytes() 하시면 됩니다:

buf.writeBytes(ChannelBuffers.copiedBuffer("안녕하세요", "UTF-8"));

> 음.. 네티에 바라는 점은 멀티캐스트 예제, 스프링과의 통합에 대한 구체적인 예제하고 POJO를 다룰 때 일반적인 자바 타입들
> 이 어떻게 다루어져 있는지에 대해 약간 보강되어졌으면 하는거예요^^

말씀해 주신 부분에 대해서는 지속적인 문서화로 해결해야 겠네요. 관련해서 블로그 포스팅 하시면 좋을 것 같기도 합니다 ^^;

> 성실하게 답변해 주셔서 대단히 감사합니다.^^
> 나중에 기회 되면 멀티 캐스트 예제 간단하게나마 구성해서 올려보도록 할께요^^

저야말로 덕택에 한 가지 배우게 되었네요. 앞으로도 많은 문의 및 버그 보고 부탁드립니다^^

이희승 드림

[Trustin Lee]

2009/4/22 Trustin Lee <tru...@gmail.com>:

> On Apr 22, 8:29 pm, penny <keuns...@gmail.com> wrote:
>> ChannelBuffer는 보니깐 이전 자바의 ByteBuffer나, 미나의 ByteBuffer에서처럼 putString이나
>> putInt 같은것이 없고, 대신 ChannelBufferOutputStream이나 ChannelBufferInputStream
>> 을 사용해서 String 타입이나 float 타입을 접근하는 것 같은데, 이렇게 접근하는 방식이 맞는건가요?
>
> ChannelBuffers.copiedBuffer(String str, String encoding) 메소드를 이용하면 버퍼로
> 변환이 되고, 그 버퍼를 인수로 주고 writeBytes() 하시면 됩니다:
>
> buf.writeBytes(ChannelBuffers.copiedBuffer("안녕하세요", "UTF-8"));

답변이 하나 빠졌네요;

float 나 double 의 경우에는 Float.floatToIntBits() 나
Double.doubleToLongBits() 로 변환 후 writeInt 나 writeLong 을 사용하시면 되겠습니다.

이희승 드림