서비의 다락방

ResultSet 출력하기

자. 이제 위의 예제코드의 ResultSet을 XML데이터로 변형 해 봅시다.
이를 위해 com.sun.rowset.WebRowSetImple 클래스를 이용할 수 있습니다.
위 예제 코드에 몇 라인의 코드를 추가함으로써 result set을 XML 파일로 출력 할 수 있습니다.

[code]
... ... ...
ResultSet rs =  stmt.executeQuery("select * from student");
WebRowSet wrs = new WebRowSetImpl();
wrs.populate(rs);
try {
  wrs.writeXml(
  new FileOutputStream("student.xml"));
} catch (FileNotFoundException e) {
  e.printStackTrace();
} catch (IOException e) {
  e.printStackTrace();
}
... ... ...
[/code]

wrs.writeXML()의 출력형태는 WebRowSet scheme definition. 의 형태를 따르며
출력은 properties, metadata, data의 세 부분으로 구분 되어집니다.
일반적인 출력 레이아웃은 다음과 같습니다.

[code]
<?xml version="1.0"?>
<webRowSet xmlns= "http://java.sun.com/xml/ns/jdbc"
           xmlns:xsi= "http://www.w3.org/2001/XMLSchema-instance"
           xsi:schemaLocation= "http://java.sun.com/xml/ns/jdbc 
           http://java.sun.com/xml/ns/jdbc/webrowset.xsd">
 <properties>
       ... ... ...
 </properties>
 <metadata>
       ... ... ...
 </metadata>
 <data>
       ... ... ...
</data>
</webRowSet>
[/code]

<properties> 태그는 provider( isolation leve, RowSet type 등)를 의미 합니다. <metadata> 태그는 해당 데이타베이스의 테이블의 갯수, 이름, 컬럼타입 등을 나타내며, 마지막으로 <data> 태그는 해당 테이블의 실제 정보를 기술합니다.

[code]
 <data>
   <currentRow>
     <columnValue>200 < /columnValue>
     <columnValue>Jack</columnValue>
     <columnValue>Dakota</columnValue>
     <columnValue>21</columnValue>
   </currentRow>
   <currentRow>
     <columnValue>100</columnValue>
     <columnValue>John</columnValue>
     <columnValue>Doe</columnValue>
     <columnValue>26</columnValue>
   </currentRow>
 </data>
[/code]

위의 예에서 보이는 <currentRow> 태그는 WebRowSet의 각 Row에 저장되어있는 데이터를 나타냅니다. insert, update, delete같은 데이터 조작은 다음편에서 계속하겠습니다.

ResultSet 이용하기

아래에 이어질 예제는 JDK5.0과 Oracle 데이터베이스 10.2를 이용하여 진행하고 있음을 밝혀둡니다.

자.. 'student'라는 테이블에 아래와 같은 데이터를 갖는 간단한 데이터베이스가 있다고 합시다.

SQL> select * from student;

모든 자바 클래스의 최상위 부모클래스인 java.lang.Object 클래스에는 finalize() 메소드가 존재하며, Java API 에는 이 메소드는 '가비지 컬렉터가 레퍼런스를 잃은 클래스의 인스턴스를 가비지 컬렉션할 때 호출된다' 라고 기술하고 있습니다.

이 메소드는 객체인스턴스가 가비지 콜렉션에 의해 소멸되는 시점에 특정한 동작을 수행해야 할때도 요긴하게 사용할 수 있는 메소드입니다만 일반적인 경우 불필요하게 이 finalize() 메소드를 오버라이딩하는 것은 자제해야합니다.

