随笔-46  评论-64  文章-2  trackbacks-0

一、一些概念

    WebService技术现在几乎无处不在,以前玩.NET的时候最开始接触这个概念,C#语言对WebService近似原生性的支持使我们用C#可以非常迅速的开发出一个WebService,没有任何复杂烦扰的步骤。
    后来没有机会再在.Net Framework上面开发,转投了Java的怀抱,想要开发出一个WebService感觉比较,搞一堆命令生成一堆什么代码,好不容易才能搭出来,尝试一次之后终于还是放弃了,觉得麻烦。
    Java6.0出来之后对WebService也说原生支持了,所以再做毕业设计的时候想到体验一下Java6.0的WebService,果然容易上手很多,易用。毕业设计把这个计算在内,智能设备+WebService可以作为系统应用的一部分。

   开始代码之前先大概说说我对这几个概念的理解

    WebService 是分布式应用程序组件,这么说可能太抽象,这其实以经不是一个新的概念了,但是突然间要解释这个名次还比较不容易。它其实是构建在已有技术基础上的一个概念,WebService的核心是xml、soap、wsdl等,客户可以通过web请求的方式使用WebService。或者说得更通俗点就是服务提供商把他提供的服务发布到Internet上,然后客户可以通过Internet使用这个服务。

    RMI这个东西上手也不那么容易,不过这个概念可以简单点来理解,就是不同JVM之间通讯的一个手段,这里调用的是Java代码。不同的JVM可以在不同的机器上或者是同一台机器上。这个纯Java的分布式应用的一个典型的Solution. RMI技术和CORBA互为补充。
   
   对于CORBA我没有详细学习过,不过概念很容易懂,CORBA 允许应用程序和其他的应用程序通讯,而不论他们在什么地方或者由谁来设计。CORBA和语言实现是无关的,C++和Java实现的系统通过CORBA通信。EMA里面就有这个CORBA。

二、协作的需求模型

    下面切入正题,说说WebService和RMI的协作。我们先来看这个需求的模型是怎么样的。看下图
                                WebService + RMI 协作.png
 
   系统要求有Smart device对远程的JVM2里的程序控制,所以我们引入了WebService,通过WebService间接调用JVM2里的东西,WebSerivce本身运行在JVM1,JVM1和JVM2可以在不同机器上,这里demo程序是在一台机器上运行的。
   WebService在这里既是SmartDevice的Server端,又是RMI的Client端。RMI的Server端在JVM2的App里作为一部分服务存在。

三、代码分解,下面我们开始demo这个协作的代码

3.1 首先我们抽象一个RMI的Interface

package  cn.heapstack.rmi.interfaces;

import  java.rmi.Remote;
import  java.rmi.RemoteException;
import  java.util.Date;

public   interface  IBridge  extends  Remote
{
    
public  Date getDate()  throws  RemoteException;
    
    
public  String getOtherInfo()  throws  RemoteException;
}

简单的接口,一个是获得时间的,一个是获取随便什么消息的接口

3.2实现RMI的Server端

package  cn.heapstack.rmi.server;

import  java.rmi.RemoteException;
import  java.rmi.server.UnicastRemoteObject;
import  java.util.Date;

import  cn.heapstack.rmi.interfaces.IBridge;

public   class  BriderImpl  extends  UnicastRemoteObject  implements  IBridge
{

    
protected  BriderImpl()  throws  RemoteException
    
{
        
super ();
    }


    
private   static   final   long  serialVersionUID  =   - 2194578051853930272L ;

    
public  Date getDate()  throws  RemoteException
    
{
        
return   new  Date( 2008 , 5 , 10 );
    }


    
public  String getOtherInfo()  throws  RemoteException
    
{
        
return   " This is the message from the jvm, path info:  "   +  BriderImpl. class .getResource( " / " ).getPath();
    }


}

 

package  cn.heapstack.rmi.server;


import  java.rmi.Naming;
import  java.rmi.registry.LocateRegistry;

import  cn.heapstack.rmi.interfaces.IBridge;

public   class  RmiServer 
{

    
public   static   void  main(String[] args)
    
{
         
try    
          
{    
             LocateRegistry.createRegistry(
1099 );    
             IBridge bridge 
=   new  BriderImpl();
             Naming.rebind(
" bridge " , bridge);    
             
             System.out.println(
" RMI Server is ready. " );
          }
    
          
catch  (Exception e)    
          
{    
             System.out.println(
" RMI Server failed:  "   +  e);    
          }
    

    }

}



3.3我们可以先写个RMI的Client测试一下
package  cn.heapstack.rmi.client;

import  java.rmi.Naming;

import  cn.heapstack.rmi.interfaces.IBridge;

public   class  RmiClient
{

    
/**
     * 
@param  args
     
*/

    
public   static   void  main(String[] args)
    
{
        IBridge bridge;
        
try
        
{
            bridge 
=  (IBridge) Naming.lookup( " bridge " );
        
        
            System.out.println( bridge.getDate() );
        }

        
catch (Exception e)
        
{
            e.printStackTrace();
        }


    }


}


      由于在本机上,省略了ip什么的,如果对这段代码不是很懂,建议看后面的参考资料
      测试方法,先运行Server,再运行Client,不出以外,你能看到2008年5月10号。

