UDP:用户数据报协议（User Datagram Protocol）
面向非连接、传输不可靠、用于传输少量数据(数据包模式)、速度快。
UDP传输:1.只要是网络传输，必须有socket 。
2.数据一定要封装到数据包中，数据包中包括目的地址、端口、数据等信息。
直接操作udp不可能，应该使用DatagramSocket将udp封装成对象。DatagramSocket 封装了udp传输协议的socket对象。
因为数据包中包含的信息较多，为了操作这些信息方便，也一样会将其封装成对象。
这个数据包对象就是：DatagramPacket.通过这个对象中的方法，就可以获取到数据包中的各种信息。
DatagramSocket具备发送和接受功能，在进行udp传输时，需要明确一个是发送端，一个是接收端。
udp的发送端：1.建立udp的socket服务，创建对象时如果没有明确端口，系统会自动分配一个未被使用的端口。
2.明确要发送的具体数据。
3.将数据封装成了数据包。
4.用socket服务的send方法将数据包发送出去。
5.关闭资源。
udp的接收端：1.创建udp的socket服务，必须要明确一个端口，作用在于，只有发送到这个端口的数据才是这个接收端可以处理的数据。
2.定义数据包，用于存储接收到数据。
3.通过socket服务的接收方法将收到的数据存储到数据包中。
4.通过数据包的方法获取数据包中的具体数据内容，比如ip、端口、数据等等。
5.关闭资源。
综合示例：通过UDP实现简单的发送数据功能
- import java.net.*;
- class UDPSend{
- public static void main(String[] args) throws Exception {
- // 1.创建UDP服务，通过DatagramSocket对象，系统默认端口号888，可指定
- DatagramSocket ds = new DatagramSocket(888);
- // 2.确定数据,并封装成数据包DtagramPacket(byte[] buf,int length,InteAddress address,int port);
- byte[] buf = "UDP Coming...".getBytes();
- DatagramPacket dp =
- new DatagramPacket(buf,buf.length,InetAddress.getByName("36.56.13.139"),1000);//指定ip
- //地址和Socket号
- ds.send(dp); //3.通过Socket服务，将已有的数据包发送出去，通过send方法
- //4.关闭资源
- ds.close();
- }
- }
- class UDPReceive{
- public static void main(String[] args) throws Exception{
- DatagramSocket ds = new DatagramSocket(1000);//创建UDP服务通过DatagramSocket对象,并指定Socket
- byte[] buf = new byte[1024];
- DatagramPacket dp = new DatagramPacket(buf,buf.length);//创建数据包，用于接收数据
- ds.receive(dp);//通过DatagramSocket对象接收数据包
- String ip = dp.getAddress().getHostAddress();//解析数据包，获得IP地址
- String data = new String(dp.getData(),0,dp.getLength());//解析数据包获得数据
- int port = dp.getPort();//解析数据包获得端口号
- System.out.println(ip+"::"+data+"::"+port);
- ds.close(); //关闭资源
-
- }
- }
---------------------------------------------------------------------------------------------------------------------------------------------
TCP：传输控制协议（Transmission Control Protocol）
面向连接、传输可靠(保证数据正确性,保证数据顺序)、用于传输大量数据(流模式)、速度慢，建立连接需要开销较多(时间，系统资源)。
两个端点的建立连接后会有一个传输数据的通道，这通道称为流，而且是建立在网络基础上的流，称之为socket流。该流中既有读取，也有写入。
TCP的两个端点：一个是客户端，一个是服务端。
客户端：对应的对象，Socket
服务端：对应的对象，ServerSocket
TCP客户端：1.建立tcp的socket服务，最好明确具体的地址和端口。这个对象在创建时，就已经可以对指定ip和端口进行连接(三次握手)。
2.如果连接成功，就意味着通道建立了，socket流就已经产生了。只要获取到socket流中的读取流和写入流即可，
只要通过getInputStream和getOutputStream就可以获取两个流对象。
3.关闭资源。
TCP服务端：1.创建服务端socket服务，并监听一个端口。
2.服务端为了给客户端提供服务，获取客户端的内容，可以通过accept方法获取连接过来的客户端对象。
3.可以通过获取到的socket对象中的socket流和具体的客户端进行通讯。
4.如果通讯结束，关闭资源。注意：要先关客户端，再关服务端。
综合示例：通过TCP从客户端享服务端传输一个文件
- </blockquote></div>[hide]<div class="blockcode"><blockquote>import java.io.*;
- import java.net.*;
- //客户端
- class TextClient{
- public static void main(String[] args) throws Exception {
- Socket s = new Socket("192.168.1.111",10006);//开启一个Socket端口，指定主机的IP地址和端口号
- BufferedReader bufr = new BufferedReader(
- new FileReader("client.txt"));//通过BufferReader传输一个文件，文件必须提前存在，否则抛异常
- PrintWriter out = new PrintWriter(s.getOutputStream(),true);//获得一个打印流，并得到端口的输出流，记得true
- String line = null;
- while((line=bufr.readLine()) != null){//判断读取的数据是否为空
- out.println(line);
- }
- //out.println("over");
- s.shutdownOutput();//关闭输出流端口
- BufferedReader bufIn = new BufferedReader(
- new InputStreamReader(s.getInputStream()));//创建读取流用于读取服务段发来的信息
-
- String str = bufIn.readLine();//读取的信息存储在String类型的引用中
- System.out.println(str);//打印
- bufr.close();//关闭Buferreader
- s.close();//关闭端口
- }
- }
- //服务端
- class TextServer{
- public static void main(String[] args) throws Exception{
- ServerSocket ss = new ServerSocket(10006);//开启服务端端口，并指定端口号，必须和客户端端口号一直
- Socket s = ss.accept();//接收信息并传递给Socket端口
- String ip = s.getInetAddress().getHostAddress();//解析信息获得主机IP地址
- System.out.println(ip+"......connected!");
- BufferedReader bufr = new BufferedReader(
- new InputStreamReader(s.getInputStream()));
- PrintWriter out = new PrintWriter(new FileWriter("server.txt"),true);//获得打印流，并创建一个文件用于存储信息
- String line= null;
- while((line=bufr.readLine()) != null){ //判断读取的信息是否为空
- out.println(line);
- }
- PrintWriter pw = new PrintWriter(s.getOutputStream(),true);//创建打印流并获得端口的输出流
- pw.println("上传成功！");//输出的数据
-
- out.close();//关闭打印流端口，否则文件，没有flush，不显示内容
- s.close();//关闭端口号
- ss.close();//关闭服务器端口号
- }
- }
[/hide]
|
|
收藏
淘帖
踩
