(22.10.31)Java 프로그래밍: Thread, Stream 실습 네트워크간 소통

키보드에서 숫자를 입력할 때마다 입력된 수의 구구단이 화면에 표시되는 기능을 무한히 반복한다.

그와 동시에 오늘 날짜를 1초에 한번씩 dates.txt 파일에 한행으로 기록하기를 무한히 반복한다.

만약 이용자가 숫자를 입력하는 대신 문자를  입력하면, 모든 기능이 정지되고 프로그램이 종료되도록한다.

Thread를 종료하려면 쓰레드가 실행하는 무한 루프를 완전히 종료하면 된다.

 

Daemon 쓰레드 : 어떤 쓰레드가 종료할 때, 그 쓰레드가 생성한 하위 쓰레드도 함께 종료되는 쓰레드

Main() 메소드는 자바에서 지원하는 Main Thread가 실행하도록 되어 있고, Main() 메소드 안에서 생성되는 쓰레드는 Main Thread의 하위 (자식) 쓰레드인 셈이다. 부모 쓰레드가 종료할 때 그 안에서 생성된 자식 쓰레드까지 종료 되도록 하려면, 자식 쓰레드를 생성할 때 참조변수가 t1이라면 t1.setDaemon(true)를 사용하면 된다. 이런 상태에서 부모 쓰레드가 종료되면 그 자식 쓰레드인 t1도 함께 종료한다. 

 

import java.io.FileWriter;
import java.io.*;
import java.io.PrintWriter;
import java.util.Date;
import java.util.Scanner;
 