이유는 'finalize 메소드에 의한 Collection 지연과 OOME(Out of Memory Exception)발생 가능성'때문입니다.
특정 Class에 finalize 메소드가 정의되어 있는 경우, 이 Class Type의 Object는 Garbage Collection 발생시 즉각적으로 Collection 되지 않습니다. 대신 Finalization Queue에 들어간 후 Finalizer에 의해 정리가 되는데요. Finalizer는 Object의 finalize 메소드를 실행한 후 메모리 정리 작업을 수행하게됩니다.
만일 finalize 메소드를 수행하는데 오랜 시간이 걸린다면 그 만큼 객체가 오랫동안 메모리를 점유하게 되고 이로 인해 OOME가 발생할 확률이 높아집니다.
이런 이유로 finalize 메소드는 되도록 사용하지 말아야 합니다.

java.lang 패키지의 Runtime 클래스는 자바에서 외부 프로세스를 생성하는 방법을 제공한다.
예를 들어 자바를 이용하여 MS 윈도우에서 MS 엑셀을 실행하는것등에 이 Runtime클래스를 이용할 수 있다.

예를 들어 C:\Program Files\Microsoft Office\Office\excel.exe 위치에 있는 excel.exe를 실행
하는 코드는 아래와 같다.
[code]
try {
   Runtime run = Runtime.getRuntime ();
   run.exec ( "C:\\Program Files\\Microsoft Office\\Office\\excel.exe" );
} catch ( IOException ie )
{ 
   System.err.println ( ie );
}
[/code]
어떤가, 무척 간단하지 않는가?
그럼, 한걸음 더 나아가 보자.
윈도우는 파일확장자별로 대표 프로그램을 등록하여 파일을 더블클릭하는것만으로 해당 프로그램을 실행 할 수가
있는데 이렇게 특정 파일을 선택하여 그와 연결된 프로그램을 실행하는 코드도 자바로 가능 할까?
물론, 가능하다. 여기에는 윈도우즈 명령어를 조금 알아야 하는 부분이 있지만 그 부분만 알고 있다면 나머지는
위와 동일하게 Runtime 객체로 그 명령어를 실행 하기만 하면된다.
아래 코드를 보자.
[code]
package javacodesnipet;

import java.io.File;
import java.io.IOException;

/**
 * Runtime클래스를 이용하여 해당 파일과 연결된 프로그램을 실행한다.
 * @author 신윤섭
 */
public class RuntimeExample {
 public static void main(String[] args){
  try {
     File file = new File("d:\\sample.pdf");
   
     //MS Windows Only
     Process p= Runtime.getRuntime().exec("rundll32 url.dll,FileProtocolHandler " +
     file.getAbsolutePath());
     // or
     //Process p= Runtime.getRuntime().exec("rundll32 SHELL32.DLL,ShellExec_RunDLL " +
     // file.getAbsolutePath());
   
     //Apple Mac Only
     //Process p= Runtime.getRuntime().exec("open " + file.getAbsolutePath());
   
     p.waitFor();
     System.out.println("Process Done");
   
  } catch (InterruptedException ex) {
     ex.printStackTrace();
  } catch (IOException ex) {
     ex.printStackTrace();
  }
 }
}
[/code]
위 코드는 윈도우 탐색기에서 d:\sample.pdf를 더블클릭하여 아크로뱃리더를 실행하고 해당 pdf문서를
여는것과 동일한 효과를 얻을 수 있다.  윈도우의 rundll32 명령으로 해당 파일과 연결된 프로그램을 구동
할 수 있는데 이를 Runtime객체를 이용하여 수행하는 코드이다.

rundll32 more..

double을 퍼센트(%)로 표현하기위해 여러가지 방법을 이용할 수 있지만  java.text 패키지의 NumberFormat 클래스
API를 이용하면 아래와 같이 간단히 double값을 퍼센트 문자열로 변환할 수 있다.

[code]
package javacodesnipet;

import java.util.Locale;
/**
 *
 * @author 신윤섭
 */
