수다닷컴

import java.io.*;
import java.net.*;
import java.util.*;
public class P2PUserServer {
private Hashtable users = null;

//호스트리스트를 초기화한다.
public P2PUserServer() {
//로그인한 호스트정보를 저장하기위한 해쉬테이블 객체를 초기화한다.
users = new Hashtable();
}

//연결된 호스트의 정보를 저장한다.
//호스트의 ID를 키로 사용하여 소켓을 해쉬테이블에 저장한다.
public void addHost(String id, Socket con) {
//동기화를 위해 synchronized를 사용한다.
synchronized(users) {
users.put(id,con);
}
}

//연결이 끊긴 호스트를 해쉬테이블에서 제거한다.
//인자로받은 ID에 해당하는 호스트를 리스트에서 제거한다.
public void removeHost(String id) {
synchronized(users) {
users.remove(id);
}
}

//호스트 정보(리스트)를 해쉬테이블로 반환한다.
public Hashtable getHostList() {
return users;
}

//호스트로부터 연결이 발생하면 쓰레드를 생성해 처리한다.
//서버소켓을 생성하고 연결이 발생하면 UserServerThread 클래스 객체를 생성하여 처리한다.
public void run(int port) {
try {
ServerSocket server = new ServerSocket(port);

while(true) {
Socket con = server.accept();
UserServerThread ust = new UserServerThread(this, con);
Thread t = new Thread(ust); //이부분이 에러가 나는데요, 자꾸 두번째 Thread에서 오류나네요
//cannot find symbol
//symbol : constructor Thread(UserServerThread)
//location: class java.lang.Thread 이라고요.. 헬프미.. t.start();
}
}catch(IOException ioe) {}
}

//호스트정보관리 서버의 메인 메서드
public static void main(String[] args) {
int port = 9000;
if(args.length==1)
port = Integer.parseInt(args[0]);

P2PUserServer server = new P2PUserServer();
server.run(port);
}
}
===========================================================================================================
import java.io.*;
import java.net.*;
import java.util.*;
//자바 보안 패키지를 수입한다.
import java.security.*;
import javax.crypto.*;
public class UserServerThread {
private P2PUserServer server = null;
private Socket con = null;
private DataInputStream dis =null;
private DataOutputStream dos = null;

private String id = null;
private String ip = null;
private long time = 0;
private MessageDigest md = null;

//소켓과 스트림 객체를 초기화한다.
public UserServerThread(P2PUserServer server, Socket con) {
this.server = server;
this.con = con;

Date d = new Date();
ip = con.getInetAddress().getHostAddress();
time = d.getTime();
String ptext = id + time;

byte[] buf = null;

try {
//접속 시간과 IP를 MD5로 해쉬하여 호스트 ID를 구한다.
md = MessageDigest.getInstance(MD5);
md.update(ptext.getBytes());
buf = md.digest();

//MD5해쉬를 해서 얻은 byte배열을 Base64형식으로 변환한다.
id = Base64.byteArrayToBase64String(buf);

//연결호스트 목록에 ID와 소켓을 저장한다.
server.addHost(id,con);
//연결된 호스트 정보를 출력한다.
System.out.println([호스트 접속]);
System.out.println(IP :+ip);
System.out.println(접속시간 :+d.toLocaleString());
System.out.println(ID :+id);
}catch(NoSuchAlgorithmException nsae) {
//MD5알고리즘을 처리할 수 없다면 NoSuchAlgoSuchAlgorithmException 을 발생시킨다.
}

try {
dis = new DataInputStream(con.getInputStream());
dos = new DataOutputStream(con.getOutputStream());

//호스트에 byte배열을 길이+byte배열 형태로 ID를 전송한다.
buf = id.getBytes();
dos.writeInt(buf.length);
dos.write(buf);
dos.flush();
}catch(IOException ioe) {}
}

//호스트로부터 메시지를 수신하여 처리한다.
public void run() {
try {
while(true) {
//수신한 정수값으로 다음 수신되는 데이터를 어떻게 처리할지 판단한다.
int code = dis.readInt();
}
}catch(IOException ioe) {
//소켓의 연결이 끊어지면 호스트의 연결이 종료되었음을 출력한다.
server.removeHost(id);
System.out.println([호스트 접속종료]);
System.out.println(IP :+ip);
System.out.println(ID :+id);
}catch(Exception e) {}
}

}유저쓰레드 소스부분입니다.

신청하기