import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class Main {

	public static void main(String[] args) {

		Socket cs = null;       // 클라이언트 담당 소켓 생성
		
		try {
			ServerSocket svs = new ServerSocket(1234);   // 서버 소켓 생성
			
			System.out.println("접속 대기중");
			
			cs = svs.accept();
			
			System.out.println("IP:"+ cs.getInetAddress()+"port: "+cs.getPort());
			
      // recv
      
			BufferedReader reader = new BufferedReader(new InputStreamReader(cs.getInputStream()));  // 담당 소켓의 스트림으로부터 데이터 읽어들임
			
			String pecket = reader.readLine();  // 한줄씩 문자열 읽어옴
			
			System.out.println("client로 부터 받은 데이터: "+pecket );
			
      // send (서버의 보내기는 받은 내용을 다른 host로 보내는 기능을 한다.)
      
			PrintWriter pw = new PrintWriter (cs.getOutputStream());  // cs(클라이언트소켓)의 스트림에서 출력
			pw.println(pecket); 
			pw.flush();  // 반드시 flush를 해줘야 정상 작동 한다.
			
			cs.close();
			svs.close();
			
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.util.Scanner;

public class Main {

	public static void main(String[] args) {

	
		Scanner sc = new Scanner(System.in);
		InetSocketAddress sockAddr = new InetSocketAddress("127.0.0.1", 1234); // 127.0.0.1 의 부분에 접속할 서버 IP 입력 , 포트넘버 입력
		Socket clientsc = new Socket();  // 클라이언트 소켓 생성
		
		try {
			clientsc.connect(sockAddr);  // connect을 통해 서버 접속
			
			InetAddress ia; // 확인용
			if((ia = clientsc.getInetAddress())!=null) {
				System.out.println("connect success" + ia);
			}
			else {
				System.out.println("connect fail");
			}
			
			System.out.print("전송할 텍스트 입력: ");   
			String pecket = sc.next();
			
      //send
      
			PrintWriter pw = new PrintWriter(clientsc.getOutputStream());   //소켓을 통해 위에서 입력 받은 텍스트 출력
			pw.println(pecket);		//실제 송신 
			pw.flush();

			//recv
      
			BufferedReader reader = new BufferedReader(new InputStreamReader(clientsc.getInputStream())); //소켓을 통해 들어온 문자열 입력
			String str = reader.readLine(); // 한줄씩 인식
			System.out.println("Server로 부터 받은 데이터: "+str);
			
			clientsc.close();
			
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

import java.io.Serializable;

// Serialize(직렬화) 전송 -> 순서를 정해야 한다. 
// Network, web 에서 송수신을 할때 반드시 적어 주어야 한다.
// dto는 서버에도 있어야 하며 클라이언트도 있어야한다. (둘다 직렬화가 되어있어야 한다.)

public class MemberDto implements Serializable{

	/**
	 * 
	 */
	private static final long serialVersionUID = 7159726773562029167L;
	private int number;
	private String name;
	
	public MemberDto() {
	}

	public MemberDto(int number, String name) {
		super();
		this.number = number;
		this.name = name;
	}

	public int getNumber() {
		return number;
	}

	public void setNumber(int number) {
		this.number = number;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	@Override
	public String toString() {
		return "MemberDto [number=" + number + ", name=" + name + "]";
	}
}

import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;

import dto.MemberDto;

public class Main {

	public static void main(String[] args) throws Exception{

		ServerSocket serSocket = new ServerSocket(9000);
		
		System.out.println("대기중...");
		Socket socket = serSocket.accept();
		
		System.out.println("client IP: "+socket.getInetAddress()  //들어온 소켓의 IP 및 포트 넘버출력
									+" Port: "+socket.getPort());
		
		//recv 
		ObjectInputStream ois = new ObjectInputStream(socket.getInputStream()); // ObjectInputSrteam 인스턴스 생성 소켓으로 받은 내용 읽어들임
		//MemberDto dto = (MemberDto)ois.readObject(); // 멤버dto의 클래스 형 변환 
		Object obj = ois.readObject();        // 위의 방법 대로 형변환을 해주어서 받을 수도 있고 Object로 바로 받을 수 있다.
		
		//System.out.println("client로 부터 Dto: "+dto.toString());
		
		//send
		ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream()); 
		//oos.writeObject(dto);  // 변현환 된 dto는 다시 Object로 담길수 있기 때문에 바로 전송 가능
		oos.writeObject(obj);    // 만약 object로 받으면 그대로 넣어서 송신 가능하다.
		
		oos.flush();
		serSocket.close();
	}
}

import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Socket;

import dto.MemberDto;

public class Main {

	public static void main(String[] args)throws Exception {

		InetSocketAddress sockAddr = new InetSocketAddress("127.0.0.1", 9000); // 수신받을 서버의 IP와 포트넘버 기입
		Socket socket = new Socket();
		
		socket.connect(sockAddr);     // 접속 까지는 방식이 String과 같다.
		
		InetAddress inetAddr; // 접속 확인용
		if((inetAddr = socket.getInetAddress()) != null){
			System.out.println("Server connect success: "+ inetAddr);
			
		}else {
			System.out.println("Server connect fail");
		}
		
		MemberDto sendDto = new MemberDto(111,"홍길동");     // 송신할 인스턴스를 생성한다.
		
		// send 부터
		ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
		oos.writeObject(sendDto);
		oos.flush();
		
		//recv
		ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
		MemberDto recvDto = (MemberDto)ois.readObject();
		
		System.out.println("Server로부터 받은 Dto: "+recvDto.toString());
		socket.close();
	}
}