public class NumberFormatPercent {
 public static void main(String[] args){  
    //아래 double 값을 퍼센트 문자열로 표현해 보자
    double value = 0.343234532d;
    //NumberFormat 객체로 부터 PercentInstance를 얻어온다.
    java.text.NumberFormat pformat = java.text.NumberFormat.getPercentInstance(Locale.KOREA);
    //퍼센트로 표현할 소수점 이하의 자리수를 정한다.
    pformat.setMaximumFractionDigits ( 4 );
    //자... 이제 double을 String형식의 퍼센트로 변환하자.
    String sPercent = pformat.format ( value);
    //값을 확인 해 보자 -> 34.3235% 과 같이 표현 된다.
    System.out.println(sPercent);
    }
}
[/code]

우리는 java.util.Date 혹은 java.sql.Date 타입의 객체에서 특정한 형식의 문자열로 날짜를 가져오기 위해서
java.text.SimpleDateFormat 클래스를 이용할 수 있다는 것을 알고 있다.
[code]
package javacodesnipet;
/**
 * @author 신윤섭
 */
public class SimpleDateFormatTest {
 
 public static void main(String[] args){
 
  // 현재 일시 정보를 갖는 Date 객체를 생성한다.
  java.util.Date currentDate = new java.util.Date();  
  //Date객체로부터 특정한 형식의 문자열로 일시를 만들어내기 위한 포매터를 생성한다.
  java.text.SimpleDateFormat format = new java.text.SimpleDateFormat("yyyy년MM월dd일 HH시mm분ss초");
  //포매터를 이용하여 Date객체로부터 문자열을 만들어낸다.
  String dateString = format.format(currentDate);
  //변환된 문자열을 확인한다.  결과 : 2007년07월22일 02시21분42초
  System.out.println(dateString);  
 
 }
}
[/code]
위의 코드는 흔히 사용하는 코드일 것이다.

그런데 이 SimpleDateFormat 클래스의 parse() 메소드를 이용하면 역으로 문자열 형식의 날짜로부터
Date객체를 생성 해낼 수도 있다.
[code]
package javacodesnipet;
/**
 * @author 신윤섭
 */
public class SimpleDateFormatTest {
 
 public static void main(String[] args){
  try {
   // "2007-07-22" 이란 문자열로 2007년 7월 22일의 정보를 갖는 Date객체를 만들어보자
   String textDate = "2007-07-22";

   // 입력할 날짜의 문자열이 yyyy-MM-dd 형식이므로 해당 형식으로 포매터를 생성한다.
   java.text.SimpleDateFormat format = new java.text.SimpleDateFormat("yyyy-MM-dd");

   //SimpleDateFormat.parse()메소드를 통해 Date객체를 생성한다.
   //SimpleDateFormat.parse()메소드는 입력한 문자열 형식의 날짜가
   //포맷과 다를경우 java.text.ParseException을 발생한다.
   java.util.Date date = format.parse(textDate);

   //위에서 만든 date객체가 정말 7월22일인지 확인 해보자.
   java.text.SimpleDateFormat format1 = new java.text.SimpleDateFormat("yyyy년MM월dd일 HH시mm분ss초");
   String dateString = format1.format(date);
   //Date객체의 날자를 확인한다..  결과 : 2007년07월22일 00시00분00초
   System.out.println(dateString);
  } catch (java.text.ParseException ex) {
   ex.printStackTrace();
  }
 
 }
}
[/code]

지난 포스트를 통해 자바로 파일을 복사하는 몇가지 방법을 알아보았다.
이번시간에는 각 코드의 성능을 간단히 확인해 보고자 한다.

[code]
/*
 * author 신윤섭
 */
package filecopy;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;

/**
 * Stream을 이용한 파일복사 코드 스니핏
 * @author 신윤섭
 */
public class StreamCopy {

