네트웍 통신시 아래와 같은 에러가 발생합니다.
혹 이런 에러에 대해서 아시면 한수 가르침좀 부탁드립니다.
소스는 아래쪽에 써놓았습니다.

READ ERROR : null : sun.io.MalformedInputException
        at sun.io.ByteToCharDoubleByte.flush(ByteToCharDoubleByte.java:51)
        at java.io.InputStreamReader.flushInto(InputStreamReader.java:154)
        at java.io.InputStreamReader.fill(InputStreamReader.java:178)
        at java.io.InputStreamReader.read(InputStreamReader.java:249)
        at java.io.BufferedReader.fill(BufferedReader.java:139)
        at java.io.BufferedReader.readLine(BufferedReader.java:299)
        at java.io.BufferedReader.readLine(BufferedReader.java:363)
        at it21.acom_tcplib.RecvMsg_FromTcp(acom_tcplib.java:97)
        at incheon_segu_daily.Send_Message(incheon_segu_daily.java:273)
        at incheon_segu_daily.Get_Result(incheon_segu_daily.java:166)
        at incheon_segu_daily.service(incheon_segu_daily.java:142)
        at xecure.servlet.XecureHttpServlet.service(XecureHttpServlet.java:261)
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:274)
        at jeus.servlet.engine.ServletWrapper.execSingleThreadServlet(ServletWrapper.java:222)
        at jeus.servlet.engine.ServletWrapper.execServlet(ServletWrapper.java:236)
        at jeus.servlet.engine.ApacheRequestProcessor.run(ApacheRequestProcessor.java:85)

아래 소스 main에서 보면 args[0]는 1인 경우에는 위와 같은 에러가 발생하고
1이 아닌 경우에는 제대로 데이터를 받습니다.
물론 위의 에러를 일으킨 소스는 웹쪽에서 서비스 되는 건데
아래의 소스와 같은 라이브러리를 사용합니다.

왜인지 아무리 생각해도 모르겠네요..
두 소스의 차이점은 args[0]는 1인 경우는 BufferedReader를 사용했고
아닌경우는 DataInputStream을 사용했다는 차임점인데 잘 모르겠습니다.

참고로 통신서버는 SUN 솔라리스이고 서블릿 엔진은 JEUS를 사용했습니다.

import java.io.*;
import java.net.*;
import java.util.*;
import java.text.*;
import java.util.Date;

public class TcpNet {
	public static void main(String args[]){
		Socket sock = null;
		String url = "210.112.177.2";
		String port="8300";
		String sendMsg = send();
		String recvMsg = null;
		int len = sendMsg.length();
		long timelimit=10000 ;

		System.out.println("SEND=["+sendMsg+"]");
		if( args[0].equals("1") ) {
			try{ 
				sock = connect( url, port );
				send1( sock, sendMsg, len, timelimit );
				recvMsg = read1( sock, timelimit );
			}catch(Exception e){
				e.printStackTrace();
			}finally{
				close(sock);
			}
		} else {
			try{
				sock = connect( url, port );
				send2( sock, sendMsg, len, timelimit );
				recvMsg = read2( sock, timelimit );
			}catch(Exception e){
				e.printStackTrace();
			}finally{
				close(sock);
			}
		}
		System.out.println("RECV=["+recvMsg+"]");
		System.exit(0);
	}

	public static String send() {
		//지방세 조회 EFFV
		String sendMsg = "TEMP20020209Y                      000000000000000000000000 　　　　　                                          　　　　　             0000000000000                000000000000000000 　　　　　                                          　　　　　             0000000000000                000000000000000000 　　　　　                                          　　　　　             0000000000000                000000000000000000 　　　　　                                          　　　　　             0000000000000                000000000000000000 　　　　　                                          　　　　　             0000000000000                000000000000000000 　　　　　                                          　　　　　             0000000000000                000000000000000000　　　　　　　　　　　　　　　　　　　　　　　　";
		return sendMsg;
	}

	public static Socket connect(String url, String port) throws Exception {
		Socket client;
		//첫글자가 숫자면 ip 로처리
		if(Character.isDigit(url.charAt(0))) {
			client = new Socket(url, Integer.parseInt(port));
		}else{
       		InetAddress url_ = InetAddress.getByName(url);
       		client = new Socket(url_, Integer.parseInt(port));
		}
		return client;
	}

	public static void send1(Socket sock, String sendMsg, int len, long timelimit) {
		try {
		   sock.setTcpNoDelay(true);
           PrintWriter pw = new PrintWriter( new OutputStreamWriter( sock.getOutputStream() ), true );
           pw.print( sendMsg );
           pw.flush();
		} catch(Exception e) {
			close(sock);
			e.printStackTrace();
		}
	}

	public static void send2(Socket sock, String sendMsg, int len, long timelimit) {
		OutputStream pw = null;
		try {
			sock.setSoTimeout( (int)timelimit); 
			pw = sock.getOutputStream();
			byte[] b=sendMsg.getBytes();
			pw.write(b);
			pw.flush();
		}catch(Exception e){
			if(pw!=null){ try{ pw.close(); }catch(IOException ioe){} }
			close(sock);
			e.printStackTrace();
		}
	}

	public static String read1(Socket sock, long timelimit){
        String recvMsg = "";
		BufferedReader br=null;
		try {
			sock.setSoTimeout( (int)timelimit );   // 수신제한시간 설정 milli sec ( 1분 )
			br = new BufferedReader( new InputStreamReader( sock.getInputStream() ) );
            String line = null;
			int i = 0;
            while( ( line = br.readLine() ) != null ) {
              recvMsg += line;
            }
            br.close();
		} catch(Exception e) {
			close(sock);
			e.printStackTrace();
		}
	
		return recvMsg;
	}

