(22.11.02)Java 프로그래밍: 네트워크 데이터 통신, Stream, 웹서버 프로그래밍

메시지와 수신자 송신자를 객체화 하여 객체를 바이트 데이터로 바꾸어 데이터 송수신 하기

 

ChatMsg 클래스 코드

import java.io.Serializable;
 
public class ChatMsg implements Serializable{
    private String sender;
    private String receiver;
    private String message;
    private String uid;
    private String upw;
    
    public ChatMsg() { }
 
    public ChatMsg(String sender, String receiver, String message) {
        super();
        this.sender = sender;
        this.receiver = receiver;
        this.message = message;
    }
    public ChatMsg(String msg) {
        this.message=msg;
    }
    
    public ChatMsg(String uid, String upw) {
        this.uid=uid;
        this.upw=upw;
    }
 
    public String getUid() {
        return uid;
    }
 
    public void setUid(String uid) {
        this.uid = uid;
    }
 
    public String getUpw() {
        return upw;
    }
 
    public void setUpw(String upw) {
        this.upw = upw;
    }
 
    public String getSender() {
        return sender;
    }
 
    public void setSender(String sender) {
        this.sender = sender;
    }
 
    public String getReceiver() {
        return receiver;
    }
 
    public void setReceiver(String receiver) {
        this.receiver = receiver;
    }
 
    public String getMessage() {
        return message;
    }
 
    public void setMessage(String message) {
        this.message = message;
    }
}

데이터를 객체화 할 ChatMsg 클래스를 먼저 만든다. 객체화 된 데이터는 직렬화를 통해 스트림으로 입력 출력되기 때문에  직렬화 인터페이스를 implements 해줘야한다.

 

클라이언트 클래스 코드

import java.io.*;
import java.net.*;
import java.util.Scanner;
 
