Netty实战专栏 | Java网络编程深入解析

1 package org.javatop.net.ip;
 2 
 3 import java.net.InetAddress;
 4 import java.net.UnknownHostException;
 5 
 6 /**
 7  * InetAddress用来代表IP地址 一个InetAddress对象代表一个IP地址
 9  * @author Leo
10  *
11  */
12 public class TestInetAddress {
13 
14     public static void main(String[] args) throws UnknownHostException {
15     //如何创建一个InetAddress对象
16     InetAddress inet = InetAddress.getByName("www.baidu.com");
17     System.out.println(inet);
18     System.out.println(inet.getHostName());
19     System.out.println(inet.getHostAddress());
20     //获取本机信息
21     inet = InetAddress.getLocalHost();
22     System.out.println(inet);
23     System.out.println(inet.getHostName());
24     System.out.println(inet.getHostAddress());
25     }
26 
27 }

Socket()
Socket(InetAddress address, int port) throws UnknownHostException,IOException
Socket(InetAddress address, int port, InetAddress localAddr, int localPort) throws IOException
Socket(String host, int port) throws UnknownHostException,IOException
Socket(String host, int port, InetAddress localAddr, int localPort) throws IOException
Socket(Proxy proxy)

Socket socket = new Socket();
SocketAddress remoteAddr = new InetSocketAddress("1ocalhostn", 8000);
// 参数endpoint指定服务器的地址,参数timeout设定的超时时间(ms)
// 如果参数timeout被设为0则表示永远不会超时
socket.connect(remoteAddr, 60000);

// address表示主机的IP地址
Socket(InetAddress address, int port)
// address表示主机的名字
Socket(String host, int port)

// 返回本地主机的IP地址、
InetAddress addr1 = inetAddress.getLocalHost();
// 返回代表 "222.34.57” 的 IPv4 地址
InetAddress addr2 = InetAddress.getByName("222.34.5.7");
// 返同代表 ”2001:DB8:2DE::E13" 的 IPv6 地址
InetAddress addr3 = InetAddress.getByName("2001:DB8:2DE::E13");
// 返回主机名为 "www.javathinker.net" 的 IP 地址
InetAddress addr4 = InetAddress.getByName ("www.javathinker.net");

Socket(InetAddress address, int port, InetAddress localAddr, int localPort) throws IOException
Socket(String host, int port, InetAddress localAddr, int localPort) throws IOException

InetAddress remoteAddr = InetAddress.getByName("112.5,4.45");
InetAddress localAddr = InetAddress.getByName("112.5.4.3");
//客户端使用口2345
Socket socket = new Socket(remoteAddr, 8000, localAddr, 2345);

String proxyIP = "myproxy.abc.oom"; // 代理服务器地址
int proxyPort = 1080; // 代理服务器端口
// 创建代理对象
Proxy proxy = new Proxy(Proxy.Type.SOCKS, new InetSocketAddress(proxyIP, proxyPort));
Socket socket  new Socket(proxy);
//连接到远程服务器
socket.connect(new InetSocketAddress("www.javathinker.net", 80));

// 返回代表 "222.34.5.7" 的 IPv4 地址
InetAddress addr2 = InetAddress,getByName("222.34.5.7");
// 返回主机名为 "www.javathinker.net" 的 IP 地址
InetAddress addr4 = InetAddress.getByName("www.javathinker.net");

public boolean isReachable(int timeout) throws IOException
public boolean isReachable(NefworkInterface interface, int ttl, int timeout) throws IOException

// 参数 name 指定网络接口的名字，如果不存在与名字对应的网络接口，就返回 null
getByName(String name)
// 参数 address 指定网络接口的 IP 地址，如果不存在与 IP 地址对应的网络接口，就返回 null
getByInetAddress(InetAddress address)

// 返回网络接口的名字
public String getName()
// 返回和网络接口绑定的所有 IP 地址，返回值为 Enumeration 类型，里面存放了表示 IP 地址的 InetAddress 对象
public Enumeration getInetAddresses()

