|
| 목록으로 | 수정 | 삭제 | 정보추가[reply] | 신규입력 |
|
별도의 설명은 추가하지 않습니다. 소스안의 주석처리만으로도 프로그램을 분석하는데 별 어려움이 없을것 같아.... // 서버 // ============================================================ // Message Server 4 (Multi Client) // date : 2003 // make : pwg // note : 다중 클라이언트가 브라우져를 통해 접속하고 // 이를 벡터에 추가하여 클라이언트가 전달한 메시지를 // 나머지 클라이언트들에게 전송하도록 작성함. // msgServer3 과 소스내용 동일함. // ============================================================ import java.io.*; import java.net.*; import java.util.*; public class msgServer4 { ServerSocket server; // 서버용 소켓 Vector VecClient; // 접속한 클라이언트 소켓 벡터에 저장 Socket socket; // 처리될 소켓 Client client; // 실시간으로 각 클라이언트에서 메시지가 수신되었는를 체크, 처리 Vector VecMessage; // 수신된 메시지들을 벡터에 저장 public msgServer4() { VecClient = new Vector(); // 접속 클라이언트 저장 VecMessage = new Vector(); // 수신된 메시지 저장 msgInit(); // 벡터에 저장된 메시지 초기화 try { server = new ServerSocket(7777); System.out.println("Server Starting(msgServer4)..."); acceptProcess(); } catch (Exception e) { System.out.println("Starting error " + e); } } // 클라이언트가 접속되면 클라이언트별로 클래스를 만들고 메시지를 실시간으로 수신하도록 조치 public void acceptProcess() { while(true) { try { System.out.println("clinet accepting..."); socket = server.accept(); // 클라이언트가 접속되었는가 if(socket == null) break; client= new Client(socket); // 접속된 소켓을 가지고 클라이너트 쓰레드 생성 VecClient.addElement(client); // 접속된 소켓정보를 벡터에 저장 sendMsgAll(client); // 현재 접속자에게 저장된 메시지 전송 client.start(); // 각 클라이언트별 쓰레드 시작 System.out.println("add Client..."); } catch (Exception e) { System.out.println("Client accept error..."); } } } // 처음 클라이언트가 접속되면 현재 서버가 가지고 있는 메시지 전부를 해당 클라이언트에게 // 모두 전송한다. public void sendMsgAll(Client c) { for(Enumeration enum = VecMessage.elements() ; enum.hasMoreElements();) { c.send.println((String)enum.nextElement()); } } // 접속된 모든 클라이언트에게 새롭게 추가된 메시지를 전송한다. public void sendProcess(String m) { int cnt=0; for(Enumeration enum = VecClient.elements() ; enum.hasMoreElements();) { cnt++; Client c = (Client)enum.nextElement(); c.send.println(m); //c.send.flush(); System.out.println("No=[" + cnt +"]"+ m); } } // 접속된 모든 클라이너트별로 클래스가 만들어지고 쓰레드가 작동된다. class Client extends Thread { Socket clientSocket; String msg; // 메시지 송수신에 필요한 객체들. InputStream input; InputStreamReader reader; BufferedReader receive; OutputStream output; OutputStreamWriter writer; PrintWriter send; // 서버가 accept한 소켓을 가지고 Client 객체를 만들고, // Client 가 메시지를 송수신 할수 있도록 객체 생성. public Client(Socket socket) { clientSocket = socket; try { input = clientSocket.getInputStream(); reader = new InputStreamReader(input); receive = new BufferedReader(reader); output = clientSocket.getOutputStream(); writer = new OutputStreamWriter(output); send = new PrintWriter(writer,true); } catch (Exception e) { System.out.println("Stream error..."); } } // Client별로 쓰레도 작동(메시지 수신여부 체크) public void run() { while(true) { try { Thread.sleep(500); msg = receive.readLine(); if(msg==null) { msg="null"; continue; } // 수신된 메시지가 이와 같으면 서버가 가지고 있는 메시지 벡터 // 를 초기화 한다. if(msg.equals("message_init")) { msgInit(); allClientMsgInit(); continue; } // 수신된 메시지가 이와 같으면 서버에 저장된 클라이언트 정보를 // 벡터에서 제거한다. if(msg.equals("client_close")) { clientCloseProcess(); continue; } System.out.println(msg); VecMessage.addElement(msg); sendProcess(msg); } catch (Exception e) { System.out.println("readLine error..."); } } } // 서버가 가지고 있는 클라이언트 정보를 벡터에서 제거한다. // 이렇게 함으로써 불필요한 클라이언트에 대한 정보를 // 제거한다. public void clientCloseProcess() { System.out.println("Client cnt= " + VecClient.size()); try { receive.close(); send.close(); } catch (Exception e) { System.out.println("Closing error.."); } VecClient.removeElement(this); VecClient.trimToSize(); System.out.println("Client cnt= " + VecClient.size()); this.stop(); } } // inner Client class end // 메시지 초기화 public void msgInit() { VecMessage.removeAllElements(); VecMessage.trimToSize(); VecMessage.addElement("message_init"); VecMessage.addElement("안녕하세요. 좋은 하루 되십시요..."); } // 접속되어 있는 모든 클라이언트의 메시지를 초기화 한다. public void allClientMsgInit() { String str; for(Enumeration c=VecClient.elements() ; c.hasMoreElements();) { Client client=(Client)c.nextElement(); for(Enumeration m=VecMessage.elements() ; m.hasMoreElements();) { str = (String)m.nextElement(); client.send.println(str); } } } public static void main(String[] args) { msgServer4 f = new msgServer4(); } } // 클라이언트 // ======================================================= // client socket test 4(Applet) // msg client // date : 2003 // make : pwg // note : java ver 1.3 // applet version // 한개의 서버에 다중 클라이언가 접속하여 메시지 주고 받기 // 실시간 메시지 표시기능으로 전환 // ======================================================= import java.net.*; import java.io.*; import java.awt.*; import java.applet.*; import java.awt.event.*; import java.util.*; public class msgClient4 extends Applet implements ActionListener { Socket socket; //현재 제어할 클라이언트 소켓 TextField txtSendMsg; // 입력할 문자열 Button btnSend; // 메시지 전송 버튼 Label msg; // 서버로 부터 전달 받은 메시지들 표시 String serverAddress = "studyto.cafe24.com"; // 연결할 서버주소 int portNumber = 7777; // 연결할 포트번호 Vector VecMessage; // 서버에서 받은 메시지 저장 벡터 Receive r; // 메시지 수신 클래스(쓰래드로 작동) viewMessage v; // 벡터에 저장된 메시지를 한개씩 표시 // 메시지 수신에 필요한 객체들 InputStream input; InputStreamReader reader; BufferedReader receive; // 메시지 송신에 필요한 객체들 OutputStream output; OutputStreamWriter writer; PrintWriter send; // 브라우져가 최초로 띄워졌을때 초기화 public void init() { setLayout(null); setBackground(new Color(255,255,255)); VecMessage = new Vector(); msg = new Label(); msg.setBounds(0,0,595,30); msg.setBackground(new Color(255,255,0)); msg.setForeground(new Color(0,0,255)); add(msg); txtSendMsg = new TextField(); txtSendMsg.setBounds(0,32,500,20); add(txtSendMsg); btnSend = new Button("send"); btnSend.setBounds(503,32,92,20); add(btnSend); btnSend.addActionListener(this); } // 브라우저를 리로드할때 public void start() { if(socket !=null) { disConnectProcess(); // 리로드한 브라우저의 소켓을 제거 } v = new viewMessage(); // 메시지를 표시하는 쓰레드 작동 v.start(); connectProcess(); // 소켓 새롭게 생성및 연결 r = new Receive(); // 메시지 수신에 관계한 쓰레드 작동 r.start(); } // 브라우저가 다른 URL로 이동할때 소켓에 관계된 내용 제거 public void stop() { if(socket !=null) { disConnectProcess(); } } // 브라우저를 종료시켰을때 소켓에 관계된 내용 제거 public void destroy() { if(socket !=null) { disConnectProcess(); } } // 소켓 연결 public void connectProcess() { try { socket = new Socket(serverAddress,portNumber); //socket.setSoTimeout(1); if(socket !=null) // 소켓이 정상적으로 연결되었다면 { VecMessage.removeAllElements(); // 가지고 있는 메시지 모두 제거한후 // 메시지를 수신하고 송신할 수 있도록 객체 연결작업 input = socket.getInputStream(); reader = new InputStreamReader(input); receive = new BufferedReader(reader); output = socket.getOutputStream(); writer = new OutputStreamWriter(output); send = new PrintWriter(writer,true); } } catch (Exception e) { msg.setText("connect error" + e); } } // 각 클라이언트가 입력한 메시지 서버로 전송 public void sendMsg() { String txt = txtSendMsg.getText(); if(txt != null) { send.println(txt); txtSendMsg.setText(""); } } public void actionPerformed(ActionEvent e) { if(e.getActionCommand() == "send") // "send" 버튼이 눌려지면 { sendMsg(); // 메시지 전송 } } // 소켓 연결이 끊어지면 서버에 자신이 종료되었음을 알리고, // 작동되었던 쓰레드를 중지 한다. public void disConnectProcess() { send.println("client_close"); r.stop(); v.stop(); } // 서버로 부터 전송받은 메시지를 벡터에서 하나씩 꺼내 타자치는 효과를 주어 // 한줄씩 표시한다. class viewMessage extends Thread { int locate,len=0,i; String strVector=new String(); int msgTotCnt; public viewMessage() { locate=0; // 표시할 메시지의 위치 msgTotCnt = VecMessage.size(); // 벡터에 저장된 메시지의 총 개수. } public void run() { msgTotCnt = VecMessage.size(); while(true) { try { Thread.sleep(2000); // 2초마다 메시지를 바꾸어 표시한다. msgTotCnt = VecMessage.size(); if(locate >= msgTotCnt) locate=0; if(msgTotCnt <1) continue; strVector= "[" + (locate+1) + " / " + msgTotCnt + "] " + (String)VecMessage.elementAt(locate); len = strVector.length(); for(i = 0 ; i<=len ; i++) { msg.setText(strVector.substring(0,i)); try { Thread.sleep(77); } catch (Exception e){} } locate++; }catch (Exception e){msg.setText("run error" + e);} } } }; // 서버로 부터 메시지를 수신받는다. class Receive extends Thread { int enum,i,msgCnt; int msgTotCnt = VecMessage.size(); int len; String str; String strVector; int locate=0; public void run() { i=1; while(true) { try { Thread.sleep(500); str = receive.readLine(); // 메시지 수신 msg.setText("Receive message " + i); if(str.equals("message_init")) // 메시지의 내용이 이와 같은면 메시지 초기화 { VecMessage.removeAllElements(); continue; } if( str!= null) { VecMessage.addElement(str) ; } i++; }catch (Exception e){msg.setText("readling error" + e );} } // while end } // run() end }; // inner class end } |
| 목록으로 | 수정 | 삭제 | 정보추가[reply] | 신규입력 |