package test;
import java.net.InetAddress;
import java.net.UnknownHostException;
public class Demo {
    public static void main(String[] args) throws UnknownHostException {
        //1,static InetAddress getByName(String host) 	確定主機(jī)名稱的IP地址。 主機(jī)名稱可以是機(jī)器名稱，也可以是IP地址
//        InetAddress address = InetAddress.getByName("YM");
        InetAddress address = InetAddress.getByName("192.168.128.1"); //推薦使用
        System.out.println(address); //YM/192.168.128.1
        //2,String getHostName() 	獲取此IP地址的主機(jī)名
        String hostName = address.getHostName();
        System.out.println(hostName); //YM
        //3,String getHostAddress() 	返回文本顯示中的IP地址字符串
        String hostAddress = address.getHostAddress();
        System.out.println(hostAddress); //192.168.128.1
    }
}

package test;
import java.io.IOException;
import java.net.*;
public class Demo {
    public static void main(String[] args) throws IOException {
        //1、創(chuàng)建發(fā)送端的Socket對(duì)象(DatagramSocket)
        DatagramSocket ds = new DatagramSocket();
        //2、創(chuàng)建數(shù)據(jù)， 并把數(shù)據(jù)打包
        //DatogramPacket (byte[] buf, int Length, InetAddress address, int port)
        // 構(gòu)造一個(gè)數(shù)據(jù)包，發(fā)送長(zhǎng)度為length的數(shù)據(jù) 包到指定主機(jī)上的指定端口號(hào)。
        byte[] bys = "hello,java".getBytes();
        DatagramPacket dp = new DatagramPacket(bys,bys.length, InetAddress.getByName("127.0.0.1"),10086);
        //3、調(diào)用DatagramSocket對(duì)象的方法發(fā)送數(shù)據(jù)
        //void send(DatagramPacket p)
        ds.send(dp);
        //4、關(guān)閉發(fā)送端
        ds.close();
    }
}

package test;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class ReceiveDemo {
    public static void main(String[] args) throws IOException {
        //1、創(chuàng)建接收端的Socket對(duì)象(DatagramSocket)：DatagramSocket(int port)
        DatagramSocket ds = new DatagramSocket(10086);
        //2、創(chuàng)建一個(gè)數(shù)據(jù)包， 用于接收數(shù)據(jù)
        //DatagramPacket(byte[] buf, int length)：構(gòu)造一個(gè)DatagramPacket用來(lái)接收長(zhǎng)度為length的數(shù)據(jù)包
        byte[] bys = new byte[1024];
        DatagramPacket dp = new DatagramPacket(bys, bys.length);
        //3、調(diào)用DatagramSocket對(duì)象的方法接收數(shù)據(jù)：void receive(DatagramPacketp)
        ds.receive(dp);
        //4、解析數(shù)據(jù)包， 并把數(shù)據(jù)在控制臺(tái)顯示：
        // byte[] getData():返回?cái)?shù)據(jù)緩沖區(qū) int getLength()
        byte[] datas = dp.getData();
        //int getlength():返回要發(fā)送的數(shù)據(jù)長(zhǎng)度或接收的數(shù)據(jù)長(zhǎng)度
        int len = dp.getlength();
        String dataString = new String(datas,0,len);
        System.out.println("數(shù)據(jù)是："+dataString);
        //5、關(guān)閉接收端：void close()
        ds.close();
    }
}

package test;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class SendDemo {
    public static void main(String[] args) throws IOException {
        //1、創(chuàng)建發(fā)送端的Socket對(duì)象(DatagramSocket)：DatagramSocket()
        DatagramSocket ds = new DatagramSocket();
        //鍵盤錄入數(shù)據(jù)
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        String line;
        while ((line = br.readLine()) != null) {
            if ("886".equals(line)) {
                break;
            } else {
                //創(chuàng)建數(shù)據(jù)并把數(shù)據(jù)打包
                byte[] bys = line.getBytes();
                DatagramPacket dp = new DatagramPacket(bys, bys.length, InetAddress.getByName("127.0.0.1"), 1001);
                //3、調(diào)用DatagramSocket對(duì)象的方法發(fā)送數(shù)據(jù)：void send(DatagramPacket p)
                ds.send(dp);
            }
        }
        ds.close();
    }
}

package test;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class ReceiveDemo {
    public static void main(String[] args) throws IOException {
        //創(chuàng)建接收端的Socket對(duì)象(DatagramSocket)：DatagramSocket(int port)
        DatagramSocket ds = new DatagramSocket(1001);
        while(true) {
            //創(chuàng)建一個(gè)數(shù)據(jù)包接收數(shù)據(jù)
            byte[] bys = new byte[1024];
            DatagramPacket dp = new DatagramPacket(bys, bys.length);
            //調(diào)用DatagramSocket對(duì)象的方法接收數(shù)據(jù)：void receive(DatagramPacketp)
            ds.receive(dp);
            //解析數(shù)據(jù)包， 并把數(shù)據(jù)在控制臺(tái)顯示：byte[] getData()、int getLength()
            System.out.println("數(shù)據(jù)是：" + new String(dp.getData(), 0, dp.getLength()));
        }
        //關(guān)閉
//        ds.close();
    }
}