 /**
  * source에서 target으로의 파일 복사
  * @param source
  * @param target
  */
 public void copy(String source, String target) {
  //복사 대상이 되는 파일 생성
  File sourceFile = new File( source );
 
  //스트림 선언
  FileInputStream inputStream = null;
  FileOutputStream outputStream = null;
 
  try {
   //스트림 생성
   inputStream = new FileInputStream(sourceFile);
   outputStream = new FileOutputStream(target);
   
   int bytesRead = 0;
   //인풋스트림을 아웃픗스트림에 쓰기
   byte[] buffer = new byte[1024];  
   while ((bytesRead = inputStream.read(buffer, 0, 1024)) != -1) {
    outputStream.write(buffer, 0, bytesRead);
   }
   
  } catch (Exception e) {
   e.printStackTrace();
  }finally{
   //자원 해제
   try{
    outputStream.close();
   }catch(IOException ioe){}
   try{
    inputStream.close();
   }catch(IOException ioe){}
  }

 }
}
[/code]
[code]
/*
 * author 신윤섭
 */
package filecopy;

import java.io.File;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;

/**
 * Buffer를 이용한 파일복사 코드 스니핏
 * @author 신윤섭
 */
public class BufferCopy {

 /**
  * source에서 target으로의 파일 복사
  * @param source
  * @param target
  */
 public void copy(String source, String target) {
  //복사 대상이 되는 파일 생성
  File sourceFile = new File( source );
 
  //스트림, 버퍼 선언
  FileInputStream inputStream = null;
  FileOutputStream outputStream = null;
  BufferedInputStream bin = null;
  BufferedOutputStream bout = null;
 
  try {
   //스트림 생성
   inputStream = new FileInputStream(sourceFile);
   outputStream = new FileOutputStream(target);
   //버퍼 생성
   bin = new BufferedInputStream(inputStream);
   bout = new BufferedOutputStream(outputStream);
   
   //버퍼를 통한 스트림 쓰기
   int bytesRead = 0;
   byte[] buffer = new byte[1024];
   while ((bytesRead = bin.read(buffer, 0, 1024)) != -1) {
    bout.write(buffer, 0, bytesRead);
   }

  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   //자원 해제
   try{
    outputStream.close();
   }catch(IOException ioe){}
   try{
    inputStream.close();
   }catch(IOException ioe){}
   try{
    bin.close();
   }catch(IOException ioe){}
   try{
    bout.close();
   }catch(IOException ioe){}
  }
 }
}
[/code]
[code]
/*
 * author 신윤섭
 */
package filecopy;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.nio.channels.FileChannel;
import java.io.IOException;

/**
 * NIO Channel을 이용한 파일복사 코드 스니핏
 * @author 신윤섭
 */
public class ChannelCopy {

 /**
  * source에서 target으로의 파일 복사
  * @param source 복사할 파일명을 포함한 절대 경로
  * @param target 복사될 파일명을 포함한 절대경로
  */
 public void copy(String source, String target) {
  //복사 대상이 되는 파일 생성
  File sourceFile = new File( source );

  //스트림, 채널 선언
  FileInputStream inputStream = null;
  FileOutputStream outputStream = null;
  FileChannel fcin = null;
  FileChannel fcout = null;

  try {
   //스트림 생성
   inputStream = new FileInputStream(sourceFile);
   outputStream = new FileOutputStream(target);
   //채널 생성
   fcin = inputStream.getChannel();
   fcout = outputStream.getChannel();
   
   //채널을 통한 스트림 전송
   long size = fcin.size();
   fcin.transferTo(0, size, fcout);

  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   //자원 해제
   try{
    fcout.close();
   }catch(IOException ioe){}
   try{
    fcin.close();
   }catch(IOException ioe){}
   try{
    outputStream.close();
   }catch(IOException ioe){}
   try{
    inputStream.close();
   }catch(IOException ioe){}
  }
 }
}
[/code]

이상의 샘플코드를 이용하여 700Mbytes 짜리 파일을 5번 복사하여 그 시간을 측정해 본 결과는 아래와 같다.
테스트는 Win XP Pro sp3, Intel Core2 Duo 2GHz, 2Gbytes, 5400rpm의 노트북용 HDD 에서 JDK 1.6.0_06
을 이용하여 이루어졌다.

