JAVA 채팅 프로그램 해설 및 주석하며 리뷰

처음부터 다시 주석달면서 정리한 버전의 채팅프로그램.

SimpleServer

/* 서버가 하는일! : ServerSocket 만들기, aceept상태 구성, Thread로 만들어서 IO통신 */ public class R_SimpleServer { //Field - 클래스 전체에서 사용하기 위해서 필드에 선언 ServerSocket server; Socket s; //Constructor //R_SimpleServer 즉 기본 생성자에서 socket생성 public R_SimpleServer(){ try { // 1. 서버생성 : ServerSocket 생성 System.out.println("1 서버 생성."); server = new ServerSocket(3000); System.out.println("1-1 서버 실행."); while(true){ // 2. 접속대기 : accept에 있다가 socket 즉 s 에 담김. s = server.accept(); System.out.println("2 접속 대기상태"); // 3. 클라이언트 송수신 할 Thread 생성! // 길을 만들기 위해서는 accept에서 반환한 "s"에 담겨있는 길 즉 Stream이 필요하다. R_ServerChatter chatter = new R_ServerChatter(s); chatter.start(); // Thread 실행 } } catch (Exception e) {e.printStackTrace();} } //Method }

ServerChatter Thread

// R_ServerChatter 는 Thread 이다. public class R_ServerChatter extends Thread{ //Field // 소켓을 받아오니까 소켓필요 Socket s; // 길을 만드는 작업 Object 타입으로 만들자 ObjectInputStream ois; ObjectOutputStream oos; //Client와 소통하는건 server 가 아닌 독립적 쓰레드라 msg가 여깃음. R_Message msg; //Constructor //소켓타입 s를 반환하는 생성자 public R_ServerChatter(Socket s){ // socket받아서 s에다가 넣으면 됨. this.s = s; //길을 받아왔다. try { // s즉 소켓에 담겨있는 Stream을 받아온다. ois = new ObjectInputStream(s.getInputStream()); oos = new ObjectOutputStream(s.getOutputStream()); } catch (IOException e) {e.printStackTrace();} }//Constructor //Method //Thread는 반드시 독립적으로 실행 및 종료가 되기때문에 반드시 run()을 오버라이딩 해야한다. //run에서는 송수신을 독립적으로 실행 및 종료를 한다. public void run(){ try { // 클라이언트한테 받아온 정보를 다시 보내는 작업. //process - 2 : client 에서 넘어온 Message 객체를 수신! msg = (R_Message)ois.readObject();// R_Message 타입으로 넘어온데이터이기 때문에 명시해줌. String Contents = msg.getTalk(); // Merry xmas 내용을 뽑아옴 System.out.println("process 2 : 수신완료."); //process - 3 : client 로 Message 객체를 송신! (보낸다) //Contents값이 null 이 아니면 계속 전송한ㄴ다. while(Contents != null){ msg.setTalk(Contents+" 저는 서버에요"); // 뽑아온 내용이 저장된 Contents + "" 전송 oos.writeObject(msg); oos.flush(); System.out.println("process 3 : 전송완료."); msg = (R_Message)ois.readObject();// R_Message 타입으로 넘어온데이터이기 때문에 명시해줌. Contents = msg.getTalk(); // Merry xmas 내용을 뽑아옴 System.out.println("process 2 : 수신완료."); } } catch (Exception e) {} }//run }

Client

public class R_SimpleClient implements ActionListener{ //Field Socket s; ObjectOutputStream oos; ObjectInputStream ois; //Message를 객체로 만들어서 보낼 것이므로 생성. R_Message msg; //UI 적용 JFrame j = new JFrame(); TextArea ta = new TextArea(); TextField tf = new TextField(); //Constructor public R_SimpleClient() { j.add(ta, BorderLayout.CENTER); ta.enable(false); j.add(tf, BorderLayout.SOUTH); j.setSize(300,400); j.setVisible(true); tf.addActionListener(this); //길을 만드는 작업. try { System.out.println("1111"); s = new Socket("127.0.0.1",3000); System.out.println("2222"); //먼저 보낼꺼니까 oos oos = new ObjectOutputStream(s.getOutputStream()); ois = new ObjectInputStream(s.getInputStream()); System.out.println("33"); } catch (Exception e) {e.printStackTrace();} System.out.println("44"); new Chat().start(); System.out.println("55"); // chatting(); }//end Constructor //Method // public void chatting(){ class Chat extends Thread{ public void run(){ while(true){ try { System.out.println("66"); //process - 4 : server에서 받은 내용 수신 msg = (R_Message)ois.readObject(); String uid = msg.getUserid(); String uContents = msg.getTalk(); ta.append(uContents); System.out.println("process 4 : 수신 완료. 그리고 내용"); System.out.println("--------------------끝."); } catch (Exception e1) {e1.printStackTrace();} } } } public void actionPerformed(ActionEvent arg0) { String str = tf.getText().trim(); System.out.println("엔터 겟 텍스트"); try { msg = new R_Message("ID",str); System.out.println("메세지"); oos.writeObject(msg); oos.flush(); System.out.println("플러쉬"); } catch (Exception e2) {} tf.setText(""); tf.requestFocus(); } }

Message

//network 송수신 데이터는 얼음땡 즉 Serializable //Serializable : userid, talk 는 메모리에 잡힘 전송될때 메모리의 값까지 함께 보낸다. public class R_Message implements Serializable{ //Field //다른 사람들이 접근하면 안되니까 private ,private이면 set,getter 로 접근해야함. private String user_id=""; //아이디 private String talk=""; //ㄴ채팅내용 //Constructor public R_Message(String id, String talk){ this.user_id = id; this.talk = talk; } //Method public void setUserid(String id){ this.user_id = id; } public String getUserid(){ return user_id; } public void setTalk(String talk){ this.talk = talk; } public String getTalk(){ return talk; } }

서버가 실행되면, 서버는 accept 상태에서 호출을 기다리게 되고

server = new ServerSocket(3000);

while(true){

s = server.accept(); 까지 실행됨

이후 클라이언트가 실행하면서  

s = new Socket("127.0.0.1",3000); 

으로 서버에 요청을 하면

서버는 s 즉 소켓을 Thread 로 값을 넘겨준다

(소켓타입의 Thread로 반환)

R_ServerChatter chatter = new R_ServerChatter(s); << 이부분

chatter.start(); // Thread 실행

그럼 Thread는 소켓타입으로 반환하여 s 를 저장하고 

public R_ServerChatter(Socket s){

this.s = s; 

갖고 있는 Socket 으로 길을 연다 여기서 형태는 object 타입

try {

ois = new ObjectInputStream(s.getInputStream());

oos = new ObjectOutputStream(s.getOutputStream());

그리고 chatter.start(); 에 의해 run() method가 호출되어.

msg = (R_Message)ois.readObject();

msg에 R_Message 타입으로 object들을 읽어서 넣는다.

---

* 여기서 Message 객체를 만든 이유는 여러가지 type 의 객체들을 묶어서 통신 하기 위함인데,

int

string

vector

이런식으로 이루어진 data를 통신하기 위해 Message 객체를 따로 두어서 한번에 보낸다

또 여기서 한번에 보낼때 stack에 있는 data (int) , Heap에 저장되는 data (vector)들이 유실되거나

못읽어오는 경우가 발생할 수 있기때문에 serializable 화를 하여 한번에 캡슐화 하는 것이다.

---

그 뒤 Line 48~ 를 살펴보면 

Contents에 Message의 talk(채팅내용) 이 없을때 까지 while문을 반복시킨다.

String Contents = msg.getTalk();

while(Contents != null){

msg.setTalk(Contents); 

oos.writeObject(msg);

    oos.flush();

System.out.println("process 3 : 전송완료.");

while의 내용은

msg에 ois.readObject(); 으로 클라이언트가 전송한 값이 저장되어 있으므로

이를 setTalk 하여

msg에 저장하고 그 값을 다시 전송하는것이다.

---

여기서 문제는 값을 다시 받아와서 뿌려줘야 하는데 받았던 값을 계속 뿌려주던 것이다.

*캡쳐하는 와중에도 계속 (Contents+" 저는 서버에요") 라는 문자를 찍어주는 모습

새로운 값을 받아서 contents에 넣고 다시 뿌려주는 작업이 되지 않았는데 이유는

public void run(){

try {

msg = (R_Message)ois.readObject();

String Contents = msg.getTalk();

while(Contents != null){

msg.setTalk(Contents+" 저는 서버에요");

oos.writeObject(msg);

oos.flush();

System.out.println("process 3 : 전송완료.");

msg = (R_Message)ois.readObject();

Contents = msg.getTalk();

}

} catch (Exception e) {}

}//run

flush() 한 뒤로 contents 는 계속 null 값이 아니기 때문에 계속 flush() 만 하고있는것이다.

즉 새로운 값을 입력받고 비교받고 다시 입력받고 이과정이 반복 되야 하기에 

msg = (R_Message)ois.readObject();

Contents = msg.getTalk();

이 부분이 while문에 추가되어야 하는 것이다.

---

구조는 이러하다 

클라이언트가 입력한 정보를 msg에 넣어 서버로 송신하여 그 내용을 묶어서 다시 클라이언트에 전송한다.

이제 마지막 

4번 과정 즉 클라이언트에 출력만 하면되는데.

class Chat extends Thread{

public void run(){

while(true){

try {

//process - 4 : server에서 받은 내용 수신

msg = (R_Message)ois.readObject();

String uid = msg.getUserid();

String uContents = msg.getTalk();

ta.append(uContents);

System.out.println("process 4 : 수신 완료. 그리고 내용");

System.out.println("--------------------끝.");

} catch (Exception e1) {e1.printStackTrace();}

}

}

}

이런 스레드를 만들어 처리하였다 (굳이 뭐..)

그냥 ta = TextArea에 계속 반복하여 뿌려주는게 전부.

스스로 정리하면서 코딩하니까 미약하게나마 정리가 된다. ㅠㅠ 근데 아직 모르는 부분이 넘많아

4번 왜 반복하는데 계속 안뿌리지? 값이 어디로 날아감 ㅡㅡ?