package test;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //1、創(chuàng)建客戶端的Socket對(duì)象(Socket)：Socket(String host, int port)
        Socket s = new Socket("127.0.0.1",1000);
        //2、獲取輸出流，寫(xiě)數(shù)據(jù)：OutputStream對(duì)象的getOutputStream()方法
        OutputStream os = s.getOutputStream();
        os.write("hello,java".getBytes());
        //3、釋放資源：void close()
        s.close();
    }
}

package test;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class SeverDemo {
    public static void main(String[] args) throws IOException {
        //1、創(chuàng)建服務(wù) 器端的Socket對(duì)象(ServerSocket)：ServerSocket(int port)
        ServerSocket ss = new ServerSocket(1000);
        //2、監(jiān)聽(tīng)客戶端連接, 返回個(gè)Socket對(duì)象:Socket accept()
        Socket s = ss.accept();
        //3、獲取輸入流, 讀數(shù)據(jù)，并把數(shù)據(jù)顯示在控制臺(tái):InputStream對(duì)象的getInputStream()方法
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1014];
        int len = is.read(bys);
        String data = new String(bys,0,len);
        System.out.println(data);
        //4、釋放資源：void close()
        s.close();
        ss.close();
    }
}

package test;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //1、創(chuàng)建客戶端的Socket對(duì)象(Socket)：Socket(String host, int port)
        Socket s = new Socket("127.0.0.1",1000);
        //2、獲取輸出流，寫(xiě)數(shù)據(jù)：OutputStream對(duì)象的getOutputStream()方法
        OutputStream os = s.getOutputStream();
        os.write("hello,java".getBytes());
        //接收服務(wù)器反饋
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1024];
        int len = is.read(bys);
        String data = new String(bys,0,len);
        System.out.println("客戶端:"+data);
        //3、釋放資源：void close()
        s.close();
        //客戶端:數(shù)據(jù)已經(jīng)收到
    }
}

package test;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class SeverDemo {
    public static void main(String[] args) throws IOException {
        //1、創(chuàng)建服務(wù) 器端的Socket對(duì)象(ServerSocket)：ServerSocket(int port)
        ServerSocket ss = new ServerSocket(1000);
        //2、監(jiān)聽(tīng)客戶端連接, 返回個(gè)Socket對(duì)象:Socket accept()
        Socket s = ss.accept();
        //3、獲取輸入流, 讀數(shù)據(jù)，并把數(shù)據(jù)顯示在控制臺(tái):InputStream對(duì)象的getInputStream()方法
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1014];
        int len = is.read(bys);
        String data = new String(bys,0,len);
        System.out.println("服務(wù)器："+data);
        //給出反饋
        OutputStream os = s.getOutputStream();
        os.write("數(shù)據(jù)已經(jīng)收到".getBytes());
        //4、釋放資源：void close()
        s.close();
        ss.close();
        //服務(wù)器：hello,java
    }
}

package test;
import java.io.*;
import java.net.Socket;
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //創(chuàng)建客戶端的Socket對(duì)象(Socket)：Socket(String host, int port)
        Socket s = new Socket("127.0.0.1",1000);
        //數(shù)據(jù)來(lái)源于鍵盤錄入，直到886停止
        System.out.println("請(qǐng)輸入數(shù)據(jù)");
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        //封裝輸出流對(duì)象
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while((line= br.readLine())!=null) {
            if("886".equals(line)) {
                break;
            }
            //獲取輸出流對(duì)象
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //釋放資源
        s.close();
//        hello
//        886
    }
}

package test;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class SeverDemo {
    public static void main(String[] args) throws IOException {
        //1、創(chuàng)建服務(wù) 器端的Socket對(duì)象(ServerSocket)：ServerSocket(int port)
        ServerSocket ss = new ServerSocket(1000);
        //2、監(jiān)聽(tīng)客戶端連接, 返回個(gè)Socket對(duì)象:Socket accept()
        Socket s = ss.accept();
        //3、獲取輸入流, 讀數(shù)據(jù)，并把數(shù)據(jù)顯示在控制臺(tái):InputStream對(duì)象的getInputStream()方法
//        InputStream is = s.getInputStream();
//        InputStreamReader isr = new InputStreamReader(is);
//        BufferedReader br = new BufferedReader(isr);
        BufferedReader br  = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String line;
        while((line=br.readLine())!=null) {
            System.out.println(line);
        }
        //4、釋放資源：void close()
        s.close();
        //hello
    }
}