// 获得远程被连接进程的IP地址
getInetAddress()
// 获得远程被连接进程的端口
getPort()
// 获得本地的IP地址
getLocalAddress()
// 获得本地的端口
getLocalPort()
// 获得输入流,如果Socket还没有连接,或者已经关团,或者已经通过shutdownInput()方法关闭输入流,那么此方法会抛出IOException
getInputStream()
// 获得输出流,如果Socket还没有连接,或者已经关闭,或者已经通过shutdownOutput()方法关闭输出流,那么此方法会抛出 IOException
getOutputStream()

// 如果Socket没有关闭，则返回false，否则返回true
isClosed()
// 如果Socket曾经连接到远程主机，不管当前是否已经关闭，都返回true。如果Socket从未连接到远程主机，就返回false
isConnected()
// 如果Socket已经与一个本地端口绑定，则返回true，否则返回false
isBound()

String isConnected = socket.isConnected() && !socket.isClosed();

ByteArrayOutputstream bufferenew = ByteArrayOutputstream();
byte[] buff = new byte[1024);
int len = -1;
while((len = socketIn.read(buff)) != -1) {
    buffer.write(buff, 0, len);   
}

shutdownInput() // 关闭输入流
shutdownOutput() // 关团输出流

// 发出请求信息
String data = ...;
OutputStream socketOut = socket.getOutputStream();
socketOut.write(data.getBytes());
socketOut.flush();
// 读取响应
InputStream socketIn = socket.getInputStream();
if(服务器端返回提示信息，表明已经接收到客户端的所有请求数据)
    socket.shutdownOutput(); //关闭输出流
//继续通过socketIn读取数据
...

public boolean isInputShutdown() // 如果输入流关闭，则返回true，否则返回false
public boolean isOutputShutdown() // 如果输出流关闭，则返回true，否则返回false

package org.javatop.socket;
import java.io.IOException;

import java.io.InputStream;

import java.net.ServerSocket;

import java.net.Socket;
/**


@author : Leo


@version 1.0


@date 2023-11-02 9:44


@description : 服务端

*/

public class SocketTCPServer01 {
public static void main(String[] args) throws IOException {
 /*
     * 1. 在本机的8888端口监听, 等待连接
     * 细节: 要求在本机没有其它服务在监听9999
     * 细节：这个 ServerSocket 可以通过 accept() 返回多个Socket[多个客户端连接服务器的并发]
 */

 ServerSocket serverSocket = new ServerSocket(8888);
 System.out.println("服务端，在8888端口监听，等待连接..");
 //2. 当没有客户端连接9999端口时，程序会 阻塞, 等待连接
 //如果有客户端连接，则会返回Socket对象，程序继续

 Socket socket = serverSocket.accept();

 System.out.println("服务端 socket ="+socket.getClass());
 //
 //3. 通过socket.getInputStream() 读取客户端写入到数据通道的数据, 显示
 InputStream is = socket.getInputStream();
 //4. 通过IO流读取
 byte[] buf = new byte[1024];
 int readLen = 0;
 while((readLen = is.read(buf))!=-1){
     //根据读取到的实际长度，显示内容.
     System.out.println(new String(buf, 0, readLen));
 }
 //5.关闭流和socket
 is.close();
 socket.close();
 serverSocket.close();//关闭

}


}

package org.javatop.socket;

import java.io.IOException;

import java.io.OutputStream;

import java.net.InetAddress;

import java.net.Socket;
/**


@author : Leo


@version 1.0


@date 2023-11-02 9:44


@description : 客户端

*/

