网站的建设成本,北京市专业网站建设,wordpress用户vip,设计图片素材网站有哪些1. 网络编程入门
1.1 网络编程概述 计算机网络 是指将地理位置不同的具有独立功能的多台计算机及其外部设备#xff0c;通过通信线路连接起来#xff0c;在网络操作系统#xff0c;网络管理软件及网络通信协议的管理和协调下#xff0c;实现资源共享和信息传递的计算机系统…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 InetAddress
InetAddress此类表示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.创建对象ServerSockerServerSocket 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.创建对象ServerSockerServerSocket 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;}Overridepublic 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;}Overridepublic 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();}}}}
}
