分布计算实验2.doc

福州大学数学与计算机科学学院 上机实验报告 专业和班级 信息数学02班 姓名 詹小青 成绩 课程名称 分布计算 实验名称 利用组通信函数，实现组通信 实 验 目 的 和 要 求 1.实验目的 （1）学习类与对象的定义。 （2）掌握类与对象的使用方法。 （3）学习数据成员与成员函数的访问方式。 2.实验要求 （1）可以定义出一个类 （2）创建该类的对象 （3）对象的访问 实 验 内 容 和 步 骤 1.实验内容： 编写自己的组播应用。编写一个应用使多个进程使用组通信完成选举。有两个候选人：John和Smith。每个进程通过一个标明自身身份及选票的消息组播自己的选票。每个进程跟踪每个候选人的得票数，也包括自己的得票情况。选举结束时(例如，John 10，Smith 5)。提交你的应用程序清单并回答下列问题： （1）你的设计是如何允许参与者加入组播组的？ （2）你的设计是如何同步选举开始的，使得每个进程都准备就绪，等待接收组成员发出的任何选票？ 2.实验基本步骤： （1）程序： import java.io.*; import java.net.*; public class send { public static void main(String[] args) throws Exception { InetAddress group = InetAddress.getByName(239.1.2.3); int port = 8888; MulticastSocket socket = null; InputStreamReader is = new InputStreamReader(System.in); BufferedReader br = new BufferedReader(is); String character = br.readLine(); byte[] data = null; data = character.getBytes(); DatagramPacket packet = new DatagramPacket(data, data.length, group,port); Thread theThread = new Thread(new ReadThread(group, port)); theThread.start(); System.out.println(Hit return when ready to send); br.readLine(); socket = new MulticastSocket(port); socket.send(packet); socket.close(); } } class ReadThread implements Runnable { static final int MAX_LEN=30; private InetAddress group; private int port; int John=0; int Smith=0; public ReadThread(InetAddress group,int port) { this.group=group; this.port=port; } public void run() { try{ MulticastSocket socket=new MulticastSocket(port); socket.joinGroup(group); while(true){ byte[] data=new byte[MAX_LEN]; DatagramPacket packet=new DatagramPacket(data,data.length,group,port); socket.receive(packet); String s=new String(packet.getData()); s=s.substring(0, 4); if(s.equals(John)) System.out.println(John: + ++this.John+\nSmith + this.Smith); else System.out.println(John: + this.John+\nSmith + ++this.Smith); } }catch(Exception e) { e.printSt