public class SocketTCPClent01 {
public static void main(String[] args) throws IOException {

/*

*  1. 连接服务端 (ip , 端口）

*  连接本机的 8888端口, 如果连接成功，返回Socket对象

*/
 Socket socket = new Socket(InetAddress.getLocalHost(), 8888);
 System.out.println("客户端 socket返回=" + socket.getClass());

 //2. 连接上之后，生成Socket, 通过socket.getOutputStream()
 // 得到 和 socket对象关联的输出流对象
 OutputStream outputStream = socket.getOutputStream();
 //3. 通过输出流，写入数据到 数据通道
 outputStream.write("hello, SocketTCPServer01,我是客户端，这是我给你发的一条信息".getBytes());
 //4. 关闭流对象和socket, 必须关闭
 outputStream.close();
 socket.close();
 System.out.println("客户端退出.....");

}

}

package org.javatop.socket;



import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.ServerSocket;

import java.net.Socket;
/**


@author : Leo


@version 1.0


@date 2023-11-02 9:44


@description : 服务端

*/

public class SocketTCPServer02 {
public static void main(String[] args) throws IOException {
 /*
     * 1. 在本机的8888端口监听, 等待连接
     * 细节: 要求在本机没有其它服务在监听9999
     * 细节：这个 ServerSocket 可以通过 accept() 返回多个Socket[多个客户端连接服务器的并发]
 */

 ServerSocket serverSocket = new ServerSocket(8888);
 System.out.println("服务端，在8888端口监听，等待连接..");
 //2. 当没有客户端连接8888端口时，程序会 阻塞, 等待连接
 //如果有客户端连接，则会返回Socket对象，程序继续

 Socket socket = serverSocket.accept();

 System.out.println("服务端 socket ="+socket.getClass());
 //
 //3. 通过socket.getInputStream() 读取客户端写入到数据通道的数据, 显示
 InputStream is = socket.getInputStream();
 //4. 通过IO流读取
 byte[] buf = new byte[1024];
 int readLen = 0;
 while((readLen = is.read(buf))!=-1){
     //根据读取到的实际长度，显示内容.
     System.out.println(new String(buf, 0, readLen));
 }
 //5. 获取socket相关联的输出流
 OutputStream outputStream = socket.getOutputStream();
 outputStream.write("hello, SocketTCPClent02,我是服务端，这是我给你回的一条信息....".getBytes());
 //6.设置结束标记
 socket.shutdownOutput();
 //7.关闭流和socket
 is.close();
 socket.close();
 serverSocket.close();

}

}

package org.javatop.socket;



import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.InetAddress;

import java.net.Socket;
/**


@author : Leo


@version 1.0


@date 2023-11-02 9:44


@description : 客户端

*/

public class SocketTCPClent02 {
public static void main(String[] args) throws IOException {

/*

*  1. 连接服务端 (ip , 端口）

*  连接本机的 8888端口, 如果连接成功，返回Socket对象

*/
 Socket socket = new Socket(InetAddress.getLocalHost(), 8888);
 System.out.println("客户端 socket返回=" + socket.getClass());

 //2. 连接上之后，生成Socket, 通过socket.getOutputStream()
 // 得到 和 socket对象关联的输出流对象
 OutputStream outputStream = socket.getOutputStream();

 //3. 通过输出流，写入数据到 数据通道
 outputStream.write("hello, SocketTCPServer02,我是客户端，这是我给你发的一条信息".getBytes());

 //4.设置结束标记
 socket.shutdownOutput();

 //5. 获取和socket关联的输入流. 读取数据(字节)，并显示
 InputStream inputStream = socket.getInputStream();
 byte[] buf = new byte[1024];
 int readLen = 0;
 while ((readLen = inputStream.read(buf)) != -1) {
     System.out.println("客户端收到服务端的 回复信息 = " + new String(buf, 0, readLen));
 }
 //6.关闭流对象和socket, 必须关闭
 outputStream.close();
 socket.close();
 System.out.println("客户端退出.....");

}

}

