자바 서버 기초소스

import java.io.InputStream;

import java.io.ObjectInputStream;

import java.io.ObjectOutputStream;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.net.ServerSocket;

import java.net.Socket;

public class Server extends Thread {

private InputStream is;

private OutputStream os;

private ServerSocket serversocket;

private ObjectInputStream ois;

private ObjectOutputStream oos;

private Socket socket;

DB db;

/**

* @param args

*/

public void run() {

db = new DB();

try {

// 5000번 서버소켓 생성

serversocket = new ServerSocket(5555);

while (true) {

System.out.println("[Server Open]");

socket = serversocket.accept();

// 접속된 클라이언트 ip정보출력

System.out.println("[Connect client]: "

+ socket.getInetAddress());

is = socket.getInputStream();

os = socket.getOutputStream();

ois = new ObjectInputStream(is);

oos = new ObjectOutputStream(os);

// 클라이언트에서 스트림을 READ

String msg = (String) ois.readObject();

System.out.println("Server[Read] : " + msg);

// 클라이언트로 DB에서 리턴값 메시지전송

oos.writeObject(db.test(msg)); //이부분에서 전송

System.out.println("Server[Send] : " + db.test(msg));

// 한번입출력하고 소켓을 닫아주는 부분

socket.close();

}

} catch (Exception e) {

System.out.println("server " + e.toString());

}

}

public static void main(String[] args) {

// TODO Auto-generated method stub

Server server_start = new Server();

server_start.start();

}

}