|
| 목록으로 | 수정 | 삭제 | 정보추가[reply] | 신규입력 |
|
소스에 대한 별다른 설명은 추가하지 않습니다. 소스내에게 있는 주석만으로도 이해 할수 있으리란 기대로... // 서버 // ============================================================ // Message Server 3 (Multi Client) // date : 2003 // make : pwg // note : 다중 클라이언트가 브라우져를 통해 접속하고 // 이를 벡터에 추가하여 클라이언트가 전달한 메시지를 // 나머지 클라이언트들에게 전송하도록 작성함. // ============================================================ import java.io.*; import java.net.*; import java.util.*; public class msgServer3 { ServerSocket server; Vector VecClient; // 접속된 클라이언트 소켓 저장 Socket socket; // 현재 제어될 클라이언트 소켓 Client client; // 메시지를 실시간으로 받기 위한 클라이언트 public msgServer3() { VecClient = new Vector(); // 접속 클라이언트 저장하기 위해 벡터 생성 try { server = new ServerSocket(7776); System.out.println("Server Starting..."); acceptProcess(); } catch (Exception e) { System.out.println("Starting error " + e); } } public void acceptProcess() { while(true) { try { System.out.println("clinet accepting..."); // 클라이언트로 부터 접속이 되면 해당 소켓을 벡터에 저장하고 // clinet 클래스의 쓰레드를 시작한다. socket = server.accept(); if(socket != null) { client= new Client(socket); VecClient.addElement(client); client.start(); System.out.println("add Client..."); } } catch (Exception e) { System.out.println("Client accept error..."); } } } // 전달된 메시지를 각 클라이언트에게 전달한다. 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; // 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..."); } } // 실시간으로 메시지를 수신한다. public void run() { while(true) { try { Thread.sleep(500); msg = receive.readLine(); // 메시시 수신 if(msg==null) { msg="null"; return; } // 클라이언트 브라우져가 종료되거나 다시 시작하면 // 서버에 저장된 클라이언트 정보 제거 if(msg.equals("socket_close")) { closeRtn(); } System.out.println(msg); sendProcess(msg); } catch (Exception e) { System.out.println("readLine error..."); } } } // 서버에 있는 클라이언트 정보 제거 public void closeRtn() { 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 static void main(String[] args) { msgServer3 f = new msgServer3(); } } // 클라이언트 // ======================================================= // client socket test 3(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 msgClient3 extends Applet implements ActionListener,KeyListener { Socket socket; TextField txtAddress, txtSendMsg; Button btnConnect,btnSend; TextArea msg; int portNumber = 7776; // 실시간으로 메시지를 수신하는 클래스 인스턴스 Receive r; InputStream input; InputStreamReader reader; BufferedReader receive; OutputStream output; OutputStreamWriter writer; PrintWriter send; public void init() { setLayout(null); txtAddress = new TextField("studyto.cafe24.com"); txtAddress.setBounds(0,0,100,20); add(txtAddress); btnConnect = new Button("connect"); btnConnect.setBounds(105,0,70,20); add(btnConnect); btnConnect.addActionListener(this); msg = new TextArea(); msg.setBounds(0,22,200,70); add(msg); txtSendMsg = new TextField(); txtSendMsg.setBounds(0,95,100,20); txtSendMsg.addKeyListener(this); // 엔터키를 처리하기 위한 리스너 add(txtSendMsg); btnSend = new Button("send"); btnSend.setBounds(105,95,70,20); add(btnSend); btnSend.addActionListener(this); } // 현재 브라우져가 다시 로딩되면 소켓을 닫았다가 다시 생성 public void start() { if(socket !=null) { disConnectProcess(); } connectProcess(); r = new Receive(); r.start(); } // 브라우져가 종료되면 서버에 종료 메시지 전달 public void stop() { if(socket !=null) { disConnectProcess(); } } // 브라우져가 완전히 종료되면 종료 메시지 전달 public void destroy() { if(socket !=null) { disConnectProcess(); } } // 송수신에 필요한 객체들과 소켓 생성 public void connectProcess() { try { socket = new Socket(txtAddress.getText(),portNumber); if(socket !=null) { 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.append("connect error"+e+"\n"); } } // 서버로 메시지 전달 public void sendMsg() { String txt = txtSendMsg.getText(); if(txt != null) { send.println(txt); txtSendMsg.setText(""); } } // 버튼에 대한 이벤트 처리 public void actionPerformed(ActionEvent e) { // connect 버튼을 클릭했을때 if(e.getActionCommand() == "connect") { if(socket != null) // 현재 소켓이 존재하면 소켓을 닫고 { disConnectProcess(); } connectProcess(); // 소켓 생성 r = new Receive(); // 실시간으로 메시지 수신 쓰레드 시작 r.start(); } if(e.getActionCommand() == "send") { if(socket !=null) sendMsg(); } } // 엔터키가 눌려지면 메시지 전송 public void keyPressed(KeyEvent e) { if(e.getKeyCode() == KeyEvent.VK_ENTER) { if(socket !=null) sendMsg(); } } public void keyTyped(KeyEvent e) { } public void keyReleased(KeyEvent e) { } // 소켓이 종료되면 쓰레드 종료 송수신 객체 제거 public void disConnectProcess() { send.println("socket_close"); try { send.close(); receive.close(); r.stop(); } catch (Exception e) { } } // 실시간으로 메시지를 수신하는 클래스 // 쓰레드로 작동 class Receive extends Thread { String txtMsg; public void run() { while(true) { try { Thread.sleep(500); txtMsg=receive.readLine(); if(txtMsg !=null) { msg.append(txtMsg+"\n"); } } catch (Exception e) { } } } }; } |
| 목록으로 | 수정 | 삭제 | 정보추가[reply] | 신규입력 |