A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© SenGoo 中级黑马   /  2014-10-18 10:05  /  1060 人查看  /  0 人回复  /   1 人收藏 转载请遵从CC协议 禁止商业使用本文

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(); //关闭资源
  •         }
  • }

[color=rgb(177, 8, 0) !important]复制代码

---------------------------------------------------------------------------------------------------------------------------------------------

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();//关闭服务器端口号
  •         }
  • }


[color=rgb(177, 8, 0) !important]复制代码


0 个回复

您需要登录后才可以回帖 登录 | 加入黑马