결과는 아래와 같다.

Stream을 이용한 파일 복사

Buffer를 이용한 파일 복사

Channel을 이용한 파일 복사

FileInputStream.read()실행에 대부분의 시간을 소비하고 있다.

Stream보다는 나아졌다고는 하나 역시 read()메소드가 대부분의 실행시간을 소비하고 있다.

위 두 방식과는 확연히 다른 동작 성향을 보여주고 있다.

자바로 파일을 복사할 수 있는 방법은 크게 3가지 정도가 있다.
InputStream, OutputStream을 이용한 방법, Buffer를 이용한 방법, Channel을 이용한 방법이 그것이다.
물론 Buffer를 이용하면서도 단순히 Stream에 Buffer 필터를 적용할 수도, MappedByteBuffer를 쓸 수도 있고
Channel을 이용하면서도 inputChannel과 outputChannel을 이용하거나 transterTo()를 이용하는 등
다양한 방법을 구사할 수 있다.
여기서는 자바로 구현 할 수 있는 대표적인 파일 복사 코드를 살펴보고 각 코드간의 성능에 대한 이야기도 나눠
보도록 하겠다.

Java입문서등을 통하여 io (Input/Output)부분을 언급하며 나오는 개념이 Stream일 것이다. 스트림의 개념을
설명하고 처음 접하는 코드는 아래와 유사할 것이다. 파일을 인풋스트림으로 읽어들인 후 그 길이만큼 아웃풋
스트림에다 흘려보내는 방식으로 파일을 복사할 수 있다.

[code java] FileInputStream inputStream = new FileInputStream(file); FileOutputStream outputStream = new FileOutputStream(saveFullPath); int bytesRead = 0; byte[] buffer = new byte[1024]; while ((bytesRead = inputStream.read(buffer, 0, 1024)) != -1) { outputStream.write(buffer, 0, bytesRead); } outputStream.close(); inputStream.close(); [/code]

* Stream에 Buffer Filter를 연결하여 성능을 향상.
위와같은 방법으로 충분히 만족할만 한가? 그렇다고 할수도있고 아니라고 할수도 있다. 위 두 방식은 스트림으로
데이터를 전송하는데 항상 cpu의 연산을 필요로 한다. 즉 스트림을 처리하는동안 cpu가 계속해서 명령을 처리
해줘야 한다는것이다.(비록 cpu사용율은 얼마 안될지 모르지만.. )

컴퓨터의 입장에서 본다면 IO는 상당히 느린 작업중의 하나이다. 이런 작업을 조금이라도 빨리 처리하기위해
하드웨어 혹은 운영체제 수준에서 많은 기법들을 제공하고 있다.
자바는 버전 1.4에 이르러서 기존 io와는 차별화된 nio(new io) 패키지가 추가되었는데 이 nio를 통하여
운영체제가 제공해 주는 향상된 io기능을 활용할 수 있게 되었다. 그 대표적인 것이 Channel과 Selector일 것이다.
아래와 같은 코드는 JDK 1.4이상부터 사용 가능하며 transferTo() 메소드를 호출하면 내부적으로 OS의 네이티브IO
기능을 활용하여 더욱 효율적인 스트림 전송이 가능하다.
 
[code java] FileInputStream inputStream = new FileInputStream(file); FileOutputStream outputStream = new FileOutputStream(saveFullPath); FileChannel fcin = inputStream.getChannel(); FileChannel fcout = outputStream.getChannel(); long size = fcin.size(); fcin.transferTo(0, size, fcout); fcout.close(); fcin.close(); outputStream.close(); inputStream.close(); [/code]

* Channel을 이용한 네이티브OS 기능 사용하기.

이상으로 3가지 대표적인 자바 파일복사 코드를 살펴보았다. 다음 포스트에서는 각 방식의 성능 차이에 대해
알아보도록 하겠다.

자바 파일복사 코드와 성능 2