	public static String read2(Socket sock, long timelimit){
        String recvMsg = "";
		DataInputStream in = null; 
		byte[] recvData = new byte[1024];

		try {
			sock.setSoTimeout( (int)timelimit); 	
			in = new DataInputStream(sock.getInputStream() );

			int i = 0, start_pos = 0;
			i = in.read( recvData );

			recvMsg = new String(recvData);

		}catch(Exception e){
			e.printStackTrace();
			return null;
		}finally{
			if(in!=null){ try{ in.close(); }catch(IOException ioe){} }
			if(sock!=null){ try{ sock.close(); }catch(IOException ioe){} }
		}
		return recvMsg;
	}

	public static void close(Socket client) {
		try {
			client.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

>
> {질문 sun.io.MalformedInputException에 대해서}
> {손님(guest), lsk7up@hanmail.net}
>
> 네트웍 통신시 아래와 같은 에러가 발생합니다.
> 혹 이런 에러에 대해서 아시면 한수 가르침좀 부탁드립니다.
> 소스는 아래쪽에 써놓았습니다.
> 
> READ ERROR : null : sun.io.MalformedInputException
>         at sun.io.ByteToCharDoubleByte.flush(ByteToCharDoubleByte.java:51)
>         at java.io.InputStreamReader.flushInto(InputStreamReader.java:154)
>         at java.io.InputStreamReader.fill(InputStreamReader.java:178)
>         at java.io.InputStreamReader.read(InputStreamReader.java:249)
>         at java.io.BufferedReader.fill(BufferedReader.java:139)
>         at java.io.BufferedReader.readLine(BufferedReader.java:299)
>         at java.io.BufferedReader.readLine(BufferedReader.java:363)
>         at it21.acom_tcplib.RecvMsg_FromTcp(acom_tcplib.java:97)
>         at incheon_segu_daily.Send_Message(incheon_segu_daily.java:273)
>         at incheon_segu_daily.Get_Result(incheon_segu_daily.java:166)
>         at incheon_segu_daily.service(incheon_segu_daily.java:142)
>         at xecure.servlet.XecureHttpServlet.service(XecureHttpServlet.java:261)
>         at javax.servlet.http.HttpServlet.service(HttpServlet.java:274)
>         at jeus.servlet.engine.ServletWrapper.execSingleThreadServlet(ServletWrapper.java:222)
>         at jeus.servlet.engine.ServletWrapper.execServlet(ServletWrapper.java:236)
>         at jeus.servlet.engine.ApacheRequestProcessor.run(ApacheRequestProcessor.java:85)
> 
> 아래 소스 main에서 보면 args[0]는 1인 경우에는 위와 같은 에러가 발생하고
> 1이 아닌 경우에는 제대로 데이터를 받습니다.
> 물론 위의 에러를 일으킨 소스는 웹쪽에서 서비스 되는 건데
> 아래의 소스와 같은 라이브러리를 사용합니다.
> 
> 왜인지 아무리 생각해도 모르겠네요..
> 두 소스의 차이점은 args[0]는 1인 경우는 BufferedReader를 사용했고
> 아닌경우는 DataInputStream을 사용했다는 차임점인데 잘 모르겠습니다.
> 

 MalformedInputException 을 구지 해석하자면 ...

 잘못된 형식의 입력으로 error 발생한 것입니다.

 문제의 원인은 Stream의 끝에서 에러가 발생한 듯 싶습니다.

 DataInputStream 을 사용했을 때에는 문제가 없고 BufferedReader 를 사용했을때
 
 문제가 발생하는것은..

 DataInputStream 는 한바이트씩 읽어서 처리하지만,

 BufferedReader 는 2바이트를 읽어 하나의 char로 변환합니다.
 
 위의 MalformedInputException 은 이 과정에서 발생한 듯 싶습니다.
 
 한 바이트를 읽고 난 다음에 다음 바이르틀 읽어 하나의 Char를 만들려다가 
 실패한 것이지요 ...

 제가 소스를 전체적으로 살펴본것은 아니지만, 

 네트웍 상에서는 데이터의 전송을 \r\n으로 구분지어서 전송합니다 ....

 전송되는 데이터의 끝에 \r\n을 추가하여 전송해 보세요 ...

 음냥... 

 그럼 수거하세요 ...

출처 : javasevice.net

     Network Server Application을 구현할 때 마다 느끼는 것이지만 맨날 반복되는 코드에
    지겹다는 생각을 많이 했다. 물론 초보자에게는 Thread, Socket, IO 관련 프로그램
    이 어렵게 느껴지겠고, 그리고, Thread Pool, Concurrency Issue등의 문제도 골치가 
    아플것이다. 아마도 이런 이유 때문에 application server를 쓰는지도 모르겠다. 하
    지만 application server에서는 Socket Connector는 제공하지 않는다.
     어째든 server application을 재활용하기 위한 차원에서 Socket Server Framework
    을 만들어 보았다. 요즘 프로젝트가 다 웹이라 이런 Socket server를 얼마나 많이 개발
    할지는 모르겠지만, 지금 참여하고 있는 프로젝트(EAI)에서는 중요한 부분으로 사용
    되고 있다. (2003.11.23 일요일)

 written by Jeon HongSeong [hsjeon70@dreamwiz.com]      

1. 개 요

 ◆ jNetServer1.0 개발 시 이용한 open source List

    - MX4J-1.1 : JMX1.0 Reference Implementation
    - Jakarta Log4J-1.2.8
    - Jakarta Common Digester-1.5
    - Jakarta Common Pooling-1.1
    - Jakarta Tomcat source 일부
	

 ◆ jNetServer Framework은 Java Network Server Programming에 대한 Basic 
    Infrastructure를 제공한다.
 ◆ Network Server Application을 구현할 때 필요한 Thread Pooling이나, Object 
    Pooling, Logger 등의 기능을 제공한다.
 ◆ API에 정의된 NetTask 내 클라이언트로부터 데이터를 read하고, 결과를 write하는
    로직만 간단히 구현하면 된다.
 ◆ Configuration 설정만으로 Network Server Connector, InputAdapter, Object 
    Pool이 생성 초기화 된다.
 ◆ 클라이언트 시스템(IP) 별로 접근 권한 및 통신 프로토콜을 다르게 정의할 수 
    있다.
 ◆ 모든 Java Object들이 JMX MBean object로 관리되고, MX4J에서 제공하는 JMX Http
    Admin 관리 콘솔을 제공한다.
 ◆ 관리 콘솔 상에서 서버 및 모든 MBean object를 제어 할 수 있다.
 ◆ JMX Monitor Bean을 이용해 Connector의 상태를 Counter, Gauge 방식으로 모니터
    링 할 수 있다.
 ◆ jNetServer Framework 내에서 configuration 설정 만으로 SSL(Secure Socket Layer)
    를 지원한다. SSL용 NetTask의 구현은 일반 Socket 일때와 동일하다.
 ◆ NetTask의 확장으로 프락시 서버, 로드 발런스 등의 서버를 쉽게 구현할 수 있다.
	

2. 설치 및 실행

 ◆ jNetServer1.0-app.jar 파일을 c:\jNetServer1.0 디렉토리 밑에 압축을 해제한다.
	
C:\jNetServer1.0>jar xvf jNetServer1.0-app.jar
C:\jNetServer1.0>dir
C 드라이브의 볼륨에는 이름이 없습니다.
볼륨 일련 번호: 3D26-12D4

C:\jNetServer1.0 디렉터리

2003-11-29  12:48a      <DIR>          .
2003-11-29  12:48a      <DIR>          ..
2003-11-29  12:48a                 637 runSsl.bat
2003-11-29  12:48a                 789 startup.bat
2003-11-29  12:48a                  18 lcp.bat
2003-11-29  12:48a                 705 runMulti.bat
2003-11-29  12:48a                 720 stop.bat
2003-11-29  12:48a                 645 runEcho.bat
2003-11-29  12:48a      <DIR>          logs
2003-11-29  12:48a      <DIR>          docs
2003-11-29  12:48a      <DIR>          server
2003-11-29  12:48a      <DIR>          common
2003-11-29  12:48a      <DIR>          config
              6개 파일           3,514 바이트
              7 디렉터리   2,378,612,736 바이트 남음
 
 ◆ jNetServer1.0/config/server.xml에 Server 태그의 address 속성을 설치 시스템의 
    IP 주소로 변경한다.	

   <ServerGroup>
         <Server info="jNetServer1.0" 	name="svr1" 
                     address="192.168.0.13" 	port="8110" 
                     mode="standalone"	shutdown="SHUTDOWN">

 ◆ startup.bat 파일을 실행하여 jNetServer를 start 시킨다. 이때 keystore file의 
 비밀번호를 입력해야 하는데 "java11"을 입력한다. 

C:\jNetServer1.0>startup
CLASSPATH=.;D:\bea\weblogic81\server\lib\weblogic.jar;server\lib\jNetServer1.0.j
ar;server\lib\jakarta\commons-configuration-0.8.1.jar;server\lib\jakarta\commons
-digester.jar;server\lib\jakarta\commons-net-1.0.1-dev.jar;server\lib\jakarta\co
mmons-daemon.jar;server\lib\jakarta\commons-collections.jar;server\lib\jakarta\c
ommons-logging-api.jar;server\lib\jakarta\commons-beanutils.jar;server\lib\jakar
ta\commons-logging.jar;server\lib\jakarta\commons-pool-1.1.jar;server\lib\jakart
a\commons-dbcp.jar;server\lib\jakarta\commons-lang.jar;server\lib\log4j\log4j-1.
2.8.jar;server\lib\mx4j\mx4j-jmx.jar;server\lib\mx4j\mx4j-tools.jar;common\class
es;config
[00:51:29]  INFO - @ jNetServer1.0 @@@@@@@@@@@@@@@@@@@@@@@@@@
[00:51:29]  INFO - >> jnet.home=.
[00:51:29]  INFO - >> jnet.server=svr1
[00:51:29]  INFO - >> Logger=jnet.logger
Enter the password of the keystore file : java11

[00:54:12]  INFO - >> Including directory C:\jNetServer1.0\.\common\classes
[00:54:12]  INFO - StandardConnector{7130} listen 192.168.0.13
[00:54:12] DEBUG - EchoTask#taskCreate()- EchoTask{echo1}[0]
[00:54:12] DEBUG - EchoTask#taskPassivate()- EchoTask{echo1}[0]
[00:54:12] DEBUG - EchoTask#taskCreate()- EchoTask{echo1}[1]
[00:54:12] DEBUG - EchoTask#taskPassivate()- EchoTask{echo1}[1]
[00:54:12] DEBUG - EchoTask#taskCreate()- EchoTask{echo1}[2]
[00:54:12] DEBUG - EchoTask#taskPassivate()- EchoTask{echo1}[2]
[00:54:12]  INFO - StandardTask{echo1} started
[00:54:12]  INFO - StandardInputAdapter{everyone} started
[00:54:12]  INFO - StandardMonitor[idleHandlers] started
[00:54:12]  INFO - StandardMonitor[curHandlers] started
[00:54:12]  INFO - Handler{7130}[0] has been started
[00:54:12]  INFO - Handler{7130}[1] has been started
[00:54:12]  INFO - Handler{7130}[2] has been started
[00:54:12]  INFO - Handler{7130}[3] has been started
[00:54:12]  INFO - Handler{7130}[4] has been started
[00:54:12]  INFO - StandardConnector{7130} started
[00:54:12]  INFO - StandardConnector{7131} listen 192.168.0.13
[00:54:13] DEBUG - SSLProxyTask#taskCreate()- SSLProxyTask{proxy}[0]
[00:54:13] DEBUG - SSLProxyTask#taskPassivate()- SSLProxyTask{proxy}[0]
[00:54:13] DEBUG - SSLProxyTask#taskCreate()- SSLProxyTask{proxy}[1]
[00:54:13] DEBUG - SSLProxyTask#taskPassivate()- SSLProxyTask{proxy}[1]
[00:54:13] DEBUG - SSLProxyTask#taskCreate()- SSLProxyTask{proxy}[2]
[00:54:13] DEBUG - SSLProxyTask#taskPassivate()- SSLProxyTask{proxy}[2]
[00:54:13] DEBUG - SSLProxyTask#taskCreate()- SSLProxyTask{proxy}[3]
[00:54:13] DEBUG - SSLProxyTask#taskPassivate()- SSLProxyTask{proxy}[3]
[00:54:13] DEBUG - SSLProxyTask#taskCreate()- SSLProxyTask{proxy}[4]
[00:54:13] DEBUG - SSLProxyTask#taskPassivate()- SSLProxyTask{proxy}[4]
[00:54:13]  INFO - StandardTask{proxy} started
[00:54:13]  INFO - StandardInputAdapter{192.168.0.13} started
[00:54:13] DEBUG - SSLEchoTask#taskCreate()- SSLEchoTask{echo2}[0]
[00:54:13] DEBUG - SSLEchoTask#taskPassivate()- SSLEchoTask{echo2}[0]
[00:54:13] DEBUG - SSLEchoTask#taskCreate()- SSLEchoTask{echo2}[1]
[00:54:13] DEBUG - SSLEchoTask#taskPassivate()- SSLEchoTask{echo2}[1]
[00:54:13] DEBUG - SSLEchoTask#taskCreate()- SSLEchoTask{echo2}[2]
[00:54:13] DEBUG - SSLEchoTask#taskPassivate()- SSLEchoTask{echo2}[2]
[00:54:13] DEBUG - SSLEchoTask#taskCreate()- SSLEchoTask{echo2}[3]
[00:54:13] DEBUG - SSLEchoTask#taskPassivate()- SSLEchoTask{echo2}[3]
[00:54:13] DEBUG - SSLEchoTask#taskCreate()- SSLEchoTask{echo2}[4]
[00:54:13] DEBUG - SSLEchoTask#taskPassivate()- SSLEchoTask{echo2}[4]
[00:54:13]  INFO - StandardTask{echo2} started
[00:54:13]  INFO - StandardInputAdapter{everyone} started
[00:54:13]  INFO - Handler{7131}[0] has been started
[00:54:13]  INFO - Handler{7131}[1] has been started
[00:54:13]  INFO - Handler{7131}[2] has been started
[00:54:13]  INFO - Handler{7131}[3] has been started
[00:54:13]  INFO - Handler{7131}[4] has been started
[00:54:13]  INFO - StandardConnector{7131} started
[00:54:13]  INFO - StandardServer{svr1} started
[00:54:13]  INFO - StandardServerGroup started
[00:54:13]  INFO - ConsoleGaugeListener>> MonitorNotification [ sequence=1, time
Stamp=Sat Nov 29 00:54:13 KST 2003, type=jmx.monitor.gauge.low, userData=null, m
essage=, derivedGauge=5, observedObject=jnet.server:name=svr1/con7130, observedA
ttribute=IdleHandlers, trigger=5, source=javax.management.monitor.GaugeMonitor@c
623af ]
[00:54:13]  INFO - ConsoleCounterListener>> MonitorNotification [ sequence=1, ti
meStamp=Sat Nov 29 00:54:13 KST 2003, type=jmx.monitor.counter.threshold, userDa
ta=null, message=, derivedGauge=5, observedObject=jnet.server:name=svr1/con7130,
 observedAttribute=CurHandlers, trigger=3, source=javax.management.monitor.Count
erMonitor@50ca0c ]
	

3. Admin Console

 ◆ jNetServer가 실행되면, Http Admin Console에 접근해 관리할수 있다.
 
 	http://192.168.0.13:8080
 	
    브라우저로 8080 포트로 접근해 보면 아래와 같이 로그온 화면이 나타나는데, 
    jlook/jlook으로 오그온을 한다. admin 계정과 비밀번호는 은 config/server.xml
    에 설정되어 있다.
    
 	
 ◆ 로그인하면 start된 jNetServer의 JMX MBean object를 관리할수 있는 기능과 상태
    를 모니터링 할 수 있는 화면을 제공한다. 	
    
	

4. EchoTask Bean 및 테스트

 ◆ 설치된 jNetServer에는 예제로 EchoTask Bean이 제공된다. Task Bean의 
    개발은 jlook.jnet.task.NetTask 인터페이스를 구현하면 된다. 다음은 NetTask의 
    소스이다.       
    
     package jlook.jnet.task;
     
     import java.io.IOException;
     import java.io.BufferedInputStream;
     import java.io.BufferedOutputStream;
     
     /**
      * Socket 요청을 받아 처리할 Beans를 구정의하기 위한 NetTask interface 
      *
      * @since 	jNetServer1.0
      * @author 	HongSeong Jeon(hsjeon70@dreamwiz.com)
      */
     public interface NetTask {
     	/**
     	 * NetTask object의 id를 반환한다.
     	 *	
     	 * @return	id
     	 */
     	public String getId();	
     		
     	/**
     	 * NetTask Beans object 생성 후 callback
     	 */
     	public void taskCreate();
     	
     	/**
     	 * NetTask Beans object가 요청에 의해 pooling으로 부터 나와 할당된 
     	 * 후 callback
     	 */
     	public void taskActivate();
     	
     	/**
     	 * NetTask Beans object가 요청을 처리하고, pooling으로 반환된 후 
     	 * callback
     	 */
     	public void taskPassivate();
     	
     	/**
     	 * NetTask Beans object가 pooling으로 부터 deallocated 될때 callback
     	 */
     	public void taskDestroy();
     	
     	
     	/**
     	 * 클라이언트의 요청을 받아 NetContext object를 초기화하기 위해 
     	 * 실행된다.
     	 *
     	 * @param	context	NetContext object
     	 */
     	public void setContext(NetContext context);
     	
     	/**
     	 * 클라이언트의 요청에 대한 처리로직을 위해 실행된다.
     	 *	
     	 * @param	in	BufferedInputStream object
     	 * @param	out	BufferedOutputStream object
     	 * @exception	TaskException
     	 */
     	public void doTask(BufferedInputStream in, BufferedOutputStream out)
     	throws TaskException;
     	
     	/**
     	 * 클라이언트의 요청에 대한 처리로직을 실행한 후 후처리 작업을 
     	 * 위해 실행된다.
     	 *
     	 * @param	success	doTask() 메서드에서 Exception의 발생여부를 
     	 * 		나타내는 flag
     	 */
     	public void doEnd(boolean success);
     }
     
	
   - taskCreate() : Task Bean이 생성되고, Bean의 초기화 작업을 위해 호출된다.
   - taskDestory() : Task Bean이 Object Pool에서 삭제될 때 초기화 작업의 undo를 
	              위해 호출된다.
   - taskActivate() : Task Bean이 Object Pool에 반환될때 호출된다.
   - taskPassivate() : Task Bean이 Object Pool로 부터 나와 서비스 되기 직전에 
                               호출된다.
   - setContext() : 클라이언트의 요청 시 클라이언트의 정보를 갖는 Context 정보를 
                          초기화 하기 위해 호출된다.\
   - doTask() : 클라이언트 요청시 setContext() 가 실행된 다음 호출된다. 파라미터의 
                    InputStream, OutputStream을 이용해 실재 해당 요청의 처리로직을 
                    구현한다.
   - doEnd() : 후처리 작업을 위해 마지막에 호출된다.
   
 ◆ NetTask의 구현은 실재 NetTaskSupport 클래스를 상속받아 정의한다. 다음은 제공
    되는 EchoTask의 소스이다.
    
    
     package jlook.jnet.task;
     
     import java.io.*;
     
     import jlook.jnet.Keys;
     import jlook.jnet.util.Logger;
     
     public class EchoTask extends NetTaskSupport {
     	private static Logger logger = Logger.getLogger(Keys.LOGGER);
     	
     	public void taskCreate() {
     		logger.debug("EchoTask#taskCreate()- "+id);	
     	}
     	
     	public void taskActivate(){
     		logger.debug("EchoTask#taskActivate()- "+id);	
     	}
     	
     	public void taskPassivate(){
     		logger.debug("EchoTask#taskPassivate()- "+id);	
     	}
     	
     	public void taskDestroy(){
     		logger.debug("EchoTask#taskDestroy()- "+id);	
     	}
     	
     	public void setContext(NetContext context) {
     		super.setContext(context);
     		logger.debug("EchoTask#setContext()- "+id);	
     	}
     	
     	public void doTask(BufferedInputStream in, BufferedOutputStream out)
     	throws TaskException {
     		Logger logger = context.getLogger();
     		logger.debug("EchoTask#doTask()- "+id);	
     		byte[] msg = new byte[100];
     		logger.debug(id+"#doTask()- read....");
     		
     		try {
 		   int len = in.read(msg);
 		   String str = new String(msg,0,len);
 	
 		   logger.debug(id+"#doTask()- received msg>> "+str);
 		   str = "Hi... "+str;
 		   byte[] rt = str.getBytes();
 		   out.write(rt, 0, rt.length);
     		} catch(Exception e) {
     		   throw new TaskException(e.getMessage());
     		}
     	}	
     	
     	public void doEnd(boolean success) {
     		logger.debug("EchoTask#doEnd()- "+id);	
     		
     	}
     	
     	public String toString() {
     		return "SampleNetTask>>"+id;	
     	}
     }
    
 ◆ 개발된 NetTask Bean은 config/server.xml에 다음과 같이 설정해야 한다.
    
    
     <InputAdapter source="everyone" 		
     		 connectionTimeout="10000" 	
     		 sendBufferSize="10240"
     		 receiveBufferSize="10240"
     	  	 className="jlook.jnet.connector.StandardInputAdapter">     
     	<Task 	name="echo1"	initSize="5"	maxSize="50"
     		className="jlook.jnet.connector.StandardTask"
     		beanClass="jlook.jnet.task.EchoTask"/>
     			
    </InputAdapter>
    
    - name : unique name
    - initSize : object pool의 initial size
    - maxSize : object pool의 maximum size
    - className : Tag에 대한 정보를 갖는 Bean으로 위와 같이 반드시 제공되는 
      StandardTask 클래스를 설정한다.
    - beanClass : 개발한 NetTask Bean class를 설정한다.
    
 ◆ 다음은 EchoTask에 대한 Client 프로그램이다.
	
    
     package jlook.jnet.task;
     
     import java.io.*;
     import java.net.*;
     
     public class EchoClient implements Runnable {                            
     	private String server;
     	private int    port;
     	private String message;
     	
     	private boolean success;
     	private Socket sck;
     		
     	public EchoClient(String server, int port, String message) 
     	throws Exception {
	   this.server = server;
	   this.port = port;
	   this.message = message;	
	   try {
	   	sck = new Socket(server, port);
	   } catch(Exception e) {
	   	System.out.println(Thread.currentThread().getName() + 
	   	" Error>> "+e.toString());
	   	sck = new Socket(server, port);
	   }
     	}
     	
     	public static void main(String[] args) throws Exception {
	   if(args.length!=3) {
	   	System.out.println("usage : java EchoClient "+
	   	"  ");
	   	return;
	   }
	   
	   int port = -1;
	   try {
	   	port = Integer.parseInt(args[1]);
	   } catch(Exception e) {
	   	System.out.println("invalid port - "+port);
	   	throw e;
	   }
	   
	   EchoClient ec = new EchoClient(args[0], port, args[2]);
	   Thread t = new Thread(ec);
	   t.start();
     	}
     	
     	public boolean isSuccess() {
     		return success;	
     	}
     	
     	public void run() {
   	   InputStream in = null;
   	   OutputStream out = null;
   	   try {
   	     in = sck.getInputStream();
   	     out = sck.getOutputStream();
   	     	
   	     byte[] b = message.getBytes();
   	     out.write(b, 0, b.length);
   	     	
   	     byte[] buff = new byte[100];
   	     int len = in.read(buff);
   	     
   	     System.out.println(Thread.currentThread().getName()+
   	     "] "+ new String(buff, 0, buff.length));
   	     success = true;
   	     } catch(Exception e) {
   	     success = false;
   	     System.out.println(Thread.currentThread().getName() + 
   	     " Error>> "+e.toString());
   	     e.printStackTrace();
   	   } finally {
   	     try { notifyAll();} catch(Exception e){}	
   	     try { if(in!=null) in.close();} catch(Exception e) {}
   	     try { if(out!=null) out.close();} catch(Exception e) {}
   	     try { if(sck!=null) sck.close();} catch(Exception e) {}
   	   }
     	}
     }    

 ◆ 위 EchoClient를 테스트 하기 위해 runEcho.bat 파일 내 ip를 수정하고, 다음과 
    같이 runEcho.bat를 실행한다.

    C:\jNetServer1.0>runEcho
    CLASSPATH=.;D:\bea\weblogic81\server\lib\weblogic.jar;lib\jNetServer1.0.jar;
    classes;config
    Thread-1] Hi... hongseong

 ◆ 다음은 jNetServer쪽 콘솔에 나타난 로그 내용이다. 이 로그를 통해 NetTask에 정의된 
    메서드가 언제 실행되는지 이해할 수 있다.
 
    [21:32:48] DEBUG - @ request client address : 192.168.0.13              
    [21:32:48] DEBUG - StandardInputAdapter#doExecute() is started          
    [21:32:48] DEBUG - EchoTask#taskActivate()- EchoTask{echo1}[4]          
    [21:32:48] DEBUG - EchoTask#setContext()- EchoTask{echo1}[4]            
    [21:32:48] DEBUG - EchoTask#doTask()- EchoTask{echo1}[4]                
    [21:32:48] DEBUG - EchoTask{echo1}[4]#doTask()- read....                
    [21:32:48] DEBUG - EchoTask{echo1}[4]#doTask()- received msg>> hongseong
    [21:32:48] DEBUG - EchoTask#doEnd()- EchoTask{echo1}[4]                 
    [21:32:48] DEBUG - EchoTask#taskPassivate()- EchoTask{echo1}[4]         
    [21:32:49] DEBUG - Handler{7130}[4] process time : 0.38 sec             

	

5. SSL 설정 및 테스트

 ◆ config/server.xml의 내용을 보면 다음과 같이 7131 포트가 SSL 로 설정되어 있다.	
	
    
<Connector name="con7131" className="jlook.jnet.connector.StandardConnector" 
	    	port="7131" 		ssl="true"
	        enableLookups="true" acceptCount="50"
	        minHandlers="5" 		maxHandlers="50">
	<InputAdapter 	source="everyone" 		
		connectionTimeout="10000" 	
		sendBufferSize="10240"
		receiveBufferSize="10240"
	  	className="jlook.jnet.connector.StandardInputAdapter">
		
		<Task 	name="echo2" initSize="5" maxSize="50"
		  className="jlook.jnet.connector.StandardTask"
		  beanClass="jlook.jnet.task.SSLEchoTask"/>
				
	</InputAdapter>		
	
	<InputAdapter 	source="192.168.0.10" 		
		connectionTimeout="10000" 	
		sendBufferSize="10240"
		receiveBufferSize="10240"
	  	className="jlook.jnet.connector.StandardInputAdapter">
		
		<Task 	name="proxy" initSize="5" maxSize="50"
		  className="jlook.jnet.connector.StandardTask"
		  beanClass="jlook.jnet.task.SSLProxyTask">
		  <Parameter name="target.server" value="192.168.0.13"/>
		  <Parameter name="target.port"	 value="7130"/>
		  <Parameter name="buffer.size"	 value="9"/>
		</Task>
						
	</InputAdapter>
    
 ◆ 7131이 SSL로 설정되어 있으므로 앞에서 실행했던 runEcho.bat 파일의 port를 7131로 
    수정 후 실행해 보면 다음과 같이 에러가 발생한다.

### Client console]
C:\jNetServer1.0>runEcho
CLASSPATH=.;D:\bea\weblogic81\server\lib\weblogic.jar;server\lib\jNetServer1.0.j
ar;common\classes;config
Thread-1] 

### jNetServer console]
[01:16:24] ERROR - Unrecognized SSL message, plaintext connection?
javax.net.ssl.SSLException: Unrecognized SSL message, plaintext connection?
        at com.sun.net.ssl.internal.ssl.InputRecord.b(DashoA6275)
        at com.sun.net.ssl.internal.ssl.InputRecord.read(DashoA6275)
        at com.sun.net.ssl.internal.ssl.SSLSocketImpl.a(DashoA6275)
        at com.sun.net.ssl.internal.ssl.SSLSocketImpl.j(DashoA6275)
        at com.sun.net.ssl.internal.ssl.SSLSocketImpl.startHandshake(DashoA6275)	

