blog.Toby

												
														<soapenv:Envelope 
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" 
xmlns:xsd="http://www.w3.org/2001/XMLSchema" 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
 <soapenv:Body>
   ...
   <client-id>001sf3242x-234234</client-id>
   <call-params>… </call-param>
   <call-method>
    getLogCount
   </call-method>
 </soapenv:Body>
</soapenv:Envelope>

												
										

												
														例程1 ServiceLifecycle
package javax.xml.rpc.server;
public interface ServiceLifecycle {
void init(Object context) throws ServiceException;
void destroy();
}

												
										

												
														例程2 ServletEndpointContext接口
package javax.xml.rpc.server;
public interface ServletEndpointContext {
public java.security.Principal getUserPrincipal();
public javax.xml.rpc.handler.MessageContext getMessageContext();
public javax.servlet.http.HttpSession getHttpSession();
public javax.servlet.ServletContext getServletContext();
}

												
										

												
														例程3 定義服務(wù)端點接口
package com.hellking.study.webservice.session;

import java.rmi.Remote;
import java.rmi.RemoteException;
/**
 *Web服務(wù)端點接口，它定義了三個服務(wù)方法。
 */
public interface SessionTestIF extends Remote {
    public String login(String id,String password) throws RemoteException;
    public String getLoginCount() throws RemoteException;    
    public void logout() throws RemoteException;
}

												
										

												
														例程4 服務(wù)實現(xiàn)類
package com.hellking.study.webservice.session;

import java.rmi.Remote.*;
import javax.xml.rpc.server.ServiceLifecycle;
import javax.xml.rpc.server.ServletEndpointContext;
import javax.xml.rpc.handler.soap.SOAPMessageContext;
import java.util.Properties;
import java.io.FileInputStream;
import javax.servlet.http.HttpSession;
/**
 *SessionTestImpl是Web服務(wù)實現(xiàn)類，用于測試Web服務(wù)中Session的使用。
 *由于要使用Session，需要實現(xiàn)ServiceLifecycle接口。
 */
public class SessionTestImpl implements SessionTestIF,ServiceLifecycle{
 
 //服務(wù)端點上下文
 private ServletEndpointContext serviceContext;
    
    /**
     *ServiceLifecycle方法：初始化服務(wù)端點，或者要使用的資源。
     */
    public void init(java.lang.Object context)
    {
  serviceContext=(ServletEndpointContext)context;
 }
 /**
     *ServiceLifecycle方法：銷毀服務(wù)端點實例。
     */
    public void destroy() 
    {
     this.serviceContext=null;
    //可能還有其它釋放資源的方法。
    }
 /**
  *Web服務(wù)方法：登錄，并且保存一些信息到HTTP會話中。
  */
    public String login(String id,String password) 
    {
     String ret=null;//返回值。
     Properties users=new Properties();
     try
     {
      //獲得用戶名、密碼屬性，一般是在數(shù)據(jù)庫中，這里簡化，把這些信息保存在一個文件中。
        users.load(com.hellking.study.webservice.session.SessionTestImpl.class
          .getResourceAsStream("password.properties"));
     }
     catch(java.io.FileNotFoundException e)
     {
      e.printStackTrace();
     }
     catch(java.io.IOException e)
     {
      e.printStackTrace();
     }
     try
     {
      String passwd=(String)users.getProperty(id);
      if(password.equals(passwd))
      {
       ret="登錄成功，你可以執(zhí)行其它操作！";
    HttpSession session = serviceContext.getHttpSession();
    //保存用戶會話狀態(tài)，它和一般的HTTP會話一樣，都使用HttpSession來進行。
    session.setAttribute("isLogin",new Boolean(true));
    session.setAttribute("userId",id);    
    //更新登錄次數(shù),在這里省略。
      }
     }
     catch(Exception e)
     {
      ret="登錄失敗，請確認用戶名和密碼正確！";
      e.printStackTrace();
     } 
     return ret;
    }
    