3.4我们开始实现我们的WebService Server端
      Java6.0实现WebService也很简单,我直接贴代码了。Server端如下,如果不太懂,还是建议看后面的参考资料
package cn.heapstack.ws.server;

import java.net.MalformedURLException;
import java.rmi.Naming;
import java.rmi.NotBoundException;
import java.rmi.RemoteException;
import java.util.Date;

import javax.jws.WebMethod;
import javax.jws.WebService;
import javax.jws.soap.SOAPBinding;

import cn.heapstack.rmi.interfaces.IBridge;

@WebService(targetNamespace 
= "http://www.heapstack.cn/ws/MyTimeServer")
@SOAPBinding(style 
= SOAPBinding.Style.RPC)
public class MyTimeServer
{

    
    @WebMethod
    
public String getServerTime()
    
{
        
//通常的做法
        
//return new Date(System.currentTimeMillis()).toString();
        
        
//这里我想要调用RMI,取得另一个JVM中程序调用的结果,当然这个JVM可以在两外一台机器上运行
        
//这里WebService的Server 其实是RMI的 Client
        Date date = null;
        
try
        
{
            IBridge bridge 
= (IBridge) Naming.lookup("bridge");
            date 
= bridge.getDate();
            
return date.toString();
        }

        
catch(Exception e)
        
{
            e.printStackTrace();
        }

        
return null;

        
    }


}

发布WebService
package cn.heapstack.ws.server;

import javax.xml.ws.Endpoint;

import cn.heapstack.ws.server.MyTimeServer;
public class Main
{

    
public static void main(String[] args)
    
{
        Endpoint.publish(
"http://localhost:8435/MyTimeServer"new MyTimeServer());
    }


}


3.6实现WebService的客户端
      首先cd到src目录,然后敲wsimport -keep http://localhost:8435/MyTimeServer?wsdl这个会自动生成一堆代码,基本上可以理解为stub一类的东西
      然后我们就可以直接调用啦
package cn.heapstack.ws.client;

import cn.heapstack.ws.mytimeserver.*
;

public class
 WSClient
{

    
/**
     * 
@param args
     
*/

    
public static void main(String[] args)
    
{
        
//自动生成的代码    WebService的Stub

        MyTimeServerService ws = new MyTimeServerService();
        
//自动生成的代码    WebService的实例类

        MyTimeServer service = ws.getMyTimeServerPort();
        
//调用WebService,WebSerivce会调用RMI的方法获得返回结果

        String date = service.getServerTime();
        System.out.println(
"WS Client get:"+
 date );

    }

}


到此为止,这个WebService和RMI的协作完成了,代码尽量精简了

参考资料:
      JAVA RMI 实例-damies -JavaEye技术社区,  RMI的入门资料,很容易看懂
      交口称赞 blog中 关于java 6.0 WebService的部分,也是很好的新手学习资料
      
posted on 2007-03-31 21:27 jht 阅读(3673) 评论(3)  编辑  收藏 所属分类: J2SE

评论:
# re: 使用WebService 和RMI远程协作 2012-03-08 10:57 | try_lin
测试rmi注册时 报错
java.rmi.StubNotFoundException: Stub class not found: server.TaskRemoteImp_Stub; nested exception is:
java.lang.ClassNotFoundException: server.TaskRemoteImp_Stub
at sun.rmi.server.RemoteProxy.getStub(RemoteProxy.java:98)
at sun.rmi.server.RemoteProxy.getStub(RemoteProxy.java:55)
at sun.rmi.server.UnicastServerRef.setSkeleton(UnicastServerRef.java:179)
at sun.rmi.server.UnicastServerRef.exportObject(UnicastServerRef.java:142)
at sun.rmi.server.UnicastServerRef.exportObject(UnicastServerRef.java:129)
at java.rmi.server.UnicastRemoteObject.exportObject(UnicastRemoteObject.java:275)
at java.rmi.server.UnicastRemoteObject.exportObject(UnicastRemoteObject.java:178)
at java.rmi.server.UnicastRemoteObject.<init>(UnicastRemoteObject.java:75)
at java.rmi.server.UnicastRemoteObject.<init>(UnicastRemoteObject.java:61)
at server.TaskRemoteImp.<init>(TaskRemoteImp.java:13)
at rmiMain.main(rmiMain.java:16)
Caused by: java.lang.ClassNotFoundException: server.TaskRemoteImp_Stub
at java.net.URLClassLoader$1.run(URLClassLoader.java:199)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:187)
at java.lang.ClassLoader.loadClass(ClassLoader.java:289)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:274)
at java.lang.ClassLoader.loadClass(ClassLoader.java:235)
at sun.rmi.server.RemoteProxy.loadClassFromClass(RemoteProxy.java:191)
at sun.rmi.server.RemoteProxy.getStub(RemoteProxy.java:93)
... 10 more
Exception in thread "main"

报错 。。。。。。。。
和你的写法一致 jdk1.4


怎么解决呢??  回复  更多评论
  
# re: 使用WebService 和RMI远程协作 2012-03-08 10:58 | try_lin
请把解决方案发我邮箱号码 try_lin@sina.cn
  回复  更多评论
  
# re: 使用WebService 和RMI远程协作 2013-12-10 15:37 | 11
实现类没有找到  回复  更多评论
  

只有注册用户登录后才能发表评论。


网站导航:
博客园   IT新闻   Chat2DB   C++博客   博问