public class SendDemo {
    public static void main(String[] args) throws IOException {
        //创建发送端的Socket对象(DatagramSocket)
        // DatagramSocket() 构造数据报套接字并将其绑定到本地主机上的任何可用端口
        DatagramSocket ds = new DatagramSocket();
    //创建数据，并把数据打包
    //DatagramPacket(byte[] buf, int length, InetAddress address, int port)
    //构造一个数据包，发送长度为 length的数据包到指定主机上的指定端口号。
    byte[] bys = "hello,udp,我来了".getBytes();

    DatagramPacket dp = new DatagramPacket(bys,bys.length,InetAddress.getByName("127.0.0.1"),10086);

    //调用DatagramSocket对象的方法发送数据
    //void send(DatagramPacket p) 从此套接字发送数据报包
    ds.send(dp);

    //关闭发送端
    //void close() 关闭此数据报套接字
    ds.close();
}

}

public class ReceiveDemo {

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

//创建接收端的Socket对象(DatagramSocket)

DatagramSocket ds = new DatagramSocket(12345);

  	//创建一个数据包，用于接收数据
  	byte[] bys = new byte[1024];
  	DatagramPacket dp = new DatagramPacket(bys, bys.length);

  	//调用DatagramSocket对象的方法接收数据
  	ds.receive(dp);

  	//解析数据包，并把数据在控制台显示
  	System.out.println("数据是：" + new String(dp.getData(), 0,dp.getLength()));
    }
}

}

/*

UDP发送数据：

数据来自于键盘录入，直到输入的数据是886，发送数据结束

*/

public class SendDemo {

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

//创建发送端的Socket对象(DatagramSocket)

DatagramSocket ds = new DatagramSocket();

//键盘录入数据

Scanner sc = new Scanner(System.in);

while (true) {

String s = sc.nextLine();

//输入的数据是886，发送数据结束

if ("886".equals(s)) {

break;

}

//创建数据，并把数据打包

byte[] bys = s.getBytes();

DatagramPacket dp = new DatagramPacket(bys, bys.length, InetAddress.getByName("192.168.1.66"), 12345);

        //调用DatagramSocket对象的方法发送数据
        ds.send(dp);
    }
    //关闭发送端
    ds.close();
}

}
/*

UDP接收数据：

因为接收端不知道发送端什么时候停止发送，故采用死循环接收

*/

public class ReceiveDemo {

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

//创建接收端的Socket对象(DatagramSocket)

DatagramSocket ds = new DatagramSocket(12345);

while (true) {

//创建一个数据包，用于接收数据

byte[] bys = new byte[1024];

DatagramPacket dp = new DatagramPacket(bys, bys.length);

//调用DatagramSocket对象的方法接收数据

ds.receive(dp);

//解析数据包，并把数据在控制台显示

System.out.println("数据是：" + new String(dp.getData(), 0, dp.getLength()));

}

//关闭接收端

//        ds.close();

}

}

// 发送端
public class ClinetDemo {
    public static void main(String[] args) throws IOException {
        // 1. 创建发送端的Socket对象(DatagramSocket)
        DatagramSocket ds = new DatagramSocket();
        String s = "hello 组播";
        byte[] bytes = s.getBytes();
        InetAddress address = InetAddress.getByName("224.0.1.0");
        int port = 10000;
        // 2. 创建数据，并把数据打包(DatagramPacket)
        DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,port);
        // 3. 调用DatagramSocket对象的方法发送数据(在单播中,这里是发给指定IP的电脑但是在组播当中,这里是发给组播地址)
        ds.send(dp);
        // 4. 释放资源
        ds.close();
    }
}
// 接收端
public class ServerDemo {
    public static void main(String[] args) throws IOException {
        // 1. 创建接收端Socket对象(MulticastSocket)
        MulticastSocket ms = new MulticastSocket(10000);
        // 2. 创建一个箱子,用于接收数据
        DatagramPacket dp = new DatagramPacket(new byte[1024],1024);
        // 3. 把当前计算机绑定一个组播地址,表示添加到这一组中.
        ms.joinGroup(InetAddress.getByName("224.0.1.0"));
        // 4. 将数据接收到箱子中
        ms.receive(dp);
        // 5. 解析数据包,并打印数据
        byte[] data = dp.getData();
        int length = dp.getLength();
        System.out.println(new String(data,0,length));
        // 6. 释放资源
        ms.close();
    }
}

