B站韩顺平java学习笔记(二十)-- 网络编程 章节
目录
一 网络的编程概念
1 网络通信
(1)概念
(2)网络通信
2 网络
(1)概念
(2)基于网络的覆盖范围进行分类
3 IP地址
4 域名
(1)示例
(2)好处
(3)概念
5 端口号
(1)概念
(2)表示形式
(3)常见的网络程序端口号
6 网络通信协议
7 TCP和UDP
(1)TCP协议(传输控制协议)
(2)UDP协议(用户数据协议)
二 InetAddress类
1 相关方法
2 应用案例
三 Socket套接字
1 基本介绍
2 TCP网络通信编程
(1)基本介绍
(2)应用实例1
(3)应用实例2
(4)应用实例3【使用字符流】
(5)应用实例4
(6)netstat指令
3 UDP网络通信编程
(1)基本介绍
(2)基本流程
(3)示意图
(4)应用案例
4 课后作业
(1)编程题
(2)编程题
(3)编程题
一 网络的编程概念
1 网络通信
(1)概念
两台设备之间通过网络实现数据传输;
(2)网络通信
将数据通过网络从一台设备传输到另一台设备;
Java.net包下提供了一系列的类或接口,供程序员使用,完成网络通信。
2 网络
(1)概念
两台或多台设备通过一定物理设备连接起来构成了网络。
(2)基于网络的覆盖范围进行分类
局域网:覆盖范围最小,仅仅覆盖一个教师或一个机房;
城域网:覆盖范围较大,可以覆盖一个城市;
广域网:覆盖范围最大,可以覆盖全国,甚至全球,万维网是广域网的代表。
3 IP地址
(1)概念:用于唯一表示网络中的每台计算机/主机;
(2)查看ip地址:ipconfig;
(3)ip地址的表示形式:点分十进制 xx.xx.xx.xx;
(4)每一个十进制数的范围:0-255;
(5)ip地址的组成 = 网络地址 + 主机地址 ,比如:192.128.16.69;
(6)IPv6是互联网工程任务组设计的用于替代IPv4的下一代IP协议,其地址数量号可以称为全世界的每一粒沙子编上一个地址;
(7)由于IPv4最大的问题在于网络地址资源有限,严重制约了互联网的应用和发展。IPv6的使用,不仅能解决网络地址资源数量的问题,而且也解决了多种接入设备连入互联网的障碍。
4 域名
(1)示例
www.baidu.com
(2)好处
为了方便记忆,解决记IP的困难。
(3)概念
将IP地址映射成域名。
5 端口号
(1)概念
用于表示计算机上某个特定的网络程序。
(2)表示形式
以整数形式,端口范围0~65535【2个字节表示端口0~(2的16次方)-1】
(3)常见的网络程序端口号
0~1024已经被占用,比如ssh 22,ftp 21,smtp 25,http 80;
tomcat 8080,mysql 3306,oracle 1521,sqlserver 1433。
6 网络通信协议
(1)协议(tcp/ip)
TCP/IP(Transmission Control Protocol/Internet Protocol)的简写。中文名为传输控制协议/因特网互联协议,又叫网络通讯协议、这个协议是Internet最基本的协议、Internet国际互联网络的基础,简单来说,就是由网络层的IP协议和传输层的TCP协议组成的。
(2)示意图
7 TCP和UDP
(1)TCP协议(传输控制协议)
① 使用TCP协议前,须先建立TCP连接,形成传输数据通道;
② 传输前,采用“三次握手”方式,确认是可靠的;
③ TCP协议进行通信的两个应用进程:客户端、服务端;
④ 在连接中可进行大数据量的传输;
⑤ 传输完毕,需释放已建立的连接,效率低。
(2)UDP协议(用户数据协议)
① 将数据、源、目的封装成数据包,不需要建立连接;
② 每个数据报的大小限制在64K内,不适合传输大量数据;
③ 因无需连接,故是不可靠的;
④ 发送数据结束时无需释放资源(因为不是面向连接的),速度快;
⑤ 举例:测试通知:发短信。
二 InetAddress类
1 相关方法
(1)获取本机InetAddress对象 getLocalHost;
(2)根据指定主机名/域名获取IP地址对象,getByName;
(3)获取InetAddress对象的主机名 getHostName;
(4)获取InetAddress对象的地址 getHostAddress。
2 应用案例
public class API_ {public static void main(String[] args) throws UnknownHostException {//1. 获取本机的InetAddress 对象InetAddress localHost = InetAddress.getLocalHost();System.out.println(localHost);//DESKTOP-S4MP84S/192.168.12.1//2. 根据指定主机名 获取 InetAddress对象InetAddress host1 = InetAddress.getByName("DESKTOP-S4MP84S");System.out.println("host1=" + host1);//DESKTOP-S4MP84S/192.168.12.1//3. 根据域名返回 InetAddress对象, 比如 www.baidu.com 对应InetAddress host2 = InetAddress.getByName("www.baidu.com");System.out.println("host2=" + host2);//www.baidu.com / 110.242.68.4//4. 通过 InetAddress 对象,获取对应的地址String hostAddress = host2.getHostAddress();//IP 110.242.68.4System.out.println("host2 对应的ip = " + hostAddress);//110.242.68.4//5. 通过 InetAddress 对象,获取对应的主机名/或者的域名String hostName = host2.getHostName();System.out.println("host2对应的主机名/域名=" + hostName); // www.baidu.com}
}
三 Socket套接字
1 基本介绍
(1)套接字(Socket)开发网络应用程序被广泛采用,以至于成为事实上的标准;
(2)通讯的两端都要有Socket,是两台机器之间的通讯端点;
(3)网络通信其实就是Socket间的通信;
(4)Socket允许程序把网络连接当成一个流,数据在两个Socket间通过IO传输;
(5)一般主动发起通信的应用程序属于客户端,等待通信请求的为服务端。
2 TCP网络通信编程
(1)基本介绍
① 基于客户端-服务端的网络通信;
② 底层使用的是TCP/IP协议;
③ 应用场景举例:客户端发送数据,都无端接受并显示控制台;
④ 基于Sockte的TCP编程。
(2)应用实例1
//Client类/*** 客户端,发送 "hello, server" 给服务端*/
public class SocketTCP01Client {public static void main(String[] args) throws IOException {//思路//1. 连接服务端 (ip , 端口)//解读: 连接本机的 9999端口, 如果连接成功,返回Socket对象Socket socket = new Socket(InetAddress.getLocalHost(), 9999);System.out.println("客户端 socket返回=" + socket.getClass());//2. 连接上后,生成Socket, 通过socket.getOutputStream()// 得到 和 socket对象关联的输出流对象OutputStream outputStream = socket.getOutputStream();//3. 通过输出流,写入数据到 数据通道outputStream.write("hello, server".getBytes());//4. 关闭流对象和socket, 必须关闭outputStream.close();socket.close();System.out.println("客户端退出.....");}
}
//Server类
/*** 服务端*/
public class SocketTCP01Server {public static void main(String[] args) throws IOException {//思路//1. 在本机 的9999端口监听, 等待连接// 细节: 要求在本机没有其它服务在监听9999// 细节:这个 ServerSocket 可以通过 accept() 返回多个Socket[多个客户端连接服务器的并发]ServerSocket serverSocket = new ServerSocket(9999);System.out.println("服务端,在9999端口监听,等待连接..");//2. 当没有客户端连接9999端口时,程序会 阻塞, 等待连接// 如果有客户端连接,则会返回Socket对象,程序继续Socket socket = serverSocket.accept();System.out.println("服务端 socket =" + socket.getClass());////3. 通过socket.getInputStream() 读取客户端写入到数据通道的数据, 显示InputStream inputStream = socket.getInputStream();//4. IO读取byte[] buf = new byte[1024];int readLen = 0;while ((readLen = inputStream.read(buf)) != -1) {System.out.println(new String(buf, 0, readLen));//根据读取到的实际长度,显示内容.}//5.关闭流和socketinputStream.close();socket.close();serverSocket.close();//关闭}
}
(3)应用实例2
//Client类
/*** 客户端,发送 "hello, server" 给服务端*/
@SuppressWarnings({"all"})
public class SocketTCP02Client {public static void main(String[] args) throws IOException {//思路//1. 连接服务端 (ip , 端口)//解读: 连接本机的 9999端口, 如果连接成功,返回Socket对象Socket socket = new Socket(InetAddress.getLocalHost(), 9999);System.out.println("客户端 socket返回=" + socket.getClass());//2. 连接上后,生成Socket, 通过socket.getOutputStream()// 得到 和 socket对象关联的输出流对象OutputStream outputStream = socket.getOutputStream();//3. 通过输出流,写入数据到 数据通道outputStream.write("hello, server".getBytes());// 设置结束标记socket.shutdownOutput();//4. 获取和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));}//5. 关闭流对象和socket, 必须关闭inputStream.close();outputStream.close();socket.close();System.out.println("客户端退出.....");}
}
//Server类
//** * 服务端*/
@SuppressWarnings({"all"})
public class SocketTCP02Server {public static void main(String[] args) throws IOException {//思路//1. 在本机 的9999端口监听, 等待连接// 细节: 要求在本机没有其它服务在监听9999// 细节:这个 ServerSocket 可以通过 accept() 返回多个Socket[多个客户端连接服务器的并发]ServerSocket serverSocket = new ServerSocket(9999);System.out.println("服务端,在9999端口监听,等待连接..");//2. 当没有客户端连接9999端口时,程序会 阻塞, 等待连接// 如果有客户端连接,则会返回Socket对象,程序继续Socket socket = serverSocket.accept();System.out.println("服务端 socket =" + socket.getClass());////3. 通过socket.getInputStream() 读取客户端写入到数据通道的数据, 显示InputStream inputStream = socket.getInputStream();//4. IO读取byte[] buf = new byte[1024];int readLen = 0;while ((readLen = inputStream.read(buf)) != -1) {System.out.println(new String(buf, 0, readLen));//根据读取到的实际长度,显示内容.}//5. 获取socket相关联的输出流OutputStream outputStream = socket.getOutputStream();outputStream.write("hello, client".getBytes());// 设置结束标记socket.shutdownOutput();//6.关闭流和socketoutputStream.close();inputStream.close();socket.close();serverSocket.close();//关闭}
}
(4)应用实例3【使用字符流】
//Client类
/*** 客户端,发送 "hello, server" 给服务端, 使用字符流*/
@SuppressWarnings({"all"})
public class SocketTCP03Client {public static void main(String[] args) throws IOException {//思路//1. 连接服务端 (ip , 端口)//解读: 连接本机的 9999端口, 如果连接成功,返回Socket对象Socket socket = new Socket(InetAddress.getLocalHost(), 9999);System.out.println("客户端 socket返回=" + socket.getClass());//2. 连接上后,生成Socket, 通过socket.getOutputStream()// 得到 和 socket对象关联的输出流对象OutputStream outputStream = socket.getOutputStream();//3. 通过输出流,写入数据到 数据通道, 使用字符流BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));bufferedWriter.write("hello, server 字符流");bufferedWriter.newLine();//插入一个换行符,表示写入的内容结束, 注意,要求对方使用readLine()!!!!bufferedWriter.flush();// 如果使用的字符流,需要手动刷新,否则数据不会写入数据通道//4. 获取和socket关联的输入流. 读取数据(字符),并显示InputStream inputStream = socket.getInputStream();BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));String s = bufferedReader.readLine();System.out.println(s);//5. 关闭流对象和socket, 必须关闭bufferedReader.close();//关闭外层流bufferedWriter.close();socket.close();System.out.println("客户端退出.....");}
}
//Server类
/*** 服务端, 使用字符流方式读写*/
@SuppressWarnings({"all"})
public class SocketTCP03Server {public static void main(String[] args) throws IOException {//思路//1. 在本机 的9999端口监听, 等待连接// 细节: 要求在本机没有其它服务在监听9999// 细节:这个 ServerSocket 可以通过 accept() 返回多个Socket[多个客户端连接服务器的并发]ServerSocket serverSocket = new ServerSocket(9999);System.out.println("服务端,在9999端口监听,等待连接..");//2. 当没有客户端连接9999端口时,程序会 阻塞, 等待连接// 如果有客户端连接,则会返回Socket对象,程序继续Socket socket = serverSocket.accept();System.out.println("服务端 socket =" + socket.getClass());////3. 通过socket.getInputStream() 读取客户端写入到数据通道的数据, 显示InputStream inputStream = socket.getInputStream();//4. IO读取, 使用字符流, 老师使用 InputStreamReader 将 inputStream 转成字符流BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));String s = bufferedReader.readLine();System.out.println(s);//输出//5. 获取socket相关联的输出流OutputStream outputStream = socket.getOutputStream();// 使用字符输出流的方式回复信息BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));bufferedWriter.write("hello client 字符流");bufferedWriter.newLine();// 插入一个换行符,表示回复内容的结束bufferedWriter.flush();//注意需要手动的flush//6.关闭流和socketbufferedWriter.close();bufferedReader.close();socket.close();serverSocket.close();//关闭}
}
(5)应用实例4
//Client类
/*** 文件上传的客户端*/
public class TCPFileUploadClient {public static void main(String[] args) throws Exception {//客户端连接服务端 8888,得到Socket对象Socket socket = new Socket(InetAddress.getLocalHost(), 8888);//创建读取磁盘文件的输入流//String filePath = "e:\\qie.png";String filePath = "e:\\abc.mp4";BufferedInputStream bis = new BufferedInputStream(new FileInputStream(filePath));//bytes 就是filePath对应的字节数组byte[] bytes = StreamUtils.streamToByteArray(bis);//通过socket获取到输出流, 将bytes数据发送给服务端BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());bos.write(bytes);//将文件对应的字节数组的内容,写入到数据通道bis.close();socket.shutdownOutput();//设置写入数据的结束标记//=====接收从服务端回复的消息=====InputStream inputStream = socket.getInputStream();//使用StreamUtils 的方法,直接将 inputStream 读取到的内容 转成字符串String s = StreamUtils.streamToString(inputStream);System.out.println(s);//关闭相关的流inputStream.close();bos.close();socket.close();}}
//Server类
/*** 文件上传的服务端*/
public class TCPFileUploadServer {public static void main(String[] args) throws Exception {//1. 服务端在本机监听8888端口ServerSocket serverSocket = new ServerSocket(8888);System.out.println("服务端在8888端口监听....");//2. 等待连接Socket socket = serverSocket.accept();//3. 读取客户端发送的数据// 通过Socket得到输入流BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());byte[] bytes = StreamUtils.streamToByteArray(bis);//4. 将得到 bytes 数组,写入到指定的路径,就得到一个文件了String destFilePath = "src\\abc.mp4";BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(destFilePath));bos.write(bytes);bos.close();// 向客户端回复 "收到图片"// 通过socket 获取到输出流(字符)BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));writer.write("收到图片");writer.flush();//把内容刷新到数据通道socket.shutdownOutput();//设置写入结束标记//关闭其他资源writer.close();bis.close();socket.close();serverSocket.close();}
}
(6)netstat指令
① netstat -an 可以查看当前主机网络情况,包括端口监听情况和网络连接情况;
② netstat -an | more 可以分页显示;
③ 要求在dos控制台下执行win + r
说明:
a Listening 表示某个端口在监听;
b 如果由一个外部程序(客户端)连接到该端口,就会显示一条连接信息;
c 可以输入ctrl + c 退出指令。
(7)TCP的注意事项
① 当客户端连接到服务端后,实际上客户端也是通过一个端口和服务端进行通讯的,这个端口是TCP/IP来分配的。
② 示意图
③ 程序验证
3 UDP网络通信编程
(1)基本介绍
(2)基本流程
(3)示意图
(4)应用案例
//ReceiverA类
/*** UDP接收端*/
public class UDPReceiverA {public static void main(String[] args) throws IOException {//1. 创建一个 DatagramSocket 对象,准备在9999接收数据DatagramSocket socket = new DatagramSocket(9999);//2. 构建一个 DatagramPacket 对象,准备接收数据// 在前面讲解UDP 协议时,老师说过一个数据包最大 64kbyte[] buf = new byte[1024];DatagramPacket packet = new DatagramPacket(buf, buf.length);//3. 调用 接收方法, 将通过网络传输的 DatagramPacket 对象// 填充到 packet对象//老师提示: 当有数据包发送到 本机的9999端口时,就会接收到数据// 如果没有数据包发送到 本机的9999端口, 就会阻塞等待.System.out.println("接收端A 等待接收数据..");socket.receive(packet);//4. 可以把packet 进行拆包,取出数据,并显示.int length = packet.getLength();//实际接收到的数据字节长度byte[] data = packet.getData();//接收到数据String s = new String(data, 0, length);System.out.println(s);//===回复信息给B端//将需要发送的数据,封装到 DatagramPacket对象data = "好的, 明天见".getBytes();//说明: 封装的 DatagramPacket对象 data 内容字节数组 , data.length , 主机(IP) , 端口packet =new DatagramPacket(data, data.length, InetAddress.getByName("192.168.12.1"), 9998);socket.send(packet);//发送//5. 关闭资源socket.close();System.out.println("A端退出...");}
}
//UDPSenderB类
/*** 发送端B ====> 也可以接收数据*/
@SuppressWarnings({"all"})
public class UDPSenderB {public static void main(String[] args) throws IOException {//1.创建 DatagramSocket 对象,准备在9998端口 接收数据DatagramSocket socket = new DatagramSocket(9998);//2. 将需要发送的数据,封装到 DatagramPacket对象byte[] data = "hello 明天吃火锅~".getBytes(); ////说明: 封装的 DatagramPacket对象 data 内容字节数组 , data.length , 主机(IP) , 端口DatagramPacket packet =new DatagramPacket(data, data.length, InetAddress.getByName("192.168.12.1"), 9999);socket.send(packet);//3.=== 接收从A端回复的信息//(1) 构建一个 DatagramPacket 对象,准备接收数据// 在前面讲解UDP 协议时,老师说过一个数据包最大 64kbyte[] buf = new byte[1024];packet = new DatagramPacket(buf, buf.length);//(2) 调用 接收方法, 将通过网络传输的 DatagramPacket 对象// 填充到 packet对象//老师提示: 当有数据包发送到 本机的9998端口时,就会接收到数据// 如果没有数据包发送到 本机的9998端口, 就会阻塞等待.socket.receive(packet);//(3) 可以把packet 进行拆包,取出数据,并显示.int length = packet.getLength();//实际接收到的数据字节长度data = packet.getData();//接收到数据String s = new String(data, 0, length);System.out.println(s);//关闭资源socket.close();System.out.println("B端退出");}
}
4 课后作业
(1)编程题
//Client类
/*** 客户端,发送 "hello, server" 给服务端, 使用字符流*/
@SuppressWarnings({"all"})
public class Homework01Client {public static void main(String[] args) throws IOException {//思路//1. 连接服务端 (ip , 端口)//解读: 连接本机的 9999端口, 如果连接成功,返回Socket对象Socket socket = new Socket(InetAddress.getLocalHost(), 9999);//2. 连接上后,生成Socket, 通过socket.getOutputStream()// 得到 和 socket对象关联的输出流对象OutputStream outputStream = socket.getOutputStream();//3. 通过输出流,写入数据到 数据通道, 使用字符流BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));//从键盘读取用户的问题Scanner scanner = new Scanner(System.in);System.out.println("请输入你的问题");String question = scanner.next();bufferedWriter.write(question);bufferedWriter.newLine();//插入一个换行符,表示写入的内容结束, 注意,要求对方使用readLine()!!!!bufferedWriter.flush();// 如果使用的字符流,需要手动刷新,否则数据不会写入数据通道//4. 获取和socket关联的输入流. 读取数据(字符),并显示InputStream inputStream = socket.getInputStream();BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));String s = bufferedReader.readLine();System.out.println(s);//5. 关闭流对象和socket, 必须关闭bufferedReader.close();//关闭外层流bufferedWriter.close();socket.close();System.out.println("客户端退出.....");}
}
//Server类
/*** 服务端, 使用字符流方式读写*/
@SuppressWarnings({"all"})
public class Homework01Server {public static void main(String[] args) throws IOException {//思路//1. 在本机 的9999端口监听, 等待连接// 细节: 要求在本机没有其它服务在监听9999// 细节:这个 ServerSocket 可以通过 accept() 返回多个Socket[多个客户端连接服务器的并发]ServerSocket serverSocket = new ServerSocket(9999);System.out.println("服务端,在9999端口监听,等待连接..");//2. 当没有客户端连接9999端口时,程序会 阻塞, 等待连接// 如果有客户端连接,则会返回Socket对象,程序继续Socket socket = serverSocket.accept();////3. 通过socket.getInputStream() 读取客户端写入到数据通道的数据, 显示InputStream inputStream = socket.getInputStream();//4. IO读取, 使用字符流, 老师使用 InputStreamReader 将 inputStream 转成字符流BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));String s = bufferedReader.readLine();String answer = "";if ("name".equals(s)) {answer = "我是韩顺平";} else if("hobby".equals(s)) {answer = "编写java程序";} else {answer = "你说的啥子";}//5. 获取socket相关联的输出流OutputStream outputStream = socket.getOutputStream();// 使用字符输出流的方式回复信息BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));bufferedWriter.write(answer);bufferedWriter.newLine();// 插入一个换行符,表示回复内容的结束bufferedWriter.flush();//注意需要手动的flush//6.关闭流和socketbufferedWriter.close();bufferedReader.close();socket.close();serverSocket.close();//关闭}
}
(2)编程题
//Homework02ReceiverA类
/*** UDP接收端*/
@SuppressWarnings({"all"})
public class Homework02ReceiverA {public static void main(String[] args) throws IOException {//1. 创建一个 DatagramSocket 对象,准备在8888接收数据DatagramSocket socket = new DatagramSocket(8888);//2. 构建一个 DatagramPacket 对象,准备接收数据// 在前面讲解UDP 协议时,老师说过一个数据包最大 64kbyte[] buf = new byte[1024];DatagramPacket packet = new DatagramPacket(buf, buf.length);//3. 调用 接收方法, 将通过网络传输的 DatagramPacket 对象// 填充到 packet对象System.out.println("接收端 等待接收问题 ");socket.receive(packet);//4. 可以把packet 进行拆包,取出数据,并显示.int length = packet.getLength();//实际接收到的数据字节长度byte[] data = packet.getData();//接收到数据String s = new String(data, 0, length);//判断接收到的信息是什么String answer = "";if("四大名著是哪些".equals(s)) {answer = "四大名著 <<红楼梦>> <<三国演示>> <<西游记>> <<水浒传>>";} else {answer = "what?";}//===回复信息给B端//将需要发送的数据,封装到 DatagramPacket对象data = answer.getBytes();//说明: 封装的 DatagramPacket对象 data 内容字节数组 , data.length , 主机(IP) , 端口packet =new DatagramPacket(data, data.length, InetAddress.getByName("192.168.12.1"), 9998);socket.send(packet);//发送//5. 关闭资源socket.close();System.out.println("A端退出...");}
}
//Homework02SenderB类
/*** 发送端B ====> 也可以接收数据*/
@SuppressWarnings({"all"})
public class Homework02SenderB {public static void main(String[] args) throws IOException {//1.创建 DatagramSocket 对象,准备在9998端口 接收数据DatagramSocket socket = new DatagramSocket(9998);//2. 将需要发送的数据,封装到 DatagramPacket对象Scanner scanner = new Scanner(System.in);System.out.println("请输入你的问题: ");String question = scanner.next();byte[] data = question.getBytes(); ////说明: 封装的 DatagramPacket对象 data 内容字节数组 , data.length , 主机(IP) , 端口DatagramPacket packet =new DatagramPacket(data, data.length, InetAddress.getByName("192.168.12.1"), 8888);socket.send(packet);//3.=== 接收从A端回复的信息//(1) 构建一个 DatagramPacket 对象,准备接收数据// 在前面讲解UDP 协议时,老师说过一个数据包最大 64kbyte[] buf = new byte[1024];packet = new DatagramPacket(buf, buf.length);//(2) 调用 接收方法, 将通过网络传输的 DatagramPacket 对象// 填充到 packet对象//老师提示: 当有数据包发送到 本机的9998端口时,就会接收到数据// 如果没有数据包发送到 本机的9998端口, 就会阻塞等待.socket.receive(packet);//(3) 可以把packet 进行拆包,取出数据,并显示.int length = packet.getLength();//实际接收到的数据字节长度data = packet.getData();//接收到数据String s = new String(data, 0, length);System.out.println(s);//关闭资源socket.close();System.out.println("B端退出");}
}
(3)编程题
//Homework03Server类
/*** 先写文件下载的服务端*/
public class Homework03Server {public static void main(String[] args) throws Exception {//1 监听 9999端口ServerSocket serverSocket = new ServerSocket(9999);//2.等待客户端连接System.out.println("服务端,在9999端口监听,等待下载文件");Socket socket = serverSocket.accept();//3.读取 客户端发送要下载的文件名// 这里老师使用了while读取文件名,时考虑将来客户端发送的数据较大的情况InputStream inputStream = socket.getInputStream();byte[] b = new byte[1024];int len = 0;String downLoadFileName = "";while ((len = inputStream.read(b)) != -1) {downLoadFileName += new String(b, 0 , len);}System.out.println("客户端希望下载文件名=" + downLoadFileName);//老师在服务器上有两个文件, 无名.mp3 高山流水.mp3//如果客户下载的是 高山流水 我们就返回该文件,否则一律返回 无名.mp3String resFileName = "";if("高山流水".equals(downLoadFileName)) {resFileName = "src\\高山流水.mp3";} else {resFileName = "src\\无名.mp3";}//4. 创建一个输入流,读取文件BufferedInputStream bis =new BufferedInputStream(new FileInputStream(resFileName));//5. 使用工具类StreamUtils ,读取文件到一个字节数组byte[] bytes = StreamUtils.streamToByteArray(bis);//6. 得到Socket关联的输出流BufferedOutputStream bos =new BufferedOutputStream(socket.getOutputStream());//7. 写入到数据通道,返回给客户端bos.write(bytes);socket.shutdownOutput();//很关键.//8 关闭相关的资源bis.close();inputStream.close();socket.close();serverSocket.close();System.out.println("服务端退出...");}
}
//Homework03Client类
/*** 文件下载的客户端*/
public class Homework03Client {public static void main(String[] args) throws Exception {//1. 接收用户输入,指定下载文件名Scanner scanner = new Scanner(System.in);System.out.println("请输入下载文件名");String downloadFileName = scanner.next();//2. 客户端连接服务端,准备发送Socket socket = new Socket(InetAddress.getLocalHost(), 9999);//3. 获取和Socket关联的输出流OutputStream outputStream = socket.getOutputStream();outputStream.write(downloadFileName.getBytes());//设置写入结束的标志socket.shutdownOutput();//4. 读取服务端返回的文件(字节数据)BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());byte[] bytes = StreamUtils.streamToByteArray(bis);//5. 得到一个输出流,准备将 bytes 写入到磁盘文件//比如你下载的是 高山流水 => 下载的就是 高山流水.mp3// 你下载的是 韩顺平 => 下载的就是 无名.mp3 文件名 韩顺平.mp3String filePath = "e:\\" + downloadFileName + ".mp3";BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(filePath));bos.write(bytes);//6. 关闭相关的资源bos.close();bis.close();outputStream.close();socket.close();System.out.println("客户端下载完毕,正确退出..");}
}
B站韩顺平java学习笔记(二十)-- 网络编程 章节相关推荐
- B站韩顺平java学习笔记(三)--运算符章节
目录 一.算术运算符 1. 表格 2. 练习题: 二. 关系运算符 1. 表格 三.逻辑运算符 1. 表格 2. 练习题 四.赋值运算符 1. 介绍 2.细节特点 五.三元运算符 1. ...
- B站韩顺平java学习笔记(十六)-- 多线程基础章节
目录 一 线程介绍 1 线程相关概念 (1)程序 (2)进程 (3)什么是线程 (4)其他相关概念 (5)查看电脑有多少个cpu核 二 线程的使用 1 线程的创建 (1)继承Thread类,重 ...
- B站韩顺平java学习笔记(二十五)-- 正则表达式章节
目录 一 正则表达式入门 1 极速体验正则表达式威力 二 为什么要学正则表达式 三 正则表达式基本介绍 1 介绍 2 正则表达式底层实现
- B站韩顺平java学习笔记(二十三)-- MYSQL基础篇 章节
目录 一 数据库 1 数据库简单原理图 2 使用命令行窗口连接MYSQL数据库 3 MySQL三层结构 4 数据在数据库中的存储方式 5 SQL语句分类 6 创建数据库 7 查看.删除 ...
- B站韩顺平java学习笔记(六)--面向对象编程章节
目录 一.类和对象 1.定义及区别 2.对象内存布局 3.属性/成员变量 (1)基本介绍 (2)注意事项和细节说明 (3)访问属性 4.对象 (1)创建对象 (2)对象分配机制 (3)Java创建对 ...
- B站韩顺平java学习笔记(八)-- 房屋出租系统(项目)章节
目录 一 项目需求说明 1 项目界面 二 房屋租赁程序框架图 三 系统实现 1 完成House类 2 显示主菜单和完成退出软件的功能 3 完成显示房屋列表的功能 4 添加房屋信息的功能 ...
- 韩顺平Java学习笔记_IO流专题
目录 一 文件 1.文件的概念: 文件是保存数据的地方 2.文件流:文件在程序中是以流的形式来操作的 2.1.输入流指数据从数据源(文件)到程序(内存)的路径 2.2.输出流指数据从程序(内存)到数据 ...
- 韩顺平Java学习笔记P245对象创建流程分析P246this关键字-P250
P245对象创建流程分析 //1.先在方法区加载方法类 //2.在堆里开空间一个存放age,一个存放name //3.(先默认初始化有默认值age=0,name=null,再显示初始化age=90,n ...
- Java学习笔记二十五:Java面向对象的三大特性之多态
Java面向对象的三大特性之多态 一:什么是多态: 多态是同一个行为具有多个不同表现形式或形态的能力. 多态就是同一个接口,使用不同的实例而执行不同操作. 多态性是对象多种表现形式的体现. 现实中,比 ...
- Java学习笔记二十:Java中的内部类
Java中的内部类 一:什么是内部类: (1).什么是内部类呢? 内部类( Inner Class )就是定义在另外一个类里面的类.与之对应,包含内部类的类被称为外部类. (2).那为什么要将一个类定 ...
最新文章
- Github项目解析(九)--实现Activity跳转动画的五种方式
- html5 网页弹幕,Damoo
- python gis 经纬度 库_入门-Python-GIS坐标转换
- linux有关网络服务的接口,linux系统有关网络服务接口定义是哪个?
- Android之解决主页面Activity监听fragment退出问题(由NavHostFragment和RxFragment一起管理fragment)
- 铠侠 RC10 固态硬盘寿命暴力写入测试:1100pe 毫发无损
- linspace函数matlab_Matlab入门2-莫比乌斯环
- 「三分钟系列03」3分钟看懂什么是三次握手/四次挥手
- 【D】分布式系统的CAP理论
- java实现5 4 3 2 1递归_递归及递归的使用
- 运维工具之轻量级自动化运维工具Fabric源码安装
- python安装apk到手机_python自动安装apk文件
- 数字货币钱包 - 助记词 及 HD 钱包密钥原理
- C语言4位BCD码加法器,四位二进制8421BCD码加法器
- windows10去桌面图标小箭头和恢复小箭头
- SSMS证书已被颁发者吊销解决办法
- python冒号亮红无效语法_新的python无效语法*更新
- 电影《可可西里》散记
- TCP/UDP协议首部格式
- 关键路径和前导图的计算
热门文章
- python可以代替按键精灵吗_Python 假装自己是按键精灵
- linux 卸载 java_Linux安装卸载JDK完整步骤
- 连续获两家乘用车前向定点, 又一家国产毫米波雷达企业欲“赶超”外资巨头
- window安装python27和配置环境变量
- ArcView GIS 应用与开发技术(11)-空间分析
- 刘意JavaSE 学习笔记 Day19-Day21——异常,IO(File类/字符流/字节流)
- Wordle_1.0
- hd_Lanswitch Web System
- 移远ec20型号区别_移远的EC20 4G模块
- 【L298N 驱动电机的线路连接图】