什么是网络编程?
网络编程可以让程序与网络上的其他设备中的程序进行数据交互。
网络通信基本模式
常见的通信模式有如下2种形式:Client-Server(CS)、Browser/Server(BS)
网络通信三要素
要素一:IP地址
IP常用命令:
ipconfig:查看本机IP地址ping IP地址/域名:检查网络是否连通
特殊P地址:
本机lP:127.0.0.1或者localhost(相当于本机的域名):称为回送地址也可称本地回环地址,只会寻找当前所在本机。
IP地址操作类-InetAddress:
其接口:
//1.获取本机地址对象。InetAddress ip1 = InetAddress.getLocalHost();System.out.println(ip1.getHostName());System.out.println(ip1.getHostAddress());//2.获取域名ip对象InetAddress ip2 = InetAddress.getByName("");System.out.println(ip2.getHostName());System.out.println(ip2.getHostAddress());//4,判断是否能通:ping 5s之前测试是否可通 返回布尔类型.System.out.println(ip2.isReachable(timeout:5000));
要素二:端口号标识正在计算机设备上运行的进程(程序),被规定为一个16位的二进制,范围是0~65535.
端口类型
周知端口:0~1023,被预先定义的知名应用占用(如:HTTP占用80,FTP占用21)注册端口:1024~49151,分配给用户进程或某些应用程序。(如:Tomcat占用8080,MySQL占用3306)动态端口:49152到65535,之所以称为动态端口,是因为它一般不固定分配某种进程,而是动态分配。
注意:我们自己开发的程序选择注册端口,且一个设备中不能出现两个程序的端口号一样,否则出错。
要素三:协议连接和通信数据的规则被称为网络通信协议
传输层的2个常见协议
TCP(Transmission Control Protocol):传输控制协议UDP(User Datagram Protocol):用户数据报协议
TCP协议特点
使用TCP协议,必须双方先建立连接,它是一种面向连接的可靠通信协议。传输前,采用“三次握手”方式建立连接,所以是可靠的。在连接中可进行大数据量的传输。连接、发送数据都需要确认,且传输完毕后,还需释放已建立的连接,通信效率较低。
TCP协议通信场景
对信息安全要求较高的场景,例如:文件下载、金融等数据通信。
UDP协议:・
UDP是一种无连接、不可靠传输的协议。将数据源P、目的地P和端口封装成数据包,不需要建立连接每个数据包的大小限制在64KB内发送不管对方是否准备好,接收方收到也不确认,故是不可靠的可以广播发送,发送数据结束时无需释放资源,开销小,速度快。
UDP协议通信场景
语音通话,视频会话等。
UDP通信-快速入门
DatagramPacket:数据包对象
DatagramPacket常用方法:
DatagramSocket:发送端和接收端对象(人)
DatagramSocket类成员方法
示例:
UDP通信-广播、组播
UDP如何实现广播
使用广播地址:255.255.255.255具体操作:发送端发送的数据包的目的地写的是广播地址、且指定端口。
UDP如何实现组播
组播地址:224.0.0.0~239.255.255.255
具体操作:
①发送端的数据包的目的地是组播1P(例如:224.0.1.1,端口:9999)
②接收端必须绑定该组播1P(224.0.1.1),端口还要对应发送端的目的端口9999,这样即可接收该组播消息。
③DatagramSocket的子类MulticastSocketi可以在接收端绑定组播IP。
代码变动部分:
TCP通信-快速入门
TCP协议回顾:
TCP是一种面向连接,安全、可靠的传输数据的协议传输前,采用“三次握手”方式,点对点通信,是可靠的在连接中可进行大数据量的传输
注意:在java中只要是使用.Socket类实现通信,底层即是使用了TCP协议
客户端:
服务端:
示例(一发一收):
TCP通信-多发多收消息
具体要求:
可以使用死循环控制服务端收完消息继续等待接收下一个消息。客户端也可以使用死循环等待用户不断输入消息。客户端一旦输入了exit,则关闭客户端程序,并释放资源。
修改部分:
客户端:
服务端:
TCP通信-同时接受多个客户端消息
解决办法:引入多线程
如何实现服务端接收多个客户端的消息:
主线程定义了循环负责接收客户端Socket管道连接每接收到一个Socketi通信管道后分配一个独立的线程负责处理它。
//线程类public class ServerReaderThread extends Thread{private Socket socket;public ServerReaderThread(Socket socket){this.socket = socket;}@Overridepublic void run(){try{//3、从socket.通信管道中得到一个字节输入流Inputstream is = socket.getInputstream();//4、把字节输入流包装成缓冲字符输入流进行消息的接收BufferedReader br = new BufferedReader(new InputstreamReader(is));//5、按照行读取消息String msg;while ((msg br.readLine()) != null){System.oUt.println(socket.getRemoteSocketAddress()+"说了::"+ msg);}}catch(xception e){e.printstackTrace();}
//客户端不变//======服务端======public class ServerDemo{public static void main(String[] args){try{//1、注册端口ServerSocket serverSocket = new ServerSocket(port:7777);//定义一个死循环由主线程负责不断的接收客户端的Socket管道连接。while (true){//2、每接收到一个客户端的Socket管道,交给一个独立的子线程负责读取消息Socket socket = serverSocket.accept();//3、开始创建独立线程处理socketnew ServerReaderThread(socket).start();}}catch (Exception e){e.printStackTrace();}
TCP通信-使用线程池优化(略)
TCP通信实战案例-即时通信
TCP通信实战案例-模拟BS系统