 ◆ runssl.bat 파일을 오픈해 ip{192.168.0.13}를 시스템에 맞게 변경하고, 실행해 
   보면 다음과 같은 결과를 확인해 볼수 있다. 

### Client console]
C:\jNetServer1.0>runssl
CLASSPATH=.;D:\bea\weblogic81\server\lib\weblogic.jar;server\lib\jNetServer1.0.j
ar;common\classes;config
connect to the server.[192.168.0.13, 7131]
received message>> Hello hongseong   
   
### jNetServer console]
[01:27:12] DEBUG - @ request client address : 192.168.0.13
[01:27:12] DEBUG - StandardInputAdapter#doExecute() is started
[01:27:12] DEBUG - InputAdapter>>svr1/con7131/everyone
[01:27:12] DEBUG - StandardInputAdapter#doExecute()- start handshake
[01:27:12] DEBUG - SSLEchoTask#taskActivate()- SSLEchoTask{echo2}[4]
[01:27:12] DEBUG - SSLEchoTask#setContext()- SSLEchoTask{echo2}[4]
[01:27:12] DEBUG - SSLEchoTask#doTask()- SSLEchoTask{echo2}[4]
[01:27:12] DEBUG - SSLEchoTask{echo2}[4]#doTask()- read....
[01:27:12] DEBUG - SSLEchoTask{echo2}[4]#doTask()- received msg>> hongseong
[01:27:12] DEBUG - SSLEchoTask#taskPassivate()- SSLEchoTask{echo2}[4]
[01:27:12] DEBUG - Handler{7131}[4] process time : 0.431 sec
  
