SOA在实际项目中的运用

日期: 2008-02-01 作者:bluesky35 来源:TechTarget中国

  提到SOA(Service-Oriented Architecture) 面向服务架构,大家恐怕都不陌生, 它是一种架构模型,可以根据需求通过网络对松散耦合的粗粒度应用组件进行分布式部署、组合和使用。SOA中最重要的莫过于服务层,它可以直接被应用调用,从而有效控制系统中与软件代理交互的人为依赖性。

  接下来给大家演示一个SOA的典型用例,我将项目中的一些组件代码抽出,聚合成可使用的sample,简单给大家讲一下.我们要做的是建立一个简单的SOA服务构架,然后从本地访问服务并且从服务中获得基础信息.

  基于其中一些朋友可能是初学,所以给大家演示时我尽量做到傻瓜式,即使一点也不懂的朋友也可以跟着例子一步一步走下去,相信这篇文章能给大家带来意外的收获.

  首先,我们用java来做这个例子,请大家先在本地安装以下软件:

  1. JDK 1.5.0

  2. Eclipse 3.2.0

  一. 打开eclipse,新建Java Project工程,起名为SOASample,JRE选择1.5,如下图所示:

  二. 既然SOA涉及到本地和服务层之间的交互,那一定需要交互的中间介质,毫无疑问是一个保存数据的对象,做欧美项目的朋友叫做BEAN,做对日项目的朋友叫做DTO,我们创建的DTO包含一个属性name_,让我们按下图建立一个DTO.

  三. 完善DTO的代码(注意:由于需要在网络中进行传输,所以应该进行序列化,即实现Serializable)

  import java.io.Serializable;
 
  publicclass RmiServiceDTO implements Serializable{
 
       /**
        *serialVersionUID
        */
       privatestaticfinallongserialVersionUID = 1L;
 
  /**
        *serialVersionUID
        */
       private String _name = null;
      
       /**
        *@return_name。
        */
       public String getName() {
              return_name;
       }
       /**
        *@param_name_name。
        */
       publicvoid setName(String _name) {
              this._name = _name;
       }

  现在大家的环境应该都与下图一致.

  
  四. 由于SOA需要与服务进行交互,所以我们得建立一个基于RMI的远程接口,与前面建立DTO一样,我们建立名为RMIImpl的接口,代码如下:

  publicinterface RMIImpl extends java.rmi.Remote{
       public RmiServiceDTO execute() throws java.rmi.RemoteException;
  } 

  五. 大家都知道,访问服务一般都使用代理模式,即在本地建立代理,然后通过代理访问服务,接收结果.接下来我们建立一个实现以上RMIImpl接口的名为RMIImplProxy的代理,代码如下:

  import java.rmi.Naming;
 
  publicclass RMIImplProxy implements RMIImpl{
      
       public RmiServiceDTO execute() throws java.rmi.RemoteException{
             
              RmiServiceDTO message = null;
             
           try{
               RMIImpl obj = (RMIImpl)Naming.lookup("/HelloServer");
               message = obj.execute();
 
             }catch(Exception e){
               System.out.println(e.toString());
             }
            
             // 
             return message;
       }

  在这个代理中,我们通过Naming寻找网络上的名为HelloServer的服务,找到后我们调用该服务的execute方法取得发返回结果.

  六. 代理的使用方法有很多种,其中最简单的方式是将它直接实例化使用,为了能在多个代理之间进行统一管理,我们选择工厂方式,接下来我们建立一个工厂,通过调用这个工厂,我们可以获得任何一个代理,代码如下:

  publicclass ServiceFactory {
 
       privatestaticfinal ServiceFactory instance = new ServiceFactory  ();
      
       private ServiceFactory() {
              super();
       }
      
       /**
        *
        *@return
        */
       publicstatic ServiceFactory getInstance() {
              returninstance;
       }
      
       publicRMIImpl getGUSO() {
              returnnew RMIImplProxy();
       }

  七. 接下来我们调用工厂取得代理对象,通过代理对象可以访问远程服务,本地客户端执行代码如下所示:

  import java.rmi.RemoteException;
 
  publicclass Client {
 
       publicstaticvoid main(String[] args) {
             
        // Service作成
        ServiceFactory factory = ServiceFactory.getInstance();
       
              try {
                     // Green
                     RmiServiceDTO rmiServiceDTO = factory.getGUSO().execute();
                    
                     System.out.println(rmiServiceDTO.getName());
              } catch (RemoteException e) {
                     e.printStackTrace();
              }
       }

  八. 至今为止,客户端的所有代码都已编写完成,接下来我们模拟一个服务器端服务供客户端调用,代码如下:

  import java.rmi.*;
  import java.rmi.server.*;
 
  publicclass HelloServer extends UnicastRemoteObject implements RMIImpl{
 /**
        *
        */
       privatestaticfinallongserialVersionUID = 1L;
 
  public HelloServer() throws RemoteException{
    super();
 }
 
 public RmiServiceDTO execute() throws java.rmi.RemoteException{
     
      RmiServiceDTO rmiServiceDTO = new RmiServiceDTO();
     
      rmiServiceDTO.setName("zhaolin");
     
      return rmiServiceDTO;
 }

  客户端调用服务,返回一个持有内容为zhaolin的DTO.

  九. 由于服务需要启动才能被调用,所以我们再写一个注册程序注册这个服务以便客户端调用,注册程序代码如下:

  import java.rmi.Naming;
 
  publicclass RegistIt {
 
       publicstaticvoid main(String[] args) {
           try{
               HelloServer obj = new HelloServer();
               System.out.println("Object is" + obj);
               Naming.rebind("/HelloServer",obj);
               System.out.println("Already Start");
             }catch(Exception e){
               System.out.print(e);
             }
       } 

  十. 好了,最后要做的就是测试我们之前所写的所有代码,测试这个程序一共有三个步骤.

  1. 启动JAVA的服务注册许可

  2. 注册并启动服务

  3. 调用客户端访问服务取得信息

  首先,启动java的服务注册许可,使用命令rmiregistry -J-Djava.security.policy=java.policy启动注册表,如下图所示:

  一定要注意:请在所有class的根目录下注册,比如我是将所有代码和class放在E:SOASample目录下,所以我便在E:SOASample目录下执行以上注册语句.

  然后我们注册并启动服务,在eclipse中执行RegistIt.java,结果如下:

  最后我们执行Client.java,通过工厂方式实力化代理对象,通过代理对象访问服务并取得数据,最后的执行结果如下:

  整个例子完成了, 有一点需要提一下,在这个例子中,我们是通过模拟的服务返回结果,而在实际应用中,这个服务被单独建立在服务器端,并且服务之间也有通讯,这些服务不一定就是java所写,也可能是使用cobol等语言写的程序,当服务变更,我们只需要调用不同的Proxy即可,而在实际应用中,一个服务就对应一个Proxy,而一个Factory中可以装载所有可供选用的Proxy.

 

我们一直都在努力坚持原创.......请不要一声不吭,就悄悄拿走。

我原创,你原创,我们的内容世界才会更加精彩!

【所有原创内容版权均属TechTarget,欢迎大家转发分享。但未经授权,严禁任何媒体(平面媒体、网络媒体、自媒体等)以及微信公众号复制、转载、摘编或以其他方式进行使用。】

微信公众号

TechTarget微信公众号二维码

TechTarget

官方微博

TechTarget中国官方微博二维码

TechTarget中国

相关推荐

  • 事件驱动框架和SOA在空军的应用

    空军正在利用SOA来改善数据共享,并实时跟踪战机,美国空军机动司令部的Michael Marek解释了企业可从中学习的经验。

  • 揭秘New Relic APM技术细节

    New Relic应性能管理(APM)套件主要用于Web软件开发。它允许用户在面向服务的架构(SOA)上跟踪关键事务性能,并且支持代码级别的可见性来评估特定代码段和SQL语句对性能的影响

  • 仅凭SOA和云无法解决业务数据管理风险问题

    SOA和云可以是某些恼人问题高效的解决方案;这一点我们已经知道了。但是也要记住它们并不是所有事情的直接答案,特别是当你的问题是业务数据管理风险,而不是技术问题时。

  • 内存数据网格提供商一头扎进Java

    10年的时间里,应用性能解决方案提供商Alachisoft一直在用NCache(针对N-Tier和网格计算.NET应用的内存计算和数据网格产品)为.NET社区服务。