JAVA UDP通信實(shí)驗(yàn)報(bào)告.doc

2012-2013學(xué)年第一學(xué)期網(wǎng)絡(luò)編程技術(shù)實(shí)驗(yàn)報(bào)告實(shí)驗(yàn)名稱（課內(nèi)課外實(shí)驗(yàn)5）姓 名 _汪何媛_ 學(xué)號(hào)_100341324_ 實(shí)驗(yàn)日期 2012 年 12 月10 日 實(shí)驗(yàn)報(bào)告日期2012 年 12月17 日成 績(jī) _ 一. 實(shí)驗(yàn)?zāi)康?、理解并掌握數(shù)據(jù)報(bào)通信的原理2、熟練掌握利用Java語(yǔ)言實(shí)現(xiàn)C/S下的UDP通信 二實(shí)驗(yàn)環(huán)境1.Myeclipse 10.0三.實(shí)驗(yàn)實(shí)際完成內(nèi)容及結(jié)果分析1.請(qǐng)請(qǐng)編輯并調(diào)試下面的程序，給出程序的運(yùn)行過(guò)程、結(jié)果和各個(gè)類文件的功能說(shuō)明。1.CudpSocket類package udp;import java.io.IOException; import .DatagramPacket; import .DatagramSocket; import .SocketException; public class CudpSocket DatagramPacket dp = null; /建一個(gè)新數(shù)據(jù)報(bào)包DatagramSocket dgsocket=null; /建一個(gè)數(shù)據(jù)報(bào)包的套接字public CudpSocket() try byte buf = new byte1000; / 構(gòu)造一個(gè)新分配的 Byte 對(duì)象，表示指定的 byte 值dgsocket = new DatagramSocket(12345);/創(chuàng)建數(shù)據(jù)報(bào)套接字并將其綁定到本地主機(jī)上的指定端口12345dp= new DatagramPacket(buf,buf.length);/構(gòu)造 DatagramPacket，用來(lái)接收長(zhǎng)度為 length 的數(shù)據(jù)包 catch (SocketException e) e.printStackTrace(); public static void main(String args) System.out.println(enter the server);CudpSocket css = new CudpSocket();try css.dgsocket.receive(css.dp); / 從css.dp套接字接收數(shù)據(jù)報(bào)包byte data = css.dp.getData(); /為css.dp包設(shè)置數(shù)據(jù)緩沖區(qū)System.out.println(datac.length : +data.length); for(int i=0;idata.length;i+) System.out.println(datai);NetFileW nfw = new NetFileW(D:/JAVA/MyEclipse6.0/happy.txt); nfw.write(css.dp.getData();catch (IOException e) e.printStackTrace();2.NetFileR類package udp;import java.io.DataInputStream; import java.io.File; import java.io.FileInputStream; import java.io.IOException; public class NetFileR private String filePath; public NetFileR(String filePath) this.filePath = filePath;public byte getData() throws IOException /通過(guò)將給定路徑名字符串轉(zhuǎn)換成抽象路徑名來(lái)創(chuàng)建一個(gè)新 File 實(shí)例File file = new File(filePath);FileInputStream filein = new FileInputStream(file); /創(chuàng)建一個(gè)FileInputStream流DataInputStream in = new DataInputStream(filein); /創(chuàng)建一個(gè) DataInputStreambyte data = new byte1024; /構(gòu)造一個(gè)新分配的 Byte 對(duì)象，表示指定的 byte 值in.read(data); return data;public String getFilePath() return filePath; public void setFilePath(String filePath) this.filePath = filePath; 3. SudpSocket類package udp;import java.io.IOException;import .DatagramPacket; import .DatagramSocket; import . Inet4Address; import .SocketException; import .UnknownHostException; public class SudpSocket private DatagramSocket dgs = null; /建一個(gè)數(shù)據(jù)報(bào)包的套接字private DatagramPacket dgp = null; /建一個(gè)新數(shù)據(jù)報(bào)包public SudpSocket(String host,int prot,byte data) try dgs = new DatagramSocket(9999);/創(chuàng)建數(shù)據(jù)報(bào)套接字并將其綁定到本地主機(jī)上的指定端口9999Inet4Address target=null;/建立一個(gè)IPv4地址try target = (Inet4Address) Inet4Address.getByName(host); /在給定主機(jī)名的情況下確定主機(jī)的 IP 地址 catch (UnknownHostException e) / TODO Auto-generated catch blocke .printStackTrace();dgp = new DatagramPacket(data,data.length,target,prot); /構(gòu)造數(shù)據(jù)報(bào)包，用來(lái)將長(zhǎng)度為 length 的包發(fā)送到指定主機(jī)上的指定端口號(hào) catch (SocketException e) e.printStackTrace();public static void main(String args) NetFileR nf = new NetFileR(D:/JAVA/MyEclipse6.0/UDP/happy.txt);SudpSocket sps;try byte data = nf.getData();System.out.println(data.length : +data.length); for(int i=0;idata.length;i+) System.out.println(datai);sps = new SudpSocket(localhost,12345,data); catch (IOException e1) e1.printStackTrace(); sps=null;try sps.dgs.send(sps.dgp); catch (IOException e) e.printStackTrace(); sps=null;System.out.println(over the sending); 4. NetFileW類package udp;import java.io.File;import java.io.FileOutputStream; import java.io.IOException; public class NetFileW public NetFileW(String filePath) this.filePath = filePath;private String filePath;public void write(byte data) throws IOException /通過(guò)將給定路徑名字符串轉(zhuǎn)換成抽象路徑名來(lái)創(chuàng)建一個(gè)新 File 實(shí)例File file = new File(filePath);FileOutputStream out = new FileOutputStream(file);/創(chuàng)建一個(gè)FileOutputStream流out.write(data);public String getFilePath() return filePath;public void setFilePath(String filePath) this.filePath = filePath; 執(zhí)行結(jié)果：首先，本代碼中要發(fā)送的文件目錄及文件名為D:/JAVA/ MyEclipse6.0/ UDP/happy.txt。創(chuàng)建好相應(yīng)文件之后，先運(yùn)行CudpSocket類，然后再運(yùn)行SudpSocket發(fā)送文件happy.txt。結(jié)果如下：SudpSocket下的控制臺(tái)：data.length : 1024104101108108111330（）0over the sendingCudpSocket下的控制臺(tái)enter the serverdata.length : 1000104101108108111330（）02.請(qǐng)參考步驟 1 的代碼及本章的 DatagramTester.java、 MulticastSender.java、 MulticastReceiver.java程序，實(shí)現(xiàn)基于UDP的組播文件傳輸功能，即可以向組內(nèi)用戶群發(fā)文件的功能（要求：文件大小大于1K的，設(shè)計(jì)使用多個(gè)UDP 報(bào)文進(jìn)行發(fā)送）。1.MulticastSender類import .*;import java.io.*;public class MulticastSender public static void main(String args) throws Exception InetAddress group=InetAddress.getByName();/緩存 int port=4000; /設(shè)置端口4000 MulticastSocket ms = null; try ms = new MulticastSocket(port);/創(chuàng)建多播套接字并將其綁定到特定端口 / ms.joinGroup(group); while (true) String message = Hello + new java.util.Date(); byte buffer=message.getBytes(); DatagramPacket dp = new DatagramPacket(buffer, buffer.length,group,port); /構(gòu)造數(shù)據(jù)報(bào)包，用來(lái)將長(zhǎng)度為 length 的包發(fā)送到指定主機(jī)上的指定端口號(hào) ms.send(dp); System.out.println(發(fā)送數(shù)據(jù)報(bào)給 +group+:+port); Thread.sleep(1000); catch (IOException e) e.printStackTrace(); finally if (ms != null) try ms.leaveGroup(group); ms.close(); catch (IOException e) 2.MulticastReceiver類import .*;import java.io.*;public class MulticastReceiver public static void main(String args) throws Exception InetAddress group=InetAddress.getByName();/設(shè)置緩存 int port=4000; MulticastSocket ms = null; try ms = new MulticastSocket(port);/創(chuàng)建多播套接字并將其綁定到特定端口 ms.joinGroup(group); byte buffer = new byte8192;/構(gòu)造一個(gè)新分配的 Byte 對(duì)象，以表示指定的 byte 值 while (true) DatagramPacket dp = new DatagramPacket(buffer, buffer.length); /構(gòu)造數(shù)據(jù)報(bào)包，用來(lái)將長(zhǎng)度為 length 的包發(fā)送到指定主機(jī)上的指定端口號(hào) ms.receive(dp); String s = new String(dp.getData(),0,dp.getLength(); /構(gòu)造一個(gè)新的 String，方法是使用指定的字符集解碼字節(jié)的指定子數(shù)組 System.out.println(s); catch (IOException e) e.printStackTrace(); finally if (ms != null) try ms.leaveGroup(group); ms.close(); catch (IOException e) MulticastSender發(fā)送的數(shù)據(jù)包給:4000MulticastReceiver1和MulticastReceiver2分別收到兩條信息四思考題試請(qǐng)給出UDP支持下的Client /Server通信的全過(guò)程?？梢杂糜诠艿莱绦蛲ㄟ^(guò)UDP在不同機(jī)器之間的傳送1.Client類import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import .DatagramPacket;import .DatagramSocket;import .InetAddress;import .SocketException;public class CollectPipe private static final int DEFAULT_PORT = 8888; / should hold the max size of a udp packet private static final int BUFFER_LENGTH = 2048; public static void main(String args) throws Exception if (args.length 1) port = Integer.parseInt(args1); DatagramSocket aSocket = null; try aSocket = new DatagramSocket(); InetAddress serverAddress = InetAddress.getByName(args0); BufferedReader in = new BufferedReader(new InputStreamReader( System.in); String str = ; while (str != null) str = in.readLine(); if (str = null) break; byte buffer = str.getBytes(); DatagramPacket packet = new DatagramPacket(buffer, buffer.length, serverAddress, port); aSocket.send(packet); catch (SocketException e) System.out.println(Socket: + e.getMessage(); catch (IOException e) System.out.println(IO: + e.getMessage(); finally if (aSocket != null) aSocket.close(); 2.Server 端import java.io.IOException;import .DatagramPacket;import .DatagramSocket;import .SocketException;public class CollectPipeServer private static final int DEFAULT_PORT = 8888; private static final int BUFFER_LENGTH = 2048; publi