  ◆ 클라이언트 시스템이 192.168.0.13 이므로 클라이언트 시스템에 대하 InputAdapter가 
    설정되어 있지 않기 때문에 default인 "everyone"의 InputAdapter가 동작한 것이다.
    그리고, Task beans는 SSLEchoTask가 실행되었고, 그 소스는 아래와 같다. SSL 관련
    추가 코드는 필요하지 않다.
	
package jlook.jnet.task;

import java.io.*;

import jlook.jnet.Keys;
import jlook.jnet.util.Logger;

public class SSLEchoTask extends NetTaskSupport {
	private static Logger logger = Logger.getLogger(Keys.LOGGER);
	
	public void taskCreate() {
		logger.debug("SSLEchoTask#taskCreate()- "+id);	
	}
	
	public void taskActivate(){
		logger.debug("SSLEchoTask#taskActivate()- "+id);	
	}
	
	public void taskPassivate(){
		logger.debug("SSLEchoTask#taskPassivate()- "+id);	
	}
	
	public void taskDestroy(){
		logger.debug("SSLEchoTask#taskDestroy()- "+id);	
	}
	
	public void setContext(NetContext context) {
		super.setContext(context);
		logger.debug("SSLEchoTask#setContext()- "+id);	
	}
	
	public void doTask(BufferedInputStream in, BufferedOutputStream out) 
	throws TaskException {
		Logger logger = context.getLogger();
		logger.debug("SSLEchoTask#doTask()- "+id);	
		byte[] msg = new byte[100];
		logger.debug(id+"#doTask()- read....");
		
		try {
			int len = in.read(msg);
			String str = new String(msg,0,len);
		
			logger.debug(id+"#doTask()- received msg>> "+str);
			str = "Hi... "+str;
			byte[] rt = str.getBytes();
			out.write(rt, 0, rt.length);
		} catch(Exception e) {
			logger.error(e.getMessage(),e);
			throw new TaskException(e.getMessage());
		}
	}	
	