JProbe 8.0은 두가지 특징적인 기능이 포함되었습니다.
첫번째로 자바 어플리케이션의 프로파일링을 좀 더 원활히 진행하기위해 Eclipse 플러그인을 지원하여 IDE를 통하여 개발, 테스트 및 성능평가에 이르는 프로세스를 단축하여 좀 더 높은 생산성을 제공합니다.
또다른 특징으로는 UI개선을 통한 사용성 향상을 꼽을 수 있습니다. Data Visualization기능을 통하여 좀 더 빠르고 효율적으로 memory allocation 문제를 진단할 수 있습니다.

	Freeware	Commercial
Main Features
# installations	unlimited	per license
Memory Heap Dump Analysis
Memory JProbe Snapshot Analysis	X
Performance Analysis	X
Code Coverage	X
Automation	X
Quest Support	JProbe Community	Quest Support

java study 질답 게시판에서 서버-클라이언트 소켓 통신을 하는데 통신이 단절된다는 내용의 질문을 접했습니다.

질문자의 원글 보기..

코드를 보면 지극히 정석으로 코드를 작성 해 둔 상황입니다. 하지만 동작 중 어느 순간이 되면 통신이 안되기 시작하죠..
이는 비단 자바뿐만 아니라 다른 언어로 소켓 프로그래밍을 하더라도 동일한 현상이 발생할 겁니다.
원 질문자께서 저 코드로 어디까지 다버깅을 해 보셨는지는 알지 못하겠지만, 제가 판단하건데 동작이 안되는 시점은
필시 클라언트와 서버 양쪽 모두 while((read = bin.read())!=-1) 문에서 서로의 데이터를 기다리느라
블록 상태에 빠졌기 때문일 겁니다.

왜? 무슨 이유로 read() 에서 블록 상태에 빠졌을까요?

원인은 서버 소켓 쓰레드인 ClientHandler 쪽에서 찾을수 있습니다. 
서버 소켓 코드를 보시면 클라이언트에서 받은 데이타를 읽는게 끝이나면 클라이언트로 데이타를 전송하는
절차적 구조로 작성 되어있는데요..

문제는 클라이언트로부터 데이터가 유입되는
[code]// received InputStream in = null;
BufferedInputStream bin = null;
in = m_socketClient.getInputStream();
bin = new BufferedInputStream(in);
ByteArrayOutputStream baos = new ByteArrayOutputStream();
int read;
while ((read = bin.read()) != -1) {
    baos.write(read);
}
[/code]
부분이 원인입니다... 감이 좀 잡히시나요?

한번 API를 확인 해 볼 필요가 있겠군요. API를 보시면.. BufferedInputStream의 read() 메소드의 리턴 값을
the next byte of data, or -1 if the end of the stream is reached. 라고 명시하고 있습니다.
'스트림의 끝까지 갔을 때 -1을 리턴 한다'라고.. 데이터가 끝났을 때 -1이 아닙니다.

비록 클라이언트가 보낸 데이타는 끝이 났을지언정 클라이언트와 연결된 스트림은 끝나지 않았단 말이죠.
쉽게 말하자면 bin.read()에서 block된 상황은 BufferedInputStream인 bin이 끝나지 않았으며, 언젠간
새로운 데이터가 유입될테니 대기중이다.는 얘기지요.

이제 좀 감이 잡히시죠? ^^
결국 지금의 코드 대로라면 서버 소켓은 클라이언트에서 보낼 데이터를 영원히(혹은 time out까지) 기다리고 있는거죠..

이제 원인을 알았으니 해결책에 대한 아이디어도 떠오르셨을거라 생각합니다.
이런 경우 클라이언트 소켓도 쓰레드로 돌려야 하지만 인풋 스트림과 아웃풋 스트림도 각각 쓰레드로 처리 해
주셔야 질문과 같이 blocking으로 어플리케이션이 멈춰있는 문제를 회피할 수 있습니다.