分布计算环境作业(initial).docx

1分布计算环境作业一判断是非题1) RDF没有描述资源间关系的能力，且不能描述两个类的互不相交关系、类的基数和等价性等，因此在语义Web中需要引入本体。 错2) 无状态会话Bean也可以用于实现有状态的应用。 对二多项选择题1) 你认为BT可能是基于下面_D_结构实现的？A. 中心化拓扑 B. 全分布式非结构化拓扑C. 全分布式结构化拓扑 D. 半分布式拓扑 2) 在五层沙漏结构中，位于_C_层的协议需要在所有提供共享资源的节点上提供。A. 资源层 B. 连接层C. 构造层 D. 汇聚层E. 应用层三问答题1、（15分）试分析为什么近年来云计算发展得如此迅猛？ 2、（15分）现要为某网上商城实现一个商品价格查询服务，该服务具有以下功能： 用户可以主动查询某个商品的价格。 用户可以订购某个商品的价格，当商品价格低于用户指定的阈值时，该服务通知订购用户当前的价格。 多个用户可同时使用该服务。现要使用面向对象的技术，如CORBA技术实现该服务：请描述该服务对象和客户端程序分别需要实现的接口。接口可以采用任何一种程序设计语言描述（甚至夹杂自然语言），但要明确每个接口名、接口中的方法名、方法的返回值和参数名以及类型。首先是定义一个idl文件 interface DataService double select(Double productid);void recievenote(Double productid，Double value);void buy(Double productid，Double value); ;Server端代码：/实现数据库查询基本类importjava.sql.Connection; importjava.sql.DriverManager; importjava.sql.ResultSet; importjava.sql.SQLException; publicclass DBManager private static String user =root; private static String pass =962464; private static String className=com.mysql.jdbc.Driver; private static String url =jdbc:mysql:/localhost:3306/students; private static Connection conn; private static java.sql.Statement state; public static void init() try Class.forName(className); conn =DriverManager.getConnection(url,user,pass); state =conn.createStatement(); catch (ClassNotFoundException e) / TODO Auto-generated catchblock e.printStackTrace(); catch (SQLException e) / TODO Auto-generated catchblock e.printStackTrace(); /插入订购记录 public static void buy(String Productnum,double Value) String sql = insert into stuScore values(+Productnum+,+Value+); try state.execute(sql); catch (SQLException e) / TODO Auto-generated catchblock e.printStackTrace(); /查询产品价格 public static double select(String Productnum) String sql = select score from stuScore where num= +num+; double Value= 0; try ResultSet rs =state.executeQuery(sql); while(rs.next() result = rs.getDouble(score); catch (SQLException e) / TODO Auto-generated catchblock e.printStackTrace(); return Value; 服务器端主函数：/*服务端实现了Runnable接口，以便多线程扩展*/public class CORBAServer implements Runnable /*构造函数*/ public CORBAServer(String args) initORB(args); /*初始化ORB*/ private void initORB(String args) try /根据参数初始化ORB ORB orb = ORB.init(args, null); /新建一个服务实现对象 OperateImpl operateRef = new OperateImpl(); /连接该服务实现对象 orb.connect(operateRef); /解析根名字引用 org.omg.CORBA.Object objRef = orb.resolve_initial_references(NameService); /匹配CORBA对象 NamingContext ncRef = NamingContextHelper.narrow(objRef); /新建指定接口模块名的名字组件 NameComponent nc = new NameComponent(test, ); NameComponent path = nc; /根据名字服务绑定CORBA服务对象 ncRef.rebind(path, operateRef);catch(Exception e) e.printStackTrace(); /*实现Runnable接口*/ public void run() try java.lang.Object object = new java.lang.Object(); /同步对象，等待客户调用 synchronized(object) object.wait(); DBManager.select(num); /查询产品价格 catch(Exception e) e.printStackTrace(); /*主入口函数*/ public static void main(String args) CORBAServer cs =new CORBAServer(args);/运行CORBA服务对象cs.run(); timer.schedule(new Task()Double value = DBManager.select(num);if(value 100)notifyvlient(Productnum,value);/通知client端购买, 60 * 1000) .run(); /定时，每分钟调用查询价格，若大于100则通知client 这样服务器端提供的功能都实现了，然后在服务端创建服务对象并将其向ORB注册这样服务端的代码就写好了。下面就是写客户端的代码，和前面一个将生成的文件加入到客户端文件中，然后编写一个客户端文件，主要是实现数据初始化，并且连接服务程序，这里面需要输入IOR码，并且必须和服务器端产生的一样，这样才能得到服务端的服务，得到服务对象之后就是对服务端的方法的调用实现数据的插入和查询操作。Client 端代码：public class CORBAClient/*主入口函数*/public static void main(String args)tryBufferedReader readIn = new BufferedReader(new InputStreamReader(System.in);ORB orb = ORB.init(args, null); /初始化ORB/解析根名字引用org.omg.CORBA.Object objRef = orb.resolve_initial_references(NameService);/匹配CORBA对象NamingContext ncRef = NamingContextHelper.narrow(objRef);/根据指定接口创建名字组件NameComponent nc = new NameComponent(test, );NameComponent path = nc;/根据名字服务定位指定接口对象operate opRef = operateHelper.narrow(ncRef.resolve(path);System.out.println(Please Input Data1: );String productid = readIn.readLine(); /读入查询产品id System.out.println