서버
package ex20.ch01;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
public class MyServer01 {
public static void main(String[] args) {
try {
ServerSocket ss = new ServerSocket(20000); // 2만번 포트 만들고 대기
System.out.println("서버소켓이 대기중입니다. 연결을 시도 해주세요.");
Socket socket = ss.accept(); // 프로세스 대기
System.out.println("소켓이 연결되었습니다.");
BufferedReader br = new BufferedReader(
new InputStreamReader(socket.getInputStream())
);
String body = br.readLine();
System.out.println("서버측 : " + body);
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}클라이언트
package ex20.ch01;
import java.io.*;
import java.net.Socket;
public class MyClient01 {
public static void main(String[] args) {
try {
Socket socket = new Socket("localhost", 20000); // 소켓 연결
BufferedReader keyboard = new BufferedReader(new InputStreamReader(System.in));
System.out.println("키보드 입력 대기중...");
String msg = keyboard.readLine();
BufferedWriter bw = new BufferedWriter(
new OutputStreamWriter(socket.getOutputStream())
);
bw.write(msg);
bw.write("\n");
bw.flush();
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}Share article