baggio785的专栏

[原]SOUNDEX函数介绍-007

baggio785 — Sat, 12 May 2007 11:08:00 +0800

在ORACLE中，SOUNDEX 函数返回字符串参数的语音表示形式，对于比较一些读音相同，但是拼写不同的单词非常有用。

SOUNDEX函数的语法为：SOUNDEX(string)

计算语音的算法如下：

1 保留字符串首字母，但删除a、e、h、i、o、w、y。

2 将下表中的数字赋给相对应的字母

1） 1：b、f、p、v

2） 2：c、g、k、q、s、x、z

3） 3：d、t

4） 4：l

5） 5：m、n

6） 6：r

3 如果字符串中存在拥有相同数字的2个以上（包含2个）的字母在一起（例如b和f），或者只有h或w，则删除其他的，只保留1个

4 只返回前4个字节，不够用0填充

例子：

soundex('two'),soundex('too'),soundex('to')，他们的结果都是T000

soundex('cap'),soundex('cup')，他们的结果都是C100

soundex('house'),soundex('horse')，他们的结果都分别是H200，H620

作者：baggio785 发表于2007-5-12 11:08:00 原文链接

阅读：7740 评论：1 查看评论

[原]TIMESTAMP数据类型-007

baggio785 — Sun, 06 May 2007 23:51:00 +0800

以下代码的运行环境：oracle9.2,pl/sql developer

一、TIMESTAMP

TIMESTAMP数据类型，是DATE的扩展，可以存储年、月、日、小时、分钟、秒，同时还可以存储秒的小数部分。

语法为：TIMESTAMP [(fractional_seconds_precision)]

fractional_seconds_precision为可选项，指定秒的小数部分的精度，取值范围为0-9，默认值为6。

示例代码：

declare
v_inteval timestamp(7);
begin
v_inteval := TIMESTAMP'2007-05-05 23:34:45.1234567';
dbms_output.put_line(v_inteval);
end;

结果为：05-5月 -07 11.34.45.1234567 下午。

说明：如果精度为5,则结果为05-5月 -07 11.34.45.12346 下午；如果精度为8，则结果为05-5月 -07 11.34.45.12345670 下午。

二、TIMESTAMP WITH TIME ZONE

TIMESTAMP WITH TIME ZONE数据类型是可以指定时区的TIMESTAMP。时区的偏移是指本地时间和格林尼治（UTC）时间之间的差异（小时和分钟）。

语法为：TIMESTAMP [(fractional_seconds_precision)] WITH TIME ZONE

fractional_seconds_precision为可选项，指定秒的小数部分的精度，取值范围为0-9，默认值为6。

如果2个TIMESTAMP WITH TIME ZONE，相对于UTC代表相同的时间，则认为这2个TIMESTAMP WITH TIME ZONE是相等的，而不管这2个TIMESTAMP WITH TIME ZONE所代表的具体时间，例如：TIMESTAMP '1999-04-15 8:00:00 -8:00'和TIMESTAMP '1999-04-15 11:00:00 -5:00'是相等的，虽然他们分别表示当地的8点和11点，其中-8:00以及-5:00，表示相对UTC的偏移量。

在上例中，也可以将偏移量替换成时区地区（TRZ，time zone region），例如，上例中的TIMESTAMP '1999-04-15 8:00:00 -8:00'，与TIMESTAMP '1999-04-15 8:00:00 US/Pacific'是相等的。

为了削除因为夏令时引起的时间歧义，同时使用TRZ，以及和TRZ相对应的TRD来确保返回正确的时间，例如：TIMESTAMP '1999-10-29 01:30:00 US/Pacific PDT'。如果没有使用TZD元素，并且ORACLE的ERROR_ON_OVERLAP_TIME session参数设置为TRUE，则ORACLE会返回错误。如果ERROR_ON_OVERLAP_TIME session参数设置为FALSE，则ORACLE认为该TIMESTAMP WITH TIME ZONE为标准时间。

代码一：

declare
v_inteval timestamp(7) with time zone;
begin
v_inteval := TIMESTAMP'2007-05-05 23:34:45.1234567';
dbms_output.put_line(v_inteval);
end;

结果为：05-5月 -07 11.34.45.123456700 下午 +08:00。

说明：该结果与（一）中的代码结果相比，多了一个时区偏移量+08:00，说明该时间为北京时间。

代码二：

declare
v_inteval_1 timestamp(3) with time zone;
v_inteval_2 timestamp(3) with time zone;
begin
v_inteval_1 := TIMESTAMP'1999-04-15 8:00:00 -8:00';
v_inteval_2 := TIMESTAMP'1999-04-15 11:00:00 -5:00';
if(v_inteval_1=v_inteval_2) then
dbms_output.put_line('v_inteval_1=v_inteval_2');
else
dbms_output.put_line('v_inteval_1!=v_inteval_2');
end if;
end;

结果为：v_inteval_1=v_inteval_2。

三、TIMESTAMP WITH LOCAL TIME ZONE

TIMESTAMP WITH LOCAL TIME ZONE数据类型也是可以指定时区的TIMESTAMP，和TIMESTAMP WITH TIME ZONE不同的是，他存储的是数据库的时区，时区偏移量并不存储。当用户提交数据，ORACLE返回的是用户的本地所在的时区。时区的偏移是指本地时间和格林尼治（UTC）时间之间的差异（小时和分钟）。TIMESTAMP WITH LOCAL TIME ZONE主要用于CS二层系统应用。

语法：TIMESTAMP [(fractional_seconds_precision)] WITH LOCAL TIME ZONE

作者：baggio785 发表于2007-5-6 23:51:00 原文链接

阅读：8153 评论：0 查看评论

[原]INTERVAL数据类型-007

baggio785 — Sun, 06 May 2007 00:23:00 +0800

INTERVAL数据类型用来存储两个时间戳之间的时间间隔。可以指定years and months，或者days,hours,minuts,seconds之间的间隔。

oracle支持两种INTEVAL类型，它们分别是YEAR TO MONTH和DAY TO SECOND。每个类型都包含leading field和trailing field。主参数定义要被计算的date或者time，副参数定义最小增长量。

下面根据实例来介绍YEAR TO MONTH和DAY TO SECOND。

一、INTERVAL YEAR TO MONTH

声明INTERVAL YEAR TO MONTH的语法是：

其中：

1 'INTEGER[-INTEGER],为leading field以及可选的trailing field指定具体的数值。同时month即trailing field的取值范围是0到11。

2 percision，即精度，是对leading field的数值的最大长度的限制。取值范围为0-9，默认值是2。

代码一：

declare
v_inteval INTERVAL YEAR(3) TO MONTH;
begin
v_inteval := INTERVAL '123-2' YEAR TO MONTH;
dbms_output.put_line(v_inteval);
end;

结果为：+123-02。

说明：表示123年2个月。在这个例子中，必须指定YEAR，即leading field的精度(percision),因为默认值为2，如果将声明部分修改为 v_inteval INTERVAL YEAR TO MONTH;会提示精度太小错误。另外，需要注意的是，声明部分需要标注精度，但是赋值部分，即v_inteval := INTERVAL '123-2' YEAR TO MONTH;不需要标注精度，如果标注，会提示语法错误。在本例中，如果精度修改为4，则结果为+0123-02。

代码二：

select INTEVAL '1234' YEAR(4) from dual;

结果为：+1234-00。

说明：表示1234年0个月。因为INTEVAL类型之一，INTERVAL YEAR TO MONTH，声明时YEAR(leading field)和MONTH(trailing field)必须同时存在，否则会提示错误信息。所以，如果我们单独引用YEAR或者MONTH时，代码二的例子无法编译通过，只能通过sql语句。

类似的例子还有：

select INTERVAL '345' MONTH(3) from dual;

结果为：+28-09。

二、INTERVAL DAY TO SECOND

声明INTERVAL DAY TO SECOND的语法是：

其中：

1 INTEGER指定days的数值，数值不能超过leading_percision。

2 time_expr指定格式为HH[:MI[:SS[.n]]]or MI[:SS[.n]] or SS[.n]的时间，n是second的小数部分，n的长度不能大于fractional_seconds_precision，并受限于fractional_seconds_precision的位数。如果leading field为day，则可以选择integer time_expr的模式。

3 leading_precision为leading_field的精度，取值范围为0-9，默认值为2。

4 fractional_seconds_precision为秒的精度取值范围1-9，默认值为6。

5 HOUR的取值范围为0-23，MINUTE的取值范围为0-59，MINUTE的取值范围为0-59.999999999。

代码一：

declare
v_inteval INTERVAL DAY(7) TO SECOND(5);
begin
v_inteval := INTERVAL '4 5:12:10.222' DAY TO SECOND;
dbms_output.put_line(v_inteval);
end;

结果为：++0000004 05:12:10.22200。

说明：表示4天5小时12分10.222秒。在这个例子中，DAY以及SECOND的精度都是可选的，类似INTERVAL YEAR TO MONTH，声明部分需要标注精度，但是赋值部分，不需要标注精度，如果标注，会提示语法错误。

代码二：

select INTERVAL '4 5:12' DAY TO MINUTE from dual;

结果为：+04 05:12:00。

说明：表示4天5小时12分0秒。因为INTEVAL类型之一，INTERVAL DAY TO SECOND，声明时DAY和SECOND必须同时存在，否则会提示错误信息。所以，如果我们单独引用YEAR或者MONTH时，代码二的例子无法编译通过，只能通过sql语句。

类似的例子还有：

select INTERVAL '400 5' DAY(3) TO HOUR from dual;
select INTERVAL '400' DAY(3) from dual;
select INTERVAL '11:12:10.2222222' HOUR TO SECOND(7) from dual;
select INTERVAL '11:20' HOUR TO MINUTE from dual;
select INTERVAL '10' HOUR from dual;
select INTERVAL '10:22' MINUTE TO SECOND from dual;
select INTERVAL '10' MINUTE from dual;
select INTERVAL '120' HOUR(3) from dual;
select INTERVAL '30.12345' SECOND(2,4) from dual;(注意，该结果为+00 00:00:30.1235，如果精度为1,3,则结果为+0 00:00:30.123，如果精度为3,7，则结果为+000 00:00:30.1234500)

作者：baggio785 发表于2007-5-6 0:23:00 原文链接

阅读：7943 评论：0 查看评论

[转]用 Lucene 加速 Web 搜索应用程序的开发

baggio785 — Tue, 12 Sep 2006 23:43:00 +0800

周登朋 (zhoudengpeng@yahoo.com.cn), 软件工程师, 上海交通大学

2006 年 9 月 06 日

在本篇文章中，你会学习到如何利用 Lucene 实现高级搜索功能以及如何利用 Lucene 来创建 Web 搜索应用程序。通过这些学习，你就可以利用 Lucene 来创建自己的搜索应用程序。

架构概览

通常一个 Web 搜索引擎的架构分为前端和后端两部分，就像图一中所示。在前端流程中，用户在搜索引擎提供的界面中输入要搜索的关键词，这里提到的用户界面一般是一个带有输入框的 Web 页面，然后应用程序将搜索的关键词解析成搜索引擎可以理解的形式，并在索引文件上进行搜索操作。在排序后，搜索引擎返回搜索结果给用户。在后端流程中，网络爬虫或者机器人从因特网上获取 Web 页面，然后索引子系统解析这些 Web 页面并存入索引文件中。如果你想利用 Lucene 来创建一个 Web 搜索应用程序，那么它的架构也和上面所描述的类似，就如图一中所示。

Figure 1. Web 搜索引擎架构

利用 Lucene 实现高级搜索

Lucene 支持多种形式的高级搜索，我们在这一部分中会进行探讨，然后我会使用 Lucene 的 API 来演示如何实现这些高级搜索功能。

布尔操作符

大多数的搜索引擎都会提供布尔操作符让用户可以组合查询，典型的布尔操作符有 AND, OR, NOT。Lucene 支持 5 种布尔操作符，分别是 AND, OR, NOT, 加(+), 减(-)。接下来我会讲述每个操作符的用法。

OR: 如果你要搜索含有字符 A 或者 B 的文档，那么就需要使用 OR 操作符。需要记住的是，如果你只是简单的用空格将两个关键词分割开，其实在搜索的时候搜索引擎会自动在两个关键词之间加上 OR 操作符。例如，“Java OR Lucene” 和 “Java Lucene” 都是搜索含有 Java 或者含有 Lucene 的文档。
AND: 如果你需要搜索包含一个以上关键词的文档，那么就需要使用 AND 操作符。例如，“Java AND Lucene” 返回所有既包含 Java 又包含 Lucene 的文档。
NOT: Not 操作符使得包含紧跟在 NOT 后面的关键词的文档不会被返回。例如，如果你想搜索所有含有 Java 但不含有 Lucene 的文档，你可以使用查询语句 “Java NOT Lucene”。但是你不能只对一个搜索词使用这个操作符，比如，查询语句 “NOT Java” 不会返回任何结果。
加号（+）: 这个操作符的作用和 AND 差不多，但它只对紧跟着它的一个搜索词起作用。例如，如果你想搜索一定包含 Java，但不一定包含 Lucene 的文档，就可以使用查询语句“+Java Lucene”。
减号（-）: 这个操作符的功能和 NOT 一样，查询语句 “Java -Lucene” 返回所有包含 Java 但不包含 Lucene 的文档。

接下来我们看一下如何利用 Lucene 提供的 API 来实现布尔查询。清单1 显示了如果利用布尔操作符进行查询的过程。

清单1：使用布尔操作符

  //Test boolean operator