package test;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class SeverDemo {
    public static void main(String[] args) throws IOException {
        //1、創(chuàng)建服務(wù) 器端的Socket對(duì)象(ServerSocket)：ServerSocket(int port)
        ServerSocket ss = new ServerSocket(1000);
        //2、監(jiān)聽(tīng)客戶端連接, 返回個(gè)Socket對(duì)象:Socket accept()
        Socket s = ss.accept();
        //3、獲取輸入流, 讀數(shù)據(jù)，并把數(shù)據(jù)顯示在控制臺(tái):InputStream對(duì)象的getInputStream()方法
        BufferedReader br  = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //把數(shù)據(jù)寫(xiě)入文本文件
        BufferedWriter bw = new BufferedWriter(new FileWriter("E:\\test\\java.txt"));
        String line;
        while((line=br.readLine())!=null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //4、釋放資源：void close()
        bw.close();
        ss.close();
        //文件中數(shù)據(jù)：hello
    }
}

package test;
import java.io.*;
import java.net.Socket;
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //創(chuàng)建客戶端的Socket對(duì)象(Socket)：Socket(String host, int port)
        Socket s = new Socket("127.0.0.1",1000);
        //封裝文本文件數(shù)據(jù)
        BufferedReader br  =new BufferedReader(new FileReader("E:\\test\\fos.txt"));
        //封裝輸出流對(duì)象
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while((line= br.readLine())!=null) {
            //獲取輸出流對(duì)象
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //釋放資源
        br.close();
        s.close();
    }
}

package test;
import java.io.*;
import java.net.Socket;
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //創(chuàng)建客戶端的Socket對(duì)象(Socket)：Socket(String host, int port)
        Socket s = new Socket("127.0.0.1",1000);
        //封裝文本文件數(shù)據(jù)
        BufferedReader br  =new BufferedReader(new FileReader("E:\\test\\fos.txt"));
        //封裝輸出流對(duì)象
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while((line= br.readLine())!=null) {
            //獲取輸出流對(duì)象
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
//        //自定義結(jié)束標(biāo)記
//        bw.write("886");
//        bw.newLine();
//        bw.flush();
        s.shutdownOutput();//Socket類中方法：表示輸出結(jié)束
        //接收反饋
        BufferedReader brClient = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String data = brClient.readLine(); //等待讀取數(shù)據(jù)
        System.out.println("服務(wù)器的反饋:"+data); //服務(wù)器的反饋:文件上傳成功
        //釋放資源
        br.close();
        s.close();
    }
}

package test;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class SeverDemo {
    public static void main(String[] args) throws IOException {
        //1、創(chuàng)建服務(wù) 器端的Socket對(duì)象(ServerSocket)：ServerSocket(int port)
        ServerSocket ss = new ServerSocket(1000);
        //2、監(jiān)聽(tīng)客戶端連接, 返回個(gè)Socket對(duì)象:Socket accept()
        Socket s = ss.accept();
        //3、獲取輸入流, 讀數(shù)據(jù)，并把數(shù)據(jù)顯示在控制臺(tái):InputStream對(duì)象的getInputStream()方法
        BufferedReader br  = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //把數(shù)據(jù)寫(xiě)入文本文件
        BufferedWriter bw = new BufferedWriter(new FileWriter("E:\\test\\java.txt"));
        String line;
        while((line=br.readLine())!=null) { //等待讀取數(shù)據(jù)
//            if("886".equals(line)) {
//                break;
//            }
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //給出反饋
        BufferedWriter bwServer = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        bwServer.write("文件上傳成功");
        bwServer.newLine();
        bwServer.flush();
        //4、釋放資源：void close()
        bw.close();
        ss.close();
    }
}

package test;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class SeverDemo {
    public static void main(String[] args) throws IOException {
        //創(chuàng)建服務(wù) 器端的Socket對(duì)象(ServerSocket)：ServerSocket(int port)
        ServerSocket ss = new ServerSocket(1000);
        while(true) {
            //監(jiān)聽(tīng)客戶端連接, 返回個(gè)Socket對(duì)象:Socket accept()
            Socket s = ss.accept();
            //為每一個(gè)客戶端開(kāi)啟一個(gè)線程
            new Thread(new ServerThread(s)).start();
        }
    }
}

package test;
import java.io.*;
import java.net.Socket;
public class ServerThread implements Runnable {
    private Socket s;
    public ServerThread(Socket s) {
        this.s = s;
    }
    @Override
    public void run() {
        try {
            //接收數(shù)據(jù)寫(xiě)入文本文件
            BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
//            BufferedWriter bw = new BufferedWriter(new FileWriter("E:\\test\\java.txt"));
            //解決名稱沖突問(wèn)題，上傳到不同文件中
            int count = 0;
            File file = new File("E:\\test\\["+count+"]java.txt");
            while(file.exists()) {
                count++;
                file = new File("E:\\test\\["+count+"]java.txt");
            }
            BufferedWriter bw = new BufferedWriter(new FileWriter(file));
            String line;
            while ((line=br.readLine()) != null) {
                bw.write(line);
                bw.newLine();
                bw.flush();
            }
            //給出反饋
            BufferedWriter bwSever  =new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
            bwSever.write("文件上傳成功");
            bwSever.newLine();
            bwSever.flush();
            //釋放資源
            s.close();
        }catch (IOException e) {
            e.printStackTrace();
        }
    }
}