public class ThreadMain 
{
    public static void main(String[] args) 
    {
        Thread gg = new Thread(
            new Runnable() {//익명 클래스(Anonymous Class)의 객체 생성
                @Override
                public void run() {
                    Code1();    
                }
            }
        );
        gg.setDaemon(true);
        gg.start();
 
        try {
            PrintWriter pw = new PrintWriter(new FileWriter("D:/java_test/dates.txt"));
            while(!exit) {
                pw.println(new Date());
                pw.flush();
                Thread.sleep(1000);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println("메인 쓰레드 종료");
    }
    static boolean exit = false;
    
    static void Code1(){
        boolean go = true;
        while(go) {
            System.out.println("단수를 입력하세요.");
            Scanner kbd = new Scanner(System.in);
            try {
                int inputnum = kbd.nextInt();
                kbd.nextLine();
                for(int i =1;i<10;i++) {
                    System.out.printf("%d * %d = %d\n",inputnum,i,inputnum*i);
                }
            } catch (Exception e) {
                exit = true;
            } 
        }
    }
}

콘솔 값:

단수를 입력하세요.
5
5 * 1 = 5
5 * 2 = 10
5 * 3 = 15
5 * 4 = 20
5 * 5 = 25
5 * 6 = 30
5 * 7 = 35
5 * 8 = 40
5 * 9 = 45
단수를 입력하세요.
6
6 * 1 = 6
6 * 2 = 12
6 * 3 = 18
6 * 4 = 24
6 * 5 = 30
6 * 6 = 36
6 * 7 = 42
6 * 8 = 48
6 * 9 = 54
단수를 입력하세요.
ㅁ
메인 쓰레드 종료

 

 

dates.txt 문서

deamon 쓰레드를 사용하여 code1에서 문자를 입력하면 메인 쓰레드에 있던 무한 루프에서 빠져나가게 되어 프로그램이 멈추고 함께 code1 메소드도 종료되게 만들었다. 실행후 문자를 입력하여 오류를 발생했더니 무한루프에서 빠져나가 프로그램이 끝났고 시간을 계속 찍어내는 루프도 약 8초간만 작동한 걸 확인할 수 있다.

---

Protocol :  통신 규약 (TCP/IP, HTTP)

자바에서 제공해주는 TCP 클래스 소켓 (Socket)과 서버 소켓(Sever socket)을 이용하여 네트워크간의 교류가 가능하다.

 

파일과 파일간의 데이터 이동 말고도 네트워크와 네트워크 간의 데이터 이동도 가능하다. 정보를 전달 또는 요청하는 컴퓨터를 클라이언트 컴퓨터라 하고 그것을 수신하여 결과를 보내주는 컴퓨터를 서버 컴퓨터라고 한다. 자바 코드에서도 요청하고 받고 다시 요청하고 받고 하는 일련의 과정들로 데이터를 전달 가능해 진다.

 

 

네트워크 데이터 이동 기초 맛보기

 

네트워크간의 데이터를 주고 받으려면 먼저 서버 컴퓨터가 돌아 가야한다. 서버 클래스를 실행시키면 클라이언트에서 신호를 기다리는 대기 상태로 있는다.

 

 

클라이언트 클래스를 실행시키면 입력해준 호스트의 포트로 연결을 한다. 

 

클라이언트와 잘 연결되어 프로그램이 마지막까지 실행된 걸 확인할 수 있다.

---

Stream을 이용한 네트워크간 데이터 이동(파워 코딩으로 간략한 로그인 시스템 맛보기)

 

Server 클래스 코드

import java.io.*;
import java.net.*;
 
public class Server 
{
    public static void main(String[] args) 
    {
        try { 
            ServerSocket ss = new ServerSocket(1234);
            //0~1024 : 이 포트들은 피해서 만든다.
            
            System.out.println("서버소켓 대기중");
            Socket s = ss.accept();//서버쪽에서 멈춰서 무한 대기 하다가 클라이언트가 
            //접속 요청을 하면 접속을 받아들이고 접속된 클라이언트와 통신하기 위한 Socket 생성
            System.out.println("클라이언트 접속됨");
            //접속 관리
            
            
            //클라이언트에게 메시지 호출
            OutputStream os = s.getOutputStream();
            OutputStreamWriter ow = new OutputStreamWriter(os);
            //문자열 데이터를 바이트 데이터로 변환해서 출력
            PrintWriter pw = new PrintWriter(ow);
            //문자열 한행한행을 출력
            
            pw.println("접속 성공");
            pw.flush(); //작은 데이터라도 출력하게끔 명령
            
            //클라이언트가 보내는 아이디 암호를 수신하고 인증을 수행한다.
            InputStream is = s.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String msg = br.readLine();
            String[] login = msg.split(" ");
            String uid = login[0];
            String upw = login[1];
            
            if(uid.equals("Smith")&&upw.equals("12345")) {
                pw.println("로그인 성공");
                pw.flush(); 
            }else {
                pw.println("로그인 실패");
                pw.flush(); 
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        System.out.println("서버 종료");
    }
}

 

Client 클래스 코드

import java.io.*;
import java.net.*;
 
public class Client
{
    public static void main(String[] args)
    {
        try {
            Socket s = new Socket("127.0.0.1",1234);//루프 백 아이피 주소
                                //(String host, int port)
            System.out.println("서버접속 성공");
            
            //서버에서 전송한 메시지를 수신한다
            InputStream is = s.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String msg = br.readLine();
            
            System.out.println("서버측에서 보내온 메세지:"+msg);
            
            if(msg.equals("접속 성공")) {
                OutputStream os = s.getOutputStream();
                OutputStreamWriter ow = new OutputStreamWriter(os);
                PrintWriter pw = new PrintWriter(ow);
                pw.println("Smith 12345");
                pw.flush();
                
                String loginresult = br.readLine();
                if(loginresult.equals("로그인 성공")) {
                    System.out.println("로그인 결과:"+loginresult);
                    //채팅 메시지를 송수신한다.
                    //무한 루프를 사용하여 채팅 메시지를 보내고 받는다
                    //키보드 입력 > 서버로전송 : 하나의 무한루프로 구성(출력기능)
                    //네트웍 입력 > 모니터 출력 : 하나의 무한 루프로 구성(입력 기능)
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println("클라이언트 종료");
    }
}

서버 콘솔 값:

서버소켓 대기중
클라이언트 접속됨
서버 종료

 

클라이언트 콘솔 값:

서버접속 성공
서버측에서 보내온 메세지:접속 성공
로그인 결과:로그인 성공
클라이언트 종료

 

스트림을 통해 정보를 보내고 받고 다시 보내고 받고의 과정을 반복해준다.

서버 클래스에서 접속성을 출력하면 클라이언트 클래스에서 입력 받고 그것이 조건문에 충족한다면 클라이언트 클래스에서 아이디와 비밀번호를 출력하고 서버 클래스에선 그 정보들을 입력 받는다. 받은 정보가 데이터 베이스에 있던 정보와 맞다면 로그인 성공을 출력하고 클라이언트 클래스에선 보낸 것을 입력 받는다.

 

서버 컴퓨터가 하는 일은 무한 대기하고 있다가 클라이언트 컴퓨터가 접속하면 통신한다. 근데 서버 컴퓨터라면 통신하면서 대기도 할 수 있게 병행처리 해야한다. 안그러면 한명이 서버를 이용하면 다른 이용자들이 이용하지 못한다. 이러한 방법을 해결하기 위해선  쓰레드 처리(통신용 전담 쓰레드 생성하여 실행) 를 해줘야한다.