    /**
     *Web服務(wù)方法：獲得登錄的次數(shù)，需要使用HTTP會話來獲得當(dāng)前user的id。
     */
    public String getLoginCount() 
    {
     String ret=null;//返回值
     HttpSession session = serviceContext.getHttpSession();
        Properties logcount=new Properties();
     try
     {
      //獲得用戶登錄次數(shù)。
      logcount.load(com.hellking.study.webservice.session.SessionTestImpl.class
      .getResourceAsStream("login.properties"));
     }
     catch(java.io.FileNotFoundException e)
     {
      e.printStackTrace();
     }
     catch(java.io.IOException e)
     {
      e.printStackTrace();
     }
     try
     {
      //從HTTP會話中獲得是否登錄的屬性。
      Boolean isLogin=(Boolean)session.getAttribute("isLogin");
      String userId=(String)session.getAttribute("userId");
      //如果已經(jīng)登錄，那么返回logcount屬性值。
      if(isLogin.equals(Boolean.TRUE))
      {      
       ret=logcount.getProperty(userId);
      }
     }
     catch(Exception e)
     {
      e.printStackTrace();
     }
     return ret;     
    }
    /**
     *注銷，使會話無效。
     */    
    public void logout() 
    {
     HttpSession session = serviceContext.getHttpSession();
     session.invalidate();
    }        
}

												
										

												
														serviceContext=(ServletEndpointContext)context;

												
										

												
														HttpSession session = serviceContext.getHttpSession();

												
										

												
														session.setAttribute("isLogin", new Boolean(true));

												
										

												
														Boolean isLogin=(Boolean)session.getAttribute("isLogin");

												
										

												
														例程5 service-config.xml 
<?xml version="1.0" encoding="UTF-8"?>
<configuration 
  xmlns="http://java.sun.com/xml/ns/jax-rpc/ri/config">
  <service 
      name="MySessionTestService" 
      targetNamespace="urn:SessionTest" 
      typeNamespace="urn:SessionTest" 
      packageName="sessionTest">
      <interface name="com.hellking.study.webservice.session.SessionTestIF"/>
  </service>
</configuration>

												
										

												
														wscompile -define -d . -nd . -classpath . service-config.xml

												
										

												
														wscompile -gen -classpath . -d . -nd . -mapping mapping.xml service-config.xml

												
										

												
														例程6 web.xml描述符
<?xml version="1.0" encoding="UTF-8"?>

<!DOCTYPE web-app
    PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
    "http://java.sun.com/j2ee/dtds/web-app_2_3.dtd">

<web-app>
  <display-name>sessionTest-jaxrpc</display-name>
  <description>A web application containing a simple JAX-RPC endpoint</description>
  <servlet>
    <servlet-name>SessionTestServletImpl</servlet-name>
    <servlet-class>com.hellking.study.webservice.session.SessionTestImpl</servlet-class>
    <load-on-startup>0</load-on-startup>
  </servlet>
  <servlet-mapping>
    <servlet-name>SessionTestServletImpl</servlet-name>
    <url-pattern>/mysessionTest</url-pattern>
  </servlet-mapping>
  <session-config>
    <session-timeout>60</session-timeout>
  </session-config>
</web-app>

												
										

												
														例程7 基于Stub的客戶端
package com.hellking.study.webservice.session;
import javax.xml.rpc.Stub;
/**
 *Web服務(wù)調(diào)用客戶端,測試Web服務(wù)會話。基于Stub的調(diào)用。
 */
public class SessionTestClientUseStub
{
  
   Stub stub;
   SessionTestIF sessionTest;
   //初始化Stub。
   public SessionTestClientUseStub()
   {
       stub = (Stub)(new MySessionTestService_Impl().getSessionTestIFPort());
       stub._setProperty(javax.xml.rpc.Stub.ENDPOINT_ADDRESS_PROPERTY, 
                "http://127.0.0.1:8080/sessionTest/mysessionTest"); 
       stub._setProperty(Stub.SESSION_MAINTAIN_PROPERTY,Boolean.TRUE);
       sessionTest = (SessionTestIF)stub;
    }
   
