邢台经济开发区网站百度收录情况查询
本文主要介绍了传输层的UDP协议和TCP协议,以及在Java中如何通过Socket套接字实现网络编程(内附UDP和TCP版本的回显服务器代码)
一.网络通信
网络编程,就是写一个应用程序,让这个程序可以使用网络通信,这里就需要调用传输层提供的api了。
严格的来说,两台主机进行通信就是两台主机中的应用进程进行通信。
通信的两端应该是两个主机中的应用进程。
端到端的通信是应用进程之间的通信。
传输层和网络层的区别
网络层为主机之间的通信提供服务;
运输层在网络层的基础上,为应用进程提供通信服务;
二.传输层协议
传输层协议,主要有两个:
1.UDP 用户数据报协议
2.TCP传输控制协议
提供了两套不同的api,也叫做socket 套接字。
UDP和TCP对比:
UDP:无连接,不可靠传输,面向数据报,全双工
TCP:有连接,可靠传输,面向字节流,全双工
注意:
有连接就相当于使用一块内存来保存对端的信息,双方都保存这个信息,此时连接就出现了。
可靠传输,并不是说A发给B的消息百分百能到达,而是A尽可能地把消息传给B,并且在传输失败地时候,A可以感知到,或者传输成功地时候,也可以知道自己成功了
TCp是可靠传输,但是传输效率降低了
UDp是不可靠传输,但传输效率更高
并且这也不意味着,TCP更安全,网络安全更多指的是数据是否容易被黑客截获
面向字节流 VS 面向数据报
TCP 和文件操作类似,都是流式的,而且传输的单位是字节,故称字节流
UDP面向数据报,读写的基本单位是一个UDP数据报
全双工 VS 半双工
全双工:一个通道,可以双向通信(双向车道)
半双工:一个通道,只能单向通信(单向车道)
再比如:网线也是全双工的,通常来说,网线一般有八根铜缆,四四一组,一部分负责一个方向,另一部分则负责另一个方向。
三.UDP数据报协议
Java对于UDP的socket api,有两个核心的类:
1.DatagramSocket
是一个Socket对象
注意:操作系统,使用文件这样的概念来管理一些软硬件资源
对于网卡(计算机和外界局域网连接的网络设备) --> 操作系统也是使用 文件 的方式来管理网卡的
表示网卡的这类文件,就是socket文件
Java中的socket对象,就对应系统里的socket文件(最终还是要落到网卡)
结论:要进行网络通信,就必须调用网卡;
调用网卡,就必须先创建socket对象;
创建socket对象:
构造方法:
1没有参数 DatagramSocket()
在客户端这边使用(客户端使用哪个端口,系统自动分配)
2有参数 DatagramSocket(int port)
在服务器这边使用(服务器使用哪个端口,手动指定)
说明:
服务器:需要有一个固定的端口号,方便其他客户端找到
比如,食堂的16号窗口,就相当于服务器的IP地址和端口号,此时有一个同学来食堂16号窗口吃饭,它坐的位置不需要是固定的,这就相当于是是客户端端口号。
客户端:主机上面运行的程序很多,我们不知道手动指定的端口是不是被别的程序占用了,因此更合理的做法是让系统自动分配一个空闲的端口号。
其他方法:
- receive(DatagramPacket p) 接收
- send (DatagramPacket p)发送
Close 关闭
2.DatagramPacket
表示一个UDP数据报
代表了系统中设定的UDP数据报的二进制结构
构造方法:
说明:作为UDP数据报,必然要承载一些数据,通过手动指定的byte[]作为存储数据的空间。
其他方法:
3.回显服务器
回显服务器:客户端发什么,服务器就返回什么。
>服务器代码:
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;/*** 实现一个回显服务器* 客户端发什么,服务器返回什么**/public class UdpEchoServer {private DatagramSocket socket=null;public UdpEchoServer(int port) throws SocketException {socket=new DatagramSocket(port);}/*** 启动服务器** 反复的长期的执行* @param*/public void start() throws IOException {System.out.println("服务器启动");while(true){//1读取请求,并解析/*** receive的参数是datagramPacket,是一个输出型参数,传入的receive是一个空的对象,receive内部会把这会填充这个对象当执行完就会得到一个转满内容的打他gramPacket*/DatagramPacket requestPacket=new DatagramPacket(new byte[4096],4096);/**datagrampacket对象是用来保存数据的内存时间,需要手动指定,不像集合类,内部可以自己管理内存第二个参数可以随便写,不能写太大。如果客户端的请求还没来,receive就会阻塞等待,直到有客户端发起请求过来了*/socket.receive(requestPacket);/*** 获得请求的内容* 这样的转字符串的前提是,后续客户端发起的数据就是一个文本的字符串**/String request=new String(requestPacket.getData(),0, requestPacket.getLength());//2根据请求,计算出相应(回显服务器,请求是啥,返回就是啥)/*** 由于是回显服务器,请求是啥,响应就是啥*/String response=process(request);//3把响应写给客户端/*** 此时需要告诉网卡,要发的内容是啥,要发给谁* 构造一个datagramPacket对象,把响应发给客户端*/DatagramPacket responsePacket=new DatagramPacket(response.getBytes(),response.getBytes().length,requestPacket.getSocketAddress());/*** 把数据包发给客户端,就需要直到客户端的ip和端口* datagrampacket这个对象里面包含着通信双方的ip和port*/socket.send(responsePacket);//打印日志信息System.out.printf("%s:%d req:%s,resp:%s \n",requestPacket.getAddress().toString(),responsePacket.getPort(),request,response);}}//根据请求计算响应public String process(String request){return request;}public static void main(String[] args) throws IOException {UdpEchoServer server=new UdpEchoServer(9090);server.start();}
}
>客户端代码:
import java.io.IOException;
import java.net.*;
import java.util.Scanner;/*** 实现一个udp的回显服务器* 客户端**/public class UdpEchoClient {private DatagramSocket socket=null;private String serverIp;private int serverPort;//服务器的ip和服务器的端口public UdpEchoClient(String ip,int port) throws SocketException {serverIp=ip;serverPort=port;//这个new操作,就不用再指定端口了,让系统自动分配一个空闲端口socket=new DatagramSocket();}/*** 让这个客户端反复的从控制台读取用户输入的内容,把这个内容构造成udp请求,发给服务器,再读取* 服务器返回的udp响应* 最终再显示在客户端的屏幕上*/public void start() throws IOException {System.out.println("客户端启动");Scanner scanner=new Scanner(System.in);while(true){//1.从控制台读取用户输入的内容System.out.println("->");String request=scanner.next();//2.构造请求对象,并发送给服务器DatagramPacket requestPacket=new DatagramPacket(request.getBytes(),request.getBytes().length,InetAddress.getByName(serverIp),serverPort);socket.send(requestPacket);//3.读取服务器的响应,并解析出响应内容DatagramPacket responsePacket=new DatagramPacket(new byte[4096],4096);socket.receive(responsePacket);String response=new String(responsePacket.getData(),0,responsePacket.getLength());//显示到屏幕上System.out.println(response);}}public static void main(String[] args) throws IOException {//云服务器ip地址
// UdpEchoClient client=new UdpEchoClient("8.130.66.119",9090);UdpEchoClient client=new UdpEchoClient("127.0.0.1",9090);client.start();}
}
另外,我们也可以把服务器代码打一个jar包,放到云服务器上,然后访问云服务器的地址ip地址。
IDEA手动打包方式:
1.
2.
3.选择入口类,选择jar包存放的路径,jar包就生成了
后面可以用Mobaxterm把这个jar包放到云服务器上去.....就不演示了
四.TCP传输控制协议
TCP提供的api也是主要的两个类
1.ServerSocket
给服务器使用的socket
2.Socket
既会给服务器使用,也会给客户端使用
TCP版本的回显服务器代码放在 【Java网络原理】三