프로토콜 : 자원에 접근하기 위해 서버와 통신하는데 사용되는 규약(http)
호스트명(DomainName) : 자원을 제공하는 서버의 이름
포트번호 : 통신에 사용되는 서버의 포트번호
경로명(path) : 접근하려는 자원이 저장된 서버의 위치
쿼리 : URL에서 ? 이후의 부분
참조 : URL에서 #이후의 부분

URL url = "https://www.naver.com";
InputStream in = url.openStream();
/// 위는 아래와 같다.
URLConnection conn = url.openConnection();
InputStream in = conn.getInputStream();

package Network;

import java.net.*;
import java.io.*;
import java.util.*;

public class TcpIpMultichatServer {
    // 서버에서 들어오는 client들을 Thread를 생성하여 해당 정보를 넣어 보관할 맵
    HashMap clients;


    TcpIpMultichatServer(){
        clients = new HashMap();
        Collections.synchronizedMap(clients);
    }

    public void start(){
        ServerSocket serverSocket = null;
        Socket socket = null;

        try{
            //7777번 포트에 서버 소켓을 연다.
            serverSocket = new ServerSocket(7777);
            System.out.println("서버가 시작되었습니다.");

            while(true){
                // serverSocket에 연결을 시도하면 해당 소켓의 연결을 허용해준다.
                socket = serverSocket.accept();
                System.out.println("["+socket.getInetAddress()+":"+socket.getPort()+"]에서접속하였습니다.");
                // Thread를 생성하여 들어온 소켓과 1:1 연결을 하는 소켓을 만들어줄 예정이다.
                ServerReceiver thread = new ServerReceiver(socket);
                thread.start();

            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    // HashMap에 저장한 모든 clients들에게 일괄적으로 message를 보내주는 함수
    void sendToAll(String msg){
        Iterator it = clients.keySet().iterator();

        while(it.hasNext()){
            try{
                DataOutputStream out = (DataOutputStream)clients.get(it.next());
                out.writeUTF(msg);
            } catch (IOException e){}
        }
    }
    // 채팅 서버를 실행하는 main함수
    public static void main(String[] args){
        new TcpIpMultichatServer();
    }

    // Client의 socket과 연결하는 Thread
    class ServerReceiver extends Thread{
        Socket socket; // 클라이언트와 연결할 소켓
        DataInputStream in;
        DataOutputStream out;

        // 서버 소켓이 생성한 쓰레드의 input, outputStream 을 생성해주는 생성자
        ServerReceiver(Socket socket){
            this.socket = socket;
            try{
                in = new DataInputStream(socket.getInputStream());
                out = new DataOutputStream(socket.getOutputStream());
            } catch (IOException e){}
        }
        // 쓰레드의 동작
        public void run(){
            String name= "";

            try{
                // readUTF함수는 스케너처럼 상대가 입력하지 않으면 계속 기다린다.
                // 우리 채팅서버에서 클라이언트는 연결 시 먼저 자기 이름을 보내므로, 받은 이름을 저장
                name = in.readUTF();
                // 새로운 클라이언트가 접속했음을 알린다.
                sendToAll("#"+name+"님이들어오셨습니다.");

                // clients Map에 새로온 클라이언트의 정보를 저장하며, outputStream도 같이 저장한다.
                clients.put(name, out);
                System.out.println("현재 서버접속자 수는 " + clients.size() + "입니다.");
                while(in != null){
                    // 이후 client의 정보가 들어올 때마다 계속 해당 데이터를 채팅방에 뿌려준다.
                    // 스트림이 닫히면 in==null이 된다.
                    sendToAll(in.readUTF());
                }
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                // 연결이 끊기면 해당 클라이언트가 나간것을 알려준다.
                sendToAll("#"+ name + "님이 나가셨습니다.");
                clients.remove(name);
                System.out.println(" 해당 유저는 접속을 종료하였습니다.");
            }
        }

    }
}

package Network;

import java.net.*;
import java.io.*;
import java.util.Scanner;

public class TcpIpMultichatClient {

    public static void main(String[] args){
        if(args.length != 1){
            System.out.println("USAGE: java TcpIpMultichatClient 대화명");
        }
        try{
            String serverIp = "127.0.0.1";
            // serverIp의 7777번 포트로 ㅇ녀결한다.
            Socket socket = new Socket(serverIp, 7777);
            System.out.println("서버에 연결 되었습니다.");

            // sender와 receiver 쓰레드를 각각 생성하며, 연결된 소켓으로 스트림을 연결한다.
            Thread sender = new Thread(new ClientSender(socket, args[0]));
            Thread receiver = new Thread(new ClientReceiver(socket));

            sender.start();
            receiver.start();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    // Sender, outputStream
    static class ClientSender extends Thread{
        Socket socket;
        DataOutputStream out;
        String name;

        ClientSender(Socket socket, String name){
            this.socket = socket;
            try{
                out = new DataOutputStream(socket.getOutputStream());
                this.name = name;
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        public void run(){
            Scanner scanner = new Scanner(System.in);
            try{
                // 연결이 되면 먼저 이름부터 보내준다.
                if(out!=null){
                    out.writeUTF(name);
                }
                // 연결이 끊기기 전까지 Scanner에서 입력된 모든 데이터들을 다시 보내준다.
                while(out!=null) out.writeUTF("[" + name + "]" + scanner.nextLine());
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    // Reciever, inputStream
    static class ClientReceiver extends Thread{
        Socket socket;
        DataInputStream in;

        ClientReceiver(Socket socket){
            this.socket = socket;
            try{
                in = new DataInputStream(socket.getInputStream());
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        public void run(){
            // 들어오는 모든 데이터들을 바로 출력해준다.
            while(in != null){
                try{
                    System.out.println(in.readUTF());
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

package Network;

import java.net.*;
import java.io.*;
import java.nio.charset.StandardCharsets;
import java.util.Date;
import java.text.SimpleDateFormat;

public class UdpServer {
    public void start() throws IOException{
        // 포트 7777번을 사용하는 소켓을 생성한다
        DatagramSocket socket = new DatagramSocket(7777);
        DatagramPacket inPacket, outPacket;

        byte[] inMsg = new byte[100];
        byte[] outMsg;

        while(true){
            //데이터를 수신하기 위한 패킷을 생성한다.
            inPacket = new DatagramPacket(inMsg, inMsg.length);

            // 패킷을 통해 데이터를 수신(receive)한다.
            socket.receive(inPacket);

            //수신한 패킷으로부터 client의 IP주소와 Port를 얻는다.
            InetAddress address = inPacket.getAddress();
            int port = inPacket.getPort();

            // 서버의 현재 시간을 시분초 형태 [hh:mm:ss] 로 반환한다
            SimpleDateFormat sdf = new SimpleDateFormat("[hh:mm:ss]");
            String time = sdf.format(new Date());
            outMsg = time.getBytes(); //time을 byte배열로 변환

            // 패킷을 생성해서 Client에게 전송(send)한다.
            outPacket = new DatagramPacket(outMsg, outMsg.length, address, port);
            socket.send(outPacket);
        }
    }

    public static void main(String[] args){
        try{
            new UdpServer().start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

package Network;

import java.net.*;
import java.io.*;
public class UdpClient {
    public void start() throws IOException, UnknownHostException{
        DatagramSocket datagramSocket = new DatagramSocket();
        InetAddress serverAddress = InetAddress.getByName("127.0.0.1");

        // 데이터가 저장될 공간으로 byte배열을 생성한다.
        byte[] msg = new byte[100];

        DatagramPacket outPacket = new DatagramPacket(msg, 1, serverAddress, 7777);
        DatagramPacket inPacket = new DatagramPacket(msg, msg.length);

        datagramSocket.send(outPacket);
        datagramSocket.receive(inPacket);

        System.out.println("current server time : " + new String(inPacket.getData()));

        datagramSocket.close();
    }
    public static void main(String[] args){
        try{
            new UdpClient().start();
        }  catch (Exception e) {
            e.printStackTrace();
        }
    }
}