public class Client
{
    public static void main(String[] args)
    {
        try {
            Socket s = new Socket("127.0.0.1",1234);
            System.out.println("서버접속 성공");
            
            //서버에서 전송한 메시지를 수신한다
            InputStream is = s.getInputStream();
            ObjectInputStream oin = new ObjectInputStream(is);
            
            
            new ClientThread(s, oin).start(); //네트워크 출력 쓰레드
            
            while(true) {//네트워크 입력 쓰레드
                ChatMsg m = (ChatMsg)oin.readObject();
                System.out.println("서버측에서 보내온 메세지:"+m.getMessage());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println("클라이언트 종료");
    }
    //네트워크 출력 기능을 담당할 클라이언트 측 쓰레드
    static class ClientThread extends Thread {
        Socket s;
        ObjectOutputStream oos;
        ObjectInputStream oin;
        boolean loginpass;
        ClientThread(Socket s,ObjectInputStream oin){
            this.s=s;
            this.oin=oin;
            try {
                ChatMsg msg = (ChatMsg)oin.readObject();
                System.out.println("서버측에서 보내온 메세지:"+msg);
                if(msg.getMessage().equals("접속 성공")) {
                    OutputStream os = s.getOutputStream();
                    this.oos = new ObjectOutputStream(os);
                    
                    loginpass = login();
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        @Override
        public void run() {
            Scanner kbd = new Scanner(System.in);
            while(true) {
                System.out.println("입력할 메시지:");
                String line = kbd.nextLine().strip();
                ChatMsg cmsg = new ChatMsg();
                cmsg.setSender("ChatMsg");
                cmsg.setReceiver("Laura");
                cmsg.setMessage(line);
                
                try {
                    oos.writeObject(cmsg);
                    oos.flush();
                    Thread.sleep(1000);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
        private boolean login() {
            
            try {
                ChatMsg msg = new ChatMsg("Smith", "12345");
                oos.writeObject(msg);
                oos.flush();
            } catch (IOException e1) {
                e1.printStackTrace();
            }
            
            String loginresult =null;
            try {
                loginresult = ((ChatMsg)oin.readObject()).getMessage();
                System.out.println("로그인 결과:"+loginresult);
            } catch (Exception e) {
                e.printStackTrace();
            }
            if(loginresult.equals("로그인 성공")) {
                return true;
            }else {
                return false;
            }
        }
    }            
}

텍스트데이터를 읽고 쓰는 스트림(ex PrintWriter)을 객체를 읽고 쓰는 스트림(ObjectOutputStream)으로 바꿔준다.

 

 

서버 클래스 코드

import java.io.*;
import java.net.*;
import java.util.ArrayList;
 
public class Server 
{
    static ArrayList<ObjectOutputStream> out = new ArrayList<ObjectOutputStream>();
    
    public static void main(String[] args) 
    {
        try { 
            ServerSocket ss = new ServerSocket(1234);
            while(true) {
                System.out.println("서버소켓 대기중");
                Socket s = ss.accept(); //무한대기하다가 클라이언트가 접속하면 소켓을 만들어냄
                System.out.println("클라이언트 접속됨");
                new CommThread(s).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        System.out.println("서버 종료");
    }
    //내부 클래스로 구현한 통신용 쓰레드
    static class CommThread extends Thread {
        private Socket s;
        private ObjectOutputStream oos;
        private ObjectInputStream oin;
        private boolean loginpass;
        CommThread(Socket s) {
            this.s = s;
            try {
                OutputStream os = s.getOutputStream();
                this.oos = new ObjectOutputStream(os);
                
                
                oos.writeObject(new ChatMsg("접속 성공"));
                oos.flush();
                
                loginpass = login();
                
            }catch (IOException e) {
                e.printStackTrace();
            }
        }
        @Override
        public void run() {
            if(loginpass) {
                try {
                    ObjectOutputStream toClient = null;
                    while(true) {
                        ChatMsg cmsg = (ChatMsg)oin.readObject();
                        String receiver = cmsg.getReceiver();
                        
                        for(int i=0;i<out.size();i++) {
                            toClient = out.get(i);
                            toClient.writeObject(cmsg);
                            toClient.flush();
                        }
                    }
                }catch (Exception e) {
                    System.err.println("클라이언트 나감");
                    out.remove(oos);
                    System.out.println("접속자수" + out.size());
                    
                }
            }
            System.out.println("통신 쓰레드 종료");
        }
        private boolean login() {
            try {
                InputStream is = s.getInputStream();
                this.oin = new ObjectInputStream(is);
                
                
                ChatMsg cmsg = (ChatMsg)oin.readObject();
                String uid = cmsg.getUid();
                String upw = cmsg.getUpw();
                
                if(uid.equals("Smith")&&upw.equals("12345")) {
                    out.add(oos); //모든 출력용 스트림을 한개의 리스트에 저장한다.
                    oos.writeObject(new ChatMsg("로그인 성공"));
                    oos.flush();
                    return true;
                }
            }catch (Exception e) {
                e.printStackTrace();
            }
            return false;
        }
    }
}

 

클라이언트를 2개 실행하고 한개를 종료 시킨뒤 서버클래스 콘솔 값:

 

클라이언트 클래스 콘솔 값:

 

terminated 된 클라이언트 클래스 콘솔 값:

 

---

클라이언트가 다른 클라이언트한테 메시지 보내기

List를 Map 으로 바꿔서 key를 아이디로 주어 수신자를 정해주면 그 수신자에게 메시지가 가게 하기

 

서버 클래스 코드

import java.io.*;
import java.net.*;
import java.util.HashMap;
 
public class Server 
{
    static HashMap<String, ObjectOutputStream> outmap = new HashMap<>();
    
    public static void main(String[] args) 
    {
        try { 
            
            ServerSocket ss = new ServerSocket(1234);
            while(true) {
                System.out.println("서버소켓 대기중");
                Socket s = ss.accept(); //무한대기하다가 클라이언트가 접속하면 소켓을 만들어냄
                System.out.println("클라이언트 접속됨");
                new CommThread(s).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        System.out.println("서버 종료");
    }
    //내부 클래스로 구현한 통신용 쓰레드
    static class CommThread extends Thread {
        private Socket s;
        private ObjectOutputStream oos;
        private ObjectInputStream oin;
        private boolean loginpass;
        private String uid;
        
        public String getUid() {
            return uid;
        }
        public void setUid(String uid) {
            this.uid = uid;
        }
        CommThread(Socket s) {
            this.s = s;
            try {
                OutputStream os = s.getOutputStream();
                this.oos = new ObjectOutputStream(os);
                
                
                oos.writeObject(new ChatMsg("접속 성공"));
                oos.flush();
                
                loginpass = login();
                
            }catch (IOException e) {
                e.printStackTrace();
            }
        }
        @Override
        public void run() {
            if(loginpass) {
                try {
                    ObjectOutputStream toClient = null;
                    while(true) {
                        ChatMsg cmsg = (ChatMsg)oin.readObject();//클라이언트에서 온 메시지 받기
                        String receiver = cmsg.getReceiver();
                        outmap.get(receiver).writeObject(cmsg);
                        outmap.get(receiver).flush();
                    }
                }catch (Exception e) {
                    System.err.println("클라이언트 나감");
                    outmap.remove(this.uid);
                    System.out.println("접속자수" + outmap.size());    
                }
            }
            System.out.println("통신 쓰레드 종료");
        }
        private boolean login() {
            try {
                InputStream is = s.getInputStream();
                this.oin = new ObjectInputStream(is);
                
                ChatMsg cmsg = (ChatMsg)oin.readObject();
                String uid = cmsg.getUid();
                String upw = cmsg.getUpw();
                
                if(!uid.equals("")&&uid!=null
                        &&!upw.equals("")&&upw!=null) {
                    this.uid=uid;
                    outmap.put(uid, oos); //map에 uid와 그사람의 출력스트림을 쌍으로 저장
                    oos.writeObject(new ChatMsg("로그인 성공"));
                    oos.flush();
                    return true;
                }
            }catch (Exception e) {
                e.printStackTrace();
            }
            return false;
        }
    }
}

ArrayList를 HashMap로 바꿔준다.

 

클라이언트 클래스 코드

import java.io.*;
import java.net.*;
import java.util.Scanner;
 
public class Client
{
    public static void main(String[] args)
    {
        try {
            Socket s = new Socket("127.0.0.1",1234);
            System.out.println("서버접속 성공");
            InputStream is = s.getInputStream();
            ObjectInputStream oin = new ObjectInputStream(is);
            
            new ClientThread(s, oin).start(); //네트워크 출력 쓰레드
            
            while(true) {//네트워크 입력 쓰레드
                ChatMsg m = (ChatMsg)oin.readObject();
                System.out.println("서버측에서 보내온 메세지:"+m.getMessage());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println("클라이언트 종료");
    }
    //네트워크 출력 기능을 담당할 클라이언트 측 쓰레드
    static class ClientThread extends Thread {
        Socket s;
        ObjectOutputStream oos;
        ObjectInputStream oin;
        boolean loginpass;
        ClientThread(Socket s,ObjectInputStream oin){
            this.s=s;
            this.oin=oin;
            try {
                ChatMsg msg = (ChatMsg)oin.readObject();
                System.out.println("서버측에서 보내온 메세지:"+msg.getMessage());
                if(msg.getMessage().equals("접속 성공")) {
                    OutputStream os = s.getOutputStream();
                    this.oos = new ObjectOutputStream(os);
                    
                    loginpass = login();
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        @Override
        public void run() {
            Scanner kbd = new Scanner(System.in);
            while(true) {
                System.out.println("입력할 메시지:");
                String line = kbd.nextLine().strip();
                System.out.println("수신자 명:");
                String rec = kbd.nextLine().strip();
                ChatMsg cmsg = new ChatMsg();
                cmsg.setReceiver(rec);
                cmsg.setMessage(line);
                try {
                    oos.writeObject(cmsg);
                    oos.flush();
                    Thread.sleep(1000);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
        private boolean login() {
            String loginresult = null;
            Scanner kbd = new Scanner(System.in);
            System.out.println("아이디 입력:");
            try {
                String uid = kbd.nextLine().strip();
                System.out.println("비밀번호 입력:");
                String upw = kbd.nextLine().strip();
                ChatMsg msg = new ChatMsg(uid, upw);
                oos.writeObject(msg);
                oos.flush();
 
                loginresult = ((ChatMsg)oin.readObject()).getMessage();
                System.out.println("로그인 결과:"+loginresult);
            } catch (Exception e) {
                e.printStackTrace();
            }
            if(loginresult.equals("로그인 성공")) {
                return true;
            }else {
                return false;
            }
        }
    }            
}

 

클라이언트를 두개 실행 시켜 각각 아이디를 다르게 주어 실행 했다.

 

클라이언트 1 콘솔값:

 

클라이언트2 콘솔 값:

 

클라이언트 1에서 클라이언트2를 수신자로 정해서 보낸 내용이 클라이언트1에선 보이지 않고 클라이언트 2에서만 보인다.

---

 

웹 서버 프로그래밍하기 위해선 Java, 통합개발환경(Eclipse), Web browser(ed Chrome), WAS (Web Application Server, ex Tomcat) 4가지가 갖춰져야한다.

톰캣을 다운받아 설정해준 포트로 들어가면 맞게 나온걸 확인할 수 있다.

톰캣 파일에 새 텍스트 문서를 하나 만들어서 html문서로 바꾸기

디버깅 해보기 위해서 메모장에 짧은 html양식을 맞춘 코드를 작성한다.

< / > 이렇게 되어 있는 것들은 데이터라 부르지 않고 태그라고 부르며 메타 데이터이다. 이것들은 데이터를 위한 데이터이다. 

 

 

완성된 html을 웹 브라우저에서 확인해 볼 수 있다.

글자색을 바꾸는 css 작업도 할 수 있다.

색은 RGB값으로 나타내어 코딩한다.

 

스크립트는 동적인 웹페이지를 만들때 쓰는데 무언가 행동을 하면 이벤트가 일어난다.

버튼을 만들어 클릭할 때 "안녕하세요~" 메세지가 나오게 만들었다.

---

기존까지는 자바 스탠다드 에디션으로 코딩했지만 다이나믹 프로그래밍, 웹 서버 프로그래밍을 할려면 자바 엔터프라이즈 에디션으로 코딩해야한다.(Java EE)

이클립스 Java EE 모드

메모장에서 만들던 html양식을 이클립스에서 지원해주는 것으로 쉽게 만들 수 있다.

 

 

package com.ezen.web.hello;
 
import java.io.IOException;
import java.io.PrintWriter;
 
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
 
@WebServlet("/test")
public class TestServlet extends HttpServlet 
{
    
    protected void service(HttpServletRequest request, HttpServletResponse response) 
            throws ServletException, IOException 
    {
        response.setContentType("text/html; charset=utf-8");
        PrintWriter pw = response.getWriter();
        pw.println("<? doctype html>");
        pw.println("<html>");
        pw.println("<meta charset='utf-8'>");
        pw.println("<head><title>서블릿으로 응답 만들기</title>");
        pw.println("<body>");
        pw.println("<h1>서블릿으로 html 응답하기</h1>");
        pw.println("</body>");
        pw.println("</head>");
        pw.println("</html>");
        pw.flush();
    }
}

Servlet 파일 서버에서 돌아가는 작은 프로그램

 

Run on Server 실행 결과

소스 보기