分布计算 实验1(共8页)

1、福州大学数学(shxu)与计算机科学学院上机实验报告专业和班级信息数学02班姓名詹小青成绩课程名称分布计算实验名称使用数据报和流式Socket实现消息传递实验目的和要求1.实验目的 （1）学习使用DatagramSocket和DatagramSocket实现消息传递 （2）通过使用ServerSocket为服务器端，Socket为客户端实现基于C/S范型的数据通信。 2.实验基本要求 （1）使用DatagramSocket和DatagramSocket实现消息传递 。 （2）使用ServerSocket和Socket实现消息传递 。 实验内容和步骤1.实验内容：（1）写一段出现在某main方法

2、中的java程序片段，用于打开一个最多接收100个字节数据的数据包socket，设置超时周期为50秒。如果发生超时，须在屏幕上显示“接收超时”消息；（2）考虑一个简单应用，服务器端的功能是计算圆的面积。客户端将圆的半径发送给服务器端，服务器端计算得出的圆面积将发送给客户端，并在客户端显示；（3）使用多线程实现任务（2）。2.实验基本步骤：（1）程序：Server端：import .*;import java.util.*;public class serverpublic static void main(String args) throws ExceptionDatagramSocket

3、ds = new DatagramSocket();InetAddress addr = InetAddress.getByName(localhost);byte buff = new byte100;DatagramPacket dp;String s;for (;)Thread.sleep(5000);System.out.println(sending.);s = (new Date().toString();buff = s.getBytes();dp = new DatagramPacket(buff, buff.length, addr, 1313);ds.send(dp);Ci

4、ent端：import java.io.IOException;import .*;public class clientpublic static void main(String args) throws ExceptionDatagramSocket ds = new DatagramSocket(1313);byte buff = new byte100;DatagramPacket dp = new DatagramPacket(buff, buff.length);String s;ds.setSoTimeout(5000);for (;)tryds.receive(dp); ca

5、tch (SocketTimeoutException e)System.out.println(接收超时);break;s = new String(dp.getData();System.out.println(Time received from + dp.getAddress()+ n Time is: + s);实验结果截图：先运行客户端，在运行服务器，直接超时先运行服务器，在运行客户端程序：客户端：import .*;import java.io.*;public class Client public static void main(String args) throws Ex

6、ception Socket sc=new Socket(127.0.0.1,4007); BufferedReader in=new BufferedReader(new InputStreamReader(System.in); BufferedReader sin=new BufferedReader(new InputStreamReader(sc.getInputStream(); PrintWriter ps=new PrintWriter(new OutputStreamWriter(sc.getOutputStream(); System.out.println(请输入圆的半径

7、:); String s=; while (true) s=in.readLine(); if (s.equals(88) break; ps.println(s); ps.flush(); s=sin.readLine(); System.out.println(圆的面积为: +s+n请输入圆的半径:); 服务器端：import java.io.*;import .*;public class Server public static void main(String args) throws Exception ServerSocket ss=new ServerSocket(4007);

8、 Socket sc=ss.accept(); BufferedReader in=new BufferedReader(new InputStreamReader(System.in); BufferedReader sin=new BufferedReader(new InputStreamReader(sc.getInputStream(); PrintWriter ps=new PrintWriter(new OutputStreamWriter(sc.getOutputStream(); String s=; while (true) s=sin.readLine(); double

9、 r=0; r=Integer.parseInt(s); r=3.14*r*r; /System.out.println(answer: +r); /System.out.println(please input one line:); /s=in.readLine(); if (s.equals(88) break; ps.println(r); ps.flush(); 实验结果截图：程序：Server端：import java.io.*;import .*;public class serverpublic static void main(String args) throws Exce

10、ptionServerSocket ss = null;Socket socket = null;ss = new ServerSocket(8888);int clientnum =for(;)new ServerThread(ss.accept(), clientnum).start();clientnum+;class ServerThread extends ThreadSocket socket = null;int clientnum;public ServerThread(Socket socket, int num)this.socket = socket;clientnum

11、= num + 1;public void run()tryInputStream Is = socket.getInputStream();OutputStream Os = socket.getOutputStream();DataInputStream DIS = new DataInputStream(Is);PrintStream PS = new PrintStream(Os);for(;)String recvStr = DIS.readLine();double r = Double.valueOf(recvStr);double res = r * r * Math.PI;S

12、ystem.out.println(res);PS.println(r= + r + and area= + res);catch (Exception e)Cient端：import java.io.*;import .*;import java.util.Scanner;public class client public static void main(String args) throws Exception Socket socket= new Socket(127.0.0.1, 8888);InputStream Is = socket.getInputStream();Outp

13、utStream Os = socket.getOutputStream();DataInputStream DIS = new DataInputStream(Is);PrintStream PS = new PrintStream(Os);for(;)Scanner in=new Scanner(System.in);double r=in.nextDouble();PS.println(r);System.out.println(DIS.readLine();实验结果截图：研究与探讨第一个任务中要写一段程序打开一个最多接收100个字节数据的数据包socket且超时周期为50秒，所以byte的最大值要设为100，为了设置超时时间要调用setSoTimeout函数。另外，要使接收端成功接收到发送端发送的信息，