	public void doEnd(boolean success) {
		logger.debug("SSLEchoTask#doEnd()- "+id);	
		
	}
	
	public String toString() {
		return "SampleNetTask>>"+id;	
	}
}


  ◆ 다음은 위에서 테스트한 ssl Client application 소스이다. 서버와 동일한 keystore 
    파일을 이용한 것을 알 수 있다.
	
package jlook.jnet.task;

import java.io.*;
import java.net.*;
import java.security.*;
import javax.net.*;
import javax.net.ssl.*;

public class SSLEchoClient {
	
  public static void main(String[] args) throws Exception {
	  System.setProperty("javax.net.ssl.trustStore", 
	    "config/jnet.keystore"); 
	  
	  if(args.length!=2) {
	  	System.out.println("java SSLEchoClient  ");
	  	return;	
	  }
	  
	  System.out.println("connect to the server.["+
	    args[0]+", "+args[1]+"]");
	  int port = Integer.parseInt(args[1]);
	  
	  SSLContext ctx;
	  KeyManagerFactory kmf;
	  KeyStore ks;
	  char[] passphrase = "java11".toCharArray();
      
	  ctx = SSLContext.getInstance("TLS");
	  kmf = KeyManagerFactory.getInstance("SunX509");
	  ks = KeyStore.getInstance("JKS");
      
	  ks.load(new FileInputStream("config/jnet.keystore"), passphrase);
      
	  kmf.init(ks, passphrase);
	  ctx.init(kmf.getKeyManagers(), null, null);
      
	  SSLSocketFactory factory = ctx.getSocketFactory();
      SSLSocket sck = (SSLSocket)factory.createSocket(args[0], port);
	  sck.setEnabledCipherSuites(sck.getSupportedCipherSuites());
	  sck.startHandshake();
	  
	  BufferedInputStream in = 
	  	new BufferedInputStream(sck.getInputStream());
	  BufferedOutputStream out = 
	  	new BufferedOutputStream(sck.getOutputStream());
	  
	  String msg = "hongseong";
	  byte[] tmp = msg.getBytes();
	  
	  out.write(tmp, 0, tmp.length);
	  out.flush();
	  
	  byte[] buff = new byte[1024];
	  int len = in.read(buff);
	  
	  System.out.println("received message>> "+new String(buff, 0, len));
	  out.close();
	  in.close();
	  sck.close();	

  }
}
   
	

6. SSLProxyTask Beans