// 发送端
public class ClientDemo {
    public static void main(String[] args) throws IOException {
      	// 1. 创建发送端Socket对象(DatagramSocket)
        DatagramSocket ds = new DatagramSocket();
		// 2. 创建存储数据的箱子,将广播地址封装进去
        String s = "广播 hello";
        byte[] bytes = s.getBytes();
        InetAddress address = InetAddress.getByName("255.255.255.255");
        int port = 10000;
        DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,port);
		// 3. 发送数据
        ds.send(dp);
		// 4. 释放资源
        ds.close();
    }
}
// 接收端

public class ServerDemo {

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

// 1. 创建接收端的Socket对象(DatagramSocket)

DatagramSocket ds = new DatagramSocket(10000);

// 2. 创建一个数据包，用于接收数据

DatagramPacket dp = new DatagramPacket(new byte[1024],1024);

// 3. 调用DatagramSocket对象的方法接收数据

ds.receive(dp);

// 4. 解析数据包，并把数据在控制台显示

byte[] data = dp.getData();

int length = dp.getLength();

System.out.println(new String(data,0,length));

// 5. 关闭接收端

ds.close();

}

}

public class Client {

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

//客户端：多次发送数据

//服务器：接收多次接收数据，并打印

    //1. 创建Socket对象并连接服务端
    Socket socket = new Socket("127.0.0.1",10000);

    //2.写出数据
    Scanner sc = new Scanner(System.in);
    OutputStream os = socket.getOutputStream();

    while (true) {
        System.out.println("请输入您要发送的信息");
        String str = sc.nextLine();
        if("886".equals(str)){
            break;
        }
        os.write(str.getBytes());
    }
    //3.释放资源
    socket.close();
}

}

public class Server {

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

//客户端：多次发送数据

//服务器：接收多次接收数据，并打印

    //1.创建对象绑定10000端口
    ServerSocket ss = new ServerSocket(10000);

    //2.等待客户端来连接
    Socket socket = ss.accept();

    //3.读取数据
    InputStreamReader isr = new InputStreamReader(socket.getInputStream());
    int b;
    while ((b = isr.read()) != -1){
        System.out.print((char)b);
    }

    //4.释放资源
    socket.close();
    ss.close();
}

}

// 客户端

public class ClientDemo {

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

Socket socket = new Socket("127.0.0.1",10000);

    OutputStream os = socket.getOutputStream();
    os.write("hello".getBytes());
   // os.close();如果在这里关流,会导致整个socket都无法使用
    socket.shutdownOutput();//仅仅关闭输出流.并写一个结束标记,对socket没有任何影响
    
    BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    String line;
    while((line = br.readLine())!=null){
        System.out.println(line);
    }
    br.close();
    os.close();
    socket.close();
}

}

// 服务器

public class ServerDemo {

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

ServerSocket ss = new ServerSocket(10000);
    Socket accept = ss.accept();

    InputStream is = accept.getInputStream();
    int b;
    while((b = is.read())!=-1){
        System.out.println((char) b);
    }

    System.out.println("看看我执行了吗?");

    BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(accept.getOutputStream()));
    bw.write("你谁啊?");
    bw.newLine();
    bw.flush();

    bw.close();
    is.close();
    accept.close();
    ss.close();
}

}

public class Client {

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

//客户端：将本地文件上传到服务器。接收服务器的反馈。

//服务器：接收客户端上传的文件，上传完毕之后给出反馈。

    //1. 创建Socket对象，并连接服务器
    Socket socket = new Socket("127.0.0.1",10000);

    //2.读取本地文件中的数据，并写到服务器当中
    BufferedInputStream bis = new BufferedInputStream(new FileInputStream("mysocketnet\\clientdir\\a.jpg"));
    BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
    byte[] bytes = new byte[1024];
    int len;
    while ((len = bis.read(bytes)) != -1){
        bos.write(bytes,0,len);
    }

