[JAVA] TCP 통신 예제

서버

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
 
import javax.swing.plaf.synth.SynthSeparatorUI;
 
public class TcpServer {
    public static void main(String[] args) {
        
        try {
            ServerSocket serSocket = new ServerSocket (5001);
            
            Socket client = serSocket.accept();
            BufferedWriter w = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
            BufferedReader r = new BufferedReader(new InputStreamReader(client.getInputStream()));
            
            
            String UserName = "";
            
            while(true){
                
                if(UserName.equals("")){
                    UserName = r.readLine() + "(" + client.getInetAddress().getHostAddress() +")";
                    System.out.println("유저이름저장완료!");
                    continue;
                }
                
                String data = r.readLine().trim();
                
                if(data.equals("quit"))
                    break;
            
                w.write(UserName +" : " +  data + "\n");
                w.flush();
                
                
            }
            
            w.close();
            r.close();
            serSocket.close();
            client.close();
            
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
}
 

ServerSocket  : 서버 소켓 생성 - ServerSocket(포트번호)

serSocket.accept() : 클라이언트 접솔을 기다림

BufferedWriter : 클라이언트에 보내기위해

BufferedReader : 클라이언트에서 보내온 걸 읽기위해

.write() : 클라이언트에 보낼 정보를 쓰기

.flush() : 버퍼를 비움

.readLine() : BufferedReader로 클라이언트에서 보내온 걸 한줄씩 읽음

.close() : 자원 해제

클라이언트

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
 
import javax.swing.plaf.synth.SynthSeparatorUI;
 
public class TcpClient {    
    public static void main(String[] args) {
        Scanner sc = new Scanner(System.in);    
        
        try {
            
            System.out.print("서버 아이피를 입력 하시오 ! : ");
            String ip = sc.nextLine();
                        
            Socket socket = new Socket( InetAddress.getByName(ip) , 5001);
                
            String UserName= "";
            BufferedWriter w = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            BufferedReader r = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            
            while(true){
                if(UserName.equals("")){
                    System.out.print("유저 이름 설정 : ");
                    String str = sc.next();
                    w.write(str + "\n");
                    w.flush();
                    
                    UserName= str;
                    continue;
                }
                
                    System.out.print("채팅할 말 : ");
                    String str = sc.next();
            
                    w.write(str + "\n");
                    w.flush();
                    
                    
                    if(str.equals("quit"))
                        break;
                    
                    
                    String data = r.readLine().trim();
                    System.out.println(data);
            }
            
            socket.close();
            w.close();
            r.close();
                        
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        
    }
}
 

Socket : 서버와 연결하기위해 소켓 생성 - ip, port

InetAddress.getByName(ip) : InetAddress로 ip 관리

BufferedWriter : 서버에 보낼 정보를 쓰기위해

BufferedReader : 서버에 보내온 정보를 받기위해

.write() : 서버에 보낼 정보를 쓰기

.flush() : 버퍼를 비움

.readLine() : BufferedReader로 서버에서 보내온 걸 한줄씩 읽음

.close() : 자원 해제

결과 : 

서버

유저이름저장완료!    //클라이언트에서 보낸 유저이름을 저장

클라이언트

서버 아이피를 입력 하시오 ! : 0.0.0.0    //연결할 서버 아이피 주소

유저 이름 설정 : sime

채팅할 말 : Hi                //서버로 보냄

sime(192.168.0.12) : Hi       //서버에서 옴

채팅할 말 : 안녕?

sime(192.168.0.12) : 안녕?