(22.10.27)Java 프로그래밍: Stream실습 ByteStream, 직렬화 Serialization

Stream을 이용한 실습

msg1의 내용을 msg2로 보내고 msg2의 내용을 msg1으로 보내는 기능을 만들어 보라

 

 

프로그램 구동 전 문서 

 

 

 

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.FileWriter;
 
public class StreamMain 
{
    public static void main(String[] args) 
    {
        fileSwap();
    }
    private static void fileSwap() {
        String fpath1 = "D:/java_test/msg1.txt";
        String fpath2 = "D:/java_test/msg2.txt";
        //msg1.txt의 내용을 로드하여 덮어쓰기 되지 않도록 한다.
        try {
            BufferedReader br1 = new BufferedReader(new FileReader(fpath1));
            String msg1 = br1.readLine();
            br1.close();
            
            BufferedReader br2 = new BufferedReader(new FileReader(fpath2));
            String msg2 = br2.readLine();
            br2.close();
            
            FileWriter fw1 = new FileWriter(fpath1);
            fw1.write(msg2);
            fw1.close();
            
            FileWriter fw2 = new FileWriter(fpath2);
            fw2.write(msg1);
            fw2.close();
            
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

읽은 정보들을 메모리에 올려 놓고 덮여쓰이지 않게 한다. 바로 프린트 하면 내용이 지워지기에 그럼 정보 교환이 되지 않는다.

 

프로그램 구동후 바뀐 msg 내용

---

Binary 데이터 다루기

Bytes Stream: 문자 이외의 데이터를 다룰 수 있는 스트림 

 

 

지정해준 사진 파일의 바이트 수를 몇번 읽는지 확인해보기

import java.io.FileInputStream;
 
public class StreamMain 
{
    public static void main(String[] args) 
    {
        String imgPath = "D:/java_test/health.jfif";
        try {
            FileInputStream fin = new FileInputStream(imgPath);
            byte[] buf = new byte[1024];
            int read = fin.read(buf);
            
            while((read=fin.read(buf))!=-1) {
                System.out.println(read);
            }
            //이미지의 한바이트는 0~255로 이루어져있다.(2^8)
            // 1개 화소에 3바이트 (R 1바이트 G 1바이트 B 1바이트)
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

콘솔값:

1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
1024
914

 

 

---

Byte 스트림을 사용하여 파일에 있는 이미지 원본을 복사하여 파일에 사본 이미지 파일 생성하기

 

파일 입력 스트림과 파일 출력 스트림을 이용하여 사본 이미지 만들기

import java.io.FileOutputStream;
import java.io.FileInputStream;
 
public class StreamMain 
{
    public static void main(String[] args) 
    {
        String imgPath = "D:/java_test/health.jfif";
        try {
            FileInputStream fin = new FileInputStream(imgPath);
            byte[] buf = new byte[1024];
            FileOutputStream fout = new FileOutputStream("D:/java_test/health_2.jfif");
            int read = 0;
            while((read=fin.read(buf))!=-1) {
                fout.write(buf, 0, read);
            }
            fin.close();
            fout.close();
            System.out.println("이미지 복사 성공");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

프로그램 실행 후

---

텍스트 데이터를 Byte 스트림으로 읽어서  화면에 텍스트로 출력하기

 

import java.io.File;
import java.io.FileInputStream;
 
public class StreamMain 
{
    public static void main(String[] args) 
    {
        File f = new File("D:/java_test/info.txt");
        int len = (int)f.length(); //파일의 크기를 알 수 있다.
        System.out.println("파일 크기" + len);
        
        try {
            FileInputStream fin = new FileInputStream(f);
            byte[] buf = new byte[len];
            int read = fin.read(buf);
            System.out.println("읽어온 바이트 수" + read);
        } catch (Exception e) {
            
            e.printStackTrace();
        }
    }
}

실제 파일의 크기

콘솔 값:

문자열 생성자를 쓰면 Byte 스트림으로 읽어온 데이터를 문자로 출력해 볼 수 있다.

---

 

필터스트림을 추가하여 Byte 스트림을 이용하여 문자열 생성자를 안쓰고 문자 출력해보기

 

원본 문서

 

import java.io.File;
import java.io.FileInputStream;
import java.io.InputStreamReader;
 
public class StreamMain 
{
    public static void main(String[] args) 
    {
        File f = new File("D:/java_test/info.txt");
        try {
            FileInputStream fin = new FileInputStream(f);
            InputStreamReader isr = new InputStreamReader(fin);
            int ch = isr.read();
            System.out.println((char)ch);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

InputStreamReader은 필터스트림(가공스트림)으로 문자를 바이트 스트림으로 읽었을 때 다시 문자로 바꿔준다. 이 때 한글자만 읽어 왔으므로 콘솔값에는 원본 문서의 제일 첫번째 글자인 1이 나왔다.

 

---

 

import java.io.File;
import java.io.FileInputStream;
import java.io.InputStreamReader;
 
public class StreamMain 
{
    public static void main(String[] args) 
    {
        File f = new File("D:/java_test/info.txt");
        try {
            FileInputStream fin = new FileInputStream(f);
            InputStreamReader isr = new InputStreamReader(fin);
            BufferedReader br = new BufferedReader(isr);
            String line = null;
            while((line=br.readLine())!=null) {
                System.out.println(line);
            }
            br.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

콘솔 값:

1|해린|01066665555
2|민지|01066667777
3|하니|01033335555
4|혜린|01022225555
5|다니엘|01055558888

---

바이트배열로 이미지를 로드해서 하드디스크에 저장해보기

 

ByteArrayInputStream / OutputStream

이미지 파일을 메모리에 byte[]형식으로 로드

 

FileInputStream  → ByteArrayOutputStream(메모리에 byte[]에 출력)

write() 기능을 실행할 때 read 크기만큼 쓰게끔 해서 쓰레기 데이터가 더 붙지않고 원본과 똑같은 크기의 파일을 복사할 수 있었다.

 

---

writeImage 메소드에 위의 img 배열을 전달하여 그 메소드안에서 파일에 쓰게한다.

파일명은 imgCpy

 

import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
 
public class Stream2Main 
{
    public static void main(String[] args) 
    {
        File imgFile = new File("D:/java_test/health.jfif");
        System.out.println("파일 존재?:"+ imgFile.exists());
        //파일이 존재하는지 유무 확인
        try {
            FileInputStream fin = new FileInputStream(imgFile);
            ByteArrayOutputStream bos = new ByteArrayOutputStream();
            byte[] buf = new byte[1024];
            while(true) {
                int read = fin.read(buf);
                if(read==-1) break;
                bos.write(buf, 0, read);
            }
            byte[] img = bos.toByteArray(); //이미지 정보가 모두 담긴 바이트 배열
            System.out.println("파일 사이즈?:"+ img.length);
            
            writeImage(img);
            
        } catch (Exception e) {
            e.printStackTrace();
        }    
    }
    public static void writeImage(byte[] img) {
        try {
            FileOutputStream fout = new FileOutputStream("D:/java_test/imgCpy.jfif");
            fout.write(img, 0, img.length);
            fout.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

결과 확인:

생성된 이미지를 확인할 수 있다. 기능별로 메소드를 나눌 수 있다.

---

●직렬화●

 

객체의 직렬화 (Object Serialization) : 오브젝트를 다른 컴퓨터로 전송할 때, 디스크에 객체를 저장할 때 쓰인다.

역직렬화 De - Serialization :직렬화 된 객체를 다시 복원할 때 쓰인다.

 

예시

객체를 직렬화하여 파일에 저장하기  emp.obj 파일이 생성된 걸 확인할 수 있다.

이때 직렬화할 객체는 Serializable 마크 인터 페이스를 달아줘야한다.

 

import java.io.Serializable;
 
public class Employee implements Serializable //마크 인터페이스
{
    private int empno;  
    private String ename; 
    private int deptno;
    private String hiredate;
    
    public Employee(String[] strings) {}
    public Employee() {} 
    public Employee(int empno, String ename, int deptno, String hiredate) {
        this.setEmpno(empno);
        this.setEname(ename);
        this.setDeptno(deptno);
        this.setHiredate(hiredate);
    }
    public String Employeelist() {
        
        return String.format("%d\t%s\t%d\t%s", 
                empno,ename,deptno,hiredate);
    }
    public int getEmpno() {
        return empno;
    }
    public void setEmpno(int empno) {
        this.empno = empno;
    }
    public String getEname() {
        return ename;
    }
    public void setEname(String ename) {
        this.ename = ename;
    }
    public int getDeptno() {
        return deptno;
    }
    public void setDeptno(int deptno) {
        this.deptno = deptno;
    }
    public String getHiredate() {
        return hiredate;
    }
    public void setHiredate(String hiredate) {
        this.hiredate = hiredate;
    }
    
}

 

다시 역직렬화 하여 디스크에 저장된 emp.obj 파일을 객체로서 확인하기

 

import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
 
import com.ezen.javaoop.Employee;
 
public class SerializationTest 
{
    public static void main(String[] args) 
    {
        Employee emp = new Employee();
        //직렬화 할 객체는 개발자가 클래스에 표시해줘야 한다.(마크 인터페이스)
        emp.setEmpno(11);
        emp.setEname("주현");
        emp.setDeptno(20);
        emp.setHiredate("22-10-27");
        System.out.println("원본 오브젝트:"+emp.Employeelist());
        
        
        try {
            FileOutputStream fout = new FileOutputStream("D:/java_test/emp.obj");
            ObjectOutputStream obj = new ObjectOutputStream(fout);
            obj.writeObject(emp); //객체 직렬화 및 파일에 저장
            System.out.println("Employee 오브젝트 직렬화 성공");
        } catch (Exception e) {
            System.err.println("Employee 오브젝트 직렬화 실패");
            e.printStackTrace();
        }
        deSerialization("D:/java_test/emp.obj");
    }
    public static void deSerialization(String objPath) {
        try {
            FileInputStream fin = new FileInputStream(objPath);
            ObjectInputStream oin = new ObjectInputStream(fin);
            Employee emp = (Employee)oin.readObject();
            System.out.println("복원된 Employee 객체:"+ emp.Employeelist());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

콘솔 값:

원본 오브젝트:11 주현 20 22-10-27
Employee 오브젝트 직렬화 성공
복원된 Employee 객체:11 주현 20 22-10-27

---

리스트에 Employee 오브젝트를 하나 추가하고 리스트를 직렬화 하여 파일에 저장한후 다시 리스트를 복원하여 리스트안에 Employee 오브젝트가 제대로 작동하게 해보시오.

 

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.ArrayList;
 
import com.ezen.javaoop.Employee;
 
public class SerializationTest 
{
    public static void main(String[] args) 
    {
        listSerialize();
        listdeSerialization("D:/java_test/emplist.obj");
        
    }
    
    public static void listSerialize() {
        ArrayList<Employee> list = new ArrayList<>();
        list.add(new Employee(2,"강해린",30,"22-10-27"));
        try {
            File f = new File("D:/java_test/emplist.obj");
            FileOutputStream fout = new FileOutputStream(f);
            ObjectOutputStream obj = new ObjectOutputStream(fout);
            obj.writeObject(list); 
            System.out.println("Employee list 오브젝트 직렬화 성공");
        } catch (Exception e) {
            System.err.println("Employee list 오브젝트 직렬화 실패");
            e.printStackTrace();
        }
    }
    public static void listdeSerialization(String f) {
        try {
            FileInputStream fin = new FileInputStream(f);
            ObjectInputStream oin = new ObjectInputStream(fin);
            ArrayList<Employee> list2 = (ArrayList<Employee>)oin.readObject();
            System.out.println("복원된 Employee list 객체:"+ list2.get(0));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}