    //往服务器写出结束标记
    socket.shutdownOutput();


    //3.接收服务器的回写数据
    BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    String line = br.readLine();
    System.out.println(line);


    //4.释放资源
    socket.close();

}

}

public class Server {

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

//客户端：将本地文件上传到服务器。接收服务器的反馈。

//服务器：接收客户端上传的文件，上传完毕之后给出反馈。

    //1.创建对象并绑定端口
    ServerSocket ss = new ServerSocket(10000);

    //2.等待客户端来连接
    Socket socket = ss.accept();

    //3.读取数据并保存到本地文件中
    BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
    BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("mysocketnet\\serverdir\\a.jpg"));
    int len;
    byte[] bytes = new byte[1024];
    while ((len = bis.read(bytes)) != -1){
        bos.write(bytes,0,len);
    }
    bos.close();
    //4.回写数据
    BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
    bw.write("上传成功");
    bw.newLine();
    bw.flush();

    //5.释放资源
    socket.close();
    ss.close();
}

}

 public class UUIDTest {

public static void main(String[] args) {

String str = UUID.randomUUID().toString().replace("-", "");

System.out.println(str);//9f15b8c356c54f55bfcb0ee3023fce8a

}

}

public class Client {

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

//客户端：将本地文件上传到服务器。接收服务器的反馈。

//服务器：接收客户端上传的文件，上传完毕之后给出反馈。

    //1. 创建Socket对象，并连接服务器
    Socket socket = new Socket("127.0.0.1",10000);

    //2.读取本地文件中的数据，并写到服务器当中
    BufferedInputStream bis = new BufferedInputStream(new FileInputStream("mysocketnet\\clientdir\\a.jpg"));
    BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
    byte[] bytes = new byte[1024];
    int len;
    while ((len = bis.read(bytes)) != -1){
        bos.write(bytes,0,len);
    }

    //往服务器写出结束标记
    socket.shutdownOutput();


    //3.接收服务器的回写数据
    BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    String line = br.readLine();
    System.out.println(line);


    //4.释放资源
    socket.close();

}

}

public class Server {

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

//客户端：将本地文件上传到服务器。接收服务器的反馈。

//服务器：接收客户端上传的文件，上传完毕之后给出反馈。

    //1.创建对象并绑定端口
    ServerSocket ss = new ServerSocket(10000);

    //2.等待客户端来连接
    Socket socket = ss.accept();

    //3.读取数据并保存到本地文件中
    BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
    String name = UUID.randomUUID().toString().replace("-", "");
    BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("mysocketnet\\serverdir\\" + name + ".jpg"));
    int len;
    byte[] bytes = new byte[1024];
    while ((len = bis.read(bytes)) != -1) {
        bos.write(bytes, 0, len);
    }
    bos.close();
    //4.回写数据
    BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
    bw.write("上传成功");
    bw.newLine();
    bw.flush();

    //5.释放资源
    socket.close();
    ss.close();
}

}

public class Client {

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

//客户端：将本地文件上传到服务器。接收服务器的反馈。

//服务器：接收客户端上传的文件，上传完毕之后给出反馈。

    //1. 创建Socket对象，并连接服务器
    Socket socket = new Socket("127.0.0.1",10000);

    //2.读取本地文件中的数据，并写到服务器当中
    BufferedInputStream bis = new BufferedInputStream(new FileInputStream("mysocketnet\\clientdir\\a.jpg"));
    BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
    byte[] bytes = new byte[1024];
    int len;
    while ((len = bis.read(bytes)) != -1){
        bos.write(bytes,0,len);
    }

    //往服务器写出结束标记
    socket.shutdownOutput();

    //3.接收服务器的回写数据
    BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    String line = br.readLine();
    System.out.println(line);

    //4.释放资源
    socket.close();

}

}

