[Network/Java] 자바 소켓 통신

💬 요구 사항

Java socket 통신을 구현
java_server.java 와 java_client.java로 구성

 

📌 Server 코드

서버 소켓 생성

 

ServerSocket serverSocket = new ServerSocket(9000);

 

 

서버는 client 접속을 대기하다가 client가 접속하면 accept 해준다

Socket socket = serverSocket.accept();

 

접속된 클라이언트의 주소를 출력

System.out.println("Connected by ( " + socket.getLocalAddress()+ ", "+ socket.getLocalPort()+ ") ");

 

Client가 보낸 메세지 출력

• 버퍼를 사용하면 입출력의 효율이 높아진다
• 상대방이 보낸 버퍼를 읽으려면 Socket의 기능 중 Stream을 불러와 InputStreanReader 객체에 담는다

BufferedReader bufReader = new BufferedReader( new InputStreamReader( socket.getInputStream()));
String message = bufReader.readLine();
System.out.println("Message : " + message );

 

Client에 데이터 전송

BufferedWriter bufWriter = new BufferedWriter( new OutputStreamWriter( socket.getOutputStream()));

 

받은 문자열을 다시 클라이언트에 전송

bufWriter.write(message);

 

버퍼 개행

bufWriter.newLine();

 

버퍼에 남은 데이터 출력

bufWriter.flush();

 

클라이언트, 서버 소켓을 모두 닫는다

socket.close();
serverSocket.close();
bufReader.close();
bufWriter.close();

 

Server 전체 코드

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;


public class Java_server {
    public static void main(String[] args ) {
        try {
        	
            ServerSocket serverSocket = new ServerSocket(9000);
            Socket socket = serverSocket.accept();
            
            System.out.println("Connected by ( " + socket.getLocalAddress()+ ", "+ socket.getLocalPort()+ ") ");
            
            BufferedReader bufReader = new BufferedReader( new InputStreamReader( socket.getInputStream()));
            String message = bufReader.readLine();
            System.out.println("Message : " + message );
          
            BufferedWriter bufWriter = new BufferedWriter( new OutputStreamWriter( socket.getOutputStream()));
           
            bufWriter.write(message);
            bufWriter.newLine();
            bufWriter.flush();
            
            socket.close();
            serverSocket.close();
            bufReader.close();
            bufWriter.close();
          }

          catch( Exception e ) {
            e.printStackTrace();
          }
     }

 

---

 

📌 Client 코드

서버 접속, localhost 9000번 포트에 접속

Socket socket = new Socket("127.0.0.1", 9000);​

 

서버에 보낼 데이터를 쓴다

• 버퍼를 사용하면 입출력의 효율이 높아진다
• Socket에 기능 중 Stream을 불러와 OutPutStreamWriter 객체에 담는다

BufferedWriter bufWriter = new BufferedWriter( new OutputStreamWriter( socket.getOutputStream()));

 

버퍼 출력

bufWriter.write("hello world");

 

버퍼 개행

bufWriter.newLine();

 

남아 있는 데이터 모두 출력

bufWriter.flush();

 

서버가 보낸 데이터 출력

BufferedReader bufReader = new BufferedReader( new InputStreamReader( socket.getInputStream()));
String message = bufReader.readLine();
System.out.println("Message : " + message );

 

Client 전체 코드

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;

public class Java_client {
    public static void main(String[] args ) {
        try {
            
            Socket socket = new Socket("127.0.0.1", 9000);
            BufferedWriter bufWriter = new BufferedWriter( new OutputStreamWriter( socket.getOutputStream()));
            bufWriter.write("hello world");
            bufWriter.newLine();
            bufWriter.flush();

            BufferedReader bufReader = new BufferedReader( new InputStreamReader( socket.getInputStream()));
            String message = bufReader.readLine();
            System.out.println("Message : " + message );

            socket.close();
            bufReader.close();
            bufWriter.close();
            }
        
          catch( Exception e ){
            e.printStackTrace();
          }
    }
}

 

결과