public void testOperator(String indexDirectory) throws Exception{
   Directory dir = FSDirectory.getDirectory(indexDirectory,false);
   IndexSearcher indexSearcher = new IndexSearcher(dir);
   String[] searchWords = {"Java AND Lucene", "Java NOT Lucene", "Java OR Lucene",
                    "+Java +Lucene", "+Java -Lucene"};
   Analyzer language = new StandardAnalyzer();
   Query query;
   for(int i = 0; i < searchWords.length; i++){
      query = QueryParser.parse(searchWords[i], "title", language);
      Hits results = indexSearcher.search(query);
      System.out.println(results.length() + "search results for query " + searchWords[i]);
   }
}

域搜索(Field Search)

Lucene 支持域搜索，你可以指定一次查询是在哪些域(Field)上进行。例如，如果索引的文档包含两个域，Title 和 Content，你就可以使用查询 “Title: Lucene AND Content: Java” 来返回所有在 Title 域上包含 Lucene 并且在 Content 域上包含 Java 的文档。清单 2 显示了如何利用 Lucene 的 API 来实现域搜索。

清单2：实现域搜索

//Test field search
public void testFieldSearch(String indexDirectory) throws Exception{
    Directory dir = FSDirectory.getDirectory(indexDirectory,false);
    IndexSearcher indexSearcher = new IndexSearcher(dir);
    String searchWords = "title:Lucene AND content:Java";
    Analyzer language = new StandardAnalyzer();
    Query query = QueryParser.parse(searchWords, "title", language);
    Hits results = indexSearcher.search(query);
    System.out.println(results.length() + "search results for query " + searchWords);
}

通配符搜索(Wildcard Search)

Lucene 支持两种通配符：问号（？）和星号（*）。你可以使用问号（？）来进行单字符的通配符查询，或者利用星号（*）进行多字符的通配符查询。例如，如果你想搜索 tiny 或者 tony，你就可以使用查询语句 “t?ny”；如果你想查询 Teach, Teacher 和 Teaching，你就可以使用查询语句 “Teach*”。清单3 显示了通配符查询的过程。

清单3：进行通配符查询

//Test wildcard search
public void testWildcardSearch(String indexDirectory)throws Exception{
   Directory dir = FSDirectory.getDirectory(indexDirectory,false);
   IndexSearcher indexSearcher = new IndexSearcher(dir);
   String[] searchWords = {"tex*", "tex?", "?ex*"};
   Query query;
   for(int i = 0; i < searchWords.length; i++){
      query = new WildcardQuery(new Term("title",searchWords[i]));
      Hits results = indexSearcher.search(query);
      System.out.println(results.length() + "search results for query " + searchWords[i]);
   }
}

模糊查询

Lucene 提供的模糊查询基于编辑距离算法(Edit distance algorithm)。你可以在搜索词的尾部加上字符 ~ 来进行模糊查询。例如，查询语句 “think~” 返回所有包含和 think 类似的关键词的文档。清单 4 显示了如果利用 Lucene 的 API 进行模糊查询的代码。

清单4：实现模糊查询

//Test fuzzy search
public void testFuzzySearch(String indexDirectory)throws Exception{
   Directory dir = FSDirectory.getDirectory(indexDirectory,false);
   IndexSearcher indexSearcher = new IndexSearcher(dir);
   String[] searchWords = {"text", "funny"};
   Query query;
   for(int i = 0; i < searchWords.length; i++){
      query = new FuzzyQuery(new Term("title",searchWords[i]));
      Hits results = indexSearcher.search(query);
      System.out.println(results.length() + "search results for query " + searchWords[i]);
   }
}

范围搜索(Range Search)

范围搜索匹配某个域上的值在一定范围的文档。例如，查询 “age:[18 TO 35]” 返回所有 age 域上的值在 18 到 35 之间的文档。清单5显示了利用 Lucene 的 API 进行返回搜索的过程。

清单5：测试范围搜索

//Test range search
public void testRangeSearch(String indexDirectory)throws Exception{
    Directory dir = FSDirectory.getDirectory(indexDirectory,false);
    IndexSearcher indexSearcher = new IndexSearcher(dir);
    Term begin = new Term("birthDay","20000101");
    Term end   = new Term("birthDay","20060606");
    Query query = new RangeQuery(begin,end,true);
    Hits results = indexSearcher.search(query);
    System.out.println(results.length() + "search results is returned");
}

在 Web 应用程序中集成 Lucene

接下来我们开发一个 Web 应用程序利用 Lucene 来检索存放在文件服务器上的 HTML 文档。在开始之前，需要准备如下环境：

Eclipse 集成开发环境
Tomcat 5.0
Lucene Library
JDK 1.5

这个例子使用 Eclipse 进行 Web 应用程序的开发，最终这个 Web 应用程序跑在 Tomcat 5.0 上面。在准备好开发所必需的环境之后，我们接下来进行 Web 应用程序的开发。

1、创建一个动态 Web 项目

在 Eclipse 里面，选择 File > New > Project，然后再弹出的窗口中选择动态 Web 项目，如图二所示。

图二：创建动态Web项目

在创建好动态 Web 项目之后，你会看到创建好的项目的结构，如图三所示，项目的名称为 sample.dw.paper.lucene。

图三：动态 Web 项目的结构

2. 设计 Web 项目的架构

在我们的设计中，把该系统分成如下四个子系统：

用户接口: 这个子系统提供用户界面使用户可以向 Web 应用程序服务器提交搜索请求，然后搜索结果通过用户接口来显示出来。我们用一个名为 search.jsp 的页面来实现该子系统。
请求管理器: 这个子系统管理从客户端发送过来的搜索请求并把搜索请求分发到搜索子系统中。最后搜索结果从搜索子系统返回并最终发送到用户接口子系统。我们使用一个 Servlet 来实现这个子系统。
搜索子系统: 这个子系统负责在索引文件上进行搜索并把搜索结构传递给请求管理器。我们使用 Lucene 提供的 API 来实现该子系统。
索引子系统: 这个子系统用来为 HTML 页面来创建索引。我们使用 Lucene 的 API 以及 Lucene 提供的一个 HTML 解析器来创建该子系统。

图4 显示了我们设计的详细信息，我们将用户接口子系统放到 webContent 目录下面。你会看到一个名为 search.jsp 的页面在这个文件夹里面。请求管理子系统在包 sample.dw.paper.lucene.servlet 下面，类 SearchController 负责功能的实现。搜索子系统放在包 sample.dw.paper.lucene.search 当中，它包含了两个类，SearchManager 和 SearchResultBean，第一个类用来实现搜索功能，第二个类用来描述搜索结果的结构。索引子系统放在包 sample.dw.paper.lucene.index 当中。类 IndexManager 负责为 HTML 文件创建索引。该子系统利用包 sample.dw.paper.lucene.util 里面的类 HTMLDocParser 提供的方法 getTitle 和 getContent 来对 HTML 页面进行解析。

图四：项目的架构设计

3. 子系统的实现

在分析了系统的架构设计之后，我们接下来看系统实现的详细信息。

用户接口: 这个子系统有一个名为 search.jsp 的 JSP 文件来实现，这个 JSP 页面包含两个部分。第一部分提供了一个用户接口去向 Web 应用程序服务器提交搜索请求，如图5所示。注意到这里的搜索请求发送到了一个名为 SearchController 的 Servlet 上面。Servlet 的名字和具体实现的类的对应关系在 web.xml 里面指定。

图5：向Web服务器提交搜索请求

这个JSP的第二部分负责显示搜索结果给用户，如图6所示：

图6：显示搜索结果

请求管理器: 一个名为 SearchController 的 servlet 用来实现该子系统。清单６给出了这个类的源代码。

清单６：请求管理器的实现

package sample.dw.paper.lucene.servlet;

import java.io.IOException;
import java.util.List;

import javax.servlet.RequestDispatcher;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import sample.dw.paper.lucene.search.SearchManager;

/**
* This servlet is used to deal with the search request
* and return the search results to the client
*/
public class SearchController extends HttpServlet{

    private static final long serialVersionUID = 1L;

    public void doPost(HttpServletRequest request, HttpServletResponse response)
                      throws IOException, ServletException{
        String searchWord = request.getParameter("searchWord");
        SearchManager searchManager = new SearchManager(searchWord);
        List searchResult = null;
        searchResult = searchManager.search();
        RequestDispatcher dispatcher = request.getRequestDispatcher("search.jsp");
        request.setAttribute("searchResult",searchResult);
        dispatcher.forward(request, response);
    }

    public void doGet(HttpServletRequest request, HttpServletResponse response)
                     throws IOException, ServletException{
        doPost(request, response);
    }
}

在清单6中，doPost 方法从客户端获取搜索词并创建类 SearchManager 的一个实例，其中类 SearchManager 在搜索子系统中进行了定义。然后，SearchManager 的方法 search 会被调用。最后搜索结果被返回到客户端。

搜索子系统: 在这个子系统中，我们定义了两个类：SearchManager 和 SearchResultBean。第一个类用来实现搜索功能，第二个类是个JavaBean，用来描述搜索结果的结构。清单7给出了类 SearchManager 的源代码。

清单7：搜索功能的实现

package sample.dw.paper.lucene.search;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.queryParser.ParseException;
import org.apache.lucene.queryParser.QueryParser;
import org.apache.lucene.search.Hits;
import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.Query;

import sample.dw.paper.lucene.index.IndexManager;

/**
* This class is used to search the
* Lucene index and return search results
*/
public class SearchManager {

    private String searchWord;

    private IndexManager indexManager;

    private Analyzer analyzer;

    public SearchManager(String searchWord){
        this.searchWord   =  searchWord;
        this.indexManager =  new IndexManager();
        this.analyzer     =  new StandardAnalyzer();
    }