 ◆ NetTask 응용으로 Proxy Server Beans를 소개한다. 서버를 7130, SSL 7131로 서비스 할때
    7131로 들어온 요청을 7130쪽으로 forwarding하는 SSLProxyTask의 소스와 설정을 살펴보자.
    다음은 server.xml의 7131쪽 Connector 설정 부분인데, ssl="true"로 설정된 것을 
    확인할 수 있다. 그리고, 앞 예제와는 다르게 InputAdapter의 source가 현 시스템의 
    ip{192.168.0.13}로 변경된것을 확인할 수 있다. 즉, 192.168.0.13 시스템의 클라이
    언트의 요청을 SSLProxyTask 가 처리한다는 것을 설정한 것이다.
	
    
<Connector name="con7131" className="jlook.jnet.connector.StandardConnector" 
	    	port="7131" 		ssl="true"
	        enableLookups="true" acceptCount="50"
	        minHandlers="5" 		maxHandlers="50">
	<InputAdapter 	source="everyone" 		
		connectionTimeout="10000" 	
		sendBufferSize="10240"
		receiveBufferSize="10240"
	  	className="jlook.jnet.connector.StandardInputAdapter">
		
		<Task 	name="echo2" initSize="5" maxSize="50"
		  className="jlook.jnet.connector.StandardTask"
		  beanClass="jlook.jnet.task.SSLEchoTask"/>
				
