Java---网络编程(2)-UDP
2016-05-08 16:15
351 查看
UDP
☆ UDP将数据及源和目的封装成数据包中,不需要建立连接
每个数据报的大小在限制在64k内
因无连接,是不可靠协议
不需要建立连接,速度快
DatagramSocket和DatagramPacket类
☆ TCP
建立连接,形成传输数据的通道。
在连接中进行大数据量传输
通过三次握手完成连接,是可靠协议
必须建立连接,效率会稍低
Socket 和 ServerSocket类
☆ Socket
Socket就是为网络服务提供的一种机制。
通信的两端都有Socket。
网络通信其实就是Socket间的通信。
数据在两个Socket间通过IO传输。
UDP传输
DatagramSocket与DatagramPacket建立发送端,接收端。
建立数据包。
调用Socket的发送接收方法。
关闭Socket。
发送端与接收端是两个独立的运行程序。
UDP传输编程
☆发送端在发送端,要在数据包对象中明确目的地IP及端口。
DatagramSocket ds = new DatagramSocket(); byte[] by = “hello,udp”.getBytes(); DatagramPacket dp = new DatagramPacket(by,0,by.length, InetAddress.getByName(“127.0.0.1”),10000); ds.send(dp); ds.close();
☆接收端
在接收端,要指定监听的端口。
DatagramSocket ds = new DatagramSocket(10000); byte[] by = new byte[1024]; DatagramPacket dp = new DatagramPacket(by,by.length); ds.receive(dp); String str = new String(dp.getData(),0,dp.getLength()); System.out.println(str+"--"+dp.getAddress()); ds.close();
发送方:
你们自己写的时候注意修改接收方的ip。
package cn.hncu.url.udp; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; /** * * @author 陈浩翔 * * 2016-5-8 */ public class SendDemo { public static void main(String[] args) { try { DatagramSocket ds = new DatagramSocket(9999);//用9999端口发送消息 String str = "你好,在吗?"; byte buf[] = str.getBytes("gbk"); //DatagramPacket类中,有ip地址的构造方法是用来创建发送数据包的。 DatagramPacket dp = new DatagramPacket(buf, buf.length,InetAddress.getByName("192.168.1.127"), 10000); //注意:ip和端口都是接收方的 ds.send(dp); ds.close(); } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } }
接收方:
package cn.hncu.url.udp; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.SocketException; public class ReceiveDemo { public static void main(String[] args) { try { //接收的端口 DatagramSocket ds = new DatagramSocket(10000); byte buf[] = new byte[1024]; DatagramPacket dp = new DatagramPacket(buf, buf.length); ds.receive(dp); //从dp中解析出我们想要的信息 //获取ip String ip = dp.getAddress().getHostAddress(); int port = dp.getPort();//端口 byte[] data = dp.getData(); System.out.println("ip: "+ip+" 端口:"+port+" 消息:"+new String(data)); } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } }
练习:UDP聊天程序
通过键盘录入获取要发送的信息。将发送和接收分别封装到两个线程中。
package cn.hncu.url.udp; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; class UDPChat { public static void main(String[] args) { try { DatagramSocket send = new DatagramSocket(10001); DatagramSocket receive = new DatagramSocket(10000); new Thread(new Send(send)).start(); new Thread(new Receive(receive)).start(); } catch (SocketException e) { e.printStackTrace(); } } } class Send implements Runnable{ DatagramSocket ds; public Send(DatagramSocket send) { this.ds=send; } @Override public void run() { DatagramPacket dp ; BufferedReader bfr = new BufferedReader(new InputStreamReader(System.in) ); String line; while(true){ try { line = bfr.readLine(); byte[] buf = line.getBytes(); //填写接收方的ip和端口 dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.1.127"), 10000); ds.send(dp); if("end".equals(line)){ break; } } catch (IOException e) { e.printStackTrace(); } } ds.close(); } } class Receive implements Runnable{ DatagramSocket ds; public Receive(DatagramSocket receive) { this.ds=receive; } @Override public void run() { DatagramPacket dp; byte[] buf = new byte[2048];//大小够存一次发送过来的数据就可以了。 String line; String ip; int port; while(true){ dp = new DatagramPacket(buf, buf.length); try { ds.receive(dp); } catch (IOException e) { e.printStackTrace(); } ip = dp.getAddress().getHostAddress();//获得发送方的ip port = dp.getPort();//端口 byte[] bf = dp.getData(); line = new String(bf,0,dp.getLength()); System.out.println("IP:"+ip+" 端口:"+port+" 消息:"+line); if("end".equals(line)){ System.out.println("主机:"+ip+" 下线了。"); break; } } ds.close(); } }
好了,到现在就可以实现2台联网的机子的互动了。哈哈、
只是现在还有点单调,而且用UDP协议容易丢包。
让我们一起进步吧。
相关文章推荐
- 常用应用层协议HTTP、RTSP、RTMP比较
- 移动网络优化
- Jsp+javaBean+mysql的网络云盘
- [Android Pro] Android API 23中废弃了HttpClient的解决办法
- Optimal Milking(二分图多重匹配+二分)(网络流)
- Jmeter之HTTP request
- 20145206《Java程序设计》实验五Java网络编程及安全
- R-CNN学习笔记
- 【BZOJ-3876】支线剧情 有上下界的网络流(有下界有源有汇最小费用流)
- 获取HTTP信息
- python网络入门:urllib.request模块和urllib.urllib.parse模块
- JAVA httpClient 设置header
- Android 网络状态变更的广播
- 【BZOJ-2502】清理雪道 有上下界的网络流(有下界的最小流)
- 20145208 实验五 Java网络编程
- tomcat(supplement)HttpConnector.initialize() 和 start() 方法 以及 StandardContext.start()方法的分析
- Linux tcpdump命令详解
- Retrofit+OKHttp 教你怎么持久化管理Cookie
- java链接SQL Server 时到主机的TCP/IP 连接失败
- 20145215实验五 Java网络编程及安全