UDP实验课01

UDP实验课01"/>

UDP实验课01

实验课上测试的源码。

1）服务器端

1. importjava.io.*;
2. importjava.*;
4. //服务器端
5. publicclassUDPServerTest{
6. staticpublicvoidmain(Stringargs[]){
7. DatagramSocketreceiveSocket=null;
8. try{
9. //DatagramSocket(intport)：创建实例，并固定监听Port端口的报文。通常用于服务端
10. receiveSocket=newDatagramSocket(55511);
11. bytebuf[]=newbyte[1000];
12. //DatagramPacket(byte[]buf,intlength)：将数据包中Length长的数据装进Buf数组，一般用来接收客户端发送的数据。
13. DatagramPacketreceivePacket=newDatagramPacket(buf,buf.length);
14. System.out.println("开始接受数据：");
15. booleanflag=true;//作为接收完之后退出的标记
16. while(flag){
17. //接收数据报文到d中。receive方法产生一个“阻塞”。“阻塞”是一个专业名词，它会产生一个内部循环，
18. //使程序暂停在这个地方，直到一个条件触发。
19. receiveSocket.receive(receivePacket);
20. Stringname=receivePacket.getAddress().toString();
21. System.out.println("/n来自主机："+name+"/n端口："
22. +receivePacket.getPort());
23. //从实例中取得报文的Byte数组编码
24. Strings=newString(receivePacket.getData(),0,receivePacket
25. .getLength());
26. System.out.println("接受到的数据是:"+s);
27. flag=false;
28. //需关闭连接，也关闭端口。
29. receiveSocket.close();
30. }
31. }catch(SocketExceptione){
32. receiveSocket.close();
33. e.printStackTrace();
34. System.exit(-1);
35. }catch(IOExceptione){
36. receiveSocket.close();
37. System.out.println("网络通讯出现错误，问题在"+e.toString());
38. }
39. }
40. }

2）客户端

1. importjava.io.*;
2. importjava.*;
4. //客户端
5. publicclassUDPClientTest{
6. publicstaticvoidmain(Stringargs[]){
7. DatagramSocketsendSocket=null;
8. try{
9. //DatagramSocket()：通常用于客户端编程，它并没有特定监听的端口，仅仅使用一个临时的。程序会让操作系统分配一个可用的端口。
10. //DatagramSocket(intport)：创建实例，并固定监听Port端口的报文。通常用于服务端
11. sendSocket=newDatagramSocket();
12. Stringstring="whoau没死过，不知道dead的感觉";
13. byte[]databyte=newbyte[100];
14. databyte=string.getBytes();
15. //从Buf数组中，取出Length长的数据创建数据包对象，目标是clientAddress地址，clientPort端口,通常用来发送数据给客户端。此处事发送给服务器端
16. DatagramPacketsendPacket=newDatagramPacket(databyte,
17. databyte.length,InetAddress.getByName("222.17.97.152"),
18. 55511);
19. //发送报文sendPacket到目的地
20. sendSocket.send(sendPacket);
21. System.out.println("客户端开始传送数据！");
22. sendSocket.close();
23. }catch(SocketExceptione){
24. sendSocket.close();
25. e.printStackTrace();
26. System.out.println("不能打开数据报Socket，或数据报Socket无法与指定端口连接!");
27. }catch(IOExceptionioe){
28. sendSocket.close();
29. System.out.println(ioe.toString());
30. }
31. }
32. }

总结：异常或正常退出时，最好调用close方法，否则可能造成资源无法收回。