分布式系統(tǒng)導(dǎo)論實(shí)驗(yàn)報(bào)告

分布式系統(tǒng)導(dǎo)論實(shí)驗(yàn)報(bào)告2015.5.25實(shí)驗(yàn)二無(wú)連接的數(shù)據(jù)報(bào)Sockets實(shí)驗(yàn)?zāi)康膰L試實(shí)現(xiàn)一個(gè)無(wú)連接的數(shù)據(jù)報(bào)Socket進(jìn)程間通信。二．實(shí)驗(yàn)內(nèi)容創(chuàng)建兩個(gè)進(jìn)程，使用無(wú)連接數(shù)據(jù)報(bào)Socket實(shí)現(xiàn)交換一個(gè)字符串。一個(gè)叫做Sender.java，用于向一個(gè)名為Receiver.java.的進(jìn)程發(fā)送一個(gè)字符串。Sender.java需要一個(gè)命令行參數(shù)，用于表示傳遞消息的端口號(hào).Receiver.java需要一個(gè)命令行參數(shù)用于表示接受消息的端口號(hào)。接受方需要阻塞直到從發(fā)送放收到一個(gè)消息。如果發(fā)送放在接受運(yùn)行之前發(fā)送出消息，消息會(huì)丟失。這種情況在此實(shí)驗(yàn)中是允許的。三．實(shí)驗(yàn)主要功能實(shí)現(xiàn)說(shuō)明程序源代碼//Sender.javapackagedsi;importjava.io.IOException;import.DatagramPacket;import.DatagramSocket;import.InetAddress;importjava.util.Scanner;publicclassSender{publicvoidinit()throwsIOException{try{DatagramSocketsocket=newDatagramSocket();//創(chuàng)建數(shù)據(jù)報(bào)socket并將其綁定在本地默認(rèn)IP地址的默認(rèn)端口上Scannerscan=newScanner(System.in);while(scan.hasNextLine()){byte[]sendData=scan.nextLine().getBytes();//接收鍵盤(pán)輸入，并把輸入信息放到字節(jié)數(shù)組中DatagramPacketoutPacket=newDatagramPacket(sendData,sendData.length,InetAddress.getByName(""),8080);//創(chuàng)建數(shù)據(jù)報(bào)包，指定發(fā)送的字節(jié)數(shù)組和接受方的地址socket.send(outPacket);//激活socket的send方法，并引用這個(gè)數(shù)據(jù)報(bào)包}}catch(Exceptione){e.printStackTrace();}}publicstaticvoidmain(String[]args)throwsIOException{newSender().init();}}//Receiver.javaimportjava.io.IOException;import.DatagramPacket;import.DatagramSocket;publicclassReceiver{publicvoidinit()throwsIOException{try{DatagramSocketsocket=newDatagramSocket(8080);//創(chuàng)建數(shù)據(jù)報(bào)socket并將其綁定在本地默認(rèn)IP地址的指定端口byte[]inBuff=newbyte[4096];while(true){DatagramPacketinPacket=newDatagramPacket(inBuff,inBuff.length);//創(chuàng)建數(shù)據(jù)報(bào)包，將接收到的消息放到指定字節(jié)數(shù)組中socket.receive(inPacket);//激活socket的Receive方法，并引用這個(gè)數(shù)據(jù)報(bào)包System.out.println("收到："+newString(inBuff,0,inPacket.getLength()));//打印接收到的消息}}catch(Exceptione){e.printStackTrace();}}publicstaticvoidmain(String[]args)throwsIOException{newReceiver().init();}}實(shí)驗(yàn)結(jié)果運(yùn)行Sender，發(fā)送消息：hello和12345運(yùn)行Receiver，接收到消息hello和12345實(shí)驗(yàn)4.多播實(shí)驗(yàn)?zāi)康膭?chuàng)建進(jìn)程之間的多播。二．實(shí)驗(yàn)內(nèi)容MulticastSender.java用于發(fā)送多播消息給多播接收程序。多播IP地址是端口號(hào)為1234。MulticastReceiver.java用于接收多播消息并顯示消息。三．實(shí)驗(yàn)主要功能實(shí)現(xiàn)說(shuō)明程序源代碼//MulticastSender.javaimport.DatagramPacket;import.InetAddress;import.MulticastSocket;publicclassMulticastSender{privateintport;privateStringhost;privateStringdata;publicMulticastSender(Stringdata,Stringhost,intport){this.data=data;this.host=host;this.port=port;}publicvoidsend(){try{InetAddressip=InetAddress.getByName(this.host); DatagramPacketpacket=newDatagramPacket(this.data.getBytes(),this.data.length(),ip,this.port);//創(chuàng)建數(shù)據(jù)報(bào)包，指定發(fā)送的字節(jié)數(shù)組和接受方的地址MulticastSocketms=newMulticastSocket();//使用本機(jī)默認(rèn)地址、隨機(jī)端口來(lái)創(chuàng)建MulticastSocket對(duì)象ms.send(packet);//激活send方法，廣播消息ms.close();}catch(Exceptione){e.printStackTrace();}}publicstaticvoidmain(String[]args){intport=1234;Stringhost="";Stringdata="helloworld.";System.out.println(data);MulticastSenderms=newMulticastSender(data,host,port);ms.send();}}//MulticastReceiver.javaimport.DatagramPacket;import.InetAddress;import.MulticastSocket;publicclassMulticastReceiver{privateintport;privateStringhost;publicMulticastReceiver(Stringhost,intport){this.host=host;this.port=port;}publicvoidreceive(){byte[]data=newbyte[256];try{InetAddressip=InetAddress.getByName(this.host);MulticastSocketms=newMulticastSocket(this.port);//使用本機(jī)默認(rèn)地址、指定端口來(lái)創(chuàng)建對(duì)象ms.joinGroup(ip);//將該MulticastSocket加入到指定的多點(diǎn)廣播地址DatagramPacketpacket=newDatagramPacket(data,data.length);//創(chuàng)建數(shù)據(jù)報(bào)包，將接收到的消息放到指定字節(jié)數(shù)組中ms.receive(packet);//激活Receive方法，接收消息Stringmessage=newString(packet.getData(),0,packet.getLength());System.out.println(message);//打印接收到的消息ms.close();}catch(Exceptione){e.printStackTrace();}}publicstaticvoidmain(String[]args){intport=1234;