	</InputAdapter>		
	
	<InputAdapter 	source="192.168.0.13" 		
	   connectionTimeout="10000" 	
	   sendBufferSize="10240"
	   receiveBufferSize="10240"
  	   className="jlook.jnet.connector.StandardInputAdapter">  
		
	   <Task 	name="proxy" initSize="5" maxSize="50"
	     className="jlook.jnet.connector.StandardTask"
	     beanClass="jlook.jnet.task.SSLProxyTask">
	     <Parameter name="target.server" value="192.168.0.13"/>  
	     <Parameter name="target.port"	 value="7130"/>
	     <Parameter name="buffer.size"	 value="9"/>
	   </Task>
						
	</InputAdapter>
    
 ◆ 이제 SSLProxyTask Beans의 소스를 살펴 볼것인데, 위에서 Task의 Parameter 태그는
    Task Beans에 넘길 key/value 데이터를 설정한 태그이다. 포워딩할 서버 및 포트 
    정보를 설정했다. 이것을 어떻게 얻어 내었는지 살펴보기 바란다.
	
 
package jlook.jnet.task;

import java.io.*;
import java.net.*;

import jlook.jnet.Keys;
import jlook.jnet.util.Logger;

public class SSLProxyTask extends NetTaskSupport {
	private static Logger logger = Logger.getLogger(Keys.LOGGER);
	