public class Server {

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

//客户端：将本地文件上传到服务器。接收服务器的反馈。

//服务器：接收客户端上传的文件，上传完毕之后给出反馈。

    //1.创建对象并绑定端口
    ServerSocket ss = new ServerSocket(10000);

    while (true) {
        //2.等待客户端来连接
        Socket socket = ss.accept();

        //开启一条线程
        //一个用户就对应服务端的一条线程
        new Thread(new MyRunnable(socket)).start();
    }

}

}
public class MyRunnable implements Runnable{

Socket socket;

public MyRunnable(Socket socket){

this.socket = socket;

}
@Override
public void run() {
    try {
        //3.读取数据并保存到本地文件中
        BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
        String name = UUID.randomUUID().toString().replace("-", "");
        BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("mysocketnet\\serverdir\\" + name + ".jpg"));
        int len;
        byte[] bytes = new byte[1024];
        while ((len = bis.read(bytes)) != -1) {
            bos.write(bytes, 0, len);
        }
        bos.close();
        //4.回写数据
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        bw.write("上传成功");
        bw.newLine();
        bw.flush();
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        //5.释放资源
       if(socket != null){
           try {
               socket.close();
           } catch (IOException e) {
               e.printStackTrace();
           }
       }
    }
}

}

public class Client {

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

//客户端：将本地文件上传到服务器。接收服务器的反馈。

//服务器：接收客户端上传的文件，上传完毕之后给出反馈。

    //1. 创建Socket对象，并连接服务器
    Socket socket = new Socket("127.0.0.1",10000);

    //2.读取本地文件中的数据，并写到服务器当中
    BufferedInputStream bis = new BufferedInputStream(new FileInputStream("mysocketnet\\clientdir\\a.jpg"));
    BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
    byte[] bytes = new byte[1024];
    int len;
    while ((len = bis.read(bytes)) != -1){
        bos.write(bytes,0,len);
    }

    //往服务器写出结束标记
    socket.shutdownOutput();

    //3.接收服务器的回写数据
    BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    String line = br.readLine();
    System.out.println(line);

    //4.释放资源
    socket.close();

}

}

public class Server {

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

//客户端：将本地文件上传到服务器。接收服务器的反馈。

//服务器：接收客户端上传的文件，上传完毕之后给出反馈。

    //创建线程池对象
    ThreadPoolExecutor pool = new ThreadPoolExecutor(
            3,//核心线程数量
            16,//线程池总大小
            60,//空闲时间
            TimeUnit.SECONDS,//空闲时间（单位）
            new ArrayBlockingQueue<>(2),//队列
            Executors.defaultThreadFactory(),//线程工厂，让线程池如何创建线程对象
            new ThreadPoolExecutor.AbortPolicy()//阻塞队列
    );

    //1.创建对象并绑定端口
    ServerSocket ss = new ServerSocket(10000);
    while (true) {
        //2.等待客户端来连接
        Socket socket = ss.accept();
        //开启一条线程
        //一个用户就对应服务端的一条线程
        //new Thread(new MyRunnable(socket)).start();
        pool.submit(new MyRunnable(socket));
    }
}

}

public class MyRunnable implements Runnable{

Socket socket;

public MyRunnable(Socket socket){
    this.socket = socket;
}

@Override
public void run() {
    try {
        //3.读取数据并保存到本地文件中
        BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
        String name = UUID.randomUUID().toString().replace("-", "");
        BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("mysocketnet\\serverdir\\" + name + ".jpg"));
        int len;
        byte[] bytes = new byte[1024];
        while ((len = bis.read(bytes)) != -1) {
            bos.write(bytes, 0, len);
        }
        bos.close();
        //4.回写数据
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        bw.write("上传成功");
        bw.newLine();
        bw.flush();
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        //5.释放资源
       if(socket != null){
           try {
               socket.close();
           } catch (IOException e) {
               e.printStackTrace();
           }
       }
    }
}

}