Tag Archives: 네트워크

[LINUX] iperf를 사용하여 매우 쉬운 리눅스에서 네트워크 트래픽 속도 분석하기

서버와 서버간의 파일전송을 하는데 이상하게 속도가 나지 않습니다. 두대의 서버가 모두 동일한 스위치에 그것도 기가비트 포트에 물려있는데 보장되어야 할 속도가 나오지 않는다 의심될때 가장 먼저 해봐야 할일은 실제 통신 속도를 측정하는 일일 것입니다.

정말 간단하게 테스트하고 싶다면 어떤 방법이 있을까요? 여기에 정말 좋은 솔루션이 있습니다. 그것도 무료네요.

http://sourceforge.net/projects/iperf/

iperf는 두대의 서버 사이에 한대는 서버, 한대는 클라이언트로 접속하여 속도를 측정합니다.
다음과 같이 설치를 하도록 합니다. 이 글을 쓰는 시점에서는 2.0.4가 최신버젼입니다만 적정한 최신 버젼을 사용하시면 됩니다.

[code bash]> tar -zxvf iperf-2.0.4.tar.gz
> cd iperf-2.0.4
> ./configure
> make; make install[/code]
이제 두대의 서버간의 속도를 측정해 보도록 하겠습니다.

* 서버 실행하기

[code]> iperf -s
————————————————————
Server listening on TCP port 5001
TCP window size: 85.3 KByte (default)
————————————————————[/code]
* 클라이언트 실행하기

[code]iperf -c 192.168.0.2
————————————————————
Client connecting to 192.168.0.2, TCP port 5001
TCP window size: 16.0 KByte (default)
————————————————————
[  3] local 192.168.0.3 port 55881 connected with 192.168.0.2 port 5001
[ ID] Interval       Transfer     Bandwidth
[  3]  0.0-10.0 sec  1.10 GBytes    942 Mbits/sec[/code]

위의 결과를 통해 두 서버간의 통신속도는 942 Mbit/sec 라는것을 알았습니다. 기가비트 포트의 속도가 거의 보장되고 있었네요^^

Apache MINA 2.0 에코서버 만들어 보기

사용자 삽입 이미지

제작년인가 JCO 컨퍼런스에서 이희승님의 발표 이후에 잊을 수 없던 프로젝트가 있었습니다.

바로 MINA(A Multi-purpose Infrastructure for Network Applications)인데요.

간단하게 말하면 자바의 네트워크 애플리케이션을 위한 프레임워크입니다.

필터를 사용한 뛰어난 확장성과 프로토콜 코덱과 비즈니스 로직을 분리하여 유지보수와 재사용성을 높인것이 특징입니다.

더군다나 커미터가 이희승님이라는 것이 중요한 점입니다. 한글로 질문해도 답변해 주시겠죠? -_-a

간단하게 예제 프로그램을 따라 만들어 보았습니다. [이곳]을 참고하였습니다.

현재 MINA2가 M3까지 나왔더군요. 예제를 위해서는 MINA코어뿐만 아니라 SLF4JLog4J가 필요합니다.

SLF4J의 경우에는 slf4j-api.jar파일과 slf4j-logj12.jar가 필요합니다. 13버젼용도 있지만 아직 알파버젼이니 12로 하기로 하였습니다.

그리고 log4j 1.2버젼의 jar로 세팅합니다.

MinaTimeServer
[code]import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;
 
import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
 
public class MinaTimeServer
{
    private static final int PORT = 9123;
 
    public static void main(String[] args) throws IOException
    {
        IoAcceptor acceptor = new NioSocketAcceptor();

        acceptor.getFilterChain().addLast( “logger”, new LoggingFilter() );
        acceptor.getFilterChain().addLast(“codec”, new ProtocolCodecFilter(
                                            new TextLineCodecFactory(Charset.forName(“UTF-8”))));
 
        acceptor.setHandler(new TimeServerHandler());
 
        acceptor.getSessionConfig().setReadBufferSize(2048);
        acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
 
        acceptor.bind(new InetSocketAddress(PORT));
    }
}[/code]
Non-Blocking IO로 만듭니다. FilterChain이라는것에 필터를 추가합니다.

addLast라는 것을 보니 내가 원하는 순서대로 필터를 등록할 수 있는 모양입니다.

위와 같이 로깅을 하거나 인코딩 코덱을 만들어 사용할 수 있습니다.

핸들러를 추가하고 버퍼와 유휴시간을 정의한 후에 PORT를 설정하여 Bind합니다.

TimeServerHandler
[code]import java.util.Date;
 
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
 
public class TimeServerHandler extends IoHandlerAdapter
{

    @Override
    public void exceptionCaught(IoSession session, Throwable cause)
        throws Exception
    {
        cause.printStackTrace();
    }

    @Override
    public void messageReceived(IoSession session, Object message)
        throws Exception
    {
        String str = message.toString();
 
        if(str.trim().equalsIgnoreCase(“quit”))
        {
            session.close(true);
            return;
        }
 
        Date date = new Date();
        session.write(date.toString() + “\r\n”);
        System.out.println(“Message written…”);
    }

    @Override
    public void sessionIdle(IoSession session, IdleStatus status)
        throws Exception
    {
        System.out.println(“IDLE ” + session.getIdleCount(status));
    }
}[/code]
이녀석이 실제로 통신에 사용되는 핸들러입니다. 메시지를 받을때 마다 messageReceived이 호출됩니다.

쓰레드 방식의 모델이라 보기 힘든 구조네요, 콜백형식으로 작동하는 것을 알 수 있습니다.

다음에는 객체를 Serial로 주고 받을 수 있는지 해봐야겠습니다.

sessionIdle은 Main에서 정의한 유휴시간마다 호출되는 녀석입니다. 10초로 설정해 두었으니 10초동안 유휴상태로 있다면 그때마다 이 메서드가 호출됩니다.

getIdleCount를 이용해 카운트도 알 수 있군요. 서버를 완성했으니 실행해 볼까요.

사용자 삽입 이미지


quit를 입력하면 종료되고 그 이외의 문자를 입력하면 시간이 출력되는 것을 알 수 있습니다.