	private String 	server;
	private int 	port;
	private int 	bufferSize;
	
	public static final String TARGET_SERVER 	= "target.server";
	public static final String TARGET_PORT 	= "target.port";
	public static final String BUFFER_SIZE 	= "buffer.size";
	
	public void taskCreate() {
		logger.debug("SSLProxyTask#taskCreate()- "+id);	
	}
	
	public void taskActivate(){
		logger.debug("SSLProxyTask#taskActivate()- "+id);	
	}
	
	public void taskPassivate(){
		logger.debug("SSLProxyTask#taskPassivate()- "+id);	
	}
	
	public void taskDestroy(){
		logger.debug("SSLProxyTask#taskDestroy()- "+id);	
	}
	
	public void setContext(NetContext context) {
		super.setContext(context);
		logger.debug("SSLProxyTask#setContext()- "+id);	
		server = context.getParameter(TARGET_SERVER);
		if(server == null) server = "127.0.0.1";
		try {
		  port = Integer.parseInt(context.getParameter(TARGET_PORT));
		} catch(Exception e) {
			port=80;
		}
		try {
		  bufferSize = Integer.parseInt(
		  		context.getParameter(BUFFER_SIZE));
		} catch(Exception e) {
			bufferSize=10240;
		}
	}
	
	public void doTask(BufferedInputStream in, BufferedOutputStream out) 
	throws TaskException {
		Logger logger = context.getLogger();
		logger.debug("SSLProxyTask#doTask()- "+id);	
		
		Socket proxy = null;
		BufferedInputStream 	pin  = null;
		BufferedOutputStream 	pout = null;
		try {
		  proxy= new Socket(server,port);
		  pin  = new BufferedInputStream(proxy.getInputStream());
		  pout = new BufferedOutputStream(proxy.getOutputStream());
		} catch(Exception e) {
		  String msg = "Cannot connect to target system>> "+
			e.getMessage();
		  logger.error(msg, e);
		  byte[] tmp = msg.getBytes();
		  try {
			out.write(tmp, 0, tmp.length);
			out.flush();
	  	  } catch(IOException ex){}
		  return;
		}
		
		try {
			byte[] buff = new byte[bufferSize];
			while(true) {
				int len = in.read(buff);
				if(len>"+id;	
	}
}
    
 ◆ 다음은 runssl.bat 파일의 실행 결과이다. 서버 콘솔을 보면 클라이언트 요청이 
    7131{SSLProxyTask}, 7130{EchoTask} 두번 처리된것을 확인할 수 있다.

### Client console]
C:\jNetServer1.0>runssl
CLASSPATH=.;D:\bea\weblogic81\server\lib\weblogic.jar;server\lib\jNetServer1.0.j
ar;common\classes;config
connect to the server.[192.168.0.13, 7131]
received message>> Hello hongseong

### Server console]
[01:54:29] DEBUG - @ request client address : 192.168.0.13
[01:54:29] DEBUG - StandardInputAdapter#doExecute() is started
[01:54:29] DEBUG - InputAdapter>>svr1/con7131/192.168.0.13
[01:54:29] DEBUG - StandardInputAdapter#doExecute()- start handshake
[01:54:29] DEBUG - SSLProxyTask#taskActivate()- SSLProxyTask{proxy}[4]
[01:54:29] DEBUG - SSLProxyTask#setContext()- SSLProxyTask{proxy}[4]
[01:54:29] DEBUG - SSLProxyTask#doTask()- SSLProxyTask{proxy}[4]
[01:54:29] DEBUG - @ request client address : 192.168.0.13
[01:54:29] DEBUG - StandardInputAdapter#doExecute() is started
[01:54:29] DEBUG - InputAdapter>>svr1/con7130/everyone
[01:54:29] DEBUG - EchoTask#taskActivate()- EchoTask{echo1}[2]
[01:54:29] DEBUG - EchoTask#setContext()- EchoTask{echo1}[2]
[01:54:29] DEBUG - EchoTask#doTask()- EchoTask{echo1}[2]
[01:54:29] DEBUG - EchoTask{echo1}[2]#doTask()- read....
[01:54:29] DEBUG - EchoTask{echo1}[2]#doTask()- received msg>> hongseong
[01:54:29] DEBUG - EchoTask#doEnd()- EchoTask{echo1}[2]
[01:54:29] DEBUG - EchoTask#taskPassivate()- EchoTask{echo1}[2]
[01:54:29] DEBUG - SSLProxyTask#doEnd()- SSLProxyTask{proxy}[4]
[01:54:29] DEBUG - SSLProxyTask#taskPassivate()- SSLProxyTask{proxy}[4]
[01:54:29] DEBUG - Handler{7130}[4] process time : 0.01 sec
[01:54:29] DEBUG - Handler{7131}[4] process time : 0.37 sec 
	

 written by Jeon HongSeong