package netty.test;

import org.jboss.netty.buffer.ChannelBuffer;
import org.jboss.netty.buffer.ChannelBuffers;
import org.jboss.netty.channel.Channel;
import org.jboss.netty.channel.ChannelFuture;
import org.jboss.netty.channel.ChannelHandlerContext;
import org.jboss.netty.channel.ExceptionEvent;
import org.jboss.netty.channel.MessageEvent;
import org.jboss.netty.channel.SimpleChannelHandler;

public class SimpleServerHandler extends SimpleChannelHandler
{
 
  @Override
  public void messageReceived(ChannelHandlerContext ctx,MessageEvent e)
  {
    ChannelBuffer request  =   (ChannelBuffer)e.getMessage();
    byte[] message    =   request.array();
  
    System.out.println("message:"+new String(message));
    //request 메시지 찍어보기
    if(new String(message).equals("1234a"))
    {
      ChannelBuffer response =   ChannelBuffers.dynamicBuffer();
      response.writeBytes("server write test".getBytes());
      ChannelFuture future =   e.getChannel().write(response);
    }
  }
 
  public void exceptionCaught(ChannelHandlerContext ctx,ExceptionEvent e)
  {
    e.getCause().printStackTrace();
    Channel ch     =   e.getChannel();
    ch.close();
  }
}

package netty.test;

import java.net.InetSocketAddress;
import java.util.concurrent.Executors;
import org.jboss.netty.bootstrap.ServerBootstrap;
import org.jboss.netty.channel.ChannelFactory;
import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelPipelineFactory;
import org.jboss.netty.channel.Channels;
import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;

public class SimpleServer
{
  /**
  * @param args
  */
  public static void main(String[] args)
  {
    // TODO Auto-generated method stub
    ChannelFactory factory   =   new NioServerSocketChannelFactory(
                                      Executors.newCachedThreadPool(),
                                      Executors.newCachedThreadPool()
                                  );
    //socket 을 nio 를 이용한 channel pool 로 관리 한다.
    
    ServerBootstrap bootstrap   =   new ServerBootstrap(factory);
    bootstrap.setPipelineFactory(new ChannelPipelineFactory()
    {
      @Override
      public ChannelPipeline getPipeline() throws Exception
      {
        // TODO Auto-generated method stub
        return Channels.pipeline(new SimpleServerHandler());
      }
    });
    
    bootstrap.setOption("child.tcpNoDelay", true);
    bootstrap.setOption("child.keepAlive", true);
    bootstrap.bind(new InetSocketAddress(8000));
    //열릴 port 가 8000 이라는 뜻입니다.
    //서버일 경우 bind 를 쓰고 클라이언트일 경우 connect 로 메소드를 쓴다.
  }
}