📅 2023년 12월 27일

[java 16일차]

31일차: java 심화(9)

파일 처리

• 스트림(stream)
  자바에서는 파일이나 콘솔의 입출력을 직접 다루지않고, 스트림을 이용한다.
  동시에 수행하려면 입력스트림과 출력스트림 모두 필요하고 큐(queue)와 같은 FIFO 구조로 이루어져 있다.
  

• file

/*
버퍼 기능이 구현되어있고, nio 패키지에서는 non-blocking 방식 사용
기본이 StandardCharsets.UTF_8 이다.
*/
Path filePath = Paths.get("src/C17_Exception_File_Parsing/text_file.txt"
try {
	if(Files.exists(filePath)){
		Files.write(filePath, "손흥민\n".getBytes(), StandardOpenOption.WRITE);
	}else{
		Files.write(filePath, "손흥민\n".getBytes(), StandardOpenOption.CREATE_NEW);
	}
}catch (IOException e){
	e.printStackTrace();
}

// 파일 일기 : readString , readAllLines(List 형태)
try {
	String str = Files.readString(filePath);
	System.out.println(str);
}catch (IOException e){
	e.printStackTrace();
}
System.out.println();
try {
	List<String> stringList = Files.readAllLines(filePath);
	for(String str :stringList){
		System.out.println(str);
	}
}catch (IOException e) {
	e.printStackTrace();
}

• json

 // http 클라 생성
 HttpClient client = HttpClient.newHttpClient();
 ObjectMapper mapper = new ObjectMapper();
 // http 요청객체 생성
 HttpRequest request = HttpRequest.newBuilder()
               .uri(URI.create("https://jsonplaceholder.typicode.com/posts/1"))
                .GET()
                .build();
HttpRequest request1 = HttpRequest.newBuilder()
                .uri(URI.create("https://jsonplaceholder.typicode.com/posts"))
                .GET()
                .build();
// http 응답 객체 생성
try {
	HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
	JsonNode node = mapper.readTree(response.body());
	Post post = new Post(
		node.get("userId").asInt(),
		node.get("id").asInt(),
		node.get("title").asText(),
		node.get("body").asText()
	);
	Post post1 = mapper.readValue(response.body(),Post.class);
	/*
	json Node는 트리구조 이므로,
	for(JsonNode a : jsonNode) 형식으로 사용가능
	*/
	HttpResponse<String> response1 = client.send(request1, HttpResponse.BodyHandlers.ofString());
	ArrayList<Post> postArrayList = new ArrayList<>();
	JsonNode node1 = mapper.readTree(response1.body());
	for(JsonNode a : node1){
//  	Post post3 = new Post(
//  		a.get("userId").asInt(),
//  		a.get("id").asInt(),
//  		a.get("title").asText(),
//   		a.get("body").asText()
//      );
	Post post3 = mapper.readValue(a.toString(),Post.class);
	postArrayList.add(post3);
}
System.out.println(postArrayList);
// java 객체를 json 데이터로 정렬화
String serialized_data = mapper.writeValueAsString(postArrayList);
System.out.println(serialized_data);
} catch (IOException | InterruptedException e) {
	throw new RuntimeException(e);
}

스레드(Thread)

/*
Thread 클래스에 이미 구현되어 있는 run 메서드는 아무작업도 하지 않는 빈 메서드
작업하고 싶은 내용은 run() 메서드를 overriding 하여 정의할 수 있다.
상송관계이다 보니, 다른 클래스 상속 불가
 */
public class ExtendsThreadClass extends Thread{
    // run 메서드는 쓰레드가 시작되면 실행
    @Override
    public void run(){
        System.out.println("ExtendsThreadClass : " + Thread.currentThread().getName());
    }
}

public class RunnableImplementsClass implements Runnable {
    @Override
    public void run() {
        System.out.println("RunnableImplementsClass : "+ Thread.currentThread().getName());
    }
}

public class Library {
    static int bookCount = 100;
//    public  static  void barrowBook(){
//        if(bookCount>0){
//            try{
//                Thread.sleep(10);
//            } catch (InterruptedException e) {
//                throw new RuntimeException(e);
//            }
//
//            // 책 빌리는 시간
//            bookCount -= 1;
//            System.out.println("대출 완료");
//            System.out.println("남아있는 수량: " +bookCount);
//        }else{
//            System.out.println("대출 불가");
//        }
//    }
    // synchronized 키워드를 통해 해당 메서드 한해서는 lock걸도록 설정
    public synchronized static void barrowBook(){
        if(bookCount>0){
            try{
                Thread.sleep(10);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            // 책 빌리는 시간
            bookCount -= 1;
            System.out.println("대출 완료");
            System.out.println("남아있는 수량: " +bookCount);
        }else{
            System.out.println("대출 불가");
        }
    }
}

public class MainClass {
    public static void main(String[] args) {
        Thread etc1 = new ExtendsThreadClass();
        etc1.start();
        Thread etc2 = new ExtendsThreadClass();
        etc2.start();
        Thread etc3 = new ExtendsThreadClass();
        etc3.start();
        // 스레드 실행 시 순차적으로 실행되지 않음에 유의
        // 스레드 생성자로 Runnable 객체가 전달되어 사용자가 직접 정의 run 메서드가 실행
        new Thread(new RunnableImplementsClass()).start();
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("익명객체 스레드");
            }
        }).start();
        new Thread(() -> System.out.println("익명객체 람다 스레드")).start();
        // 스레드의 동시성 이슈 테스트
        // 단일 스레드 일반호출
        for (int i =0; i<1000; i++){
            Thread th = new Thread(Library::barrowBook);
            th.start();
            // join메서드를 통해 다른 스레드의 완료전까지 새로운 스레드가 실행되지 않도록 막음.
//            try {
//                th.join();
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            }
        }
        System.out.println("최종 남은 수량 "+ Library.bookCount);
    }
}

• 프로세스와 스레드
  프로세스 : cpu에 의해 메모리에 올려져 실행중인 프로그램
  스레드 : 실질적으로 작업을 실행하는 단위
  프로세스에는 적어도 한개 이상의 스레드가 있으며, Main 스레드 하나로 시작하여 스레드를 추가 생성하게 되면 멀티 스레드 환경이 된다.
• Thread 클래스를 상속받는 방법과 다른 하나는 Runnable 인터페이스를 구현하는 방법.
• 멀티스레드의 동시성문제를 java에선 join() 또는 syncronized으로 해결.
  • join() : 한 스레드가 완료될때까지 다른 스레드의 start를 하지 않도록 할 때 사용
  • syncronized: race condition이 발생할 수 있는 코드 영역을 보호할때 사용

github java 실습 내용