1. 网络编程入门1.1 网络编程概述计算机网络是指将地理位置不同的具有独立功能的多台计算机及其外部设备通过通信线路连接起来在网络操作系统网络管理软件及网络通信协议的管理和协调下实现资源共享和信息传递的计算机系统网络编程在网络通信协议下不同计算机上运行的程序可以进行数据传输1.2 网络编程三要素IP地址要想让网络中的计算机能够互相通信必须为每台计算机指定一个标识号通过这个标识号来指定要接收数据的计算机和识别发送的计算机而IP地址就是这个标识号。也就是设备的标识端口网络的通信本质上是两个应用程序的通信。每台计算机都有很多的应用程序那么在网络通信时如何区分这些应用程序呢如果说IP地址可以唯一标识网络中的设备那么端口号就可以唯一标识设备中的应用程序了。也就是应用程序的标识协议通过计算机网络可以使多台计算机实现连接位于同一个网络中的计算机在进行连接和通信时需要遵守一定的规则这就好比在道路中行驶的汽车一定要遵守交通规则一样。在计算机网络中这些连接和通信的规则被称为网络通信协议它对数据的传输格式、传输速率、传输步骤等做了统一规定通信双方必须同时遵守才能完成数据交换。常见的协议有UDP协议和TCP协议1.3 IP地址IP地址是网络中设备的唯一标识IP地址分为两大类IPv4是给每个连接在网络上的主机分配一个32bit地址。按照TCP/IP规定IP地址用二进制来表示每个IP地址长32bit也就是4个字节。例如一个采用二进制形式的IP地址是“11000000 10101000 00000001 01000010”这么长的地址处理起来也太费劲了。为了方便使用IP地址经常被写成十进制的形式中间使用符号“.”分隔不同的字节。于是上面的IP地址可以表示为“192.168.1.66”。IP地址的这种表示法叫做“点分十进制表示法”这显然比1和0容易记忆得多IPv6由于互联网的蓬勃发展IP地址的需求量愈来愈大但是网络地址资源有限使得IP的分配越发紧张。为了扩大地址空间通过IPv6重新定义地址空间采用128位地址长度每16个字节一组分成8组十六进制数这样就解决了网络地址资源数量不够的问题DOS常用命令ipconfig查看本机IP地址ping IP地址检查网络是否连通特殊IP地址127.0.0.1是回送地址可以代表本机地址一般用来测试使用1.4 InetAddressInetAddress此类表示Internet协议IP地址相关方法方法名说明static InetAddress getByName(String host)确定主机名称的IP地址。主机名称可以是机器名称也可以是IP地址String getHostName()获取此IP地址的主机名String getHostAddress()返回文本显示中的IP地址字符串代码演示public class InetAddressDemo { public static void main(String[] args) throws UnknownHostException { //InetAddress address InetAddress.getByName(itheima); InetAddress address InetAddress.getByName(192.168.1.66); //public String getHostName()获取此IP地址的主机名 String name address.getHostName(); //public String getHostAddress()返回文本显示中的IP地址字符串 String ip address.getHostAddress(); System.out.println(主机名 name); System.out.println(IP地址 ip); } }1.5 端口和协议端口设备上应用程序的唯一标识端口号用两个字节表示的整数它的取值范围是065535。其中01023之间的端口号用于一些知名的网络服务和应用普通的应用程序需要使用1024以上的端口号。如果端口号被另外一个服务或应用所占用会导致当前程序启动失败协议计算机网络中连接和通信的规则被称为网络通信协议UDP协议用户数据报协议(User Datagram Protocol)UDP是无连接通信协议即在数据传输时数据的发送端和接收端不建立逻辑连接。简单来说当一台计算机向另外一台计算机发送数据时发送端不会确认接收端是否存在就会发出数据同样接收端在收到数据时也不会向发送端反馈是否收到数据。由于使用UDP协议消耗系统资源小通信效率高所以通常都会用于音频、视频和普通数据的传输例如视频会议通常采用UDP协议因为这种情况即使偶尔丢失一两个数据包也不会对接收结果产生太大影响。但是在使用UDP协议传送数据时由于UDP的面向无连接性不能保证数据的完整性因此在传输重要数据时不建议使用UDP协议TCP协议传输控制协议 (Transmission Control Protocol)TCP协议是面向连接的通信协议即传输数据之前在发送端和接收端建立逻辑连接然后再传输数据它提供了两台计算机之间可靠无差错的数据传输。在TCP连接中必须要明确客户端与服务器端由客户端向服务端发出连接请求每次连接的创建都需要经过“三次握手”三次握手TCP协议中在发送数据的准备阶段客户端与服务器之间的三次交互以保证连接的可靠第一次握手客户端向服务器端发出连接请求等待服务器确认第二次握手服务器端向客户端回送一个响应通知客户端收到了连接请求第三次握手客户端再次向服务器端发送确认信息确认连接完成三次握手连接建立后客户端和服务器就可以开始进行数据传输了。由于这种面向连接的特性TCP协议可以保证传输数据的安全所以应用十分广泛。例如上传文件、下载文件、浏览网页等2.UDP通信程序2.1 UDP发送数据Java中的UDP通信UDP协议是一种不可靠的网络协议它在通信的两端各建立一个Socket对象但是这两个Socket只是发送接收数据的对象因此对于基于UDP协议的通信双方而言没有所谓的客户端和服务器的概念Java提供了DatagramSocket类作为基于UDP协议的Socket构造方法方法名说明DatagramSocket()创建数据报套接字并将其绑定到本机地址上的任何可用端口DatagramPacket(byte[] buf,int len,InetAddress add,int port)创建数据包,发送长度为len的数据包到指定主机的指定端口相关方法方法名说明void send(DatagramPacket p)发送数据报包void close()关闭数据报套接字void receive(DatagramPacket p)从此套接字接受数据报包发送数据的步骤创建发送端的Socket对象(DatagramSocket)创建数据并把数据打包调用DatagramSocket对象的方法发送数据关闭发送端代码演示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(); } }2.2UDP接收数据接收数据的步骤创建接收端的Socket对象(DatagramSocket)创建一个数据包用于接收数据调用DatagramSocket对象的方法接收数据解析数据包并把数据在控制台显示关闭接收端构造方法方法名说明DatagramPacket(byte[] buf, int len)创建一个DatagramPacket用于接收长度为len的数据包相关方法方法名说明byte[] getData()返回数据缓冲区int getLength()返回要发送的数据的长度或接收的数据的长度示例代码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())); } } }2.3UDP通信程序练习案例需求UDP发送数据数据来自于键盘录入直到输入的数据是886发送数据结束UDP接收数据因为接收端不知道发送端什么时候停止发送故采用死循环接收代码实现/* 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(); } }2.4UDP三种通讯方式单播单播用于两个主机之间的端对端通信组播组播用于对一组特定的主机进行通信广播广播用于一个主机对整个局域网上所有主机上的数据通信2.5UDP组播实现实现步骤发送端创建发送端的Socket对象(DatagramSocket)创建数据并把数据打包(DatagramPacket)调用DatagramSocket对象的方法发送数据(在单播中,这里是发给指定IP的电脑但是在组播当中,这里是发给组播地址)释放资源接收端创建接收端Socket对象(MulticastSocket)创建一个箱子,用于接收数据把当前计算机绑定一个组播地址将数据接收到箱子中解析数据包,并打印数据释放资源代码实现// 发送端 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(); } }2.6UDP广播实现实现步骤发送端创建发送端Socket对象(DatagramSocket)创建存储数据的箱子,将广播地址封装进去发送数据释放资源接收端创建接收端的Socket对象(DatagramSocket)创建一个数据包用于接收数据调用DatagramSocket对象的方法接收数据解析数据包并把数据在控制台显示关闭接收端代码实现// 发送端 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(); } }3. TCP通信程序3.1TCP发送数据Java中的TCP通信Java对基于TCP协议的的网络提供了良好的封装使用Socket对象来代表两端的通信端口并通过Socket产生IO流来进行网络通信。Java为客户端提供了Socket类为服务器端提供了ServerSocket类构造方法方法名说明Socket(InetAddress address,int port)创建流套接字并将其连接到指定IP指定端口号Socket(String host, int port)创建流套接字并将其连接到指定主机上的指定端口号相关方法方法名说明InputStream getInputStream()返回此套接字的输入流OutputStream getOutputStream()返回此套接字的输出流示例代码public class Client { public static void main(String[] args) throws IOException { //TCP协议发送数据 //1.创建Socket对象 //细节在创建对象的同时会连接服务端 // 如果连接不上代码会报错 Socket socket new Socket(127.0.0.1,10000); //2.可以从连接通道中获取输出流 OutputStream os socket.getOutputStream(); //写出数据 os.write(aaa.getBytes()); //3.释放资源 os.close(); socket.close(); } }3.2TCP接收数据构造方法方法名说明ServletSocket(int port)创建绑定到指定端口的服务器套接字相关方法方法名说明Socket accept()监听要连接到此的套接字并接受它注意事项accept方法是阻塞的,作用就是等待客户端连接客户端创建对象并连接服务器,此时是通过三次握手协议,保证跟服务器之间的连接针对客户端来讲,是往外写的,所以是输出流 针对服务器来讲,是往里读的,所以是输入流read方法也是阻塞的客户端在关流的时候,还多了一个往服务器写结束标记的动作最后一步断开连接,通过四次挥手协议保证连接终止三次握手和四次挥手三次握手四次挥手示例代码public class Server { public static void main(String[] args) throws IOException { //TCP协议接收数据 //1.创建对象ServerSocker ServerSocket ss new ServerSocket(10000); //2.监听客户端的链接 Socket socket ss.accept(); //3.从连接通道中获取输入流读取数据 InputStream is socket.getInputStream(); int b; while ((b is.read()) ! -1){ System.out.println((char) b); } //4.释放资源 socket.close(); ss.close(); } }3.3TCP程序练习传输中文发送端public class Client { public static void main(String[] args) throws IOException { //TCP协议发送数据 //1.创建Socket对象 //细节在创建对象的同时会连接服务端 // 如果连接不上代码会报错 Socket socket new Socket(127.0.0.1,10000); //2.可以从连接通道中获取输出流 OutputStream os socket.getOutputStream(); //写出数据 os.write(你好你好.getBytes());//12字节 //3.释放资源 os.close(); socket.close(); } }接收端public class Server { public static void main(String[] args) throws IOException { //TCP协议接收数据 //1.创建对象ServerSocker ServerSocket ss new ServerSocket(10000); //2.监听客户端的链接 Socket socket ss.accept(); //3.从连接通道中获取输入流读取数据 InputStream is socket.getInputStream(); InputStreamReader isr new InputStreamReader(is); BufferedReader br new BufferedReader(isr); // BufferedReader br new BufferedReader(new InputStreamReader(socket.getInputStream())); int b; while ((b br.read()) ! -1){ System.out.print((char) b); } //4.释放资源 socket.close(); ss.close(); } }4. 综合练习练习一多发多收需求​ 客户端多次发送数据​ 服务器接收多次接收数据并打印代码示例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(); } }练习三上传练习TCP协议案例需求客户端数据来自于本地文件接收服务器反馈服务器接收到的数据写入本地文件给出反馈案例分析创建客户端对象创建输入流对象指向文件每读一次数据就给服务器输出一次数据输出结束后使用shutdownOutput()方法告知服务端传输结束创建服务器对象创建输出流对象指向文件每接受一次数据就使用输出流输出到文件中传输结束后。使用输出流给客户端反馈信息客户端接受服务端的回馈信息相关方法方法名说明void shutdownInput()将此套接字的输入流放置在“流的末尾”void shutdownOutput()禁止用此套接字的输出流代码实现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(); } }练习四文件名重复javapublic 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 ArrayBlockingQueuelt;gt;(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(); } } } } }