    /**
     * do search
     */
    public List search(){
        List searchResult = new ArrayList();
        if(false == indexManager.ifIndexExist()){
        try {
            if(false == indexManager.createIndex()){
                return searchResult;
            }
        } catch (IOException e) {
          e.printStackTrace();
          return searchResult;
        }
        }

        IndexSearcher indexSearcher = null;

        try{
            indexSearcher = new IndexSearcher(indexManager.getIndexDir());
        }catch(IOException ioe){
            ioe.printStackTrace();
        }

        QueryParser queryParser = new QueryParser("content",analyzer);
        Query query = null;
        try {
            query = queryParser.parse(searchWord);
        } catch (ParseException e) {
          e.printStackTrace();
        }
        if(null != query >> null != indexSearcher){
            try {
                Hits hits = indexSearcher.search(query);
                for(int i = 0; i < hits.length(); i ++){
                    SearchResultBean resultBean = new SearchResultBean();
                    resultBean.setHtmlPath(hits.doc(i).get("path"));
                    resultBean.setHtmlTitle(hits.doc(i).get("title"));
                    searchResult.add(resultBean);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return searchResult;
    }
}

在清单7中，注意到在这个类里面有三个私有属性。第一个是 searchWord，代表了来自客户端的搜索词。第二个是 indexManager，代表了在索引子系统中定义的类 IndexManager 的一个实例。第三个是 analyzer，代表了用来解析搜索词的解析器。现在我们把注意力放在方法 search 上面。这个方法首先检查索引文件是否已经存在，如果已经存在，那么就在已经存在的索引上进行检索，如果不存在，那么首先调用类 IndexManager 提供的方法来创建索引，然后在新创建的索引上进行检索。搜索结果返回后，这个方法从搜索结果中提取出需要的属性并为每个搜索结果生成类 SearchResultBean 的一个实例。最后这些 SearchResultBean 的实例被放到一个列表里面并返回给请求管理器。

在类 SearchResultBean 中，含有两个属性，分别是 htmlPath 和 htmlTitle，以及这个两个属性的 get 和 set 方法。这也意味着我们的搜索结果包含两个属性：htmlPath 和 htmlTitle，其中 htmlPath 代表了 HTML 文件的路径，htmlTitle 代表了 HTML 文件的标题。

索引子系统: 类 IndexManager 用来实现这个子系统。清单8 给出了这个类的源代码。

清单8：索引子系统的实现

package sample.dw.paper.lucene.index;

import java.io.File;
import java.io.IOException;
import java.io.Reader;

import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.store.Directory;
import org.apache.lucene.store.FSDirectory;

import sample.dw.paper.lucene.util.HTMLDocParser;

/**
* This class is used to create an index for HTML files
*
*/
public class IndexManager {

    //the directory that stores HTML files
    private final String dataDir  = "c:/dataDir";

    //the directory that is used to store a Lucene index
    private final String indexDir = "c:/indexDir";

    /**
     * create index
     */
    public boolean createIndex() throws IOException{
        if(true == ifIndexExist()){
            return true;
        }
        File dir = new File(dataDir);
        if(!dir.exists()){
            return false;
        }
        File[] htmls = dir.listFiles();
        Directory fsDirectory = FSDirectory.getDirectory(indexDir, true);
        Analyzer  analyzer    = new StandardAnalyzer();
        IndexWriter indexWriter = new IndexWriter(fsDirectory, analyzer, true);
        for(int i = 0; i < htmls.length; i++){
            String htmlPath = htmls[i].getAbsolutePath();

            if(htmlPath.endsWith(".html") || htmlPath.endsWith(".htm")){
                addDocument(htmlPath, indexWriter);
            }
        }
        indexWriter.optimize();
        indexWriter.close();
        return true;

    }

    /**
     * Add one document to the Lucene index
     */
    public void addDocument(String htmlPath, IndexWriter indexWriter){
        HTMLDocParser htmlParser = new HTMLDocParser(htmlPath);
        String path    = htmlParser.getPath();
        String title   = htmlParser.getTitle();
        Reader content = htmlParser.getContent();

        Document document = new Document();
        document.add(new Field("path",path,Field.Store.YES,Field.Index.NO));
        document.add(new Field("title",title,Field.Store.YES,Field.Index.TOKENIZED));
        document.add(new Field("content",content));
        try {
              indexWriter.addDocument(document);
    } catch (IOException e) {
              e.printStackTrace();
          }
    }

    /**
     * judge if the index exists already
     */
    public boolean ifIndexExist(){
        File directory = new File(indexDir);
        if(0 < directory.listFiles().length){
            return true;
        }else{
            return false;
        }
    }

    public String getDataDir(){
        return this.dataDir;
    }

    public String getIndexDir(){
        return this.indexDir;
    }

}

这个类包含两个私有属性，分别是 dataDir 和 indexDir。dataDir 代表存放等待进行索引的 HTML 页面的路径，indexDir 代表了存放 Lucene 索引文件的路径。类 IndexManager 提供了三个方法，分别是 createIndex, addDocument 和 ifIndexExist。如果索引不存在的话，你可以使用方法 createIndex 去创建一个新的索引，用方法 addDocument 去向一个索引上添加文档。在我们的场景中，一个文档就是一个 HTML 页面。方法 addDocument 会调用由类 HTMLDocParser 提供的方法对 HTML 文档进行解析。你可以使用最后一个方法 ifIndexExist 来判断 Lucene 的索引是否已经存在。

现在我们来看一下放在包 sample.dw.paper.lucene.util 里面的类 HTMLDocParser。这个类用来从 HTML 文件中提取出文本信息。这个类包含三个方法，分别是 getContent，getTitle 和 getPath。第一个方法返回去除了 HTML 标记的文本内容，第二个方法返回 HTML 文件的标题，最后一个方法返回 HTML 文件的路径。清单9 给出了这个类的源代码。

清单9：HTML 解析器

package sample.dw.paper.lucene.util;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.Reader;
import java.io.UnsupportedEncodingException;

import org.apache.lucene.demo.html.HTMLParser;

public class HTMLDocParser {
    private String htmlPath;

    private HTMLParser htmlParser;

    public HTMLDocParser(String htmlPath){
        this.htmlPath = htmlPath;
        initHtmlParser();
    }

    private void initHtmlParser(){
        InputStream inputStream = null;
        try {
            inputStream = new FileInputStream(htmlPath);
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        }
        if(null != inputStream){
            try {
                htmlParser = new HTMLParser(new InputStreamReader(inputStream, "utf-8"));
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            }
        }
    }

    public String getTitle(){
        if(null != htmlParser){
            try {
                return htmlParser.getTitle();
            } catch (IOException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    return "";
    }

    public Reader getContent(){
    if(null != htmlParser){
            try {
                  return htmlParser.getReader();
              } catch (IOException e) {
                  e.printStackTrace();
              }
        }
        return null;
    }

    public String getPath(){
        return this.htmlPath;
    }
}

5．在 Tomcat 5.0 上运行应用程序

现在我们可以在 Tomcat 5.0 上运行开发好的应用程序。

右键单击 search.jsp，然后选择 Run as > Run on Server，如图7所示。

图7：配置 Tomcat 5.0

在弹出的窗口中，选择 Tomcat v5.0 Server 作为目标 Web 应用程序服务器，然后点击 Next，如图8 所示：

图8：选择 Tomcat 5.0

现在需要指定用来运行 Web 应用程序的 Apache Tomcat 5.0 以及 JRE 的路径。这里你所选择的 JRE 的版本必须和你用来编译 Java 文件的 JRE 的版本一致。配置好之后，点击 Finish。如图9 所示。

图9：完成Tomcat 5.0的配置

配置好之后，Tomcat 会自动运行，并且会对 search.jsp 进行编译并显示给用户。如图10 所示。

图10：用户界面

在输入框中输入关键词 “information” 然后单击 Search 按钮。然后这个页面上会显示出搜索结果来，如图11 所示。

图11：搜索结果

单击搜索结果的第一个链接，页面上就会显示出所链接到的页面的内容。如图12 所示.

图12：详细信息

现在我们已经成功的完成了示例项目的开发，并成功的用Lucene实现了搜索和索引功能。你可以下载这个项目的源代码。

总结

Lucene 提供了灵活的接口使我们更加方便的设计我们的 Web 搜索应用程序。如果你想在你的应用程序中加入搜索功能，那么 Lucene 是一个很好的选择。在设计你的下一个带有搜索功能的应用程序的时候可以考虑使用 Lucene 来提供搜索功能。

下载

描述	名字	大小	下载方法
Lucene Web 应用程序示例	wa-lucene2_source_code.zip	504KB	HTTP

作者：baggio785 发表于2006-9-12 23:43:00 原文链接

阅读：10335 评论：5 查看评论

[转]用Spring JMS使异步消息变得简单

baggio785 — Tue, 12 Sep 2006 23:35:00 +0800

作者:Srini;David_w_johnson
原文:http://www.onjava.com/pub/a/onjava/2006/02/22/asynchronous-messaging-with-spring-jms.html

异步处理通信是面向服务架构（SOA）的重要部分，因为企业中的许多系统通信，尤其是跟外部系统通信本来就是异步的。Java消息服务（JMS）就是用来编写异步消息J2EE应用的API。使用JMS API的传统消息实现涉及到象这样的一些步骤：查找对列连接工厂、队列资源以及在实际发送和接受消息前，创建JMS会话（JMS session）。

Spring framework简化了用JEE组件（包括JMS）开发JMS应用的工作。它提供了一个模板机制来隐藏典型的JMS实现细节，所以开发者可以专注于消息处理任务而不用担心怎样创建、访问和释放JMS资源。

本文用一个运行在JBoss MQ server上的简单Web应用概述了Spring JMS API和怎样使用它异步处理（发送和接受）消息。我将对比JMS实现的传统方法和Spring JMS实现方法，以显示使用Spring JMS来处理消息是多么的简单和灵活。

异步消息和SOA

现实世界中，大多数Web请求是同步处理的。例如，当用户登陆一个站点，他或她输入用户名和口令以及服务器识别登陆凭证。如果身份验证成功，程序让用户进入站点。这里，登陆请求从客户端被接受后，立即被处理。信用卡授权也是一个同步处理的例子；仅当服务器核实了发送进来的信用卡号是有效并且该客户的帐号有足够的信用额度后，才允许客户继续进行下一步动作。让我们来考察一下订单处理系统中的支付结算步骤。一旦系统核实了那个用户的信用卡信息是正确的，而且帐户上有足够的资金，那么不需要等到支付细节和转帐最终完成。支付结算用异步方式处理，如此客户便可以继续进行结帐处理。

与典型的同步请求相比，异步处理用于需要长时间来处理的请求。异步处理的另外一个例子是住房贷款处理应用中，处理提交到AUS（Automated Underwriting System）的贷款请求。贷款人提交贷款申请后，抵押公司发送请求到AUS取得信用历史信息。因为该请求要取得综合详细的信用报告如贷款人当前和过去的信用帐户，最近的支付以及其它金融详细信息，所以从请求到获得响应常常需要很长时间。对客户端程序来说开一个到服务器的连接并且长时间等待响应是没有意义的。于是就有了异步通信；也就是，一旦请求被提交，它就被放入队列里面并且客户断开服务器连接。然后，AUS服务从特定队列摘取请求，处理它，把结果消息放入另外一个消息队列。最后客户程序从消息队列摘取响应结果继续处理信用历史结果信息。

JMS

如果用过JMS的话，会发现它类似写JDBC或JCA代码。它有创建或检索JMS资源的样板代码，每当你需要编写一个新类来发送或接受消息时，都得重复编写那个样本代码。下面列出了传统JMS实现涉及的步骤：
1、创建JNDI初始上下文context；
2、从JNDI上下文获得队列连接工厂；
3、从队列连接工厂取得队列Queue；
4、创建一个Session对象；
5、创建一个发送或接受对象；
6、利用第5部创建的发送或接受对象发送或接受消息；
7、处理完消息后，关闭所有JMS资源。

如你所见，只有第6步是处理消息的步骤。其他步骤都只是管理JMS资源，与实际业务需求无关，但开发者不得不编写和维护那些附加步骤代码。

Spring JMS

Spring框架提供一个模板机制来隐藏Java API细节。JEE开发者可用JDBCTemplate 和JNDITemplate类来分别访问后端数据库和JEE资源（数据源，连接池）。JMS没有异常。Spring提供了JMSTemplate类，所以开发者不必为JMS实现编写样本代码。当开发JMS应用时，Spring提供了一下一些优势：
1、提供了一个JMS的抽象API，简化了JMS的使用。如：访问目的地（队列或主体）和出版消息到特定目的地。
2、JEE开发者不必关心JMS不同版本之间的差异（如JMS 1.0.2 同 JMS 1.1）；
3、开发者不必特定地处理JMS异常，因为Spring为JMS代码抛出的任何JMS异常提供了一个unchecked异常。

一旦你在JMS应用中开始使用Spring，你将会欣赏到异步消息处理的简易性。Spring JMS框架提供了各种java类使JMS开发变得简单。

表1，Spring JMS类

随后的部分，我将详细解释表1中的类（如JmsTemplate, DestinationResolver,和 MessageConverter）。

JMSTemplate

JmsTemplate提供了几个helper方法来执行基本操作。开始使用JmsTemplate前，有必要知道JMS提供者支持哪种JMS规范。JBoss AS 4.0.2 和 WebLogic 8.1服务器支持JMS1.0.2规范。WebLogic 服务器 9.0包含JMS1.1支持。JMS1.1统一了PTP和Pub/Sub编程接口。有了这个改变，开发者可以创建一个事务会话，然后在同一个JMS事务中，从Queue（PTP）接受消息和发送一个消息到Topic（Pub/Sub）。JMS1.1向后兼容JMS1.0，因此基于JMS1.0编写的代码仍然能跟JMS1.1工作。

JmsTemplate提供各种方法来接收和发送消息。表2是方法列表。

表2。JMS模板方法

使用JNDI上下文存储和检索目的地。当配置Spring应用上下文时，我们用JndiObjectFactoryBean获得JMS目的地引用。DestinationResolver用来解析目的地名称到一个JMS目的地，当应用有许多目的地时，那是很有帮助的。DynamicDestinationResolver（缺省DestinationResolver实现）用于解析动态目的地。

MessageConverter接口定义了java对象和JMS消息之间转换的契约。使用转换器，应用代码可以专注于业务对象，不用操心它是如何代表JMS消息的。SimpleMessageConverter（和SimpleMessageConverter102）是缺省MessageConverter实现。它们用于将String、字节数组（(byte[]）、Map、Serializable对象分别转换成JMS TextMessage、JMS BytesMessage，JMS MapMessage，JMS ObjectMessage。你可以编写MessageConverter接口的定制实现并结合XML绑定框架如JAXB, Castor, Commons Digester, XMLBeans, 或 XStream来转换XML文档到TextMessage。

样本应用

我将用一个样本贷款应用处理系统（叫LoanProc）来说明怎样在JMS应用中使用Spring。作为贷款处理的一部分，LoanProc发送贷款详细资料（loan ID, borrower name, borrower's SSN, loan expiration date, and loan amount）从AUS系统请求信贷历史。为让例子简单一点，我们将基于两个参数：信用评分和贷款数量来获得信贷历史详细资料。让我们假定处理信用检查请求的业务规则如下：
1、如果贷款数量等于或小于$500,000，那么贷款人必须至少有一个“good”信用（例如，贷款人的信用评分在680到699之间）；
2、如果贷款数量超过$500,000，那么贷款人必须至少要有一个“very good”信用，这意味他/她的信用评分超过700。

贷款应用Use Case

贷款请求处理Use Case由下列步骤组成：
1、用户在贷款申请web页面输入贷款详细资料并提交贷款申请；
2、然后程序发送贷款详细资料到AUS系统取得信用历史详细资料。用发送请求到名叫CreditRequestSendQueue的消息队列来完成。
3、AUS系统从队列摘取贷款详细资料并用贷款参数来从数据库检索信用历史信息；
4、然后AUS系统用找到的贷款人信用历史信息创建一个新的消息并发送到名叫CreditRequestReceiveQueue的消息队列；
5、最后LoanProc从接收消息队列摘取响应消息并处理贷款申请，决定申请是被核准还是拒绝。

应用中，在同样的JBoss MQ server中配置了两个消息队列。Use Case用序列图1表示如下：

图1：贷款处理应用的序列图

技术

表3列出了例子应用中用到的一些技术和开源框架

表3，JMS应用中用到的框架

使用Hermes 的JMS资源设置

为异步处理消息，首先，我们需要消息队列来发送和接收消息。我们在JBoss中使用xml配置文件创建消息队列并且用JMS控制台来浏览队列详细资料。清单1显示了XML配置文件JMS配置片断。（这个片断可以被添加到%JBOSS_HOME%/server/all/deploy-hasingleton/jms目录下的jbossmq-destinations-service.xml文件中。）

清单1，JBoss MQ服务器中JMS队列配置

<!--  Credit Request Send Queue  -->
<mbean code="org.jboss.mq.server.jmx.Queue"
  name="jboss.mq.destination:service=Queue,name=CreditRequestSendQueue">
  <depends optional-attribute-name="DestinationManager">
    jboss.mq:service=DestinationManager
  </depends>
</mbean>

<!--  Credit Request Receive Queue  -->
<mbean code="org.jboss.mq.server.jmx.Queue"
  name="jboss.mq.destination:service=Queue,name=CreditRequestReceiveQueue">
  <depends optional-attribute-name="DestinationManager">
    jboss.mq:service=DestinationManager
  </depends>
</mbean>

现在，让我们看看怎么使用一个叫做Hermes的JMS工具浏览消息队列。Hermes是一个Java Swing应用，它能创建、管理和监控JMS提供者中的JMS destination。这样的JMS提供者有JBossMQ, WebSphereMQ, ActiveMQ 和 Arjuna。从website下载Hermes并解压zip文件到一个本地目录(如c:/dev/tools/hermes)。一旦安装，双击hermes.bat (在bin目录)启动程序。

为在Hermes中配置JBossMQ服务器，参考Hermes站点上的demo。它一步一步形象说明了JBoss MQ的配置。当配置一个新的JNDI初始上下文时，输入下面的配置信息。

•providerURL = jnp://localhost:1099
•initialContextFactory = org.jnp.interfaces.NamingContextFactory
•urlPkgPrefixes = org.jnp.interfaces:org.jboss.naming
•securityCredentials = admin
•securityPrincipal = admin

当创建一个新destinations时，输入queue/CreditRequestSendQueue 和 queue/CreditRequestReceiveQueue。图2显示了JMS控制台主屏幕，它显示了为样本JMS应用创建的新消息。

图2.Hermes中所有destinations的截屏

图3是消息发送者发送一些消息到CreditRequestSendQueue后，Hermes JMS控制台显示的消息队列详细资料。你能看到这里队列中有5个消息并且控制台显示了消息的详细信息如message ID、message destination、time stamp、和实际的消息。

图3.Hermes中队列详细资料截屏

使用Spring JMS，异步消息变得简单

用在样本应用中的这些消息队列名和其它JMS以及JNDI参数如下表4所示。

表4,Spring JMS配置参数

Spring配置

已经有了运行样本应用所需的JMS destinations，现在该是进入用XML Spring配置文件(叫做spring-jms.xml)装配JMS组件的细节的时候了。用IOC设计模式中的setter依赖注入原理装入这些组件。让我们仔细看看组件，为每一个JMS组件显示了一个XML配置片断。

JNDI上下文是获取JMS资源的入口，所以我们首先配置一个JNDI模板。清单2显示了一名为jndiTemplate的Spring bean，它具有取得JNDI初始上下文必须的常用参数。

清单2，JNDI上下文模板

<bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
    <property name="environment">
        <props>
            <prop key="java.naming.factory.initial">
                org.jnp.interfaces.NamingContextFactory
            </prop>
            <prop key="java.naming.provider.url">
                localhost
            </prop>
            <prop key="java.naming.factory.url.pkgs">
                org.jnp.interfaces:org.jboss.naming
            </prop>
        </props>
    </property>
</bean>

下一步，我们配置队列连接工厂。清单3显示了队列连接工厂。

清单3，JMS对了连接工厂配置

<bean id="jmsQueueConnectionFactory"
      class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiTemplate">
        <ref bean="jndiTemplate"/>
    </property>
    <property name="jndiName">
        <value>UIL2ConnectionFactory</value>
    </property>
</bean>

我们定义了两个JMS destinations来发送和接收消息。清单4和清单5显示了这些细节。

清单4，发送队列配置

<bean id="sendDestination"
    class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiTemplate">
        <ref bean="jndiTemplate"/>
    </property>
    <property name="jndiName">
        <value>queue/CreditRequestSendQueue</value>
    </property>
</bean>

清单5，接收队列配置

<bean id="receiveDestination"
    class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiTemplate">
        <ref bean="jndiTemplate"/>
    </property>
    <property name="jndiName">
        <value>queue/CreditReqeustReceiveQueue</value>
    </property>
</bean>

然后，我们配置JmsTemplate组件。我们在样本应用中使用JmsTemplate102。使用defaultDestination属性来指定JMS destination。

清单6，JMS template配置

<bean id="jmsTemplate" 
      class="org.springframework.jms.core.JmsTemplate102">
    <property name="connectionFactory">
        <ref bean="jmsQueueConnectionFactory"/>
    </property>
    <property name="defaultDestination">
        <ref bean="destination"/>
    </property>
    <property name="receiveTimeout">
        <value>30000</value>
    </property>
</bean>

最后，我们配置发送和接收者组件。清单7和清单8显示了Sender 和Receiver 对象配置。

清单7，JMS Sender配置

Listing 7. JMS Sender configuration
<bean id="jmsSender" class="springexample.client.JMSSender">
    <property name="jmsTemplate">
        <ref bean="jmsTemplate"/>
    </property>
</bean>

清单8，JMS Receiver配置

<bean id="jmsReceiver" class="springexample.client.JMSReceiver">
    <property name="jmsTemplate">
        <ref bean="jmsTemplate"/>
    </property>
</bean>

测试和监控

我些了一个叫做LoanApplicationControllerTest的测试类来测试LoanProc应用。我们使用这个类来设置贷款参数和调用那个信用请求服务类。

让我们看看使用传统JMS而不用Spring JMS API的消息发送者实现。清单9显示了MessageSenderJMS这个类的sendMessage方法，这个类具备使用JMS API处理消息的所有必须步骤。

清单9，传统JMS实现

public void sendMessage() {

    queueName = "queue/CreditRequestSendQueue";
    System.out.println("Queue name is " + queueName);

    /*
     * Create JNDI Initial Context
     */
    try {
        Hashtable env = new Hashtable();
        env.put("java.naming.factory.initial",
            "org.jnp.interfaces.NamingContextFactory");
        env.put("java.naming.provider.url","localhost");
        env.put("java.naming.factory.url.pkgs",
            "org.jnp.interfaces:org.jboss.naming");

        jndiContext = new InitialContext(env);
    } catch (NamingException e) {
        System.out.println("Could not create JNDI API " +
            "context: " + e.toString());
    }

    /*
     * Get queue connection factory and queue objects from JNDI context.
     */
    try {
        queueConnectionFactory = (QueueConnectionFactory)
        jndiContext.lookup("UIL2ConnectionFactory");

        queue = (Queue) jndiContext.lookup(queueName);
    } catch (NamingException e) {
        System.out.println("JNDI API lookup failed: " +
            e.toString());
    }

    /*
     * Create connection, session, sender objects.
     * Send the message.
     * Cleanup JMS connection.
     */
    try {
        queueConnection =
            queueConnectionFactory.createQueueConnection();
        queueSession = queueConnection.createQueueSession(false,
                Session.AUTO_ACKNOWLEDGE);
        queueSender = queueSession.createSender(queue);
        message = queueSession.createTextMessage();
        message.setText("This is a sample JMS message.");
        System.out.println("Sending message: " + message.getText());
        queueSender.send(message);

    } catch (JMSException e) {
        System.out.println("Exception occurred: " + e.toString());
    } finally {
        if (queueConnection != null) {
            try {
                queueConnection.close();
            } catch (JMSException e) {}
        }
    }
}

现在，让我们看看用Spring实现的消息发送者。清单10显示了MessageSenderSpringJMS类中send方法代码。

清单10，用Spring API 的JMS实现

public void send() {
    try {
        ClassPathXmlApplicationContext appContext = new ClassPathXmlApplicationContext(new String[] {
                "spring-jms.xml"});

        System.out.println("Classpath loaded");

        JMSSender jmsSender = (JMSSender)appContext.getBean("jmsSender");

        jmsSender.sendMesage();

        System.out.println("Message sent using Spring JMS.");
    } catch(Exception e) {
        e.printStackTrace();
    }
}

如你所见，所有与管理JMS资源相关的资源步骤都由Spring容器用配置文件处理。我们仅需要获取JMSSender引用并且调用它上面的sendMessage即可。

结论

本文中，我们看到Spring框架如何简化了使用JMS API的异步消息应用开发的工作。Spring移走了所有JMS消息处理必须的样板代码，如获取连接工厂，从Java代码创建队列和会话对象并在运行时用配置文件装配它们。由于这个强大的IOC原理，我们可以不必修改Java代码便可动态交换JMS资源对象。

因为异步消息是构成SOA框架整体所需的一部分，Spring非常适合放入SOA工具集。同样，JMS管理工具如Hermes使得创建，管理和控制JMS资源变得简单，尤其对系统管理员。

资源
本文样本代码
Matrix:http://www.matrix.org.cn/
Spring JMS documentation
"1-2-3 Messaging with Spring JMS"
JBoss MQ wiki

Srini Penchikala是Flagstar Bank信息系统领域问题专家。

作者：baggio785 发表于2006-9-12 23:35:00 原文链接

阅读：9247 评论：0 查看评论

[转]使Weblogic服务器的资源配置自动化

baggio785 — Tue, 12 Sep 2006 23:32:00 +0800

作者:Tanmay Ambre;leniz
原文:http://www.javaworld.com/javaworld/jw-10-2005/jw-1010-wlst.html

在Weblogic服务器上使用WLST和Ant进行资源配置

概述

企业级的Java程序如果没有进行程序服务器的配置，例如链接池、数据源、JMS队列和安全等的配置，想要准确运行是不太可能的。而这些配置都是在应用程序部署之前进行正确无误地配置的。然而，在考虑程序可能部署到多环境的情况下，这些配置工作就变得复杂起来。自动而集成的资源配置提供了这种便利，尤其是出于系统维护导致系统的配置发生变化或突然出于性能的需要需将程序部署到一个新的服务器上。这篇文章阐述的就是Weblogic服务器下借助Weblogic的脚本语言和Ant实现这种资源配置自动化。

每种可部署的J2EE组件，要在应用服务器运行准确无误都必须进行相应的配置。对于使用Weblogic服务器的开发人员来说，这种配置可以通过控制台来完成，也可以通过Weblogic Ant的wlconfig和wldeploy两个任务，或直接使用命令行工具weblogic deployer。Ant任务和命令行工具因为依赖于具体的环境特性，所以在Weblogic9.0下，都建议尽量减少这些工具的使用。

因为开发人员与应用程序之间并没有一个统一的维护和沟通配置信息的方式，从而导致一些自定义的脚本配置和手动配置并存。自定义的脚本配置难以维护，而手动配置常常导致错误的发生，获取一个流畅的传播和释放机制对J2EE而言显得艰难无比。在应用程序需部署到多样环境的下（开发，测试和产品），这变得更加复杂，因为这些多样环境使得程序很难做到完全地独立于环境。并且，如果整个程序的维护信息本身并不规范的话，突然变动程序目标将导致过程变得冗长乏味。因此，每一个程序都必须始终如一的将配置信息保持环境独立。也正据于此，一种可以自动读取配置信息并在服务器上进行自动配置的工具，将大大地提供便利，而这种工具也将成为程序部署的一个部分。这样的一个工具在加强标准和指引中起到至关重要的作用。

这篇文章提供了一个样例，在此样例中配置信息得以通过程序来维护。它同时也提供了以Ant任务的方式执行读取配置信息和在服务器部署的工具。此样例已经编译测试过，测试的环境为J2SE 1.4.2_03和Weblogic 8.1，同时也兼容Weblogic7.0，8.1和9.0。

Weblogic服务器配置的种类

J2EE程序通常使用链接池，数据源，Java信息服务（JMS），储存技术（文件储存或数据链接储存），JMS服务，JMS目标（队列和主题），以及分布式JMS目标。其中部分资源的创建是处于域级的。有些时候应用程序可以共享配置信息，有些时候却不是那样。这些共享的配置信息，在应用程序反部署的时候并不允许被删除。这篇文章所述的Ant任务和配置需要非常谨慎的处理这种情况,即共享配置不能够被删除。同时，也不能覆盖掉那些已经存在的配置信息。

资源配置和WLST

Weblogic针对每个配置创建相应的管理Bean（MBeans），并通过java管理扩展（Java Managerment Extensions（JMX））来管理这些Mbeans。所以，每一个配置都有一个对应的MBean 被创建和部署。创建这些MBean 所必须的参数有:它的名字，类别和其它一系列属性。

WLST（Wblogic Scripting Tool）是一个脚本工具，它使得用户可以访问并操作MBean，类似于在文件系统中对普通文件的操作。这是一个脚本接口，使得开发人员可以借此配置Weblogic服务器并与之交互。WLST与Weblogic 9.0相应而生，提供了在线和离线两种工作方式。当在线操作时，WLST可以以以下三种模式工作：
+脚本模式
+交互模式（命令行和GUI）
+Java封装模式

这篇文章重点放在Java封装模式上。这种模式因为可以在不需要开发人员了解WLST的脚本语法的情况下，用基于Java的工具（例如 Ant任务）很便捷地创建出WLST环境下的配置。

创建和维护资源配置

最好的维护资源配置的方法就是使得资源配置模块化。每一个可部署的应用程序都必须维护它自身的资源配置，所以这也使得我们很容易决定哪些资源是程序必须的。应用程序的资源配置可以跟着程序架构被带到各种不同的环境中。因此，针对一个机构的J2EE多环境下的程序资源配置变得易于维护和管理。

再也找不到比xml格式更适合于保存配置的了！这种格式可以通过结构化的方式来维护配置并通过模式提供有效性检测。XML文件保存着名字，类型和Weblogic服务器资源的一系列属性。你所需要注意的无非只有如下一些信息。
+MBean的类型（比如 JDBCConnectionPool）
+MBean中必须设置的属性

类型都不会改动，而通常每个MBean必须设置的属性也无外乎那些。因此完全有可能创建一个通用的配置模板，并将它结合到一些通用的IDE开发工具中（比如 IDEA和Eclipse）。XML文件中使用的值都必须独立于环境，并且这个XML文件必须要有版本控制。在程序发放阶段也必须包含它们的自己的资源配置。

参看资源部分的源码，这些源码是依据这篇文章提出的XML模式定义的，是配置文件的一个样例。现在把它称为Weblogic服务器资源配置XML。

资源配置的配置器任务

一旦应用程序开始维护它的资源配置，你需要定义一个Ant的常规任务，这个任务将执行如下的操作。
+读取Weblogic应用程序服务器的资源配置XML文件
+可以读取环境变量和其它一些来自或文件或URL或资源的默认的属性
+在给定的目标服务器上运行配置文件
+配置文件部署失败将触发程序的部署失败

这些配置任务可以通过任何一个开源的XML绑定框架(Castor, XMLBeans,或Java Architecture for XML Binding)来解析XML文件。在例子中，我使用的是XMLBeans.接下来任务必须产生一个WLST兼容的脚本，并触发它。为了在线运行这个脚本，我们必须连接到管理服务器，并在这个服务器上触发配置。下列的是配置任务的输入参数。
+url：管理服务器的URL
+username：管理服务器的用户名
+password：管理服务器的密码
+configfile: 配置文件路径
+action: 动作(创建，删除，部署，反部署)

配置任务首先解析配置文件。接着连接到一个域管理服务器.依据输入参数,按照XML文档给定的参数将产生一个WLST脚本,并以嵌入的模式执行此脚本.在完成所有配置的部署之后,这个task将优雅从容的断开与管理服务器的链接

生成的WLST脚本将首先检测bean是否存在,如果存在的话,将不创建配置.配置器任务也同时检查依赖性.(比如数据源是依赖于数据链接池的).在删除阶段,也将进行依赖性检测已确定删除万无一失.

参看资源部分的配置器源代码样例.

Ant 任务示例

Ant任务名称为com.tanmayambre.wls.tools.anttaskdefs.
WLSTConfigurator.它拥有如下的输入参数.
+url: 管理服务器的URL
+username: 管理服务器的的用户名
+password: 用户密码
+configFile: 配置文件路径
+propertiesFile: 包含环境变量的属性文件
+action: 创建,删除,部署,反部署,重部署

部署与反部署动作都将内在地先触发创建动作去创建一份配置.属性可以是环境变量
示例:

<target name="create-configuration" depends="init-demo">
   <echo message=">>>>>> Creating the Configuration"/>
   <wlsconfig
      username="${weblogic.user}" password="${weblogic.passwd}"
      url="${weblogic.url}"
      configFile="${basedir}/samples/wlsconfig/example.xml"
      propertiesFile="${basedir}/samples/wlsconfig/environment.properties"
      action="create"/>
</target>

<target name="delete-configuration" depends="init-demo">
   <echo message=">>>>>> Deleting the Configuration"/>
   <wlsconfig
      username="${weblogic.user}" password="${weblogic.passwd}"
      url="${weblogic.url}"
      configFile="${basedir}/samples/wlsconfig/example.xml"
      propertiesFile="${basedir}/samples/wlsconfig/environment.properties"
      action="delete"/>
</target>

<target name="deploy-application" depends="init-demo">
   <echo message=">>>>>> Deploying the application"/>
   <wlsconfig
      username="${weblogic.user}" password="${weblogic.passwd}"
      url="${weblogic.url}"
      configFile="${basedir}/samples/wlsconfig/example.xml"
      propertiesFile="${basedir}/samples/wlsconfig/environment.properties"
      action="deploy"/>
</target>

<target name="undeploy-application" depends="init-demo">
   <echo message=">>>>>> UNDeploying the application"/>
   <wlsconfig
      username="${weblogic.user}" password="${weblogic.passwd}"
      url="${weblogic.url}"
      configFile="${basedir}/samples/wlsconfig/example.xml"
      propertiesFile="${basedir}/samples/wlsconfig/environment.properties"
      action="undeploy"/>
</target>

<target name="redeploy-application" depends="init-demo">
   <echo message=">>>>>> Redeploying the application"/>
   <wlsconfig
      username="${weblogic.user}" password="${weblogic.passwd}"
      url="${weblogic.url}"
      configFile="${basedir}/samples/wlsconfig/example.xml"
      propertiesFile="${basedir}/samples/wlsconfig/environment.properties"
      action="redeploy"/>
</target>

实现环境独立性

某些运行期的配置会因为运行环境的不同而有所不同.比如链接数据库服务器的用户ID和用户密码在测试阶段和实际运行阶段可能不一样.对开发者而言,针对每种环境都要编写一个配置文件将是一个冗长乏味的工作.他们要考虑各种各样的环境下的配置可能.
所以不太可能这样做,一个更为有效的方法将抽象出配置文件中的信息,并将这些信息作为一个独立的属性文件(或作为环境变量).此文件将由系统管理员进行维护,而开发者所要做的无非只是从这些属性文件中提取属性值
配置器使用一个属性读取器(com.tanmayambre.wls.tools.utils.
PropertiesReader)读取不同环境的属性值,那些属性值将依照如下的顺序依次读取.后面读取的属性将覆盖之前读取的同名的属性.
+系统属性(System properties)
+环境变量(Environment variables)
+来自文件的属性(Properties from a file

环境变量可以声明为常用变量,比如环境名称或域名称.属性文件包含默认的值,比如,用户ID,用户密码,最大容量,最小容量.此文件关联着环境,所以单独的属性文件将对照不同的环境进行维护.

资源配置的XML文件不允许使用任何特殊环境下的变量,而必须使用那些声明为系统的或环境的变量,或特定环境下属性文件的某属性值.

这种解决方案的好处在于,无论开发者或是程序的编译者只需一次配置好所有环境下的配置.示例代码包含了一个这样的属性读取器,这个读取器可以读取环境相关变量.配置器使用这个属性读取器替换资源配置XML中的环境变量.此解决方法类似于Maven读取环境变量所使用的方法.

资源命名约定

因为我们要使创建的配置文件具有环境独立性，所以必须制定相应的命名规则来规范程序员和应用程序开发者对资源的命名.这也使得在跨平台使用时有统一的标准,有助于有效的维护系统.命名规格必须加于公布,文档化,并由开发者和部署人员达成共识.下列有几条关于命名规范的的指导:
+域级资源,比如数据链接池,JMS存储库等, 因为部署于跨服务器实例,所以不应该使用依赖特定服务器的变量.
+在命名时使用匈牙利字符命名方式
+根据应用程序命名的资源做为特定应用资源。

处理过程

下列步骤,概要的说明了开发和维护配置的过程.
1.针对每个环境,创建一个包含环境特性的属性文件(一次性).
2.发布资源命名约定的规范方针
3.将创建Weblogic服务器资源配置文件, 这是程序开发的一部份
4.在builder.xml中, 将创建和删除配置以及布署和反布署程序与ant任务相结合, 确保布署相关的任务依赖于资源配置任务。
5.在版本控制系统里, 检查Weblogic服务器配置和build.xml。
6.告知应用程序开发者, 环境变量已经可用.
7.在发布阶段,先发布Weblogic服务器资源配置.
8.使用ant的任务来完成部署工作.配置器任务能够创建资源配置,同时也能不熟应用程序.

优点

所建议的解决方案可以自动化以及维护Weblogic服务器配置.这些步骤具有如下的优势:
+对每个应用程序,模块化Weblogic服务器配置.部署应用程序变得异常简单.
+一种结构化的维护配置的方法.
+Weblogic9.0 使得WLST官方化
+创建配置文件只需要很少的工作量
+因为工具使用的是Ant的任务的方式,所以可以很方便地将此工具集成到Maven.

结论
这篇文章中,你已经看到如何将Weblogic服务器资源集成到应用程序中.完成这些工作借助于资源配置的XML文件，以及使用配置器任务按照必要的资源配置去布署。同时我们也看到了,如何使得我们的资源配置文件独立与环境.这些方法有助于机构完全自动化J2EE应用程序的部署和反部署工作,同时缩小错误出现的范围.如果对资源配置的XML文件加上版本控制的话,将更有利于对程序资源变动的追踪.

关于作者
Tanmay Amber就职于印度孟买的Infosys 技术公司.涉及领域包括Java/J2EE技术,并有四年从事Weblogic相关产品工作的经验.Amber同时专长于Java/J2EE平台的工具使用(特别是开源项目).

作者：baggio785 发表于2006-9-12 23:32:00 原文链接

阅读：8663 评论：1 查看评论

[转]在Eclipse3.0中配置SQLExplorer访问数据库

baggio785 — Mon, 04 Sep 2006 13:29:00 +0800

作者： Deepak Vohra

SQLExplorer是Eclipse集成开发环境的一种插件，它可以被用来从Eclipse连接到一个数据库。SQLExplorer插件提供了一个使用SQL语句访问数据库的图形用户接口（GUI）。通过使用SQLExplorer，你能够显示表格、表格结构和表格中的数据，以及提取、添加、更新或删除表格数据。SQLExplorer同样能够生成SQL脚本来创建和查询表格。所以，与命令行客户端相比，使用SQLExplorer可能是更优越的选择。在这篇指南中，我们将使用SQLExplorer插件建立一个从Eclipse3.0到开源数据库MySQL的JDBC连接。

这篇指南有如下章节：

1.概览
2.预备安装
3.配置 SQLExplorer
4.访问数据库数据

概   览
通过在集成开发环境中加入一个SQLExplorer视窗，SQLExplorer插件为Eclipse配置了一个访问数据库的SQL客户端。

为了演示SQLExplorer插件的使用，我们将在开源数据库MySQL中创建一个示例表，并且建立一个从Eclipse到MySQL数据库的JDBC连接。接着，我们将在SQLExplorer的图形SQL客户端中提取和显示示例数据。同样，我们也将通过更新和删除示例表中的数据来演示SQLExplorer插件的不同特点。

预备安装

1. 下载并安装 Eclipse 3.02
2. 下载SQLExplorer文件 net.sourceforge.sqlexplorer_2.2.3.zip.
3. 解压 SQLExplorer .zip 文件到 <Eclipse>/eclipse 目录。 <Eclipse> 是Eclipse安装的目录。这将把SQLExplorer插件的 features 和 plugins 目录添加到Eclipse中的 features 和 plugins 目录。（译者注：这里说得不是十分清楚，其实是先将SQLExplorer .zip文件解压，然后分别把features 和 plugins 目录中的所有文件拷贝到Eclipse中对应的features 和 plugins 目录中，这是安装Eclipse插件的常用方法，当然也可以使用link方式安装插件，请参阅网上相应文档）
4. 重启Eclipse.
5. 安装MySQL数据库。
6. 下载Connector/J，通过使用包含在其中的一个 .jar文件中的JDBC驱动来连接MySQL数据库。
7. 作为一个root用户登陆到MySQL数据库，命令如下：

   >mysql -u root

   root用户没有设定密码。需要通过密码登陆到数据库时，指定如下命令：

   >mysql -u root -p

8. 使用如下命令连接到test数据库，这是一个示例数据库实例：

   >use test

9. 在test数据库中创建一个示例表。示例表 Catalog 由ONJava上的文章名称组成。用来创建示例表的SQL脚本列在下面：

CREATE TABLE Catalog(CatalogId INTEGER, Journal VARCHAR(25),
      Publisher Varchar(25), 
      Date VARCHAR(25), Title Varchar(45), Author Varchar(25));

   INSERT INTO Catalog VALUES('1', 'onjava',  
      'OReilly', 'April 2005', 'Five Favorite Features from 5.0', 
      'David Flanagan');

   INSERT INTO Catalog VALUES('2', 'onjava',    
      'OReilly', 'Feb 2005', 'Introducing JBoss Remoting', 
      'John Mazzitelli');

   INSERT INTO Catalog VALUES('3', 'onjava',   
      'OReilly', 'March 2005', 'Aspect-Oriented Annotations', 
      'Bill Burke');

配置 SQLExplorer

安装了SQLExplorer插件后，我们将要在Eclipse 3.02中配置SQLExplorer.首先，在Eclipse中打开SQLExplorer视窗。在Eclipse 集成开发环境中单击 “Open a perspective”按扭来打开一个视窗。图1说明了“Open a perspective”按扭。

图 1. 打开视窗

在条目列表中，选择“Other...”来显示SQLExplorer插件，如图2所示。

图 2. “ other… ”菜单项

在 Select Perspective框中，选择SQLExplorer视窗，如图3所示。通过选择SQLExplorer视窗，SQLExplorer插件的功能部件在Eclipse中变得可用。

图 3. SQLExplorer 视窗

Drivers 标签显示了不同的数据库驱动，它们被用来连接不同的数据库。现在可用的数据库包括DB2, MySQL, Oracle, Sybase, HSQLDB, SQLServer 和 PostgreSQL。针对MySQL，我们需要配置SQLExplorer。为了配置MySQL驱动，右击 MMMySQL Driver 结点，并且选择 Change the Selected Driver, 如图4所示。

图 4. 修改驱动

在 Modify Driver框中，选择 Extra Class Path 标签，并且单击 Add 按扭将 MySQL 驱动 .jar 文件（为下载的 Connector/J 的一部分）添加到类路径中。图5阐明了将MySQL 的 JDBC 驱动加到 Eclipse 的类路径中。

图 5. 设置驱动

添加 MySQL Connector/J 驱动 .jar 文件，mysql-connector-java-3.0.16-ga-bin.jar，到类路径中。在 Example URL 域中，指定连接到数据库的 URL。一个连接到 test 数据库的JDBC连接将被创建，test数据库已经在MySQL安装的时候预先创建了。连接到 test 数据库的 URL 为 jdbc:mysql://localhost/test。在 Driver Class Name 域中，指定MySQL JDBC 驱动为 com.mysql.jdbc.Driver。MMMySQL 驱动按如图6所示的设置配置。

图 6. 设定 MySQL JDBC 设置

想要连接到 MySQL 数据库并提取其中的表格，我们需要为连接建立一个别名。一个连接的别名说明了连接设置，JDBC 驱动，URL，用户名和密码。在SQLExplorer视窗中选择 Aliases 标签。单击 “Create new Alias” 按扭来创建一个新的别名，如图7所示。

图 7. 创建一个新的别名

在“Create new Alias"框中，指定一个别名。选择MMMySQL Driver 来为MySQL数据库创建一个别名。在 URL 域中指定 test 数据库的连接 URL, jdbc:mysql://localhost/test。图8展示了MySQL 别名的设置。

图 8. 创建一个新的别名

以上操作将一个MySQL的别名加入到 Aliases 标签中，正如图9所示。想要修改一个别名，右击别名结点并选择 “Change the selected Alias.”

图 9. MySQL 别名

MySQL 别名用来连接到 MySQL 数据库并且从中提取数据。要想打开数据库连接，右击 MySQL 别名结点并选择 Open，如图10所示。

图 10. 打开别名

在 Connection 框中，指定登陆到 MySQL 数据库使用的用户名和密码，然后单击 OK 按扭。图11展示了登陆的设置。缺省情况下，对于 root 用户不需要密码。

图 11. 打开连接

一个与 MySQL 数据库的 JDBC 连接就这样建立了。一旦连接上了，Eclipse 就会显示 MySQL 数据库中的不同的数据库模式，如图12所示。

图 12. 列出数据库模式

对其他数据库的支持

这个 JDBC 连接的例子是关于配置与 MySQL 数据库连接的。通过在 Drivers 标签中为数据库选择合适的驱动，可以配置与其他数据库的 JDBC 连接。只需为选定的数据库指定驱动类和连接URL，就可以配置与该数据库的 JDBC 连接。以下列出的是其他数据库的驱动类、连接URL和驱动 .jar 文件。

DB2
o        Driver Class: COM.ibm.db2.jdbc.app.DB2Driver
o        Connection URL: jdbc:db2:<database>
o        Driver .jar/.zip: db2java.zip

Sybase
o        Driver Class: com.sybase.jdbc2.jdbc.SybDriver
o        Connection URL: jdbc:sybase:Tds:<host>:<port>/<database>
o        Driver .jar/.zip: jconn2.jar

Oracle
o        Driver Class: oracle.jdbc.driver.OracleDriver
o        Connection URL: jdbc:oracle:thin:@ <host>:<port>:<sid>
o        Driver .jar/.zip: classes12.zip

SQLServer
o        Driver Class: com.microsoft.jdbc.sqlserver.SQLServerDriver
o        Connection URL: jdbc:microsoft:sqlserver://localhost:1433
o        Driver .jar/.zip: mssqlserver.jar, msbase.jar, msutil.jar

PostgreSQL
o        Driver Class: org.postgresql.Driver
o        Connection URL: jdbc:postgresql://<server>:<port>/<database>
o        Driver .jar/.zip: postgresql.jar

在如上列表中，<database> 是指数据库实例，<port> 是数据库连接端口，<sid> 是数据库的SID，<server> 是数据库服务器。

访问数据库数据
在上一节中我们在 Eclipse 中配置了 SQLExplorer 插件。下面，我们将从示例表 Catalog 中提取并修改数据。如果是从一个命令行 SQL 客户端访问数据库，则使用如下命令来提取数据（在一行中）：

SQL>SELECT catalogId, journal, publisher, date,
title, author from Catalog;

这将以文本表的形式显示数据。使用图形 SQL 客户端 SQLExplorer,数据将以结构表的形式显示。SQLExplorer 同样也会生成创建表和从中提取数据的 SQL 脚本。如果使用 DESC 命令在一个命令行客户端中显示表格的结构，只有列名，列数据的类型，列数据的长度大小以及非空的值会被显示。有了 SQLExplorer, 索引、主键和外键值都会被显示。

在 Eclipse 的 SQLExplorer 视窗中选择 Database Structure View 标签。为了显示表 Catalog 的结构，在 Database Structure View 中选择 Database>test>TABLE>Catalog 结点。图13显示了表 Catalog 的结构。

图 13. Database Structure View

Columns 标签显示了下表中列出的列：

为了显示选中的表格中的数据，请选择 Preview 标签。图14显示了表 Catalog 中的数据。关于表格的其他的信息分别在 Indexes, Primary Key, Foreign Key 和 Row Count 标签中显示。

图 14. 显示表格数据

若想得到创建表格的 SQL 脚本，右击表结点并且选择 Create Table Script,如图15所示。

图 15. 生成建表脚本

如图16所示，这将生成创建被选表格的 SQL 脚本，并将其显示在 SQLExplorer 视窗中的 SQL Editor 中。

图 16. 建表脚本

Database Structure View 的 Preview 标签中的数据是使用缺省的 Select 查询提取的，它包括了表格中所有的列。要想显示缺省的 Select 查询语句，右击表结点并且选择 “Generate Select in Sql Editor”，如图17所示。

图 17. 生成缺省 select 查询语句

如图18所示，SQL Editor 中显示了从表 Catalog 中提取数据的缺省查询语句。注意：显示在 SQL Editor 中的 SELECT 查询语句的结尾没有分号（；）。

图 18. Select 查询语句

查询语句可能被定制为只显示表格中的几列数据。比如，修改 Select 语句使其显示除了 CatalogId 列的其他所有列。选择 Execute SQL 按扭来运行 SQL 脚本。由修改后的 select 语句得到的数据显示在 SQL Results 框中，如图19所示。

图 19. 使用定制的 SELECT 查询语句提取表中数据

接下来，SQL Editor 中的一条 SQL 脚本将会更新表 Catalog。例如，把标题“Five Favorite Features from 5.0”修改为“New Features in JDK 5.0”。如图20所示，在 SQL Editor 中运行更新表 Catalog 的脚本

图 20. 更新 SQL 脚本

表格中数据被更新了。在修改后的表格上运行缺省的 select 查询，修改后的数据将被显示在 SQL Results 框中。图21显示了表 Catalog 修改后的数据。

图 21. 修改表格数据

接着，使用 DELETE SQL语句从表中删除一行数据，如图22所示。CatalogId='3'的行将从表中删除。

图 22. DELETE SQL 脚本

运行缺省的 select 查询语句来显示修改后的表中的数据。SQL Results 框中的表格不再包括被删除的行了，如图23所示。

图 23. 删除了一行后的表格数据

通过在 Eclipse 中配置 SQLExplorer 插件，该集成开发环境获得了图形用户界面（GUI）较之命令行客户端的许多优点。

总结

例子中，我们与 MySQL 数据库建立了一个 JDBC 连接，并访问其中的一个示例数据库。SQL Explorer 同样可以被用来配置与其他数据库的连接，包括 DB2, Sybase, Oracle, HSQLDB, SQL Server 和 PostgreSQL。

作者：baggio785 发表于2006-9-4 13:29:00 原文链接

阅读：11868 评论：1 查看评论

[转]Eclipse SQL Explorer 3 发布

baggio785 — Mon, 04 Sep 2006 13:27:00 +0800

Eclipse SQL Explorer 3 发布了.

SQLExplorer是Eclipse集成开发环境的一种插件，它可以被用来从Eclipse连接到一个数据库。

SQLExplorer插件提供了一个使用SQL语句访问数据库的图形用户接口（GUI）。通过使用SQLExplorer，你能够显示表格、表格结构和表格中的数据，以及提取、添加、更新或删除表格数据。

SQLExplorer同样能够生成SQL脚本来创建和查询表格。所以，与命令行客户端相比，使用SQLExplorer可能是更优越的选择.

新版本有一系列提升.

在Eclipse3.0中配置SQLExplorer访问数据库

官方站点:
http://eclipsesql.sourceforge.net/index.html

作者：baggio785 发表于2006-9-4 13:27:00 原文链接

阅读：8821 评论：0 查看评论

[转]Java多线程程序设计详细解析

baggio785 — Fri, 01 Sep 2006 17:43:00 +0800

一、理解多线程

　　多线程是这样一种机制，它允许在程序中并发执行多个指令流，每个指令流都称为一个线程，彼此间互相独立。

　　线程又称为轻量级进程，它和进程一样拥有独立的执行控制，由操作系统负责调度，区别在于线程没有独立的存储空间，而是和所属进程中的其它线程共享一个存储空间，这使得线程间的通信远较进程简单。

　　多个线程的执行是并发的，也就是在逻辑上“同时”，而不管是否是物理上的“同时”。如果系统只有一个CPU，那么真正的“同时”是不可能的，但是由于CPU的速度非常快，用户感觉不到其中的区别，因此我们也不用关心它，只需要设想各个线程是同时执行即可。

　　多线程和传统的单线程在程序设计上最大的区别在于，由于各个线程的控制流彼此独立，使得各个线程之间的代码是乱序执行的，由此带来的线程调度，同步等问题，将在以后探讨。

　　二、在Java中实现多线程

　　我们不妨设想，为了创建一个新的线程，我们需要做些什么？很显然，我们必须指明这个线程所要执行的代码，而这就是在Java中实现多线程我们所需要做的一切！

　　真是神奇！Java是如何做到这一点的？通过类！作为一个完全面向对象的语言，Java提供了类java.lang.Thread来方便多线程编程，这个类提供了大量的方法来方便我们控制自己的各个线程，我们以后的讨论都将围绕这个类进行。

　　那么如何提供给 Java 我们要线程执行的代码呢？让我们来看一看 Thread 类。Thread 类最重要的方法是run()，它为Thread类的方法start()所调用，提供我们的线程所要执行的代码。为了指定我们自己的代码，只需要覆盖它！

　　方法一：继承 Thread 类，覆盖方法 run()，我们在创建的 Thread 类的子类中重写 run() ,加入线程所要执行的代码即可。下面是一个例子：

　　public class MyThread extends Thread
　　{
　　int count= 1, number;
　　public MyThread(int num)
　　{
　　number = num;
　　System.out.println
　　("创建线程 " + number);
　　}
　　public void run() {
　　while(true) {
　　System.out.println
　　("线程 " + number + ":计数 " + count);
　　if(++count== 6) return;
　　}
　　}
　　public static void main(String args[])
　　{
　　for(int i = 0;
　　i 〈 5; i++) new MyThread(i+1).start();
　　}
　　}
　　
　　这种方法简单明了，符合大家的习惯，但是，它也有一个很大的缺点，那就是如果我们的类已经从一个类继承（如小程序必须继承自 Applet 类），则无法再继承 Thread 类，这时如果我们又不想建立一个新的类，应该怎么办呢？

　　我们不妨来探索一种新的方法：我们不创建Thread类的子类，而是直接使用它，那么我们只能将我们的方法作为参数传递给 Thread 类的实例，有点类似回调函数。但是 Java 没有指针，我们只能传递一个包含这个方法的类的实例。

　　那么如何限制这个类必须包含这一方法呢？当然是使用接口！（虽然抽象类也可满足，但是需要继承，而我们之所以要采用这种新方法，不就是为了避免继承带来的限制吗？）

　　Java 提供了接口 java.lang.Runnable 来支持这种方法。

　　方法二：实现 Runnable 接口

　　Runnable接口只有一个方法run()，我们声明自己的类实现Runnable接口并提供这一方法，将我们的线程代码写入其中，就完成了这一部分的任务。但是Runnable接口并没有任何对线程的支持，我们还必须创建Thread类的实例，这一点通过Thread类的构造函数 public Thread(Runnable target);来实现。下面是一个例子：

　　public class MyThread implements Runnable
　　{
　　int count= 1, number;
　　public MyThread(int num)
　　{
　　number = num;
　　System.out.println("创建线程 " + number);
　　}
　　public void run()
　　{
　　while(true)
　　{
　　System.out.println
　　("线程 " + number + ":计数 " + count);
　　if(++count== 6) return;
　　}
　　}
　　public static void main(String args[])
　　{
　　for(int i = 0; i 〈 5;
　　i++) new Thread(new MyThread(i+1)).start();
　　}
　　}
　　
　　严格地说，创建Thread子类的实例也是可行的，但是必须注意的是，该子类必须没有覆盖 Thread 类的 run 方法，否则该线程执行的将是子类的 run 方法，而不是我们用以实现Runnable 接口的类的 run 方法，对此大家不妨试验一下。

　　使用 Runnable 接口来实现多线程使得我们能够在一个类中包容所有的代码，有利于封装，它的缺点在于，我们只能使用一套代码，若想创建多个线程并使各个线程执行不同的代码，则仍必须额外创建类，如果这样的话，在大多数情况下也许还不如直接用多个类分别继承 Thread 来得紧凑。

　　综上所述，两种方法各有千秋，大家可以灵活运用。

　　下面让我们一起来研究一下多线程使用中的一些问题。

　　三、线程的四种状态

　　1. 新状态：线程已被创建但尚未执行（start() 尚未被调用）。

　　2. 可执行状态：线程可以执行，虽然不一定正在执行。CPU 时间随时可能被分配给该线程，从而使得它执行。

　　3. 死亡状态：正常情况下 run() 返回使得线程死亡。调用 stop()或 destroy() 亦有同样效果，但是不被推荐，前者会产生异常，后者是强制终止，不会释放锁。

　　4. 阻塞状态：线程不会被分配 CPU 时间，无法执行。

　　四、线程的优先级

　　线程的优先级代表该线程的重要程度，当有多个线程同时处于可执行状态并等待获得 CPU 时间时，线程调度系统根据各个线程的优先级来决定给谁分配 CPU 时间，优先级高的线程有更大的机会获得 CPU 时间，优先级低的线程也不是没有机会，只是机会要小一些罢了。

　　你可以调用 Thread 类的方法 getPriority() 和 setPriority()来存取线程的优先级，线程的优先级界于1(MIN_PRIORITY)和10(MAX_PRIORITY)之间，缺省是5(NORM_PRIORITY)。

　　五、线程的同步

　　由于同一进程的多个线程共享同一片存储空间，在带来方便的同时，也带来了访问冲突这个严重的问题。Java语言提供了专门机制以解决这种冲突，有效避免了同一个数据对象被多个线程同时访问。

　　由于我们可以通过 private 关键字来保证数据对象只能被方法访问，所以我们只需针对方法提出一套机制，这套机制就是 synchronized 关键字，它包括两种用法：synchronized 方法和 synchronized 块。

　　1. synchronized 方法：通过在方法声明中加入 synchronized关键字来声明 synchronized 方法。如：

　　public synchronized void accessVal(int newVal);
　　
　　 synchronized 方法控制对类成员变量的访问：每个类实例对应一把锁，每个 synchronized 方法都必须获得调用该方法的类实例的锁方能执行，否则所属线程阻塞，方法一旦执行，就独占该锁，直到从该方法返回时才将锁释放，此后被阻塞的线程方能获得该锁，重新进入可执行状态。

　　这种机制确保了同一时刻对于每一个类实例，其所有声明为 synchronized 的成员函数中至多只有一个处于可执行状态（因为至多只有一个能够获得该类实例对应的锁），从而有效避免了类成员变量的访问冲突（只要所有可能访问类成员变量的方法均被声明为 synchronized）。

　　在 Java 中，不光是类实例，每一个类也对应一把锁，这样我们也可将类的静态成员函数声明为 synchronized ，以控制其对类的静态成员变量的访问。

　　synchronized 方法的缺陷：若将一个大的方法声明为synchronized 将会大大影响效率，典型地，若将线程类的方法 run() 声明为 synchronized ，由于在线程的整个生命期内它一直在运行，因此将导致它对本类任何 synchronized 方法的调用都永远不会成功。当然我们可以通过将访问类成员变量的代码放到专门的方法中，将其声明为 synchronized ，并在主方法中调用来解决这一问题，但是 Java 为我们提供了更好的解决办法，那就是 synchronized 块。

　　2. synchronized 块：通过 synchronized关键字来声明synchronized 块。语法如下：

　　synchronized(syncObject)
　　{
　　//允许访问控制的代码
　　}
　　
　　synchronized 块是这样一个代码块，其中的代码必须获得对象 syncObject （如前所述，可以是类实例或类）的锁方能执行，具体机制同前所述。由于可以针对任意代码块，且可任意指定上锁的对象，故灵活性较高。

　　六、线程的阻塞

　　为了解决对共享存储区的访问冲突，Java 引入了同步机制，现在让我们来考察多个线程对共享资源的访问，显然同步机制已经不够了，因为在任意时刻所要求的资源不一定已经准备好了被访问，反过来，同一时刻准备好了的资源也可能不止一个。为了解决这种情况下的访问控制问题，Java 引入了对阻塞机制的支持。

　　阻塞指的是暂停一个线程的执行以等待某个条件发生（如某资源就绪），学过操作系统的同学对它一定已经很熟悉了。Java 提供了大量方法来支持阻塞，下面让我们逐一分析。

　　1. sleep() 方法：sleep() 允许指定以毫秒为单位的一段时间作为参数，它使得线程在指定的时间内进入阻塞状态，不能得到CPU 时间，指定的时间一过，线程重新进入可执行状态。典型地，sleep() 被用在等待某个资源就绪的情形：测试发现条件不满足后，让线程阻塞一段时间后重新测试，直到条件满足为止。

　　2. suspend() 和 resume() 方法：两个方法配套使用，suspend()使得线程进入阻塞状态，并且不会自动恢复，必须其对应的resume() 被调用，才能使得线程重新进入可执行状态。典型地，suspend() 和 resume() 被用在等待另一个线程产生的结果的情形：测试发现结果还没有产生后，让线程阻塞，另一个线程产生了结果后，调用 resume() 使其恢复。

　　3. yield() 方法：yield() 使得线程放弃当前分得的 CPU 时间，但是不使线程阻塞，即线程仍处于可执行状态，随时可能再次分得 CPU 时间。调用 yield() 的效果等价于调度程序认为该线程已执行了足够的时间从而转到另一个线程。

　　4. wait() 和 notify() 方法：两个方法配套使用，wait() 使得线程进入阻塞状态，它有两种形式，一种允许指定以毫秒为单位的一段时间作为参数，另一种没有参数，前者当对应的 notify() 被调用或者超出指定时间时线程重新进入可执行状态，后者则必须对应的 notify() 被调用。

　　初看起来它们与 suspend() 和 resume() 方法对没有什么分别，但是事实上它们是截然不同的。区别的核心在于，前面叙述的所有方法，阻塞时都不会释放占用的锁（如果占用了的话），而这一对方法则相反。

　　上述的核心区别导致了一系列的细节上的区别。

　　首先，前面叙述的所有方法都隶属于 Thread 类，但是这一对却直接隶属于 Object 类，也就是说，所有对象都拥有这一对方法。初看起来这十分不可思议，但是实际上却是很自然的，因为这一对方法阻塞时要释放占用的锁，而锁是任何对象都具有的，调用任意对象的 wait() 方法导致线程阻塞，并且该对象上的锁被释放。

　　而调用任意对象的notify()方法则导致因调用该对象的 wait() 方法而阻塞的线程中随机选择的一个解除阻塞（但要等到获得锁后才真正可执行）。

　　其次，前面叙述的所有方法都可在任何位置调用，但是这一对方法却必须在 synchronized 方法或块中调用，理由也很简单，只有在synchronized 方法或块中当前线程才占有锁，才有锁可以释放。

　　同样的道理，调用这一对方法的对象上的锁必须为当前线程所拥有，这样才有锁可以释放。因此，这一对方法调用必须放置在这样的 synchronized 方法或块中，该方法或块的上锁对象就是调用这一对方法的对象。若不满足这一条件，则程序虽然仍能编译，但在运行时会出现 IllegalMonitorStateException 异常。

　　wait() 和 notify() 方法的上述特性决定了它们经常和synchronized 方法或块一起使用，将它们和操作系统的进程间通信机制作一个比较就会发现它们的相似性：synchronized方法或块提供了类似于操作系统原语的功能，它们的执行不会受到多线程机制的干扰，而这一对方法则相当于 block 和wakeup 原语（这一对方法均声明为 synchronized）。

　　它们的结合使得我们可以实现操作系统上一系列精妙的进程间通信的算法（如信号量算法），并用于解决各种复杂的线程间通信问题。关于 wait() 和 notify() 方法最后再说明两点：

　　第一：调用 notify() 方法导致解除阻塞的线程是从因调用该对象的 wait() 方法而阻塞的线程中随机选取的，我们无法预料哪一个线程将会被选择，所以编程时要特别小心，避免因这种不确定性而产生问题。

　　第二：除了 notify()，还有一个方法 notifyAll() 也可起到类似作用，唯一的区别在于，调用 notifyAll() 方法将把因调用该对象的 wait() 方法而阻塞的所有线程一次性全部解除阻塞。当然，只有获得锁的那一个线程才能进入可执行状态。

　　谈到阻塞，就不能不谈一谈死锁，略一分析就能发现，suspend() 方法和不指定超时期限的 wait() 方法的调用都可能产生死锁。遗憾的是，Java 并不在语言级别上支持死锁的避免，我们在编程中必须小心地避免死锁。

　　以上我们对 Java 中实现线程阻塞的各种方法作了一番分析，我们重点分析了 wait() 和 notify()方法，因为它们的功能最强大，使用也最灵活，但是这也导致了它们的效率较低，较容易出错。实际使用中我们应该灵活使用各种方法，以便更好地达到我们的目的。

　　七、守护线程

　　守护线程是一类特殊的线程，它和普通线程的区别在于它并不是应用程序的核心部分，当一个应用程序的所有非守护线程终止运行时，即使仍然有守护线程在运行，应用程序也将终止，反之，只要有一个非守护线程在运行，应用程序就不会终止。守护线程一般被用于在后台为其它线程提供服务。

　　可以通过调用方法 isDaemon() 来判断一个线程是否是守护线程，也可以调用方法 setDaemon() 来将一个线程设为守护线程。

　　八、线程组

　　线程组是一个 Java 特有的概念，在 Java 中，线程组是类ThreadGroup 的对象，每个线程都隶属于唯一一个线程组，这个线程组在线程创建时指定并在线程的整个生命期内都不能更改。

　　你可以通过调用包含 ThreadGroup 类型参数的 Thread 类构造函数来指定线程属的线程组，若没有指定，则线程缺省地隶属于名为 system 的系统线程组。

　　在 Java 中，除了预建的系统线程组外，所有线程组都必须显式创建。在 Java 中，除系统线程组外的每个线程组又隶属于另一个线程组，你可以在创建线程组时指定其所隶属的线程组，若没有指定，则缺省地隶属于系统线程组。这样，所有线程组组成了一棵以系统线程组为根的树。

　　Java 允许我们对一个线程组中的所有线程同时进行操作，比如我们可以通过调用线程组的相应方法来设置其中所有线程的优先级，也可以启动或阻塞其中的所有线程。

　　Java 的线程组机制的另一个重要作用是线程安全。线程组机制允许我们通过分组来区分有不同安全特性的线程，对不同组的线程进行不同的处理，还可以通过线程组的分层结构来支持不对等安全措施的采用。

　　Java 的 ThreadGroup 类提供了大量的方法来方便我们对线程组树中的每一个线程组以及线程组中的每一个线程进行操作。

　　九、总结

　　在本文中，我们讲述了 Java 多线程编程的方方面面，包括创建线程，以及对多个线程进行调度、管理。我们深刻认识到了多线程编程的复杂性，以及线程切换开销带来的多线程程序的低效性，这也促使我们认真地思考一个问题：我们是否需要多线程？何时需要多线程？

　　多线程的核心在于多个代码块并发执行，本质特点在于各代码块之间的代码是乱序执行的。我们的程序是否需要多线程，就是要看这是否也是它的内在特点。

　　假如我们的程序根本不要求多个代码块并发执行，那自然不需要使用多线程；假如我们的程序虽然要求多个代码块并发执行，但是却不要求乱序，则我们完全可以用一个循环来简单高效地实现，也不需要使用多线程；只有当它完全符合多线程的特点时，多线程机制对线程间通信和线程管理的强大支持才能有用武之地，这时使用多线程才是值得的。

作者：baggio785 发表于2006-9-1 17:43:00 原文链接

阅读：9629 评论：2 查看评论

[转]方便 Ajax 与 Java EE 的集成

baggio785 — Fri, 01 Sep 2006 17:41:00 +0800

Patrick Gan (patgan@us.ibm.com), 应用程序卓越创新服务中心的高级 IT 专家, IBM

Asynchronous JavaScript + XML （Ajax）是个相当新的术语（有些人说它是旧酒装新瓶），在不同的 Web 开发社区中，都引起了很大的争议，其中包括 Java EE 社区。Ajax 技术通过消除过多的 Web 页面刷新，提高了应用程序的可用性。而且 Ajax 二者通吃的技术，同时利用了客户端和服务器端代码，向 Web 用户呈现了几乎无缝的用户界面。Ajax 被鼓吹成 Web 开发复兴（或称为 Web 2.0）的一个主要推动者。

作为用心的 Java EE 开发人员，您可能已经阅读了许多关于 Ajax 的 how-to 文章，并对它会给应用程序带来的可能改进而兴奋。但是 Ajax 基于异步通信的模式要怎样才适合您的 Java EE 应用程序呢？这篇文章通过研究在 Java EE 应用程序的设计、开发、执行和测试各阶段引入 Ajax 会带来的影响，将帮助您回答这个问题。我的目的不是不鼓励使用 Ajax 或者暗示您可能遇到的问题是 Ajax 技术固有的问题。相反，我是为了帮助您规划并减轻这些问题，好让您更有效而顺利地利用 Ajax。

解决设计缺陷

相当一段时间以来，Java 社区一直在努力把好的设计模式应用到与 Web 有关的应用程序开发上。其中使用最广泛的一个模式就是模型-视图-控制器（MVC）。一些开放源码框架，例如 Apache Struts，就基于这个设计模式/架构（请参阅参考资料）。MVC 的众多优势包括：问题隔离 和减少冗余代码。

问题隔离在整个应用程序架构中使用预先协商好的接口，从而让应用程序开发项目中的每个开发人员都专注于自己特定的角色。例如，模型层的开发人员侧重于 JDBC、企业 JavaBean（EJB）组件或者与底层数据持久技术接口的 Java 类这一类的技术。视图层开发人员侧重于 Java 服务器页面（JSP）技术、标记库和其他与表示有关的技术。控制器层隔离及协调模型和视图，把进入的请求路由到后端持久性调用，同时维护问题的清晰隔离。图 1 演示了 MVC 架构：

图 1. MVC 架构

把 Ajax 引入 Java EE Web 应用程序对于问题的隔离（以及开发人员角色的隔离）是有意义的。在某些情况下，Ajax 会把大量 JavaScript 代码带回视图层（JSP）页面。表 1 描述了没有 Ajax 的视图层，还指出了需要的代码（假设控制器层由 servlet 实现，视图层由 JSP 技术实现。（在下一节处理开发困境我将解释同步和异步请求的区别。）

表 1. 没有 Ajax 的 MVC：与典型的视图层序列有关的代码数量

序列	说明	要求代码？
在调用同步请求之前	准备表单提交需要的脚本代码	否
调用异步请求	由按钮或链接调用引起表单提交；DOM 元素的值自动设置到 `HttpRequest`（通过 `GET` 或 `POST`）。	否：所需要的只是调用页面提交的途径。
处理同步请求的响应	在服务器端代码执行完成后，通常会向 JSP 发送回一个对象（通过 `HttpRequest` 或保存在 `HttpSession` 中）。这时，在 JSP 中可以通过 `HttpRequest` 或 `HttpSession` 访问这个对象（通过脚本或某些标记库），只需要编写极少的脚本就可以显示对象的内容。	是：最少的脚本。

对比表 1 和表 2，表 2 描述了有 Ajax 的 MVC 视图层，同样假设控制层由 servlet 实现，视图层由 JSP 技术实现。

表 2. 有 Ajax 的 MVC：与典型的视图层序列有关的代码数量

序列	说明	需要代码？
在调用异步请求之前	需要用 JavaScript 代码检索出 Ajax 调用需要的 DOM 元素的值。	是
调用异步请求	需要用 JavaScript 代码创建 `XMLHTTPRequest` 并把（以前搜集的）DOM 元素值与之关联并发送（`XMLHTTPRequest.send()`）。	是
处理异步请求的响应	在服务器端代码执行完成后，要用 JavaScript 代码得到请求（从 XML 响应流中）并把值相应地填充到适当的 DOM 元素。	是

可以看出，由于使用了 Ajax，视图层的脚本编写量增加了，从而导致三个明显缺陷：

JSP 要求大量的 JavaScript 代码。
这个设计破坏了角色问题的隔离。
设计重新带回了单一 JSP（模式 1 方法：一堆 HTML、CSS 代码、图片和脚本代码），这是一种反模式，极难阅读和维护（请参阅参考资料）。

有几个选项可以避免或者至少减轻这些设计缺陷：

设计时脑子里记着重用：不幸的是，编写特定于 Ajax 支持的代码通常很难避免。请计划和设计脚本代码，以便能够最大限度地重用它。
采用客户端 MVC 方法：可以合并使用客户端 MVC 方法，详见 Dave Crane 等编写的 Ajax in Action（请参阅参考资料）。这种方法可以促进问题的隔离，但是增加了复杂性，所以使用的时候要仔细考虑。
使用 Ajax 框架：存在多个开放源码的 Ajax 框架，例如 Direct Web Remoting （DWR）（请参阅参考资料），它们做了很好的工作，可以用最少的编码，就把 Ajax 模式集成到 Java EE 应用程序。
重新评估设计的正确性：实际上，Ajax 为 Web 应用程序提供了桌面应用程序的属性。如果一个 Web 应用程序中大多数客户端交互都利用 Ajax，那么这个应用程序可能最好设计成桌面应用程序。

处理开发困境

在 Java Web 开发中使用 Ajax 时，重要的是完整理解同步和异步通信模型的区别（请参阅参考资料）。对异步通信模型支持的缺乏，会对客户端开发、与 Web 框架的集成、标记库的使用、IDE 的使用以及线程的行为有影响。

在同步请求/响应通信模型中，总是浏览器（与 Web 服务器、应用服务器或 Web 应用程序相对）发起请求（通过 Web 用户）。接着，Web 服务器、应用服务器或 Web 应用程序响应进入的请求。在处理同步请求/响应对期间，用户不能继续使用浏览器。

图 2 中的序列图演示了传统 Web 应用程序的同步通信模型。请注意在服务器的生命线上，来自客户机的数据提交和服务器端的处理是紧密耦合的。

图 2. 同步通信序列

在异步请求/响应通信模型中，浏览器（通过 Web 用户）到 Web 服务器、应用服务器或 Web 应用程序的通信（以及反过来）是解耦的。在异步请求/响应对的处理中，Web 用户在当前异步请求被处理时还可以继续使用浏览器。一旦异步请求处理完成，异步响应就被通信（从 Web 服务器、应用服务器或 Web 应用程序）回客户机页面。典型情况下，在这个过程中，调用对 Web 用户没有影响；他们不需要等候响应。

图 3 的序列图演示了异步通信模型。请注意第一个 dataSubmission （由服务器端处理）和第一个返回的 dataSubmission，两个都用红圈圈上了。这些序列是解耦的。这个图示还强调了一个重要方面（后面将详细介绍，请参阅线程问题）：在这个模型中，可以发生多个提交（线程）。

图 3. 异步通信序列

客户端影响

在向 Web 应用程序引入 Ajax 时，开发团队需要注意几个风险，主要与生成的 HTML 页面及其与浏览器的交互方式有关。这些问题在 Chris Laffra 两部分的 Considering Ajax 系列中有详细介绍（请参阅参考资料）。有些需要记住的要点是：

可能没打开脚本功能：出于各种原因，在许多用户的浏览器上禁止了 JavaScript 支持。
跨浏览器支持增加了代码需求：支持多种浏览器和多个浏览器版本的应用程序，要求的脚本代码可能会增多，因为浏览器解释 DOM 对象的方式有细微的差异（所以操作这些元素的 JavaScript 代码也有差异）。
JavaScript 不安全：在多数浏览器中，可以选择查看源代码选项，查看到与 HTML 页面关联的 JavaScript 源代码。在使用 Ajax 模式时，要确保脚本代码中实现的逻辑不是敏感逻辑。

与 Web 框架集成

试着把 Ajax 开发与所选的 Java EE Web 框架集成，是很自然的。但是有些 Java EE Web 框架对异步通信模型提供直接可以使用的支持。要体会这个事实的意义，需要理解 servlet 处理同步和异步通信的方式。图 4 显示了处理同步请求的传统 servlet 序列：

图 4. 处理同步请求的 Servlet 序列

图 4 对于 Java EE Web 开发人员来说应当相当熟悉。来自浏览器的请求先由控制器 servlet 的 service() 处理。servlet 可以从 HttpRequest 检索到需要的任何值（以参数的形式或者以属性的形式）。一旦控制器处理完成，结果就发送回 HttpRequest （或 HttpSession），而 RequestDispatcher 则把控制转发（或包含）回页面。

图 5 显示了处理异步请求的 servlet 序列：

图 5. 处理异步请求的 Servlet 序列

图 5 中的序列与同步序列略有不同。来自浏览器的请求先由控制器 servlet 的 service() 处理。servlet 可以从 HttpRequest 检索到需要的任何值（以参数的形式或者以属性的形式）。一旦控制器处理完成，HttpServletResponse 的内容类型必须设置成 XML。而且，控制器逻辑的结果要用 PrintWriter 写入。这时，RequestDispatcher 的使用被越过。

这个（异步序列）恰恰是多数 Java EE Web 框架不支持的，从而造成与 Ajax 的集成非常困难。不支持异步通信模型的 Portlet 和 JavaServer Faces （JSF）框架面临着同样的问题。

克服这个问题也有一些选项：

与 Web 框架并存： 不必等待内置的 Ajax 支持或者在所选的框架中强行实现 Ajax 支持，可以使用独立的 servlet 来处理全部异步请求。DWR 就使用了这种方式。这种方式的不足在于 Ajax 请求不能方便地利用框架的特性。
与 Web 框架集成：通过使用免费的扩展或编写定制的扩展，可以设计出与所选 Web 框架集成的途径。
迁移到支持 Ajax 的框架：更新的框架开始支持异步通信模型。其中一个是 Apache Shale（请参阅参考资料）。

使用标记库

大量使用标记库（taglib）在 Java 的 Web 应用程序开发中是很普遍的。像许多 Java EE Web 框架一样，有些标记库现在也不支持异步通信模型，没有把通过 XMLHttpRequest 提交的数据转换成 HttpServletRequest （以及反过来）的途径。实际上，不支持异步通信的标记库，在 Ajax XMLHttpRequest 调用期间不工作。可用的选项有：

放弃使用不支持异步模型的标记库：把现在由标记库生成的代码迁移到 HTML/JavaScript 代码。（如果 Web 应用程序高度依赖标记库，这种方式最终会造成视图层页面尺寸的增大。）
解决问题：使用已经解决了这个问题的 Ajax 框架。示例之一就是 DWR（请参阅 ExecutionContext.forwardToString()）。在这种情况下，可以继续使用以前一直使用的标记库。
使用支持 Ajax 的标记库：使用支持异步模型的标记库，例如 Ajax JSP 标记库（AjaxTags）（请参阅参考资料）。

用 IDE 进行开发与调试

有许多 JavaScript 调试工具可以帮助开发人员开发 JavaScript 解决方案。但是，传统的 Java 开发环境不允许检查 XMLHTTPRequest 和与 Ajax 相关的其他东西的值。

一个解决方案是利用 AJAX Toolkit Framework（ATF）（请参阅参考资料）。ATF 是个 Eclipse 插件，带有增强的 JavaScript 编辑特性，例如编辑时语法检查，内嵌的 Mozilla Web 浏览器，内嵌的 DOM 浏览器，内嵌的 JavaScript 调试器。ATF 还包含 Personality Builder 功能，这个功能可以帮助任何 Ajax 运行时框架构建 IDE 特性，从而加入到 ATF 支持的运行时环境集中。

线程问题

在典型的同步 Web 应用程序中，有些领域对按钮或链接点击要求更长一点的处理时间。没有耐心和没经验的 Web 用户通常会不止一次地点击按钮或链接，以为可以帮助加快处理速度，从而引发多重表单提交。其他时候，用户认为需要双击（就像桌面应用程序那样）。Web 应用程序中的多重表单提交在某些情况下是无害的。而在其他情况下，副作用可能造成严重的线程问题或争用情况（此时多个线程竞争执行一个代码块）。例如，在银行应用程序中多次点击转帐按钮，可能造成不希望的多次转帐。

既支持同步通信模型又支持异步通信模型的 Web 应用程序会发现，如果它的功能没有正确分析和规划，那么自己就处在了相似的困境中。支持两种通信模型的应用程序在某个页面上可能混合了服务器端调用（即，或者同步，或者异步，或者混合了同步和异步）。就像在多重点击场景中一样，异步调用可能处理得慢些。如果应用程序不做预防，用户可能会在异步线程正在处理时又调用了一个同步调用，因为页面没有刷新，所以无法阻止页面上的进一步活动。结果是两个线程并发处理。虽然不是由 Web 页面上的同一按钮或链接引发，这类情况还是会造成服务器端的线程问题（与多重点击问题类似）。

例如，以图 6 所示的银行应用程序的转账页面为例：

图 6. 转帐示例

对于这个示例，用红色表示的转账按钮引发一个 Ajax 调用。退出链接（黄色）引发同步调用。如果不耐烦或没有经验的用户点击了红色按钮之后接着又点击黄色链接（假设两个链接在代码中有共同的路径），就会发生争用情况。

一般来说，有两种方式可以避免这类情况发生。第一种方式是客户端解决方案。一旦点击了一个链接或按钮，就用 JavaScript 确保禁止后续的页面提交，直到当前线程执行完成。第二个解决方案是允许多线程提交，但是依赖于服务器端代码中的同步来避免争用情况。如果引入同步来解决这个问题，请记住 Java EE Web 组件（servlet、portlet、JSF 等）是多线程的。要当心大段代码的同步（特别是与请求/响应生命周期处理有关的代码）。在效果上，同步的误用，会把应用程序变成单线程应用程序，从而降低吞吐率。

克服性能缺陷

使用 Ajax 还有可能影响基于 Java EE Web 的应用程序的性能。允许每个请求上有额外线程的可能性，可能会影响两个资源。

首先，servlet 容器的线程池 可能受到影响。线程池指定 Web 容器中允许并发运行的线程的最大数量。每个客户机请求需要一个线程。但是，一个客户机请求不一定等于一个用户请求。浏览器可能为一个用户请求要求多个客户机请求。例如，提交表单的一个用户可能要求多个客户机请求（其中包含提交表单的值、检索 GIF 文件、检索 JavaScript 文件、检索 CSS 文件）。如果允许并发地提交同步和异步请求，就意味着每个用户请求至少要支持多出一个的线程消耗（用于 Ajax 请求）。虽然为每个用户请求多增加一个线程的可能性看起来不多，但是当应用程序处在负载之下时，影响就明显了（这时每个用户请求多出的一个额外线程乘上平均用户数量）。显示，这种情况有可能影响 servlet 容器的性能。

另一个可能受影响的资源是数据库连接池。典型的 Java EE Web 应用程序支持一个用户请求的两类序列：浅（shallow）请求和 深（deep）请求。浅请求是执行服务器端代码但是不访问持久性存储（例如数据库）就完成请求的 Web 页面发出的请求。深请求是执行服务器端代码并访问持久性存储才能完成请求的 Web 页面发出的请求。

在深请求序列中（假设需要数据库连接），数据库连接池的这些方面可能会由于允许多个线程而受到影响：

等待连接的线程的平均数量
以毫秒为单位的连接的平均等候时间
连接被使用的平均时间

所以，可能需要提高连接池的平均大小或连接数量。

对付测试

Java 开发人员一直在不断地努力为 Java SE 和 Java EE 代码提供单元测试工具。由于 Ajax 的引入造成浏览器内的 JavaScript 增多，对可靠的 JavaScript 单元测试框架也提出了要求。现在可用的框架有 JsUnit、Selenium 和 HttpUnit（请参阅参考资料）。

这些框架提供了为 JavaScript 函数开发单元测试的工具，可以操纵 Web 页面上的 DOM 元素。它们允许把单元测试组织成测试套件。Selenium 的浏览器兼容性测试特性允许在不同的浏览器和操作系统上测试 JavaScript 函数。它利用 JavaScript 和 Iframe 在浏览器中嵌入了测试自动引擎。这项技术应当可以在任何支持 JavaScript 的浏览器中工作，对于支持多个浏览器和浏览器版本的应用程序来说特别有用。Selenium 和 JsUnit 都支持持续集成：可以把 JavaScript 单元测试和测试套件集成到自动构建过程。

结束语

把 Ajax —— 就像其他技术或模式一样 —— 引入 Java EE 应用程序，也有它的优势和不足。本文提供了把 Ajax 集成到 Java EE Web 应用程序的概述。Ajax 的异步通信模型与传统 Java EE Web 应用程序内置就支持的同步模型有很大不同。为了避免盲目，请确保在采用 Ajax 之前对潜在的问题领域有全面的事前规划。

Java EE 框架对 Ajax 的支持和工具在不断改进。未来有望会有框架自带的 Ajax 支持来降低集成的复杂性。基于 JSF 的 Apache Shale 和基于 servlet 的 DWR 是两个希望您保持关注的框架。

作者：baggio785 发表于2006-9-1 17:41:00 原文链接

阅读：9621 评论：1 查看评论