Network Programming

네트워크를 통해서 데이터를 주고 받는 프로그래밍
Server & Client
- 서버 : 사용자들에게 서비스를 제공하는 컴퓨터
- 클라이언트 : 서버에게 서비스를 요청해서 사용하는 컴퓨터
IP Address : 인터넷에서 사용하는 컴퓨터의 주소
Port : 가상의 통신 선로
Host Name, DNS, URL
- DNS (Domain Name System) : 숫자 대신 기호를 사용하는 주소
- DNS 서버 : 기호 주소를 숫자 주소로 변환해주는 서버
- URL (Uniform Resource Locator) : 인터넷 상의 자원을 나타내는 약속

Protocol

통신을 하기 위한 약속, 컴퓨터 사이의 약속(프로토콜)을 자세히 정하고, 이를 지킴으로써 통신이 성립된다.
프로토콜을 통해 무엇을 어떻게 언제 통신할 것인가를 규정

TCP (Transmission Control Protocol) : 신뢰성있게 통신하기 위하여 먼저 서로 간의 연결을 설정한 후에 데이터를 보내고 받는 방식

연결지향형 소켓의 데이터 전송 특성
- 중간에 데이터가 소멸되지 않는다.
- 전송 순서대로 데이터가 수신된다.
- 데이터의 경계가 존재하지 않는다.
- Socket : Socket의 연결은 반드시 1 : 1의 구조
Socket : TCP를 사용하여 응용 프로그램끼리 통신을 하기 위한 End Point
ServerSocket : 서버를 위한 소켓
Socket : 클라이언트를 위한 소켓

  import java.io.FileInputStream;
  import java.io.InputStream;
  import java.io.OutputStream;
  import java.net.ServerSocket;
  import java.net.Socket;
        
  public class ServerEx1 {
      public static void main(String[] args) throws Exception {
          ServerSocket server = new ServerSocket(5555);
          System.out.println("read...........!");
          Socket clientSocket = server.accept();
          OutputStream out = clientSocket.getOutputStream();
          InputStream fin = new FileInputStream("C:\\java\\sung.jpg");
          while (true) {
              int data = fin.read();
              out.write(data);
              if (data == -1) break;
          }
          fin.close();
          out.close();
          clientSocket.close();
          server.close();
      }
  }
        
  import java.io.FileOutputStream;
  import java.io.InputStream;
  import java.io.OutputStream;
  import java.net.Socket;
        
  public class ClientEx {
      public static void main(String[] args) throws Exception {
          Socket socket = new Socket("127.0.0.1", 5555);
          System.out.println("연결되었음 : " + socket);
          InputStream in = socket.getInputStream();
          OutputStream fout = new FileOutputStream("C:\\java\\get.jpg");
          while (true) {
              int data = in.read();
              if (data == -1) break;
              fout.write(data);
          }
          fout.close();
          in.close();
          socket.close();
      }
  }

UDP (User Datagram Protocol) : 데이터를 일정 개수, 고정 길이를 가진 패킷으로 분할하여 전송한다.

비연결지향형 소켓의 데이터 전송 특성
- 전송 순서 상관없이 빠른 속도의 전송을 지향
- 데이터 손실의 우려가 있다.
- 데이터의 경계가 존재한다.
- 한 번에 전송할 수 있는 데이터의 크기가 제한된다.
DatagramSocket : UDP 프로토콜을 사용하는 소켓을 생성
DatagramPacket : UDP 패킷 생성
MulticastSocket

  import javax.swing.*;
  import java.awt.*;
  import java.awt.event.ActionEvent;
  import java.awt.event.ActionListener;
  import java.io.IOException;
  import java.net.DatagramPacket;
  import java.net.DatagramSocket;
  import java.net.InetAddress;
        
  public class MessengerA {
      protected JTextField textField;
      protected JTextArea textArea;
      DatagramSocket socket;
      DatagramPacket packet;
      InetAddress address = null;
      final int myPort = 5000;
      final int otherPort = 6000;
        
      public MessengerA() throws IOException {
          MyFrame f = new MyFrame();
          address = InetAddress.getByName("127.0.0.1");
          socket = new DatagramSocket(myPort);
      }
        
      public void process() {
          while (true) {
              try {
                  byte[] buf = new byte[256];
                  packet = new DatagramPacket(buf, buf.length);
                  socket.receive(packet);
                  textArea.append("RECEIVED : " + new String(buf) + "\n");
              }
              catch (IOException e) {
                  e.printStackTrace();
              }
          }
      }
        
      class MyFrame extends JFrame implements ActionListener {
          public MyFrame() {
              super("MessengerA");
              setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
              textField = new JTextField(30);
              textField.addActionListener(this);
              textArea = new JTextArea(10, 30);
              textArea.setEditable(false);
              add(textField, BorderLayout.PAGE_END);
              add(textArea, BorderLayout.CENTER);
              pack();
              setVisible(true);
          }
        
          @Override
          public void actionPerformed(ActionEvent e) {
              String s = textField.getText();
              byte[] buffer = s.getBytes();
              DatagramPacket packet = new DatagramPacket(buffer, buffer.length, address, otherPort);
              try {
                  socket.send(packet);
              }
              catch (IOException ioe) {
                  ioe.printStackTrace();
              }
              textArea.append("SENT: " + s + "\n");
              textField.selectAll();
              textArea.setCaretPosition(textArea.getDocument().getLength());
          }
      }
        
      public static void main(String[] args) throws IOException {
          MessengerA m = new MessengerA();
          m.process();
      }
  }
        
  import javax.swing.*;
  import java.awt.*;
  import java.awt.event.ActionEvent;
  import java.awt.event.ActionListener;
  import java.io.IOException;
  import java.net.DatagramPacket;
  import java.net.DatagramSocket;
  import java.net.InetAddress;
        
  public class MessengerB {
      protected JTextField textField;
      protected JTextArea textArea;
      DatagramSocket socket;
      DatagramPacket packet;
      InetAddress address = null;
      final int myPort = 6000;
      final int otherPort = 5000;
        
      public MessengerB() throws IOException {
          MyFrame f = new MyFrame();
          address = InetAddress.getByName("127.0.0.1");
          socket = new DatagramSocket(myPort);
      }
        
      public void process() {
          while (true) {
              try {
                  byte[] buf = new byte[256];
                  packet = new DatagramPacket(buf, buf.length);
                  socket.receive(packet);
                  textArea.append("RECEIVED : " + new String(buf) + "\n");
              }
              catch (IOException e) {
                  e.printStackTrace();
              }
          }
      }
        
      class MyFrame extends JFrame implements ActionListener {
          public MyFrame() {
              super("MessengerB");
              setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
              textField = new JTextField(30);
              textField.addActionListener(this);
              textArea = new JTextArea(10, 30);
              textArea.setEditable(false);
              add(textField, BorderLayout.PAGE_END);
              add(textArea, BorderLayout.CENTER);
              pack();
              setVisible(true);
          }
        
          @Override
          public void actionPerformed(ActionEvent e) {
              String s = textField.getText();
              byte[] buffer = s.getBytes();
              DatagramPacket packet = new DatagramPacket(buffer, buffer.length, address, otherPort);
              try {
                  socket.send(packet);
              }
              catch (IOException ioe) {
                  ioe.printStackTrace();
              }
              textArea.append("SENT: " + s + "\n");
              textField.selectAll();
              textArea.setCaretPosition(textArea.getDocument().getLength());
          }
      }
        
      public static void main(String[] args) throws IOException {
          MessengerB m = new MessengerB();
          m.process();
      }
  }