|
| 목록으로 | 수정 | 삭제 | 정보추가[reply] | 신규입력 |
|
// mousePositionServer import java.io.*; import java.net.*; import java.util.*; class mousePositionServer { ServerSocket ss; // 서버 소켓 Vector clientList = new Vector(10,3); // 클라이언트 저장 벡터 ThreadClient client; // 수신 메시지 전송을 위한 클라이언트 // 클라이언트가 접속되었을때 처리 public void ConnectProcess() throws Exception { ss= new ServerSocket(4444); // 서버 시작 System.out.println("Multi Server Starting...."); while(true) { Socket s = ss.accept(); // 접근대기 // 접속된 클라이언트 소켓으로 스레드 객체 생성 ThreadClient tc=new ThreadClient(s); // 벡터에 저장 clientList.add(tc); tc.start(); // 클라이언트의 스레드 시작 } } // inner Class class ThreadClient extends Thread { Socket client; InputStream input; InputStreamReader reader; BufferedReader receive; OutputStream output; OutputStreamWriter writer; PrintWriter send; // 접속된 클라이언트 소켓을 인수로 스레드 생성. public ThreadClient(Socket s) { client = s; System.out.println("Thread starting...."); initStream(); } // 입출력 스트림 초기화 public void initStream() { try { input = client.getInputStream(); reader = new InputStreamReader(input); receive = new BufferedReader(reader); output = client.getOutputStream(); writer = new OutputStreamWriter(output); send = new PrintWriter(writer); }catch(Exception e){} } // 클라이언트로 부터 메시지가 전달되면 전달된 메시지를 갖고 // sendProcess()로 이동 public void run() { String str; while(true) { try { str = receive.readLine(); System.out.println(str); sleep(100); }catch(Exception e){} } } } // ThreadClient class(inner) end. public static void main(String args[]) throws Exception { mousePositionServer ms = new mousePositionServer(); ms.ConnectProcess(); } } |
| 목록으로 | 수정 | 삭제 | 정보추가[reply] | 신규입력 |