JAVA - 채팅프로그래밍.

어렵다 어려워 코드를 계속 짜면서도 이게 뭔가...

네이밍 센스도 구려서.. 코드 네이밍 규칙을 따로 공부해야하나 싶을정도 ㅋㅋㅋㅋㅋㅋㅋㅋ

하루가 다르게 실력이 느는게 아니라 

하루가 다르게 코드가 어색해 지고 바보가 되는 것 같은 이상한 기분...

그래도 계속 살펴보자.

ClientGUI.java 

GUI를 뿌려주는 것 외에도, 클라이언트니까 서버로 데이터 전송및 수신 기능이 있다.

public class ClientGUI implements ActionListener{ //Field JFrame Login, Main; Label ip,id; TextField txtip, txtid, submit; JTextArea svStatus,otherCli,myName; TextArea field; Panel panip,panid,pan; Panel pStat,pFild,pOther,pSubmit,pField; Button btnCon,btnSubmit,btnClose; JScrollPane jsp; Label client; String sid; public static String sip; Socket socket ; ObjectInputStream ois; ObjectOutputStream oos; Message msg; //Constructor public ClientGUI(){ Main = new JFrame("채튕!"); field = new TextArea(14,35); field .setEditable(false); jsp = new JScrollPane(field); client = new Label("0 명 접속중."); client.setBackground(Color.WHITE); // svStatus = new JTextArea(1,15); svStatus.setEditable(false); otherCli = new JTextArea("참가자명단\n",1,24); otherCli.setEditable(false); myName = new JTextArea(1,4); myName .setEditable(false); submit = new TextField(21); btnSubmit = new Button("전송"); btnClose = new Button("종료"); pStat = new Panel(); pStat.setBackground(Color.black); pFild = new Panel(new FlowLayout(FlowLayout.LEFT)); pOther = new Panel(); pField = new Panel(); pField.setBackground(Color.black); pSubmit = new Panel(); pSubmit.setBackground(Color.black); Login = new JFrame("Login"); ip = new Label("Server IP Setting :"); id = new Label("Set User Name : "); txtip = new TextField(17); txtid = new TextField(17); btnCon = new Button("Connect"); pan = new Panel(new FlowLayout(FlowLayout.LEFT)); panip = new Panel(); panid = new Panel(); panip.add(ip,BorderLayout.CENTER); panip.add(txtip); panid.add(id); panid.add(txtid); pan.add(panip); pan.add(panid); Login.add(pan); Login.add(btnCon, BorderLayout.SOUTH); Login.setVisible(true); Login.setSize(300, 150); Login.setLocation(550,300); Login.setResizable(false); Login.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); btnCon.addActionListener(this); submit.addActionListener(this); btnSubmit.addActionListener(this); btnClose.addActionListener(this); }/*******************Login view 생성자***********************/ //Method public void connect(String ip, int port){ try{ socket = new Socket(ip,port); oos = new ObjectOutputStream(socket.getOutputStream()); ois = new ObjectInputStream(socket.getInputStream()); msg = new Message(sid, " 님이 입장하셨습니다.", 0); oos.writeObject(msg); oos.flush(); }catch(Exception e){} new ClientThread().start(); } /*******************Main View***********************/ public void secondView(){ pStat.add(client); pStat.add(svStatus); pStat.add(btnClose); pFild.add(jsp); pOther.add(otherCli); pField.add(pFild); pField.add(pOther); pSubmit.add(myName); pSubmit.add(submit) ;pSubmit.add(btnSubmit); Main.add(pStat,BorderLayout.NORTH); Main.add(pField,BorderLayout.CENTER); Main.add(pSubmit,BorderLayout.SOUTH); Main.setSize(300, 390); Main.setLocation(550,250); Main.setResizable(false); Main.setVisible(true); Main.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); }//second view end class ClientThread extends Thread{ public void run(){ while(true){ try{ //서버에서 온 데이터 수신(p-4) Message msg = (Message)ois.readObject(); String id = msg.getID(); String data = msg.getContents(); field.append("["+id+"]"+data+"\n"); Vector v = msg.getuserList(); otherCli.setText(""+v); client.setText(v.size()+ " 명 접속"); System.out.println("서버에서 넘어온 데이터 : " + data); System.out.println("p-4 : 문자수신 완료"); }catch(Exception e){} } } }//end of ClientThread class @Override public void actionPerformed(ActionEvent e) { if(e.getActionCommand()=="Connect"){ sip = txtip.getText().trim(); sid = txtid.getText().trim(); Login.setVisible(false); try { connect(sip, 3000); secondView(); myName.setText(sid); } catch (Exception e2) {} }else if(e.getSource() == submit || e.getActionCommand() == "전송"){ String str = submit.getText().trim(); try { msg = new Message(sid, str, 1); oos.writeObject(msg); oos.flush(); } catch (Exception e2) {} submit.setText(""); submit.requestFocus(); System.out.println("전송끝"); } } }

Client.java 

just excute class

public class Client { public static void main(String[] args) { ClientGUI cg = new ClientGUI(); // SimpleClient sc = new SimpleClient(); } }

---

이제 서버 단인데, 큰 기능으로는 각 클라이언트에 정보를 쓰레드 객체를 통해 동시에 제공하고, 

synchronized 과 Message.java 를 통해 DTO를 만들어 데이터를 통신한다...? 이정도

Server.java

public class Server { ServerSocket server; Socket socket; public Server(){ try { //서버 소켓생성 System.out.println("스레드 소켓 생성"); server = new ServerSocket(3000); } catch (IOException e) {} } public void StartServer(){ try { while(true){ System.out.println("accept진입"); //생성된 뒤에 accept 되어짐. socket = server.accept(); System.out.println("accpet . . . . "); //서버챗터 라는 독립적인 객체(스레드) 를 생성. ChatterThread chatter = new ChatterThread(socket); chatter.start();//run 메소드 실행. } } catch (Exception e){} } }

ChatterThread.java

public class ChatterThread extends Thread{ static final Vector userlist = new Vector(); static final Vector outlist = new Vector(); Socket socket; String host ; ObjectInputStream ois; ObjectOutputStream oos; Message s_msg; boolean conn = true; // 1번. public ChatterThread(Socket socket){ socket = socket; try { ois = new ObjectInputStream(socket.getInputStream()); oos = new ObjectOutputStream(socket.getOutputStream()); } catch (Exception e) {} } //.start(); 에 의해 run() 실행됨. public void run(){ //conn=false 즉 종료 -1 될때까지 실행. while(conn){ try { s_msg = (Message) ois.readObject(); String str = s_msg.getID(); int status = s_msg.getuserSatus(); if(status == 0){ synchronized(userlist){ synchronized(outlist){ userlist.addElement(str); outlist.addElement(oos); Vector v = (Vector)userlist.clone(); s_msg.setuserList(v); broadcast(); } } }else if (status == 1){ Vector v = (Vector)userlist.clone(); s_msg.setuserList(v); broadcast(); }else if (status == -1){ userlist.remove(s_msg.getID()); outlist.remove(oos); Vector v = (Vector)userlist.clone(); s_msg.setuserList(v); broadcast(); conn=false; ois.close(); oos.close(); socket.close(); } } catch (Exception e) {} } }//while public void broadcast(){ for(int i=0; i<outlist.size();i++){ try { ObjectOutputStream os = (ObjectOutputStream)outlist.get(i); os.writeObject(s_msg); os.flush(); } catch (Exception e) {} } }//broadcast }//Chatter class

Message.java

/**Serializable !! * 데이터를 보낼때 string int 는 스텍 * vector는 힙 이따구로 막 따로 놀기도하고 * 아무튼 데이터 유실될 수도 있는데 * 시리얼라이저블을 이용하면 * 데이터가 한번에 묶여서 이동할때까지 유실되지 않는다. **/ public class Message implements Serializable{ //Field 유저ID, 대화내용, 대화상태, 사용자목록. private String userID,contents; private int Status; private Vector userList; //Constructor public Message(){} public Message(String userID, String contents, int Status){ this.userID=userID; this.contents=contents; this.Status=Status; } public Message(String userID, String contents, int Status, Vector userList){ this.userID=userID; this.contents=contents; this.Status=Status; this.userList=userList; } //Method //받을 인자값을 지정해준다 (String id) public void setID(String id){ //필드에 선언된 스트링값에 받은 인자값을 저장한다. this.userID = id; } // 가진 데이터를 넘겨주는 getID String type. public String getID(){ return userID; // = return this.userID; } public void setContents(String contents){ this.contents = contents; } public String getContents(){ return contents; } public void setuserList(Vector userlist){ this.userList = userlist; } public Vector getuserList(){ return userList; } public void setuserSatus(int userStat){ this.Status = userStat; } public int getuserSatus(){ return Status; } }

ExcuteServer.java

public class ExcuteServer { public static void main(String[] args) { Server sv = new Server(); sv.StartServer(); } }

조금 더 수정, 보완할 부분들이 있긴한데 두시간이상 바라볼 수가없다

퍄퍄퍄퍄퍄퍄 아직 이해도 제대로 못햇는데 뭔 수정,보완 개소리죠 왈왈

광광우럭따