<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    176142998

      BlogJava :: 首頁 :: 聯(lián)系 :: 聚合  :: 管理
      116 Posts :: 0 Stories :: 45 Comments :: 0 Trackbacks

    2011年4月21日 #

    官網(wǎng)地址
    http://www.oracle.com/technetwork/cn/middleware/ias/downloads/wls-main-091116-zhs.html


    各個(gè)版本的都有,以下列舉出來9.2的

    Oracle WebLogic Server 9.2 MP3版本

    http://download.oracle.com/otn/bea/weblogic/server923_win32.exe.zip

    http://download.oracle.com/otn/bea/weblogic/server923_linux32.bin.zip

    http://download.oracle.com/otn/bea/weblogic/server923_solaris32.bin.zip

     

    Oracle WebLogic Server 9.2 MP4版本

     

    http://download.oracle.com/otn/bea/weblogic/server924_win32.zip

     

    http://download.oracle.com/otn/bea/weblogic/server924_linux32.zip

    http://download.oracle.com/otn/bea/weblogic/server924_solaris32.zip

     

    Oracle WebLogic Server 10.0 MP2 版本

    http://download.oracle.com/otn/bea/weblogic/V16484-01.zip

    posted @ 2012-04-12 09:54 飛飛 閱讀(1029) | 評(píng)論 (0)編輯 收藏



    linux-geum:/etc/init.d # more start_oracle.sh
    #this script is used to start the oracle

    su - oracle -c "/opt/oracle/product/10g/bin/dbstart"

    su - oracle -c "/opt/oracle/product/10g/bin/lsnrctl start"


    ln -s /etc/init.d/start_oracle.sh  /etc/rc.d/rc2.d/S16start_oracle
    ln -s /etc/init.d/start_oracle.sh  /etc/rc.d/rc3.d/S16start_oracle
    ln -s /etc/init.d/start_oracle.sh  /etc/rc.d/rc5.d/S16start_oracle

    linux-geum:/etc/init.d # more stop_oracle.sh
    #this script is used to stop the oracle

    su - oracle -c "/opt/oracle/product/10g/bin/lsnrctl stop"

    su - oracle -c "/opt/oracle/product/10g/bin/bin/dbshut"


    ln -s /etc/init.d/stop_oracle.sh  /etc/rc.d/rc2.d/S16stop_oracle
    ln -s /etc/init.d/stop_oracle.sh  /etc/rc.d/rc3.d/S16stop_oracle
    ln -s /etc/init.d/stop_oracle.sh  /etc/rc.d/rc5.d/S16stop_oracle

    posted @ 2012-04-06 17:35 飛飛 閱讀(688) | 評(píng)論 (0)編輯 收藏

    在/etc/init.d 下新建after.local或者編輯after.local文件,

    文件內(nèi)容
    /usr/local/bin/memcached -d -m 512 -u root -l 192.168.1.106 -p 11211 -c 1024 -P /tmp/memcached.pid
    posted @ 2012-04-06 17:33 飛飛 閱讀(548) | 評(píng)論 (0)編輯 收藏

    1、主要實(shí)現(xiàn)用戶在進(jìn)行某項(xiàng)操作時(shí),多數(shù)據(jù)庫的更新、插入和刪除詳細(xì)信息。記錄操作時(shí)的請(qǐng)求信息。
    2、在進(jìn)入Controller時(shí),生成一個(gè)事物ID,在這個(gè)Controller中進(jìn)行的所有DAO操作都綁定該事物ID。并進(jìn)行記錄日志信息。


    package com.centralsoft.filter;

    import java.lang.reflect.Field;
    import java.lang.reflect.Method;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.regex.Pattern;

    import net.sf.json.JSONObject;

    import org.aspectj.lang.ProceedingJoinPoint;
    import org.aspectj.lang.annotation.Around;
    import org.aspectj.lang.annotation.Aspect;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.stereotype.Component;

    import com.centralsoft.cache.CacheService;
    import com.centralsoft.cache.annotations.Cache;
    import com.centralsoft.cache.entity.MemCacheKey;
    import com.centralsoft.entity.SysLogDetail;
    import com.centralsoft.manager.pub.ThreadBean;
    import com.centralsoft.manager.pub.ThreadId;
    import com.centralsoft.pub.dao.SysLogDAO;
    import com.centralsoft.webservice.pub.DateSHA;

    /**
     * DAO層AOP攔截器,實(shí)現(xiàn)記錄用戶操作過的所有方法和參數(shù),并實(shí)現(xiàn)DAO層緩存
     *
     * @author Administrator
     *
     */
    @Aspect
    @Component
    public class AspectAutoDAOBean {

     @Autowired
     @Qualifier("CacheService")
     private CacheService memcache;

     @Autowired
     @Qualifier("SysLogDAO")
     private SysLogDAO SysLogDAO;

     @Around("execution(* com.centralsoft.*.dao.Zr*DAO.*(..))")
     public Object before(ProceedingJoinPoint joinPoint) throws Throwable {
      // 獲取請(qǐng)求事務(wù)ID信息
      ThreadId threadId = new ThreadBean().getThreadId();
      // 調(diào)用方法名稱
      String methodName = joinPoint.getSignature().getName();
      // 調(diào)用參數(shù)
      Object[] args = joinPoint.getArgs();
      Object object = null;

      // 數(shù)據(jù)庫更新操作日志
      if (Pattern.matches("(save|insert|add|delete|remove|del|update)[\\S]*",
        methodName)) {
       if (threadId != null && threadId.getTransactionalId() != null) {
        // 獲取執(zhí)行請(qǐng)求事務(wù)ID
        String transactionalId = threadId.getTransactionalId();
        // 獲取執(zhí)行請(qǐng)求用戶ID
        String userId = threadId.getUserId();
        SysLogDetail sysLogDetail = new SysLogDetail();
        sysLogDetail.setXh(transactionalId);
        sysLogDetail.setUserId(userId);
        sysLogDetail.setMethod(methodName);
        JSONObject msg = new JSONObject();
        // 處理參數(shù)
        for (Object temp : args) {
         // 獲取參數(shù)類型,不同參數(shù)類型數(shù)據(jù)處理不一樣
         Class<? extends Object> paramClazz = temp.getClass();
         String classType = paramClazz.getName();
         if (classType.equals("java.lang.String")) {
          msg.put("key", temp);
         } else if (classType.equals("java.util.HashMap")) {
          msg.putAll((HashMap<?, ?>) temp);
         } else if (classType.startsWith("com.")) {
          try {
           Field[] f = paramClazz.getDeclaredFields();
           for (Field field : f) {
            String fieldName = field.getName();
            field.setAccessible(true);
            msg.put(fieldName, field.get(temp));
           }
          } catch (SecurityException e) {
           e.printStackTrace();
          } catch (IllegalArgumentException e) {
           e.printStackTrace();
          }
         }
        }
        sysLogDetail.setMsg(msg.toString());
        // 記錄DAO數(shù)據(jù)庫操作日志
        SysLogDAO.insertSysLogDetail(sysLogDetail);
       }
       // 執(zhí)行數(shù)據(jù)庫操作
       object = joinPoint.proceed();

       // 數(shù)據(jù)庫查詢緩存
      } else if (Pattern.matches("(query|load|get|select|read)[\\S]*",
        methodName)) {
       // DAO層緩存注解
       MemCacheKey cacheKey = new MemCacheKey();
       // 獲取cache注解屬性
       Cache cache = null;
       // 獲取請(qǐng)求方法
       Class<?> cls = joinPoint.getTarget().getClass();
       // 獲取class中的所有方法
       Method[] methods = cls.getMethods();
       for (Method m : methods) {
        // 獲取執(zhí)行方法前的注解信息。
        if (m.getName().equals(methodName)) {
         cache = m.getAnnotation(Cache.class);
         break;
        }
       }

       if (cache != null) {
        // 獲取memcacheKey,并進(jìn)行MD5加密
        cacheKey = memcacheKey(cache, args);
        // 判斷緩存服務(wù)器是否存在該可以值
        if (memcache.exist(cacheKey.getMemcacheKey())) {
         object = memcache.get(cacheKey.getMemcacheKey());
        } else {
         // 執(zhí)行數(shù)據(jù)庫操作
         object = joinPoint.proceed();
         // 將數(shù)據(jù)存放進(jìn)緩存
         if (cacheKey.getMemcacheKey() != null) {
          memcache.put(cacheKey.getMemcacheKey(),
            object == null ? "" : object, new Date(cacheKey
              .getTime()));
         }
        }
       } else {
        // 執(zhí)行數(shù)據(jù)庫操作
        object = joinPoint.proceed();
       }
      } else {
       // 執(zhí)行數(shù)據(jù)庫操作
       object = joinPoint.proceed();
      }

      return object;

     }

     /**
      * 獲取根據(jù)注解中的key獲取memcache的含參數(shù)key值
      *
      * @param cache
      * @param parameterObject
      * @return
      * @author fei.zhao 2011-10-10
      */
     @SuppressWarnings("unchecked")
     private static MemCacheKey memcacheKey(Cache cache, Object[] args) {
      MemCacheKey tempKey = new MemCacheKey();
      String key = "";
      boolean flag = true;
      StringBuilder keyBuilder = new StringBuilder(32);
      // 獲取注解中的key值
      String cacheKey = cache.key();
      Object[] cacheArgs = cacheKey.split("\\.");

      // 設(shè)置請(qǐng)求參數(shù)在args[]中的序號(hào)
      // key參數(shù)進(jìn)行循環(huán)遍歷
      for (Object s : cacheArgs) {
       // 判斷是否是格式$,$...
       if (s.toString().startsWith("$")) {
        // 獲取參數(shù)名稱
        String type = s.toString().substring(1);
        // 獲取參數(shù)值
        Object temp = args[0];
        // 獲取參數(shù)類型,不同參數(shù)類型數(shù)據(jù)處理不一樣
        Class<? extends Object> paramClazz = temp.getClass();
        String classType = paramClazz.getName();
        if (classType.equals("java.lang.String")) {
         keyBuilder.append(temp);
        } else if (classType.equals("java.util.HashMap")) {
         keyBuilder.append(((HashMap) temp).get(type));
        } else if (classType.startsWith("com.")) {
         try {
          Field f = paramClazz.getDeclaredField(type);// 實(shí)體中字段
          f.setAccessible(true);// 允許訪問私有字段
          keyBuilder.append(f.get(temp));
         } catch (SecurityException e) {
          flag = false;
          e.printStackTrace();
         } catch (NoSuchFieldException e) {
          flag = false;
          e.printStackTrace();
         } catch (IllegalArgumentException e) {
          flag = false;
          e.printStackTrace();
         } catch (IllegalAccessException e) {
          flag = false;
          e.printStackTrace();
         }
        }
       } else {
        keyBuilder.append(s);
       }
       // 每個(gè)參數(shù)后面添加 “.”號(hào)分隔
       keyBuilder.append(".");
      }
      if (args.length == 3) {
       keyBuilder.append(args[1] + ".").append(args[2]);
      }
      if (flag == true) {
       key = keyBuilder.toString();
       tempKey.setMemcacheKey(DateSHA.shaEncrypt(key));
       tempKey.setTime(cache.time());
      }
      return tempKey;
     }
    }

    posted @ 2011-11-07 19:48 飛飛 閱讀(7751) | 評(píng)論 (0)編輯 收藏

    一般的情況下我們都是使用IE或者Navigator瀏覽器來訪問一個(gè)WEB服務(wù)器,用來瀏覽頁面查看信息或者提交一些數(shù)據(jù)等等。所訪問的這些頁面有的僅僅是一些普通的頁面,有的需要用戶登錄后方可使用,或者需要認(rèn)證以及是一些通過加密方式傳輸,例如HTTPS。目前我們使用的瀏覽器處理這些情況都不會(huì)構(gòu)成問題。不過你可能在某些時(shí)候需要通過程序來訪問這樣的一些頁面,比如從別人的網(wǎng)頁中“偷”一些數(shù)據(jù);利用某些站點(diǎn)提供的頁面來完成某種功能,例如說我們想知道某個(gè)手機(jī)號(hào)碼的歸屬地而我們自己又沒有這樣的數(shù)據(jù),因此只好借助其他公司已有的網(wǎng)站來完成這個(gè)功能,這個(gè)時(shí)候我們需要向網(wǎng)頁提交手機(jī)號(hào)碼并從返回的頁面中解析出我們想要的數(shù)據(jù)來。如果對(duì)方僅僅是一個(gè)很簡單的頁面,那我們的程序會(huì)很簡單,本文也就沒有必要大張旗鼓的在這里浪費(fèi)口舌。但是考慮到一些服務(wù)授權(quán)的問題,很多公司提供的頁面往往并不是可以通過一個(gè)簡單的URL就可以訪問的,而必須經(jīng)過注冊(cè)然后登錄后方可使用提供服務(wù)的頁面,這個(gè)時(shí)候就涉及到COOKIE問題的處理。我們知道目前流行的***頁技術(shù)例如ASP、JSP無不是通過COOKIE來處理會(huì)話信息的。為了使我們的程序能使用別人所提供的服務(wù)頁面,就要求程序首先登錄后再訪問服務(wù)頁面,這過程就需要自行處理cookie,想想當(dāng)你用java.net.HttpURLConnection來完成這些功能時(shí)是多么恐怖的事情啊!況且這僅僅是我們所說的頑固的WEB服務(wù)器中的一個(gè)很常見的“頑固”!再有如通過HTTP來上傳文件呢?不需要頭疼,這些問題有了“它”就很容易解決了!

    我們不可能列舉所有可能的頑固,我們會(huì)針對(duì)幾種最常見的問題進(jìn)行處理。當(dāng)然了,正如前面說到的,如果我們自己使用java.net.HttpURLConnection來搞定這些問題是很恐怖的事情,因此在開始之前我們先要介紹一下一個(gè)開放源碼的項(xiàng)目,這個(gè)項(xiàng)目就是Apache開源組織中的httpclient,它隸屬于Jakarta的commons項(xiàng)目,目前的版本是2.0RC2。commons下本來已經(jīng)有一個(gè)net的子項(xiàng)目,但是又把httpclient單獨(dú)提出來,可見http服務(wù)器的訪問絕非易事。

    Commons-httpclient項(xiàng)目就是專門設(shè)計(jì)來簡化HTTP客戶端與服務(wù)器進(jìn)行各種通訊編程。通過它可以讓原來很頭疼的事情現(xiàn)在輕松的解決,例如你不再管是HTTP或者HTTPS的通訊方式,告訴它你想使用HTTPS方式,剩下的事情交給httpclient替你完成。本文會(huì)針對(duì)我們?cè)诰帉慔TTP客戶端程序時(shí)經(jīng)常碰到的幾個(gè)問題進(jìn)行分別介紹如何使用httpclient來解決它們,為了讓讀者更快的熟悉這個(gè)項(xiàng)目我們最開始先給出一個(gè)簡單的例子來讀取一個(gè)網(wǎng)頁的內(nèi)容,然后循序漸進(jìn)解決掉前進(jìn)中的所形侍狻?/font>

    1. 讀取網(wǎng)頁(HTTP/HTTPS)內(nèi)容

    下面是我們給出的一個(gè)簡單的例子用來訪問某個(gè)頁面

    /*

     * Created on 2003-12-14 by Liudong

     */

    package http.demo;

     

    import java.io.IOException;

     

    import org.apache.commons.httpclient.*;

    import org.apache.commons.httpclient.methods.*;

    /**

     * 最簡單的HTTP客戶端,用來演示通過GET或者POST方式訪問某個(gè)頁面

     * @author Liudong

     */

    public class SimpleClient {

     

        public static void main(String[] args) throws IOException

        {

            HttpClient client = new HttpClient();   

            //設(shè)置代理服務(wù)器地址和端口    

            //client.getHostConfiguration().setProxy("proxy_host_addr",proxy_port);

            //使用GET方法,如果服務(wù)器需要通過HTTPS連接,那只需要將下面URL中的http換成https

            HttpMethod method = new GetMethod("http://java.sun.com");

            //使用POST方法

            //HttpMethod method = new PostMethod("http://java.sun.com");

            client.executeMethod(method);

            //打印服務(wù)器返回的狀態(tài)

            System.out.println(method.getStatusLine());

            //打印返回的信息

            System.out.println(method.getResponseBodyAsString());

            //釋放連接

            method.releaseConnection();

        }
    }

     

    在這個(gè)例子中首先創(chuàng)建一個(gè)HTTP客戶端(HttpClient)的實(shí)例,然后選擇提交的方法是GET或者POST,最后在HttpClient實(shí)例上執(zhí)行提交的方法,最后從所選擇的提交方法中讀取服務(wù)器反饋回來的結(jié)果。這就是使用HttpClient的基本流程。其實(shí)用一行代碼也就可以搞定整個(gè)請(qǐng)求的過程,非常的簡單!


    2. 以GET或者POST方式向網(wǎng)頁提交參數(shù)

    其實(shí)前面一個(gè)最簡單的示例中我們已經(jīng)介紹了如何使用GET或者POST方式來請(qǐng)求一個(gè)頁面,本小節(jié)與之不同的是多了提交時(shí)設(shè)定頁面所需的參數(shù),我們知道如果是GET的請(qǐng)求方式,那么所有參數(shù)都直接放到頁面的URL后面用問號(hào)與頁面地址隔開,每個(gè)參數(shù)用&隔開,例如:http://java.sun.com?name=liudong&mobile=123456,但是當(dāng)使用POST方法時(shí)就會(huì)稍微有一點(diǎn)點(diǎn)麻煩。本小節(jié)的例子演示向如何查詢手機(jī)號(hào)碼所在的城市,代碼如下:

     

    /*

     * Created on 2003-12-7 by Liudong

     */

    package http.demo;

     

    import java.io.IOException;

     

    import org.apache.commons.httpclient.*;

    import org.apache.commons.httpclient.methods.*;

    /**

     * 提交參數(shù)演示

     * 該程序連接到一個(gè)用于查詢手機(jī)號(hào)碼所屬地的頁面

     * 以便查詢號(hào)碼段1330227所在的省份以及城市

     * @author Liudong

     */

    public class SimpleHttpClient {

     

        public static void main(String[] args) throws IOException

        {

            HttpClient client = new HttpClient();

            client.getHostConfiguration().setHost("www.imobile.com.cn", 80, "http");

     

            HttpMethod method = getPostMethod();//使用POST方式提交數(shù)據(jù)

            client.executeMethod(method);

           //打印服務(wù)器返回的狀態(tài)

            System.out.println(method.getStatusLine());

            //打印結(jié)果頁面

            String response =

               new String(method.getResponseBodyAsString().getBytes("8859_1"));

           //打印返回的信息

            System.out.println(response);

            method.releaseConnection();

        }

        /**

         * 使用GET方式提交數(shù)據(jù)

         * @return

         */

        private static HttpMethod getGetMethod(){

            return new GetMethod("/simcard.php?simcard=1330227");

        }

        /**

         * 使用POST方式提交數(shù)據(jù)

         * @return

         */

        private static HttpMethod getPostMethod(){

            PostMethod post = new PostMethod("/simcard.php");

            NameValuePair simcard = new NameValuePair("simcard","1330227");

            post.setRequestBody(new NameValuePair[] { simcard});

            return post;

        }

    }

    在上面的例子中頁面http://www.imobile.com.cn/simcard.php需要一個(gè)參數(shù)是simcard,這個(gè)參數(shù)值為手機(jī)號(hào)碼段,即手機(jī)號(hào)碼的前七位,服務(wù)器會(huì)返回提交的手機(jī)號(hào)碼對(duì)應(yīng)的省份、城市以及其他詳細(xì)信息。GET的提交方法只需要在URL后加入?yún)?shù)信息,而POST則需要通過NameValuePair類來設(shè)置參數(shù)名稱和它所對(duì)應(yīng)的值

    3. 處理頁面重定向

    在JSP/Servlet編程中response.sendRedirect方法就是使用HTTP協(xié)議中的重定向機(jī)制。它與JSP中的<jsp:forward …>的區(qū)別在于后者是在服務(wù)器中實(shí)現(xiàn)頁面的跳轉(zhuǎn),也就是說應(yīng)用容器加載了所要跳轉(zhuǎn)的頁面的內(nèi)容并返回給客戶端;而前者是返回一個(gè)狀態(tài)碼,這些狀態(tài)碼的可能值見下表,然后客戶端讀取需要跳轉(zhuǎn)到的頁面的URL并重新加載新的頁面。就是這樣一個(gè)過程,所以我們編程的時(shí)候就要通過HttpMethod.getStatusCode()方法判斷返回值是否為下表中的某個(gè)值來判斷是否需要跳轉(zhuǎn)。如果已經(jīng)確認(rèn)需要進(jìn)行頁面跳轉(zhuǎn)了,那么可以通過讀取HTTP頭中的location屬性來獲取新的地址。

    狀態(tài)碼
     對(duì)應(yīng)HttpServletResponse的常量
     詳細(xì)描述
     
    301
     SC_MOVED_PERMANENTLY
     頁面已經(jīng)永久移到另外一個(gè)新地址
     
    302
     SC_MOVED_TEMPORARILY
     頁面暫時(shí)移動(dòng)到另外一個(gè)新的地址
     
    303
     SC_SEE_OTHER
     客戶端請(qǐng)求的地址必須通過另外的URL來訪問
     
    307
     SC_TEMPORARY_REDIRECT
     同SC_MOVED_TEMPORARILY
     


    下面的代碼片段演示如何處理頁面的重定向

    client.executeMethod(post);

            System.out.println(post.getStatusLine().toString());

            post.releaseConnection();

           

            //檢查是否重定向

            int statuscode = post.getStatusCode();

            if ((statuscode == HttpStatus.SC_MOVED_TEMPORARILY) ||

                (statuscode == HttpStatus.SC_MOVED_PERMANENTLY) ||

                (statuscode == HttpStatus.SC_SEE_OTHER) ||

    (statuscode == HttpStatus.SC_TEMPORARY_REDIRECT)) {

    //讀取新的URL地址

                Header header = post.getResponseHeader("location");

                if (header != null) {

                    String newuri = header.getValue();

                    if ((newuri == null) || (newuri.equals("")))

                        newuri = "/";

                    GetMethod redirect = new GetMethod(newuri);

                    client.executeMethod(redirect);

                    System.out.println("Redirect:"+ redirect.getStatusLine().toString());

                    redirect.releaseConnection();

                } else

                    System.out.println("Invalid redirect");

            }

    我們可以自行編寫兩個(gè)JSP頁面,其中一個(gè)頁面用response.sendRedirect方法重定向到另外一個(gè)頁面用來測試上面的例子。

    4. 模擬輸入用戶名和口令進(jìn)行登錄

    本小節(jié)應(yīng)該說是HTTP客戶端編程中最常碰見的問題,很多網(wǎng)站的內(nèi)容都只是對(duì)注冊(cè)用戶可見的,這種情況下就必須要求使用正確的用戶名和口令登錄成功后,方可瀏覽到想要的頁面。因?yàn)镠TTP協(xié)議是無狀態(tài)的,也就是連接的有效期只限于當(dāng)前請(qǐng)求,請(qǐng)求內(nèi)容結(jié)束后連接就關(guān)閉了。在這種情況下為了保存用戶的登錄信息必須使用到Cookie機(jī)制。以JSP/Servlet為例,當(dāng)瀏覽器請(qǐng)求一個(gè)JSP或者是Servlet的頁面時(shí),應(yīng)用服務(wù)器會(huì)返回一個(gè)參數(shù),名為jsessionid(因不同應(yīng)用服務(wù)器而異),值是一個(gè)較長的唯一字符串的Cookie,這個(gè)字符串值也就是當(dāng)前訪問該站點(diǎn)的會(huì)話標(biāo)識(shí)。瀏覽器在每訪問該站點(diǎn)的其他頁面時(shí)候都要帶上jsessionid這樣的Cookie信息,應(yīng)用服務(wù)器根據(jù)讀取這個(gè)會(huì)話標(biāo)識(shí)來獲取對(duì)應(yīng)的會(huì)話信息。

    對(duì)于需要用戶登錄的網(wǎng)站,一般在用戶登錄成功后會(huì)將用戶資料保存在服務(wù)器的會(huì)話中,這樣當(dāng)訪問到其他的頁面時(shí)候,應(yīng)用服務(wù)器根據(jù)瀏覽器送上的Cookie中讀取當(dāng)前請(qǐng)求對(duì)應(yīng)的會(huì)話標(biāo)識(shí)以獲得對(duì)應(yīng)的會(huì)話信息,然后就可以判斷用戶資料是否存在于會(huì)話信息中,如果存在則允許訪問頁面,否則跳轉(zhuǎn)到登錄頁面中要求用戶輸入帳號(hào)和口令進(jìn)行登錄。這就是一般使用JSP開發(fā)網(wǎng)站在處理用戶登錄的比較通用的方法。

    這樣一來,對(duì)于HTTP的客戶端來講,如果要訪問一個(gè)受保護(hù)的頁面時(shí)就必須模擬瀏覽器所做的工作,首先就是請(qǐng)求登錄頁面,然后讀取Cookie值;再次請(qǐng)求登錄頁面并加入登錄頁所需的每個(gè)參數(shù);最后就是請(qǐng)求最終所需的頁面。當(dāng)然在除第一次請(qǐng)求外其他的請(qǐng)求都需要附帶上Cookie信息以便服務(wù)器能判斷當(dāng)前請(qǐng)求是否已經(jīng)通過驗(yàn)證。說了這么多,可是如果你使用httpclient的話,你甚至連一行代碼都無需增加,你只需要先傳遞登錄信息執(zhí)行登錄過程,然后直接訪問想要的頁面,跟訪問一個(gè)普通的頁面沒有任何區(qū)別,因?yàn)轭怘ttpClient已經(jīng)幫你做了所有該做的事情了,太棒了!下面的例子實(shí)現(xiàn)了這樣一個(gè)訪問的過程。


    /*

     * Created on 2003-12-7 by Liudong

     */

    package http.demo;

     

    import org.apache.commons.httpclient.*;

    import org.apache.commons.httpclient.cookie.*;

    import org.apache.commons.httpclient.methods.*;

     

    /**

     * 用來演示登錄表單的示例

     * @author Liudong

     */

    public class FormLoginDemo {

     

        static final String LOGON_SITE = "localhost";

        static final int    LOGON_PORT = 8080;

       

        public static void main(String[] args) throws Exception{

            HttpClient client = new HttpClient();

            client.getHostConfiguration().setHost(LOGON_SITE, LOGON_PORT);

          

           //模擬登錄頁面login.jsp->main.jsp

            PostMethod post = new PostMethod("/main.jsp");

            NameValuePair name = new NameValuePair("name", "ld");    

            NameValuePair pass = new NameValuePair("password", "ld");    

            post.setRequestBody(new NameValuePair[]{name,pass});

           int status = client.executeMethod(post);

            System.out.println(post.getResponseBodyAsString());

            post.releaseConnection(); 

          

           //查看cookie信息

            CookieSpec cookiespec = CookiePolicy.getDefaultSpec();

            Cookie[] cookies = cookiespec.match(LOGON_SITE, LOGON_PORT, "/", false, client.getState().getCookies());

           if (cookies.length == 0) {

               System.out.println("None");   

           } else {

               for (int i = 0; i < cookies.length; i++) {

                   System.out.println(cookies[i].toString());   

               }

           }

           //訪問所需的頁面main2.jsp

            GetMethod get = new GetMethod("/main2.jsp");

            client.executeMethod(get);

            System.out.println(get.getResponseBodyAsString());

            get.releaseConnection();

        }

    }

    5. 提交XML格式參數(shù)

    提交XML格式的參數(shù)很簡單,僅僅是一個(gè)提交時(shí)候的ContentType問題,下面的例子演示從文件文件中讀取XML信息并提交給服務(wù)器的過程,該過程可以用來測試Web服務(wù)。

    import java.io.File;

    import java.io.FileInputStream;

     

    import org.apache.commons.httpclient.HttpClient;

    import org.apache.commons.httpclient.methods.EntityEnclosingMethod;

    import org.apache.commons.httpclient.methods.PostMethod;

     

    /**

     * 用來演示提交XML格式數(shù)據(jù)的例子

     */

    public class PostXMLClient {

     

        public static void main(String[] args) throws Exception {

            File input = new File(“test.xml”);

            PostMethod post = new PostMethod(“http://localhost:8080/httpclient/xml.jsp”);

            // 設(shè)置請(qǐng)求的內(nèi)容直接從文件中讀取

            post.setRequestBody(new FileInputStream(input));

           

            if (input.length() < Integer.MAX_VALUE)

                post.setRequestContentLength(input.length());

            else            post.setRequestContentLength(EntityEnclosingMethod.CONTENT_LENGTH_CHUNKED);

           

            // 指定請(qǐng)求內(nèi)容的類型

            post.setRequestHeader("Content-type", "text/xml; charset=GBK");

           

            HttpClient httpclient = new HttpClient();

            int result = httpclient.executeMethod(post);

            System.out.println("Response status code: " + result);

            System.out.println("Response body: ");

            System.out.println(post.getResponseBodyAsString());

            post.releaseConnection();

        }

    }

    6. 通過HTTP上傳文件

    httpclient使用了單獨(dú)的一個(gè)HttpMethod子類來處理文件的上傳,這個(gè)類就是MultipartPostMethod,該類已經(jīng)封裝了文件上傳的細(xì)節(jié),我們要做的僅僅是告訴它我們要上傳文件的全路徑即可,下面的代碼片段演示如何使用這個(gè)類。

    MultipartPostMethod filePost = new MultipartPostMethod(targetURL);

    filePost.addParameter("fileName", targetFilePath);

    HttpClient client = new HttpClient();

    //由于要上傳的文件可能比較大,因此在此設(shè)置最大的連接超時(shí)時(shí)間

    client.getHttpConnectionManager().getParams().setConnectionTimeout(5000);

    int status = client.executeMethod(filePost);


    上面代碼中,targetFilePath即為要上傳的文件所在的路徑。

    7. 訪問啟用認(rèn)證的頁面

    我們經(jīng)常會(huì)碰到這樣的頁面,當(dāng)訪問它的時(shí)候會(huì)彈出一個(gè)瀏覽器的對(duì)話框要求輸入用戶名和密碼后方可,這種用戶認(rèn)證的方式不同于我們?cè)谇懊娼榻B的基于表單的用戶身份驗(yàn)證。這是HTTP的認(rèn)證策略,httpclient支持三種認(rèn)證方式包括:基本、摘要以及NTLM認(rèn)證。其中基本認(rèn)證最簡單、通用但也最不安全;摘要認(rèn)證是在HTTP 1.1中加入的認(rèn)證方式,而NTLM則是微軟公司定義的而不是通用的規(guī)范,最新版本的NTLM是比摘要認(rèn)證還要安全的一種方式。

    下面例子是從httpclient的CVS服務(wù)器中下載的,它簡單演示如何訪問一個(gè)認(rèn)證保護(hù)的頁面:


    import org.apache.commons.httpclient.HttpClient;

    import org.apache.commons.httpclient.UsernamePasswordCredentials;

    import org.apache.commons.httpclient.methods.GetMethod;

     

    public class BasicAuthenticationExample {

        public BasicAuthenticationExample() {

        }

        public static void main(String[] args) throws Exception {

            HttpClient client = new HttpClient();

            client.getState().setCredentials(

                "www.verisign.com",

                "realm",

                new UsernamePasswordCredentials("username", "password")

            );

            GetMethod get = new GetMethod("https://www.verisign.com/products/index.html");

            get.setDoAuthentication( true );

            int status = client.executeMethod( get );

            System.out.println(status+""+ get.getResponseBodyAsString());

            get.releaseConnection();

        }

    }

    8. 多線程模式下使用httpclient

    多線程同時(shí)訪問httpclient,例如同時(shí)從一個(gè)站點(diǎn)上下載多個(gè)文件。對(duì)于同一個(gè)HttpConnection同一個(gè)時(shí)間只能有一個(gè)線程訪問,為了保證多線程工作環(huán)境下不產(chǎn)生沖突,httpclient使用了一個(gè)多線程連接管理器的類:MultiThreadedHttpConnectionManager,要使用這個(gè)類很簡單,只需要在構(gòu)造HttpClient實(shí)例的時(shí)候傳入即可,代碼如下:

    MultiThreadedHttpConnectionManager connectionManager =

       new MultiThreadedHttpConnectionManager();

    HttpClient client = new HttpClient(connectionManager);

    以后盡管訪問client實(shí)例即可。

    posted @ 2011-04-22 12:38 飛飛 閱讀(522) | 評(píng)論 (0)編輯 收藏


    import org.apache.commons.httpclient.methods.PostMethod;


    public class UTF8PostMethod extends PostMethod
    {
       
        public static final String ENCODE_UTF8 = "UTF-8";
       
        /**
         * 默認(rèn)構(gòu)造函數(shù)
         * @param url    地址
         */
        public UTF8PostMethod(String url)
        {
            super(url);
        }

        /* (non-Javadoc)
         * @see org.apache.commons.httpclient.methods.EntityEnclosingMethod#getRequestCharSet()
         */
        @Override
        public String getRequestCharSet()
        {
            return ENCODE_UTF8;
        }

        /* (non-Javadoc)
         * @see org.apache.commons.httpclient.HttpMethodBase#getResponseCharSet()
         */
        @Override
        public String getResponseCharSet()
        {
            return ENCODE_UTF8;
        }
    }


    package com.org.softwore;

    import org.apache.commons.httpclient.methods.GetMethod;

    public class UTF8GetMethod extends GetMethod {
     public static final String ENCODE_UTF8 = "UTF-8";

     /**
      * 默認(rèn)構(gòu)造函數(shù)
      *
      * @param url
      *            地址
      */
     public UTF8GetMethod(String url) {
      super(url);
     }

     /*
      * (non-Javadoc)
      *
      * @see
      * org.apache.commons.httpclient.methods.EntityEnclosingMethod#getRequestCharSet
      * ()
      */
     @Override
     public String getRequestCharSet() {
      return ENCODE_UTF8;
     }

     /*
      * (non-Javadoc)
      *
      * @see org.apache.commons.httpclient.HttpMethodBase#getResponseCharSet()
      */
     @Override
     public String getResponseCharSet() {
      return ENCODE_UTF8;
     }
    }




    測試使用!

    HttpMethod method = null;
            try {
                HttpClient client = new HttpClient();
                method = new UTF8PostMethod(
                        "http://.........");
                client.executeMethod(method);
                if (method.getStatusCode() == HttpStatus.SC_OK) {
                    String response = method.getResponseBodyAsString();
                    System.out.println(response);
                }

            } catch (HttpException e1) {
                e1.printStackTrace();
            } catch (IOException e1) {
                e1.printStackTrace();
            } finally {
                if (method != null) {
                    method.releaseConnection();
                }
            }

    posted @ 2011-04-22 11:00 飛飛 閱讀(1064) | 評(píng)論 (0)編輯 收藏

     

    鼎鼎大名的Spring框架3.0版在12月5日由其作者之一——Juergen Hoeller先生在博客里宣告問世,并命為里程碑版,給Spring粉絲們帶來了震撼的快感。筆者即開“快車”拉了兩個(gè)包回來,遺憾的是參考文檔至今還沒有出來(僅有API文檔),這為學(xué)習(xí)Spring 3.0帶來了非常大的困難,但沒有阻擋筆者對(duì)新產(chǎn)品的興趣。

        Spring之父Rod Johnson先生早在2003年就預(yù)言EJB將死(觀點(diǎn)頗具爭議),攻擊EJB之臃腫是在虐待程序員。然而EJB 3.0出來后幾乎宣判Spring死刑,但自2.0版以后Spring火爆程度已經(jīng)超過EJB,兩者的爭斗至今仍不停息,這也是Spring 3.0連文檔還沒有整理出來就匆匆推出的原因。當(dāng)然,Spring與EJB有很多各自獨(dú)特優(yōu)勢之處,例如EJB的分布式運(yùn)算、標(biāo)準(zhǔn)規(guī)范,Spring的IoC、AOP切面編程、偶合集成、MVC等等,取各自之長在企業(yè)中應(yīng)用如虎添翼。Spring目前已經(jīng)加入了J2EE規(guī)范,J2EE世界將更加精彩......

        或許是用膩了Struts1那死板的WEB框架,才對(duì)Spring MVC愛不釋手,尤其是2.5版本以后,支持全注解配置方式,已經(jīng)使很久沒有再寫過xml文件了。

        3.0版是完全兼容2.5,因此了解2.5版的@MVC則更容易接受。正如Arjen Poutsma小伙子在他的博客里說的那樣,3.0時(shí)代將集中致力于表述性狀態(tài)轉(zhuǎn)移(REST,希望我沒有翻譯錯(cuò),金山詞霸翻譯為“休息”)的網(wǎng)絡(luò)服務(wù)和更容易的網(wǎng)絡(luò)編程。的確增加了更多的控制器類型,并增強(qiáng)了SOAP/WSDL/WS這些基于分布式體系結(jié)構(gòu)。

    先回憶下2.5注解方式的@MVC,來一個(gè)示例:

    @Controller
    public class ArticleController{

      @RequestMapping("/articleView")
       public String getArticle(@RequestParam("id") String id, HttpServletRequest request){
        request.setAttribute("article", service.find(Article.class, id));
        return "articleView";
       }

    }

        ArticleController沒有實(shí)現(xiàn)任何接口,是一個(gè)最普通不過的pojo,如果瀏覽器來了articleView.do?id=xxx這個(gè)請(qǐng)求,Spring會(huì)找到getArticle()這個(gè)方法,該方法第一個(gè)參數(shù)綁定到了URL上的請(qǐng)求參數(shù),第二個(gè)是J2EE標(biāo)準(zhǔn)的request對(duì)象(可見Spring MVC是非侵入式的,不像變態(tài)的Struts2),事實(shí)上還可以給定HttpServletResponse,ModelMap,甚至自己的類型,Spring都會(huì)為你將值傳入進(jìn)來。通過一個(gè)邏輯層service組件根據(jù)id參數(shù)值去底層查找Article對(duì)象,并放入request作用域中,最后返回的是面頁視圖名,這個(gè)例子中是返回到articleView.jsp中。

        上例再變通下:

    @Controller
    public class ArticleController{

      @RequestMapping("/articleView_*")
       public String getArticle(HttpServletRequest request){

        String id = StringUtil.getParam(request.getRequestURI(),"articleView_*");
        request.setAttribute("article", service.find(Article.class, id));
        return "articleView";
       }

    }

        對(duì)于articleView_aaa.do,articleView_bbbb.do,articleView_c5h8j2.do,articleView_xxx.do,這樣的請(qǐng)求都會(huì)由getArticle()這個(gè)方法來應(yīng)付,是不是很有意思?

        Spring 3.0增加了一個(gè)@ PathVariable注解來支持可變的請(qǐng)求路徑,將上面的代碼在3.0版中再變通下:

    @Controller
    public class ArticleController{

      @RequestMapping("/articleView/${id}")   //可以接受articleView/aaa.do,articleView/xxx.do...
       public String getArticle(@PathVariable String id, HttpServletRequest request){
        request.setAttribute("article", service.find(Article.class, id));
        return "articleView";
       }

    }

    再變得復(fù)雜些:

    @Controller
    public class ArticleController{

      @RequestMapping("/articleList/${pageSize}/channel/*/category/${id}")   

       public String getArticles((@PathVariable Integer pageSize, @PathVariable int id, HttpServletRequest request){
        Integer channelId = StringUtil.getParam(request.getRequestURI(),"channel/*/");
        request.setAttribute("articles", service.findScroll(Article.class, pageSize,50,"channel=? and category=?",new Object[]{channelId,id}));
        
        return "articleList";
       }

    }

        它已經(jīng)靈活到URL地址完全可以自己隨意編制。

        根據(jù)內(nèi)容協(xié)商制的視圖解析機(jī)制:

        2.5版是由@MVC控制器來決定視圖解析器,3.0版將變得更加靈活,似乎可以通過擴(kuò)展名來轉(zhuǎn)到不同的解析器中,例如請(qǐng)求一個(gè).pdf文件將是如何效果呢?3.0版都會(huì)帶來不可思議的模式。

        HTTP方法的轉(zhuǎn)換:

        先看前臺(tái)頁面一段Html代碼

    <form:form method="delete">  
    <p class="submit"><input type="submit" value="Delete Pet"/></p> 
    </form:form>

        HTTP規(guī)范中form表單只有兩種方法——POST和GET,而3.0做了一個(gè)過濾器,可以轉(zhuǎn)換這些方法至四種——GET, PUT, POST, 和 DELETE。控制器接受請(qǐng)求:

    @Controller("/deleteArticle")
    public class ArticleController{

      de style="line-height: 28px; ">@RequestMappingde>de style="line-height: 28px; ">(method = RequestMethod.DELETE)
    de>   public String deleteArticle(@PathVariable String id, HttpServletRequest request){
        service.delete(Article.class, id);
        return "message";
       }

    }
        3.0版僅在MVC子集中就增加了很多新特性,如果在IoC、AOP等等其它子集所有的變革,絕對(duì)可以稱得上Srping創(chuàng)始人所述的里程碑版本。3.0版使用的注解列表如下:

    ? @Autowired
    ? @Component
    ? @Controller
    ? @InitBinder
    ? @ManagedAttribute
    ? @ManagedOperation
    ? @ManagedOperationParameters
    ? @ManagedOperationParameter
    ? @ManagedResource
    ? @PathVariable
    ? @PostConstruct
    ? @PreDestroy
    ? @Repository
    ? @RequestMapping
    ? @Required
    ? @Resource
    ? @Service
    ? @Transactional
        目前Spring 3版本已經(jīng)到了M2,應(yīng)該是M3完成后將推出最終正式版本,我想很快會(huì)來臨,按照Spring的創(chuàng)始人羅德.約翰遜的預(yù)言,未來J2EE應(yīng)用中Spring+Tomcat將占主導(dǎo)地位,是否引起爭議,筆者不敢點(diǎn)評(píng),不過Oracle收購Sun后,Java社區(qū)將是如何,還無從知曉,似乎羅德.約翰遜對(duì)這宗收購案也有些緊張,因?yàn)镺racle不像Sun的第一個(gè)談判者IBM那樣有過開放技術(shù)的先例(可以回憶下IBM早期的主板總線開放掀起的兼容機(jī)潮至今波濤不熄)。目前國內(nèi)對(duì)新東西消化尚慢,我到圖書城看了下,Spring 2.5的資料都很難找到。且很多企業(yè)都是抱著Struts1.x在做開發(fā),盡管筆者這樣說會(huì)引來很多爭議,但Struts1時(shí)代的滅亡只是時(shí)間問題。Struts2雖然改進(jìn)了很多,依筆者看,與Spring MVC相比仍有諸多的不足,尤其看不慣那種變態(tài)的侵入模式,看看它把HttpServletRequest、HttpSession、HttpServletResponse等servlet標(biāo)準(zhǔn)組件干成什么樣?開源時(shí)代,至少我不愿意接受那種變態(tài)的潛規(guī)則。

        筆者早先常用Struts1.x框架,它搭配了一套自己的ActionForm,使得編程工作量增加,雖然可以變通使用自己的Pojo,但對(duì)于沒有掌握J(rèn)2EE底層工具類(BeanUtil)的開發(fā)人員來說,其類型匹配是非常復(fù)雜的事。事實(shí)上Spring MVC早在1.x版本就完全使用自己的pojo來對(duì)應(yīng)表單的填充,配上屬性編輯器,可以解決類型轉(zhuǎn)換問題,完全實(shí)現(xiàn)領(lǐng)域模型驅(qū)動(dòng)的設(shè)計(jì)模式。由于MVC層的控制器也是Spring容器的Bean而已,因此對(duì)整個(gè)項(xiàng)目的控制、擴(kuò)展變得非常容易。同時(shí)上文也順便點(diǎn)評(píng)了Struts2,可見Spring MVC在各類MVC框架的優(yōu)勢所在。本身羅德.約翰遜先生是設(shè)計(jì)模式高手,一個(gè)優(yōu)秀的框架給我們帶來的遠(yuǎn)遠(yuǎn)不只是開發(fā)效率,還有更先進(jìn)的開發(fā)模式和理念...

        筆者對(duì)Spring框架研究膚淺,待日后了解掌握更多時(shí)會(huì)常在博客中述之。

    posted @ 2011-04-21 11:02 飛飛 閱讀(874) | 評(píng)論 (0)編輯 收藏

    從4個(gè)層面分析這部分實(shí)現(xiàn): 
    1. iBatis的基本實(shí)現(xiàn)
    2. 基于事務(wù)的iBatis的基本實(shí)現(xiàn)
    3. 基于事務(wù)的Spring+iBatis實(shí)現(xiàn)
    4. 基于回調(diào)方式的Spring+iBatis實(shí)現(xiàn)

    1.iBatis的基本實(shí)現(xiàn)

    iBatis通過SqlMapClient提供了一組方法用于批處理實(shí)現(xiàn):
    1. startBatch() 開始批處理
    2. executeBatch() 執(zhí)行批處理

    代碼如下:
    Java代碼 復(fù)制代碼 收藏代碼
    1. public void create(List<Reply> replyList) {   
    2.   
    3.     try {   
    4.         // 開始批處理   
    5.         sqlMapClient.startBatch();   
    6.   
    7.         for (Reply reply: replyList) {   
    8.             // 插入操作   
    9.             sqlMapClient.insert("Reply.create", reply);   
    10.         }   
    11.         // 執(zhí)行批處理   
    12.         sqlMapClient.executeBatch();   
    13.   
    14.     } catch (Exception e) {   
    15.         e.printStackTrace();   
    16.     }   
    17. }  

    這是基于iBatis的最基本實(shí)現(xiàn),如果你一步一步debug,你會(huì)發(fā)現(xiàn):其實(shí),數(shù)據(jù)庫已經(jīng)執(zhí)行了插入操作!
    因此,除了這兩個(gè)核心方法外,你還需要開啟事務(wù)支持。否則,上述代碼只不過是個(gè)空架子!

    2.基于事務(wù)的iBatis的基本實(shí)現(xiàn)
    事務(wù)處理:
    1. startTransaction() 開始事務(wù)
    2. commitTransaction() 提交事務(wù)
    3. endTransaction() 結(jié)束事務(wù)


    我們以insert操作為例,把它們結(jié)合到一起:
    Java代碼 復(fù)制代碼 收藏代碼
    1. public void create(List<Reply> replyList) {   
    2.   
    3.     try {   
    4.         // 開始事務(wù)   
    5.         sqlMapClient.startTransaction();   
    6.         // 開始批處理   
    7.         sqlMapClient.startBatch();   
    8.   
    9.         for (Reply reply: replyList) {   
    10.             // 插入操作   
    11.             sqlMapClient.insert("Reply.create", reply);   
    12.         }   
    13.         // 執(zhí)行批處理   
    14.         sqlMapClient.executeBatch();   
    15.   
    16.         // 提交事務(wù)   
    17.         sqlMapClient.commitTransaction();   
    18.   
    19.     } catch (Exception e) {   
    20.         e.printStackTrace();   
    21.     } finally {     
    22.              try {   
    23.             // 結(jié)束事務(wù)   
    24.             sqlMapClient.endTransaction();   
    25.                 } catch (SQLException e) {   
    26.                          e.printStackTrace();   
    27.                      }   
    28.     }     
    29. }  

    replyList是一個(gè)List,要把這個(gè)List插入到數(shù)據(jù)庫,就需要經(jīng)過這三個(gè)步驟:
    1. 開始批處理 startBatch()
    2. 插入      insert()
    3. 執(zhí)行批處理 executeBatch()

    如果要在Spring+iBatis中進(jìn)行批處理實(shí)現(xiàn),需要注意使用同一個(gè)sqlMapClient!同時(shí),將提交事務(wù)的工作交給Spring統(tǒng)一處理!

    3.基于事務(wù)的Spring+iBatis實(shí)現(xiàn)
    Java代碼 復(fù)制代碼 收藏代碼
    1. public void create(List<Reply> replyList) {   
    2.     if (!CollectionUtils.isEmpty(replyList)) {   
    3.         // 注意使用同一個(gè)SqlMapClient會(huì)話   
    4.         SqlMapClient sqlMapClient = sqlMapClientTemplate.getSqlMapClient();   
    5.   
    6.         try {   
    7.             // 開始事務(wù)   
    8.             sqlMapClient.startTransaction();   
    9.             // 開始批處理   
    10.             sqlMapClient.startBatch();   
    11.             for (Reply reply : replyList) {   
    12.                 // 插入操作   
    13.                 sqlMapClient.insert("Reply.create", reply);   
    14.             }   
    15.   
    16.             // 執(zhí)行批處理   
    17.             sqlMapClient.executeBatch();   
    18.             // 提交事務(wù) 交給Spring統(tǒng)一控制   
    19.             // sqlMapClient.commitTransaction();   
    20.   
    21.         } catch (Exception e) {   
    22.             e.printStackTrace();   
    23.         } finally {     
    24.                  try {   
    25.                 // 結(jié)束事務(wù)   
    26.                 sqlMapClient.endTransaction();   
    27.                     } catch (SQLException e) {   
    28.                              e.printStackTrace();   
    29.                          }   
    30.         }     
    31.     }   
    32. }  

    注意使用同一個(gè)sqlMapClient:
    SqlMapClient sqlMapClient = sqlMapClientTemplate.getSqlMapClient();
    如果直接sqlMapClientTemplate執(zhí)行insert()方法,將會(huì)造成異常!

    想想,還有什么問題?其實(shí)問題很明顯,雖然解決了批處理實(shí)現(xiàn)的問題,卻造成了事務(wù)代碼入侵的新問題。 這么做,有點(diǎn)惡心!
    除此之外,異常的處理也很惡心,不能夠簡單的包裝為 DataAccessException 就無法被Spring當(dāng)作統(tǒng)一的數(shù)據(jù)庫操作異常做處理。


    4.基于回調(diào)方式的Spring+iBatis實(shí)現(xiàn)
    如果觀察過Spring的源代碼,你一定知道,Spring為了保持事務(wù)統(tǒng)一控制,在實(shí)現(xiàn)ORM框架時(shí)通常都采用了回調(diào)模式,從而避免了事務(wù)代碼入侵的可能!
    修改后的代碼如下:
    Java代碼 復(fù)制代碼 收藏代碼
    1. @SuppressWarnings("unchecked")   
    2. public void create(final List<Reply> replyList) {   
    3.     // 執(zhí)行回調(diào)   
    4.     sqlMapClientTemplate.execute(new SqlMapClientCallback() {   
    5.         // 實(shí)現(xiàn)回調(diào)接口   
    6.         public Object doInSqlMapClient(SqlMapExecutor executor)   
    7.                 throws SQLException {   
    8.             // 開始批處理   
    9.             executor.startBatch();   
    10.             for (Reply reply : replyList) {   
    11.                 // 插入操作   
    12.                 executor.insert("Reply.create", reply);   
    13.   
    14.             }   
    15.             // 執(zhí)行批處理   
    16.             executor.executeBatch();   
    17.   
    18.             return null;   
    19.   
    20.         }   
    21.     });   
    22.   
    23. }  

    注意,待遍歷的參數(shù)replyList需要加入final標(biāo)識(shí)!即,待遍歷對(duì)象不能修改!
    引用
    public void create(final List<Reply> replyList)

    這樣做,就將事務(wù)處理的控制權(quán)完全交給了Spring!
    簡述:
    1. SqlMapClientCallback 回調(diào)接口
    2. doInSqlMapClient(SqlMapExecutor executor) 回調(diào)實(shí)現(xiàn)方法
    3. DataAccessException 最終可能拋出的異常
    posted @ 2011-04-21 10:15 飛飛 閱讀(956) | 評(píng)論 (0)編輯 收藏

    主站蜘蛛池模板: 青青草免费在线视频| 国产精品成人啪精品视频免费| 亚洲最大成人网色| 亚洲A∨无码一区二区三区| 亚洲精品国产美女久久久| 国产亚洲美女精品久久久2020| 久久久精品国产亚洲成人满18免费网站| 免费看国产一级片| 亚洲欧洲久久久精品| 伊人婷婷综合缴情亚洲五月| 在线亚洲97se亚洲综合在线| 亚洲精品V欧洲精品V日韩精品| 亚洲成a人片77777kkkk| 亚洲AV日韩AV高潮无码专区| 亚洲综合在线观看视频| 亚洲最大的黄色网| 亚洲日韩国产欧美一区二区三区| 久久精品国产亚洲AV未满十八 | 啦啦啦手机完整免费高清观看| 成人黄动漫画免费网站视频 | 99久久精品毛片免费播放| 99久久99这里只有免费的精品 | 美女羞羞视频免费网站| 国产精品福利片免费看| 少妇无码一区二区三区免费| 免费国产作爱视频网站| 日韩人妻无码免费视频一区二区三区| 免费国产成人高清视频网站| 91麻豆国产自产在线观看亚洲 | 免费人妻av无码专区| 亚洲熟妇av一区二区三区| 91亚洲国产成人精品下载| 亚洲最大的黄色网| 一级毛片免费毛片毛片| 免费视频成人片在线观看| 性做久久久久久久免费看| 全部免费毛片在线| 亚洲精品乱码久久久久久| 亚洲欧洲日韩国产| 美女羞羞视频免费网站| 久久国产乱子免费精品|