    public static void main(String[] args) 
    {
  SessionTestClientUseStub test=new SessionTestClientUseStub();
  test.login();
  test.getLoginCount();
  test.logout();
        
    }
    /**
     *登錄。
     */
    public void login()
    {
     try {           
             System.out.println("正在登錄...");
            System.out.println(sessionTest.login("userid-001","abc"));
        } catch (Exception ex) {
            ex.printStackTrace();
        }  
   }
   /**
    *獲得logincount屬性值。
    */
   public void getLoginCount()
   {
      try
      {
       System.out.println("LoginCount的值為：");
       System.out.println(sessionTest.getLoginCount());
      }
      catch (Exception ex) {
            ex.printStackTrace();
        }
    }
    /**
     *注銷。
     */
    public void logout()
    {
   …//省略代碼
    }
}

												
										

												
														stub._setProperty(Stub.SESSION_MAINTAIN_PROPERTY,Boolean.TRUE);

												
										

												
														stub._setProperty(Stub.SESSION_MAINTAIN_PROPERTY,Boolean.TRUE)；

												
										

												
														stub._setProperty(Stub.SESSION_MAINTAIN_PROPERTY,Boolean.FALSE)；

												
										

												
														例程8 基于Call的客戶端
package com.hellking.study.webservice.session;

… // imports
/**
 *測試Web服務(wù)會話的使用
 */
public class SessionTestClient {
    //一些調(diào)用參數(shù)。
    private static String qnameService = "MySessionTestService";
    private static String qnamePort = "SessionTestIFPort";

    private static String BODY_NAMESPACE_VALUE =   "urn:SessionTest";
    private static String ENCODING_STYLE_PROPERTY =
         "javax.xml.rpc.encodingstyle.namespace.uri"; 
    private static String NS_XSD =   "http://www.w3.org/2001/XMLSchema";
    private static String URI_ENCODING =  "http://schemas.xmlsoap.org/soap/encoding/";
         
    ServiceFactory factory;
    Service service; 
    Call call;
    QName port;
   //初始化。 
   public SessionTestClient()
   {
        try
        {
          factory = ServiceFactory.newInstance();
          service =  factory.createService(new QName(qnameService));
          port = new QName(qnamePort);
          call = service.createCall(port);
          call.setTargetEndpointAddress("http://127.0.0.1:8000/sessionTest/mysessionTest");
          …//省略部分代碼
    }
    catch(Exception e)
    {
     e.printStackTrace();
    }       
    
   }
   /**
    *測試login操作。
    */
   
   public void login()
    {
     try {
       
            QName QNAME_TYPE_STRING = new QName(NS_XSD, "string");
            call.setReturnType(QNAME_TYPE_STRING);
            call.setProperty(Call.SESSION_MAINTAIN_PROPERTY,Boolean.TRUE);
            call.setOperationName(new QName(BODY_NAMESPACE_VALUE,"login"));
            call.addParameter("String_1", QNAME_TYPE_STRING, 
                ParameterMode.IN);
            call.addParameter("String_2", QNAME_TYPE_STRING, 
                ParameterMode.IN);    
            String[] params = {new String("userid-001"),new String("abc")};
            String result = (String)call.invoke(params);
            System.out.println("正在登錄...");
            System.out.println(result);

        } catch (Exception ex) {
            ex.printStackTrace();
       }
    }
    /**
     *和Web服務(wù)交互，獲得LoginCount值。
     */
    public void getLoginCount()
    {
     try {
      
            call.removeAllParameters();         
            …//省略部分代碼
             call.setProperty(Call.SESSION_MAINTAIN_PROPERTY,Boolean.TRUE);
             …//省略部分代碼
            String result = (String)call.invoke(params);
            System.out.println(result);

        } catch (Exception ex) {
            ex.printStackTrace();
       }
     
    }
    /**
     *和Web服務(wù)交互,注銷操作
     */
    public void logout()
    {
       try {
            call.removeAllParameters();    
              call.setProperty(Call.SESSION_MAINTAIN_PROPERTY,Boolean.TRUE);
            …//省略部分代碼
       }
    public static void main(String[] args) {
     SessionTestClient test=new SessionTestClient();
     test.login();
     test.getLoginCount();
     test.logout();
    }       
}