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

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

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

    hk2000c技術專欄

    技術源于哲學,哲學來源于生活 關心生活,關注健康,關心他人

      BlogJava :: 首頁 :: 新隨筆 :: 聯(lián)系 :: 聚合  :: 管理 ::
      111 隨筆 :: 1 文章 :: 28 評論 :: 0 Trackbacks

    2008年4月12日 #

    posted @ 2014-04-21 21:33 hk2000c 閱讀(188) | 評論 (0)編輯 收藏

    許多年以來,對于軟件項目,企業(yè)軟件開發(fā)的主流實踐一直都傾向于在單一的通用編程語言上進行標準化,從而使得Java和C#成為今天編程語言的主流選擇。隨著越來越多的目光開始投向DSL,也許我們的前腳已經(jīng)踏在了一道新的門檻之上,向前望去,我們會發(fā)現(xiàn)在軟件項目中采用多種語言已經(jīng)成為一個標準,但80年代和90年代初出現(xiàn)的問題不會重現(xiàn)。

    Martin Fowler提出,也許我們正在邁進這樣的一個新時期

    [……]在這個時期內,我們將見證多種語言在同一個項目上的應用,人們就像現(xiàn)在選擇框架一樣,根據(jù)功能來選擇相應的語言。

    Fowler稱:“像Hibernate、Struts和ADO這樣的大型框架,給人們在學習上帶來的挑戰(zhàn),絕不亞于學習一門語言,即便你在單一一門宿主語言上使用這些框架編程也是如此。”此外,在它們的宿主語言中表述需求的難度可能會相當大,并可能引出笨拙難用的配置文件,“這些配置文件實際上就是使用XML寫的外部領域特定語言”。

    在語言中嵌入DSL,而不是使用類庫,可能會是一個更為合適的解決方案。Martin給出了這樣的一個分析結論:“API就好比是在聲明一個詞匯表,而DSL則為其增加了相應的語法,使得人們能夠寫出條理清晰的句子。”因此,使用DSL而不是框架會使代碼豐富表現(xiàn)力,為人們帶來“更良好的抽象處理方式”,并使“閱讀我們寫出的代碼及對我們意圖的展示變得更加容易”。

    Piers Cawley稱,DSL的主要特性并非其可讀性,而是“它們對去相應領域的高度專注”使得它們能夠更加明確地表義。Cawley為了闡述他的觀點舉了一個例子,說明DSL不僅僅能讓我們“寫出讀起來像領域專家說出來的話一樣的程序”,也可以很技術化,用來代表一個使用它們的語法進行操控的框架。

    Neal Ford也相信,被他稱為多語言編程(Polyglot Programming)的勢頭正在興起。在軟件開發(fā)的這個新紀元中,日益明顯的主要特征就是嵌入更多的語言,使人們能夠“為所做的菜選擇一把恰到好處的刀,并且恰如其分地使用它”。他舉了一個例子,展示在Java編程語言中并行類庫的使用難度,并將其與Haskell作比。Haskell是一門函數(shù)式語言,“消除了變量所帶來的副作用”,并使“編寫線程安全的代碼”變得更容易。Ford強調說,Java和.NET平臺都存在Haskell語言的實現(xiàn)(Jaskell和Haskell.net)。

    不再使用單一語言進行開發(fā)所帶來的風險之一可能讓80年代末90年代初所出現(xiàn)的問題又再次重現(xiàn),當時語言就是完全獨立的平臺,既不能互操作也不能放在一起良好地使用。Martin Fowler指出,現(xiàn)在的情況有這樣的一個重要區(qū)別:

    在80年代末期,人們很難讓各個語言之間緊密地互操作。這些年來,人們花了很大精力創(chuàng)建出可以讓不同語言緊密共存的環(huán)境。腳本語言在傳統(tǒng)上與C語言有著很密切的關系。在JVM和CLR平臺上也有人為互操作花費了大量精力。另外人們也在類庫上投入了很多人力物力,為的是讓語言忽視類庫的存在。

    最終,要學習并使用多種語言,對于業(yè)界乃至開發(fā)人員都可能會變成一項重要資產(chǎn)。《Pragmatic Programmers》這本書里面就說到,由于這樣做會對人們對編程的思考方式產(chǎn)生影響,因此這樣能幫助人們發(fā)現(xiàn)解決問題的新途徑。

    您是怎樣認為的呢?在下去的五年中,我們會開始混合使用語言,并像用類庫一樣頻繁地使用DSL嗎?

    posted @ 2011-11-10 05:56 hk2000c 閱讀(318) | 評論 (0)編輯 收藏

         摘要: java 裝載 groovy 方法  閱讀全文
    posted @ 2011-11-10 05:45 hk2000c 閱讀(745) | 評論 (0)編輯 收藏

         摘要: java 和groovy 集成

      閱讀全文
    posted @ 2011-11-10 05:37 hk2000c 閱讀(1064) | 評論 (0)編輯 收藏

    AspectJ

     

          AspectJ是一個面向切面的框架,它擴展了Java語言。AspectJ定義了AOP語法所以它有一個專門的編譯器用來生成遵守Java字節(jié)編碼規(guī)范的Class文件


    一、AspectJ概述

    圖1 :FigureEditor例子的UML

          AspectJ(也就是AOP)的動機是發(fā)現(xiàn)那些使用傳統(tǒng)的編程方法無法很好處理的問題。考慮一個要在某些應用中實施安全策略的問題。安全性是貫穿于系統(tǒng)所有模塊間的問題,每個模塊都需要應用安全機制才能保證整個系統(tǒng)的安全性,很明顯這里的安全策略的實施問題就是一個橫切關注點,使用傳統(tǒng)的編程解決此問題非常的困難而且容易產(chǎn)生差錯,這就正是AOP發(fā)揮作用的時候了。

          傳統(tǒng)的面向對象編程中,每個單元就是一個,而類似于安全性這方面的問題,它們通常不能集中在一個類中處理因為它們橫跨多個類,這就導致了代碼無法重用,可維護性差而且產(chǎn)生了大量代碼冗余,這是我們不愿意看到的。

          面向方面編程的出現(xiàn)正好給處于黑暗中的我們帶來了光明,它針對于這些橫切關注點進行處理,就好象面向對象編程處理一般的關注點一樣。而作為AOP的具體實現(xiàn)之一的AspectJ,它向Java中加入了連接點(Join Point)這個新概念,其實它也只是現(xiàn)存的一個Java概念的名稱而已。它向Java語言中加入少許新結構:切點(pointcut)、通知(Advice)、類型間聲明(Inter-type declaration)和方面(Aspect)。切點和通知動態(tài)地影響程序流程,類型間聲明則是靜態(tài)的影響程序的類等級結構,而方面則是對所有這些新結構的封裝。

          一個連接點是程序流中指定的一點。切點收集特定的連接點集合和在這些點中的值。一個通知是當一個連接點到達時執(zhí)行的代碼,這些都是AspectJ的動態(tài)部分。其實連接點就好比是程序中的一條一條的語句,而切點就是特定一條語句處設置的一個斷點,它收集了斷點處程序棧的信息,而通知就是在這個斷點前后想要加入的程序代碼。AspectJ中也有許多不同種類的類型間聲明,這就允許程序員修改程序的靜態(tài)結構、名稱、類的成員以及類之間的關系。AspectJ中的方面是橫切關注點的模塊單元。它們的行為與Java語言中的類很象,但是方面還封裝了切點、通知以及類型間聲明。

    動態(tài)連接點模型

          任何面向方面編程的關鍵元素就是連接點模型。AspectJ提供了許多種類的連接點集合,但是本篇只介紹它們中的一個:方法調用連接點集(method call join points)。一個方法調用連接點捕捉對象的方法調用。每一個運行時方法調用都是一個不同的連接點,許多其他的連接點集合可能在方法調用連接點執(zhí)行時運,包括方法執(zhí)行時的所有連接點集合以及在方法中其他方法的調用。我們說這些連接點集合在原來調用的連接點的動態(tài)環(huán)境中執(zhí)行。

     

    切點

           在AspectJ中,切點捕捉程序流中特定的連接點集合。例如,切點

                  call(void Point.setX(int))

    捕捉每一個簽名為void Point.setX(int)的方法調用的連接點,也就是說,調用Point對象的有一個整型參數(shù)的void setX方法。切點能與其他切點通過或(||)、與(&&)以及非(!)操作符聯(lián)合。例如 call(void Point.setX(int)) || call(void Point.setY(int)) 捕捉setX或setY調用的連接點。切點還可以捕捉不同類型的連接點集合,換句話說,它們能橫切類型。例如

           call(void FigureElement.setXY(int,int)) || call(void Point.setX(int))

           || call(void Point.setY(int) || call(void Line.setP1(Point))

           || call(void Line.setP2(Point));

    捕捉上述五個方法調用的任意一個的連接點集合。它在本文的例子中捕捉當FigureElement移動時的所有連接點集合。AspectJ使程序員可以命名一個切點集合,以便通知的使用。例如可以為上面的那些切點命名

    pointcut move():

    call(void FigureElement.setXY(int,int)) || call(void Point.setX(int))

    || call(void Point.setY(int)) || call(void Line.setP1(Point)) || call(void Line.setP2(Point));

    無論什么時候,程序員都可以使用move()代替捕捉這些復雜的切點。

           前面所說的切點都是基于顯示的方法簽名,它們稱為基于名字(name-based)橫切。AspectJ還提供了另一種橫切,稱為基于屬性(property-based)的橫切。它們可以使用通配符描述方法簽名,例如 call(void Figure.make*(..)) 捕捉Figure對象中以make開頭的參數(shù)列表任意的方法調用的連接點。而 call(public & Figure.*(..)) 則捕捉Figure對象中的任何公共方法調用的連接點。但是通配符不是AspectJ支持的唯一屬性,AspectJ中還有許多其他的屬性可供程序員使用。例如cflow,它根據(jù)連接點集合是否在其他連接點集合的動態(tài)環(huán)境中發(fā)生標識連接點集合。例如 cflow(move()) 捕捉被move()捕捉到的連接點集合的動態(tài)環(huán)境中發(fā)生的連接點。

     

    通知

           雖然切點用來捕捉連接點集合,但是它們沒有做任何事。要真正實現(xiàn)橫切行為,我們需要使用通知機制。通知包含了切點和要在每個連連接點處執(zhí)行的代碼段。AspectJ有幾種通知。

    ·前通知(Before Advice)      當?shù)竭_一個連接點但是在程序進程運行之前執(zhí)行。例如,前通知在方法實際調用之前運行,剛剛在方法的參數(shù)被分析之后。

           Before() : move(){ System.out.println(“物體將移動了”);}

    ·后通知(After Advice) 當特定連接點處的程序進程執(zhí)行之后運行。例如,一個方法調用的后通知在方法體運行之后,剛好在控制返回調用者之前執(zhí)行。因為Java程序有兩種退出連接點的形式,正常的和拋出異常。相對的就有三種后通知:返回后通知(after returning)、拋出異常后通知(after throwing)和清楚的后通知(after),所謂清楚后通知就是指無論是正常還是異常都執(zhí)行的后通知,就像Java中的finally語句。

           After() returning : move(){    System.out.println(“物體剛剛成功的移動了”);}

    ·在周圍通知(Around Advice)    在連接點到達后,顯示的控制程序進程是否執(zhí)行(暫不討論)

     

    暴露切點環(huán)境

           切點不僅僅捕捉連接點,它還能暴露連接點處的部分執(zhí)行環(huán)境。切點中暴露的值可以在通知體中聲明以后使用。通知聲明有一個參數(shù)列表(和方法相同)用來描述它所使用的環(huán)境的名稱。例如后通知

           after(FigureElement fe,int x,int y) returning : somePointcuts {  someCodes  }

    使用了三個暴露的環(huán)境,一個名為fe的FigureElement對象,兩個整型變量x,y。通知體可以像使用方法的參數(shù)那樣使用這些變量,例如

           after(FigureElement fe,int x,int y) returning : somePointcuts {

                  System.out.println(fe+”移動到(”+x+”,”+y+”)”);

    }

    通知的切點發(fā)布了通知參數(shù)的值,三個原生切點this、target和args被用來發(fā)布這些值/所以上述例子的完整代碼為

           after(FigureElement fe,int x,int y) returning : call(void FigureElement.setXY(int,int)

    && target(fe) && args(x,y) {

                  System.out.println(fe+”移動到(”+x+”,”+y+”)”);

    }

    目標對象是FigureElement所以fe是after的第一個參數(shù),調用的方法包含兩個整型參數(shù)所以x和y為after的第二和第三個參數(shù)。所以通知打印出方法setXY調用返回后對象移動到的點x和y。當然還可以使用命名切點完成同樣的工作,例如

           pointcut setXY(FigureElement fe,int x,int y):call(void FigureElement.setXY(int,int)

                  && target(fe) && args(x,y);

           after(FigureElement fe,int x,int y) returning : setXY(fe,x,y){

           System.out.println(fe+”移動到(”+x+”,”+y+”)”);

           }

     

    類型間聲明

           AspectJ的類型間聲明指的是那些跨越類和它們的等級結構的聲明。這些可能是橫跨多個類的成員聲明或者是類之間繼承關系的改變。不像通知是動態(tài)地操作,類型間聲明編譯時的靜態(tài)操作。考慮一下,Java語言中如何向一個一些的類中加入新方法,這需要實現(xiàn)一個特定接口,所有類都必須在各自內部實現(xiàn)接口聲明的方法,而使用AspectJ則可以將這些工作利用類型間聲明放在一個方面中。這個方面聲明方法和字段,然后將它們與需要的類聯(lián)系。

    假設我們想有一個Sreen對象觀察Point對象的變化,當Point是一個存在的類。我們可以通過書寫一個方面,由這個方面聲明Point對象有一個實例字段observers,用來保存所有觀察Point對象的Screen對象的引用,從而實現(xiàn)這個功能。

           Aspect PointObserving{

                  Private    Collection Point.observers=new ArrayList();

    ……

    }

    observers字段是私有字段,只有PointObserving能使用。因此,要在aspect中加入方法管理observers聚集。

           Aspect PointObserving{

                  Private Collection Point.observers=new ArrayList();

                  Public static void addObserver(Point p,Screen s){

                         p.observers.add(s);

                  }

                  public static void removeObserver(Point p,Screen s){

                         p.observers.remove(s);

                  }

                  ……

    }

    然后我們可以定義一個切點stateChanges決定我們想要觀察什么并且提供一個after通知定義當觀察到變化時我們想要做什么。

           Aspect PointObserving{

                  Private Collection Point.observers=new ArrayList();

                  Public static void addObserver(Point p,Screen s){

                         p.observers.add(s);

                  }

                  public static void removeObserver(Point p,Screen s){

                         p.observers.remove(s);

                  }

                  pointcut stateChanges(Point p) : target(p) && call(void Point.set*(int));

                  after(Point p) : stateChanges(p){

                         Iterator it=p.observers.iterator();

                         While(it.hasNext()){

                                UpdateObserver(p,(Screen)it.next()));

                         }

                  }

                  private static void updateObserver(Point p,Screen s){

                         s.display(p);

                  }

    }

    注意無論是Sreen還是Point的代碼都沒有被修改,所有的新功能的加入都在方面中實現(xiàn)了,很酷吧!

     

    方面

           方面以橫切模塊單元的形式包裝了所有的切點、通知和類型間聲明。這非常像Java語言的類。實際上,方面也可以定義自己的方法,字段和初始化方法。像類一樣一個方面也可以用abstrace關鍵字聲明為抽象方面,可以被子方面繼承。在AspectJ中方面的設計實際上使用了單例模式,缺省情況下,它不能使用new構造,但是可以使用一個方法實例化例如方法aspectOf()可以獲得方面的實例。所以在方面的通知中可以使用非靜態(tài)的成員字段。

    例如

           aspect Tracing {

                  OutputStream trace=System.out;

                  After() : move(){    trace.println(“物體成功移動”); }


    二、AspectJ應用范圍

           如前所述,AspectJ可以用于應用開發(fā)的不同階段。下面討論不同階段的AspectJ的具體應用情況。

    開發(fā)型方面(Development Aspects)

           開發(fā)方面可以很容易的從真正的產(chǎn)品中刪除。而產(chǎn)品方面則被可用于開發(fā)過程和生產(chǎn)過程,但是僅僅影響某幾個類。

           這一部分將通過幾個例子說明方面在Java應用的開發(fā)階段是如何使用的。這些方面包括調試、測試和性能檢測等工作。方面定義的行為范圍包括簡單的代碼跟蹤、測試應用的內在聯(lián)系等等。使用AspectJ不僅使得模塊化這些功能變?yōu)榭赡埽瑫r也使得根據(jù)需要打開和關閉這些功能變成可能。

     

    代碼跟蹤(Tracing)
           首先讓我們看看如何增加一個程序內部工作的可視性。我們定義一個簡單的方面用于代碼跟蹤并且在每個方法調用時輸出一些信息。在前一篇的圖形編輯例子中,這樣的方面可能僅僅簡單的跟蹤什么時候畫一個點。

    aspect SimpleTracing {
        pointcut tracedCall():
            call(void FigureElement.draw(GraphicsContext));
     
        before(): tracedCall() {
            System.out.println("Entering: " + thisJoinPoint);
        }
    }
    代碼利用了thisJoinPoint變量。在所有的通知體內,這個變量將與描述當前連接點的對象綁定。所以上述代碼在每次一個FigureElement對象接受到draw方法時輸出如下信息:

    Entering: call(void FigureElement.draw(GraphicsContext))

    通常我們在調式程序時,會在特定的地方放置幾條輸出語句,而當調試結束時還需要找到這些代碼段將它們刪除,這樣做不但使我們的代碼很難看而且很費時間。而使用AspectJ我們可以克服以上的兩個問題,我們可以通過定義切點捕捉任何想要觀察的代碼段,利用通知可以在方面內部書寫輸出語句,而不需要修改源代碼,當不在需要跟蹤語句的時候還可以很輕松的將方面從應用中刪除并重新編譯代碼即可。

     

    前提條件和后續(xù)條件(Pre-and Post-Conditions)
           許多的程序員使用按契約編程(Design by Contract)的形式。這種形式的編程需要顯式的前提條件測試以保證方法調用是否合適,還需要顯式的后續(xù)條件測試保證方法是否工作正常。AspectJ使得可以模塊化地實現(xiàn)這兩種條件測試。例如下面的代碼

    aspect PointBoundsChecking {

        pointcut setX(int x):

            (call(void FigureElement.setXY(int, int)) && args(x, *))

            || (call(void Point.setX(int)) && args(x));

     

        pointcut setY(int y):

            (call(void FigureElement.setXY(int, int)) && args(*, y))

            || (call(void Point.setY(int)) && args(y));

     

        before(int x): setX(x) {

            if ( x < MIN_X || x > MAX_X )

                throw new IllegalArgumentException("x is out of bounds.");

        }

     

        before(int y): setY(y) {

            if ( y < MIN_Y || y > MAX_Y )

                throw new IllegalArgumentException("y is out of bounds.");

        }

    }

    它實現(xiàn)了邊界檢測功能。當FigureElement對象移動時,如果x或y的值超過了定義的邊界,程序將會拋出IllegalArgumentException異常。

     

    合同實施(Contract Enforcement)
           基于屬性的橫切機制在定義更加復雜的合同實施上非常有用。一個十分強大的功能是它可以強制特定的方法調用只出現(xiàn)在對應的程序中,而在其他程序中不出現(xiàn)。例如,下面的方面實施了一個限制,使得只有在知名的工廠方法中才能向注冊并添加FigureElement對象。實施這個限制的目的是為了確保沒有任何一個FigureElement對象被注冊多次。

    static aspect RegistrationProtection {

        pointcut register(): call(void Registry.register(FigureElement));

        pointcut canRegister(): withincode(static * FigureElement.make*(..));

     

        before(): register() && !canRegister() {

            throw new IllegalAccessException("Illegal call " + thisJoinPoint);

        }

    }

    這個方面使用了withincode初始切點,它表示在FigureElement對象的工廠方法(以make開始的方法)體內出現(xiàn)的所有連接點。在before通知中聲明一個異常,該通知用于捕捉任何不在工廠方法代碼內部產(chǎn)生的register方法的調用。該通知在特定連接點處拋出一個運行時異常,但是AspectJ能做地更好。使用declare error的形式,我們可以聲明一個編譯時的錯誤。

    static aspect RegistrationProtection {

        pointcut register(): call(void Registry.register(FigureElement));

        pointcut canRegister(): withincode(static * FigureElement.make*(..));

     

        declare error: register() && !canRegister(): "Illegal call"

    }

    當使用這個方面后,如果代碼中存在定義的這些非法調用我們將無法通過編譯。這種情況只出現(xiàn)在我們只需要靜態(tài)信息的時候,如果我們需要動態(tài)信息,像上面提到的前提條件實施時,就可以利用在通知中拋出帶參數(shù)的異常來實現(xiàn)。

     

    配置管理(Configuration Management)
           AspectJ的配置管理可以使用類似于make-file等技術進行處理。程序員可以簡單的包括他們想要的方面進行編譯。不想要任何方面出現(xiàn)在產(chǎn)品階段的開發(fā)者也可以通過配置他們的make-file使用傳統(tǒng)的Java編譯器編譯整個應用。

     

    產(chǎn)品型方面(Production Aspects)

           這一部分的方面例子將描述方面用于生產(chǎn)階段的應用。產(chǎn)品方面將向應用中加入功能而不僅僅為程序的內部工作增加可視性。

    改變監(jiān)視(Change Monitoring)
           在第一個例子,方面的角色是用于維護一位數(shù)據(jù)標志,由它說明對象從最后一次顯示刷新開始是否移動過。在方面中實現(xiàn)這樣的功能是十分直接的,testAndClear方法被顯示代碼調用以便找到一個圖形元素是否在最近移動過。這個方法返回標志的狀態(tài)并將它設置為假。切點move捕捉所有能夠是圖形移動的方法調用。After通知截獲move切點并設置標志位。

    aspect MoveTracking {

    private static boolean dirty = false;

     

        public static boolean testAndClear() {

            boolean result = dirty;

            dirty = false;

            return result;

        }

     

        pointcut move():

            call(void FigureElement.setXY(int, int)) ||

            call(void Line.setP1(Point)) ||

            call(void Line.setP2(Point)) ||

            call(void Point.setX(int)) ||

            call(void Point.setY(int));

     

        after() returning: move() {

            dirty = true;

        }

    }
     

    這個簡單例子同樣說明了在產(chǎn)品代碼中使用AspectJ的一些好處。考慮使用普通的Java代碼實現(xiàn)這個功能:將有可能需要包含標志位,testAndClear以及setFlag方法的輔助類。這些方法需要每個移動的圖形元素包含一個對setFlag方法的調用。這些方法的調用就是這個例子中的橫切關注點。

    ·顯示的捕捉了橫切關注點的結構

    ·功能容易拔插

    ·實現(xiàn)更加穩(wěn)定

     

    傳遞上下文(Context Passing)
    橫切結構的上下文傳遞在Java程序中是十分復雜的一部分。考慮實現(xiàn)一個功能,它允許客戶設置所創(chuàng)建的圖形對象的顏色。這個需求需要從客戶端傳入一個顏色或顏色工廠。而要在大量的方法中加入一個參數(shù),目的僅僅是為傳遞上下文信息這種不方便的情況是所有的程序員都十分熟悉的。

    使用AspectJ,這種上下文的傳遞可以使用模塊化的方式實現(xiàn)。下面代碼中的after通知僅當一個圖形對象的工廠方法在客戶ColorControllingClient的某個方法控制流程中調用時才運行。

    aspect ColorControl {

        pointcut CCClientCflow(ColorControllingClient client):

            cflow(call(* * (..)) && target(client));

     

        pointcut make(): call(FigureElement Figure.make*(..));

     

        after (ColorControllingClient c) returning (FigureElement fe):

                make() && CCClientCflow(c) {

            fe.setColor(c.colorFor(fe));

        }

    }

    這個方面僅僅影響一小部分的方法,但是注意該功能的非AOP實現(xiàn)可能 需要編輯更多的方法。

     

    提供一致的行為(Providing Consistent Behavior)
    接下來的例子說明了基于屬性的方面如何在很多操作中提供一致的處理功能。這個方面確保包com.bigboxco的所有公共方法記錄由它們拋出的任何錯誤。PublicMethodCall切點捕捉包中的公共方法調用, after通知在任何一個這種調用拋出錯誤后運行并且記錄下這個錯誤。

    aspect PublicErrorLogging {

        Log log = new Log();

     

        pointcut publicMethodCall():

            call(public * com.bigboxco.*.*(..));

     

        after() throwing (Error e): publicMethodCall() {

            log.write(e);

        }

    }

    在一些情況中,這個方面可以記錄一個異常兩次。這在com.bigboxco包內部的代碼自己調用本包中的公共方法時發(fā)生。為解決這個問題,我們可以使用cflow初始切點將這些內部調用排除:

    after() throwing (Error e) : publicMethodCall() && !cflow(publicMethodCall()) {

        log.write(e);

    }

     

    結論

           AspectJ是對Java語言的簡單而且實際的面向方面的擴展。僅通過加入幾個新結構,AspectJ提供了對模塊化實現(xiàn)各種橫切關注點的有力支持。向以有的Java開發(fā)項目中加入AspectJ是一個直接而且漸增的任務。一條路徑就是通過從使用開發(fā)方面開始再到產(chǎn)品方面當擁有了AspectJ的經(jīng)驗后就使用開發(fā)可重用方面。當然可以選取其他的開發(fā)路徑。例如,一些開發(fā)者將從使用產(chǎn)品方面馬上得到好處,另外的人員可能馬上編寫可重用的方面。

           AspectJ可以使用基于名字和基于屬性這兩種橫切點。使用基于名字橫切點的方面僅影響少數(shù)幾個類,雖然它們是小范圍的,但是比起普通的Java實現(xiàn)來說它們能夠減少大量的復雜度。使用基于屬性橫切點的方面可以有小范圍或著大范圍。使用AspectJ導致了橫切關注點的干凈、模塊化的實現(xiàn)。當編寫AspectJ方面時,橫切關注點的結構變得十分明顯和易懂。方面也是高度模塊化的,使得開發(fā)可拔插的橫切功能變成現(xiàn)實。

           AspectJ提供了比這兩部分簡短介紹更多的功能。本系列的下一章內容,The AspectJ Language,將介紹 AspectJ語言的更多細節(jié)和特征。系列的第三章,Examples將通過一些完整的例子說明如何使用AspectJ。建議大家在仔細閱讀了接下來的兩章后再決定是否在項目中加入AspectJ。


    三、AspectJ的高級特性

    (一)、The reflection API

    說到高級特性,首先要說的就是AspectJ提供的一套reflection API,主要包括JoinPoint、JoinPoint.StaticPart和Signature三個主要的接口。你可以從aspectj.jar中的javadoc來了解它們的詳細情況。那它們能提供什么功能呢?其實從字面上就能大致明白:通過這三個接口能訪問到Join Points的信息。譬如,調用thisJoinPoint.getArgs()就可以得到方法的參數(shù)列表。

    (二)、Aspect precedence

    在AspectJ中,pointcut和advice都會包含在一個aspect中。在應用系統(tǒng)中,對同一個join point會有多種advice(logging,caching等),這就會引出一個問題:如果系統(tǒng)中有很多的aspect,而這些aspect很有可能會捕獲同樣的join points,那這些aspect的執(zhí)行順序是如何安排的呢?

    AspectJ早已為我們考慮到了這個問題,它提供了一種設置aspect precedence的方法。對三種不同的advice來說:

    1、before advice是先執(zhí)行higher-precedence,后執(zhí)行l(wèi)ower-precedence;

    2、around advice是higher-precedence包含lower-precedence,當higher-precedence around advice沒有調用proceed()方法時,lower-precedence不會被執(zhí)行;

    3、after advice與before advice正好相反,先執(zhí)行執(zhí)行l(wèi)ower-precedence,然后執(zhí)行higher-precedence。

    那應該如何來聲明aspect precedence?非常簡單,只要在aspect中使用如下的語法即可:

    declare precedence : TypePattern1, TypePattern2, ..;

    從左往右,排在前面的是higher-precedence advice,后面的是lower-precedence。

    (三)、Aspect association

    在Java中,為了節(jié)省對象每次構建的耗費,增加效率,很多人會考慮使用Singleton模式,讓jvm中只有一個實例存在。AspectJ當然為我們考慮到這個問題,Aspect association實際上就是aspect與advised join point object的一種關聯(lián)關系,這很類似于OO中association,譬如1:1,1:m等。Aspect association能讓我們能更好地控制aspect的狀態(tài)信息。

    在AspectJ中可以把Aspect association大致分為三類:

    1、Per virtual machine (default)

    一個jvm中只有一個aspect instance,AspectJ默認association。

    2、Per object

    每一個advised join point object都會產(chǎn)生一個aspect instance,不過同一個object instance只會產(chǎn)生一個aspect instance。

    3、Per control-flow association

    這種association稍微復雜一些,它主要針對程序調用的控制流,譬如:A方法調用B方法,B方法又調用C方法,這就是control-flow。

    在aspect中聲明這三種association非常簡單,它的主要語法如下:

    aspect [( )] {
    ... aspect body
    }

    Per virtual machine是aspectj的默認association,不需要你額外的聲明,正常使用即可。

    Per object主要有兩種方式:perthis()和pertarget()。perthis()主要用于execution object,pertarget()主要用于target object,兩者非常類似。

    Per control-flow中也包含兩種方式:percflow()和percflowbelow()。這兩者也很類似,只是兩者的control-flow不太一樣而已。

    維護aspect的狀態(tài)信息還有一種方法,就是使用introduce。可以在aspect中introduce member fields,通過fields來保存狀態(tài)信息。

     

    四、AspectJ實例

     

    使用方面的Tracing程序

           寫一個具有跟蹤能力的類是很簡單的事情:一組方法,一個控制其開或關的布爾變量,一種可選的輸出流,可能還有一些格式化輸出能力。這些都是Trace類需要的東西。當然,如果程序需要的話,Trace類也可以實現(xiàn)的十分的復雜。開發(fā)這樣的程序只是一方面,更重要的是如何在合適的時候調用它。在大型系統(tǒng)開發(fā)過程中,跟蹤程序往往影響效率,而且在正式版本中去除這些功能十分麻煩,需要修改任何包含跟蹤代碼的源碼。出于這些原因,開發(fā)人員常常使用腳本程序以便向源碼中添加或刪除跟蹤代碼。

           AspectJ可以更加方便的實現(xiàn)跟蹤功能并克服這些缺點。Tracing可以看作是面向整個系統(tǒng)的關注點,因此,Tracing方面可以完全獨立在系統(tǒng)之外并且在不影響系統(tǒng)基本功能的情況下嵌入系統(tǒng)。

     

    應用實例

    整個例子只有四個類。應用是關于Shape的。TwoShape類是Shape類等級的基類。

    public abstract class TwoDShape {

        protected double x, y;

        protected TwoDShape(double x, double y) {

            this.x = x; this.y = y;

        }

        public double getX() { return x; }

        public double getY() { return y; }

        public double distance(TwoDShape s) {

            double dx = Math.abs(s.getX() - x);

            double dy = Math.abs(s.getY() - y);

            return Math.sqrt(dx*dx + dy*dy);

        }

        public abstract double perimeter();

        public abstract double area();

        public String toString() {

            return (" @ (" + String.valueOf(x) + ", " + String.valueOf(y) + ") ");

        }

    }

    TwoShape類有兩個子類,Circle和Square  

    public class Circle extends TwoDShape {

        protected double r;

        public Circle(double x, double y, double r) {

            super(x, y); this.r = r;

        }

        public Circle(double x, double y) { this(  x,   y, 1.0); }

        public Circle(double r)           { this(0.0, 0.0,   r); }

        public Circle()                   { this(0.0, 0.0, 1.0); }

        public double perimeter() {

            return 2 * Math.PI * r;

        }

        public double area() {

            return Math.PI * r*r;

        }

        public String toString() {

            return ("Circle radius = " + String.valueOf(r) + super.toString());

        }

    }

    public class Square extends TwoDShape {

        protected double s;    // side

        public Square(double x, double y, double s) {

            super(x, y); this.s = s;

        }

        public Square(double x, double y) { this(  x,   y, 1.0); }

        public Square(double s)           { this(0.0, 0.0,   s); }

        public Square()                   { this(0.0, 0.0, 1.0); }

        public double perimeter() {

            return 4 * s;

        }

        public double area() {

            return s*s;

        }

        public String toString() {

            return ("Square side = " + String.valueOf(s) + super.toString());

        }

    }

     

    Tracing版本一

    首先我們直接實現(xiàn)一個Trace類并不使用方面。公共接口Trace.java

    public class Trace {

        public static int TRACELEVEL = 0;

        public static void initStream(PrintStream s) {...}

        public static void traceEntry(String str) {...}

        public static void traceExit(String str) {...}

    }

    如果我們沒有AspectJ,我們需要在所有需要跟蹤的方法或構造子中直接調用traceEntry和traceExit方法并且初試化TRACELEVEL和輸出流。以上面的例子來說,如果我們要跟蹤所有的方法調用(包括構造子)則需要40次的方法調用并且還要時刻注意沒有漏掉什么方法,但是使用方面我們可以一致而可靠的完成。TraceMyClasses.java

    aspect TraceMyClasses {

        pointcut myClass(): within(TwoDShape) || within(Circle) || within(Square);

        pointcut myConstructor(): myClass() && execution(new(..));

        pointcut myMethod(): myClass() && execution(* *(..));

     

        before (): myConstructor() {

            Trace.traceEntry("" + thisJoinPointStaticPart.getSignature());

        }

        after(): myConstructor() {

            Trace.traceExit("" + thisJoinPointStaticPart.getSignature());

        }

     

        before (): myMethod() {

            Trace.traceEntry("" + thisJoinPointStaticPart.getSignature());

        }

        after(): myMethod() {

            Trace.traceExit("" + thisJoinPointStaticPart.getSignature());

        }

    }

    這個方面在合適的時候調用了跟蹤方法。根據(jù)此方面,跟蹤方法在Shape等級中每個方法或構造子的入口和出口處調用,輸出的是各個方法的簽名。因為方法簽名是靜態(tài)信息,我們可以利用thisJoinPointStaticPart對象獲得。運行這個方面的main方法可以獲得以下輸出:

      --> tracing.TwoDShape(double, double)

      <-- tracing.TwoDShape(double, double)

      --> tracing.Circle(double, double, double)

      <-- tracing.Circle(double, double, double)

      --> tracing.TwoDShape(double, double)

      <-- tracing.TwoDShape(double, double)

      --> tracing.Circle(double, double, double)

      <-- tracing.Circle(double, double, double)

      --> tracing.Circle(double)

      <-- tracing.Circle(double)

      --> tracing.TwoDShape(double, double)

      <-- tracing.TwoDShape(double, double)

      --> tracing.Square(double, double, double)

      <-- tracing.Square(double, double, double)

      --> tracing.Square(double, double)

      <-- tracing.Square(double, double)

      --> double tracing.Circle.perimeter()

      <-- double tracing.Circle.perimeter()

    c1.perimeter() = 12.566370614359172

      --> double tracing.Circle.area()

      <-- double tracing.Circle.area()

    c1.area() = 12.566370614359172

      --> double tracing.Square.perimeter()

      <-- double tracing.Square.perimeter()

    s1.perimeter() = 4.0

      --> double tracing.Square.area()

      <-- double tracing.Square.area()

    s1.area() = 1.0

      --> double tracing.TwoDShape.distance(TwoDShape)

        --> double tracing.TwoDShape.getX()

        <-- double tracing.TwoDShape.getX()

        --> double tracing.TwoDShape.getY()

        <-- double tracing.TwoDShape.getY()

      <-- double tracing.TwoDShape.distance(TwoDShape)

    c2.distance(c1) = 4.242640687119285

      --> double tracing.TwoDShape.distance(TwoDShape)

        --> double tracing.TwoDShape.getX()

        <-- double tracing.TwoDShape.getX()

        --> double tracing.TwoDShape.getY()

        <-- double tracing.TwoDShape.getY()

      <-- double tracing.TwoDShape.distance(TwoDShape)

    s1.distance(c1) = 2.23606797749979

      --> String tracing.Square.toString()

        --> String tracing.TwoDShape.toString()

        <-- String tracing.TwoDShape.toString()

      <-- String tracing.Square.toString()

    s1.toString(): Square side = 1.0 @ (1.0, 2.0)

     

    Tracing版本二

           版本二實現(xiàn)了可重用的tracing方面,使其不僅僅用于Shape的例子。首先定義如下的抽象方面Trace.java

    abstract aspect Trace {

     

        public static int TRACELEVEL = 2;

        public static void initStream(PrintStream s) {...}

        protected static void traceEntry(String str) {...}

        protected static void traceExit(String str) {...}

    abstract pointcut myClass();

     

    }

    為了使用它,我們需要定義我們自己的子類。

    public aspect TraceMyClasses extends Trace {

        pointcut myClass(): within(TwoDShape) || within(Circle) || within(Square);

     

        public static void main(String[] args) {

            Trace.TRACELEVEL = 2;

            Trace.initStream(System.err);

            ExampleMain.main(args);

        }

    }

    注意我們僅僅在類中聲明了一個切點,它是超類中聲明的抽象切點的具體實現(xiàn)。版本二的Trace類的完整實現(xiàn)如下

    abstract aspect Trace {

     

        // implementation part

     

        public static int TRACELEVEL = 2;

        protected static PrintStream stream = System.err;

        protected static int callDepth = 0;

     

        public static void initStream(PrintStream s) {

            stream = s;

        }

        protected static void traceEntry(String str) {

            if (TRACELEVEL == 0) return;

            if (TRACELEVEL == 2) callDepth++;

            printEntering(str);

        }

        protected static void traceExit(String str) {

            if (TRACELEVEL == 0) return;

            printExiting(str);

            if (TRACELEVEL == 2) callDepth--;

        }

        private static void printEntering(String str) {

            printIndent();

            stream.println("--> " + str);

        }

        private static void printExiting(String str) {

            printIndent();

            stream.println("<-- " + str);

        }

        private static void printIndent() {

            for (int i = 0; i < callDepth; i++)

                stream.print("  ");

        }

     

        // protocol part

     

        abstract pointcut myClass();

     

        pointcut myConstructor(): myClass() && execution(new(..));

        pointcut myMethod(): myClass() && execution(* *(..));

     

        before(): myConstructor() {

            traceEntry("" + thisJoinPointStaticPart.getSignature());

        }

        after(): myConstructor() {

            traceExit("" + thisJoinPointStaticPart.getSignature());

        }

     

        before(): myMethod() {

            traceEntry("" + thisJoinPointStaticPart.getSignature());

        }

        after(): myMethod() {

            traceExit("" + thisJoinPointStaticPart.getSignature());

        }

    }

    它與版本一的不同包括幾個部分。首先在版本一中Trace用單獨的類來實現(xiàn)而方面是針對特定應用實現(xiàn)的,而版本二則將Trace所需的方法和切點定義融合在一個抽象方面中。這樣做的結果是traceEntry和traceExit方法不需要看作是公共方法,它們將由方面內部的通知調用,客戶完全不需要知道它們的存在。這個方面的一個關鍵點是使用了抽象切點,它其實與抽象方法類似,它并不提供具體實現(xiàn)而是由子方面實現(xiàn)它。

     

    Tracing版本三

           在前一版本中,我們將traceEntry和traceExit方法隱藏在方面內部,這樣做的好處是我們可以方便的更改接口而不影響余下的代碼。

           重新考慮不使用AspectJ的程序。假設,一段時間以后,tracing的需求變了,我們需要在輸出中加入方法所屬對象的信息。至少有兩種方法實現(xiàn),一是保持traceEntry和traceExit方法不變,那么調用者有責任處理顯示對象的邏輯,代碼可能如下

           Trace.traceEntry("Square.distance in " + toString());

    另一種方法是增強方法的功能,添加一個參數(shù)表示對象,例如

      public static void traceEntry(String str, Object obj);

      public static void traceExit(String str, Object obj);

    然而客戶仍然有責任傳遞正確的對象,調用代碼如下

           Trace.traceEntry("Square.distance", this);

    這兩種方法都需要動態(tài)改變其余代碼,每個對traceEntry和traceExit方法的調用都需要改變。

           這里體現(xiàn)了方面實現(xiàn)的另一個好處,在版本二的實現(xiàn)中,我們只需要改變Trace方面內部的一小部分代碼,下面是版本三的Trace方面實現(xiàn)

    abstract aspect Trace {

     

        public static int TRACELEVEL = 0;

        protected static PrintStream stream = null;

        protected static int callDepth = 0;

     

        public static void initStream(PrintStream s) {

            stream = s;

        }

     

        protected static void traceEntry(String str, Object o) {

            if (TRACELEVEL == 0) return;

            if (TRACELEVEL == 2) callDepth++;

            printEntering(str + ": " + o.toString());

        }

     

        protected static void traceExit(String str, Object o) {

            if (TRACELEVEL == 0) return;

            printExiting(str + ": " + o.toString());

            if (TRACELEVEL == 2) callDepth--;

        }

     

        private static void printEntering(String str) {

            printIndent();

            stream.println("Entering " + str);

        }

     

        private static void printExiting(String str) {

            printIndent();

            stream.println("Exiting " + str);

        }

     

        private static void printIndent() {

            for (int i = 0; i < callDepth; i++)

                stream.print("  ");

        }

     

        abstract pointcut myClass(Object obj);

     

        pointcut myConstructor(Object obj): myClass(obj) && execution(new(..));

        pointcut myMethod(Object obj): myClass(obj) &&

            execution(* *(..)) && !execution(String toString());

     

        before(Object obj): myConstructor(obj) {

            traceEntry("" + thisJoinPointStaticPart.getSignature(), obj);

        }

        after(Object obj): myConstructor(obj) {

            traceExit("" + thisJoinPointStaticPart.getSignature(), obj);

        }

     

        before(Object obj): myMethod(obj) {

            traceEntry("" + thisJoinPointStaticPart.getSignature(), obj);

        }

        after(Object obj): myMethod(obj) {

            traceExit("" + thisJoinPointStaticPart.getSignature(), obj);

        }

    }

    在此我們必須在methods切點排除toString方法的執(zhí)行。問題是toString方法在通知內部調用,因此如果我們跟蹤它,我們將陷入無限循環(huán)中。這一點不明顯,所以必須在寫通知時格外注意。如果通知回調對象,通常都回存在循環(huán)的可能性。

           事實上,簡單的排除連接點的執(zhí)行并不夠,如果在這之中調用了其他跟蹤方法,那么就必須提供以下限制

    && !cflow(execution(String toString()))

    排除toString方法的執(zhí)行以及在這之下的所有連接點。

           總之,為了實現(xiàn)需求的改變我們必須在Trace方面中做一些改變,包括切點說明。但是實現(xiàn)的改變只局限于Trace方面內部,而如果沒有方面,則需要更改每個應用類的實現(xiàn)。
    (來源:http://befresh.blogbus.com/logs/2004/08/339330.html;
    Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=15565)

     

     

    posted @ 2008-10-25 00:08 hk2000c 閱讀(944) | 評論 (2)編輯 收藏

    .概述

    1.1 JMS與ActiveMQ特性  

       JMS始終在JavaEE五花八門的協(xié)議里,WebService滿天飛的時候占一位置,是因為:

    • 它可以把不影響用戶執(zhí)行結果又比較耗時的任務(比如發(fā)郵件通知管理員)異步的扔給JMS 服務端去做,而盡快的把屏幕返還給用戶。
    • 服務端能夠多線程排隊響應高并發(fā)的請求,并保證請求不丟失。
    • 可以在Java世界里達到最高的解耦。客戶端與服務端無需直連,甚至無需知曉對方是誰、在哪里、有多少人,只要對流過的信息作響應就行了,在企業(yè)應用環(huán)境復雜時作用明顯。

        ActiveMQ的特性:

    • 完全支持JMS1.1和J2EE 1.4規(guī)范的 JMS Provider實現(xiàn),也是Apache Geronimo默認的JMS provider。
    • POJO withdout EJB Container,不需要實現(xiàn)EJB繁瑣復雜的Message Bean接口和配置。
    • Spring Base,可以使用Spring的各種特性如IOC、AOP 。
    • Effective,基于Jencks的JCA Container實現(xiàn) pool connection,control transactions and manage security。 

    1.2 SpringSide 的完全POJO的JMS方案   

      SpringSide 2.0在BookStore示例中,演示了用戶下訂單時,將發(fā)通知信到用戶郵箱的動作,通過JMS交給JMS服務端異步完成,避免了郵件服務器的堵塞而影響用戶的下訂。

      全部代碼于examples\bookstore\src\java\org\springside\bookstore\components\activemq 目錄中。

      一個JMS場景通常需要三者參與:

    • 一個POJO的的Message Producer,負責使用Spring的JMS Template發(fā)送消息。
    • 一個Message Converter,負責把Java對象如訂單(Order)轉化為消息,使得Producer能夠直接發(fā)送POJO。
    • 一個MDP Message Consumer,負責接收并處理消息。

      SpringSide 2.0采用了ActiveMQ 4.1-incubator 與Spring 2.0 集成,對比SS1.0M3,有三個值得留意的地方,使得代碼中幾乎不見一絲JMS的侵入代碼:

    1. 采用Spring2.0的Schema式簡化配置。
    2. 實現(xiàn)Message Converter轉化消息與對象,使得Producer能夠直接發(fā)送POJO而不是JMS Message。
    3. 使用了Spring2.0的DefaultMessageListenerContainer與MessageListenerAdapter,消息接收者不用實現(xiàn)MessageListener 接口。
    4. 同時,Spring 2.0 的DefaultMessageListenerContainer 代替了SS1.0M3中的Jenck(JCA Container),充當MDP Container的角色。

    2.引入ActiveMQ的XSD

      ActiveMQ4.1 響應Spring 2.0號召,支持了引入XML Schema namespace的簡單配置語法,簡化了配置的語句。 

      在ApplicationContext.xml(Spring的配置文件)中引入ActiveMQ的XML Scheam 配置文件),如下:

    <beans
      xmlns="http://www.springframework.org/schema/beans"
      xmlns:amq="http://activemq.org/config/1.0"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
      http://activemq.org/config/1.0 http://people.apache.org/repository/org.apache.activemq/xsds/activemq-core-4.1-incubator-SNAPSHOT.xsd">

    由于ActiveMQ4.1 SnapShot的那個XSD有部分錯誤,因此使用的是自行修改過的XSD。

    先在ClassPath根目錄放一個修改過的activemq-core-4.1-incubator-SNAPSHOT.xsd。

    在ClassPath 下面建立META-INF\spring.schemas 內容如下。這個spring.schemas是spring自定義scheam的配置文件,請注意"http:\://"部分寫法

    http\://people.apache.org/repository/org.apache.activemq/xsds/activemq-core-4.1-incubator-SNAPSHOT.xsd=/activemq-core-4.1-incubator-SNAPSHOT.xsd

    3. 配置方案

    3.1 基礎零件 

    1. 配置ActiveMQ Broker  

       暫時采用在JVM中嵌入這種最簡單的模式,  當spring初始化時候,ActiveMQ embedded Broker 就會啟動了。

    <!--  lets create an embedded ActiveMQ Broker -->
    <amq:broker useJmx="false" persistent="false">
      	<amq:transportConnectors>
        		<amq:transportConnector uri="tcp://localhost:0"/>
     	</amq:transportConnectors>
     </amq:broker>

    2. 配置(A)ConnectionFactory

      由于前面配置的Broker是JVM embedded 所以URL為:vm://localhost

    <!--  ActiveMQ connectionFactory to use  -->
     <amq:connectionFactory id="jmsConnectionFactory" brokerURL="vm://localhost"/>

    3 配置(B)Queue

    <!--  ActiveMQ destinations to use  -->
     <amq:queue name="destination" physicalName="org.apache.activemq.spring.Test.spring.embedded"/>

    4. 配置(C)Converter

       配置Conveter,使得Producer能夠直接發(fā)送Order對象,而不是JMS的Message對象。

    <!--  OrderMessage converter  -->
     <bean id="orderMessageConverter" class="org.springside.bookstore.components.activemq.OrderMessageConverter"/>  

    3.2  發(fā)送端 

    1 配置JmsTemplate

       Spring提供的Template,綁定了(A)ConnectionFactory與(C)Converter。

    <!--  Spring JmsTemplate config -->
     <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
      <property name="connectionFactory">
       <!--  lets wrap in a pool to avoid creating a connection per send -->
       <bean class="org.springframework.jms.connection.SingleConnectionFactory">
        <property name="targetConnectionFactory" ref="jmsConnectionFactory"/>
       </bean>
      </property>
      <!-- custom MessageConverter -->
      <property name="messageConverter" ref="orderMessageConverter"/>
     </bean>

    2.Producer

       消息發(fā)送者,使用JmsTemplate發(fā)送消息,綁定了JmsTemplate (含A、C)與(B)Queue。

    <!-- POJO which send Message uses  Spring JmsTemplate,綁定JMSTemplate 與Queue -->
     <bean id="orderMessageProducer" class="org.springside.bookstore.components.activemq.OrderMessageProducer">
      <property name="template" ref="jmsTemplate"/>
      <property name="destination" ref="destination"/>
     </bean>

    3.3 接收端

      1.接收處理者(MDP)

        使用Spring的MessageListenerAdapter,指定負責處理消息的POJO及其方法名,綁定(C)Converter。

      <!--  Message Driven POJO (MDP),綁定Converter -->
     <bean id="messageListener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
      <constructor-arg>
       <bean class="org.springside.bookstore.components.activemq.OrderMessageConsumer">
        <property name="mailService" ref="mailService"/>
       </bean>
      </constructor-arg>
      <!--  may be other method -->
      <property name="defaultListenerMethod" value="sendEmail"/>
      <!-- custom MessageConverter define -->
      <property name="messageConverter" ref="orderMessageConverter"/>
     </bean> 

    2. listenerContainer

        負責調度MDP, 綁定(A) connectionFactory, (B)Queue和MDP。

    <!--  this is the attendant message listener container -->
     <bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
      <property name="connectionFactory" ref="jmsConnectionFactory"/>
      <property name="destination" ref="destination"/>
      <property name="messageListener" ref="messageListener"/>
     </bean>

      互相綁定的關系有點暈,發(fā)送端和接收端都以不同形式綁定了(A) connectionFactory, (B)Queue和 (C)Converter。

    4. 下篇


    1. 說明

       請先閱讀ActiveMQ4.1 +Spring2.0的POJO JMS方案(上)

       本篇將補充說明了:

       1) 使用數(shù)據(jù)庫持久化消息,保證服務器重啟時消息不會丟失
       2) 使用Jencks作正宗的JCA Container。

    2.持久化消息

    2.1 給Broker加入Persistence 配置

    在配置文件applicationContext-activemq-embedded-persitence.xml中的<amq:broker>節(jié)點加入  

    <amq:persistenceAdapter>
    <amq:jdbcPersistenceAdapter id="jdbcAdapter" dataSource="#hsql-ds" createTablesOnStartup="true" useDatabaseLock="false"/>
    </amq:persistenceAdapter>

    請注意MSSQL(2000/2005)和HSQL由于不支持[SELECT  * ACTIVEMQ_LOCK FOR UPDATE ]語法,因此不能使用默認的userDatabaseLock="true",只能設置成useDatabaseLock="false"

    2.2 配置多種數(shù)據(jù)源

    配置多種數(shù)據(jù)源,給jdbcPersistenceAdapter使用,SpringSide 中使用的內嵌HSQL

     <!-- The HSQL Datasource that will be used by the Broker -->
    <bean id="hsql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
    <property name="driverClassName" value="org.hsqldb.jdbcDriver"/>
    <property name="url" value="jdbc:hsqldb:res:hsql/activemq"/>
    <property name="username" value="sa"/>
    <property name="password" value=""/>
    <property name="poolPreparedStatements" value="true"/>
    </bean>

    2. 3 說明

       筆者僅僅使用了jdbcPersistenceAdapter,其實在ActiveMQ的XSD已經(jīng)描述了多種PersistenceAdapter,可以參考對應的XSD文件.

      另外對于數(shù)據(jù)庫的差異主要表現(xiàn)在設置了userDatabaseLock="true"之后,ActiveMQ使用的[SELECT * ACTIVEMQ_LOCK FOR UPDATE] 上面,會導致一些數(shù)據(jù)庫出錯(測試中MSSQL2000/2005,HSQL都會導致出錯)。另外HSQL的腳本請參見activemq.script。

    3. Jenck(JCA Container)  

       Spring 2.0本身使用DefaultMessageListenerContainer 可以充當MDP中的Container角色,但是鑒于Jencks是JCA標準的,它不僅僅能夠提供jms的jca整合,包括其他資源比如jdbc都可以做到jca管理

    所以,同時完成了這個ActiveMQ+Spring+Jencks 配置演示,更多的針對生產(chǎn)系統(tǒng)的JCA特性展示,會在稍后的開發(fā)計劃討論中確定。

         此文檔適用于說明使用 Jecncks 和 使用Spring 2.0(DefaultMessageListenerContainer)  充當MDP Container時的區(qū)別,同時演示Jecnks 的Spring 2.0 新配置實例。

    3.1 引入ActiveMQ ResourceAdapter 和Jencks 的XSD

      在ApplicationContext.xml(Spring的配置文件)中引入ActiveMQ ResourceAdapter 和Jencks 的XML Scheam 配置文件),如下:

       ActiveMQ4.1 響應Spring 2.0號召,支持了引入XML Schema namespace的簡單配置語法,簡化了配置的語句。 

      在ApplicationContext.xml(Spring的配置文件)中引入ActiveMQ的XML Scheam 配置文件),如下:

    <beans
    xmlns="http://www.springframework.org/schema/beans"   xmlns:amq="http://activemq.org/config/1.0"   xmlns:ampra="http://activemq.org/ra/1.0"   xmlns:jencks="http://jencks.org/1.3"   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
      http://activemq.org/config/1.0 http://people.apache.org/repository/org.apache.activemq/xsds/activemq-core-4.1-incubator-SNAPSHOT.xsd
      http://activemq.org/ra/1.0 http://people.apache.org/repository/org.apache.activemq/xsds/activemq-ra-4.1-incubator-SNAPSHOT.xsd
      http://jencks.org/1.3 http://repository.codehaus.org/org/jencks/jencks/1.3/jencks-1.3.xsd">

    由于ActiveMQ RA和Jencks 那個XSD 仍然有部分錯誤,因此使用的是自行修改過的XSD。(是xs:any元素引起的錯誤)

    先在ClassPath根目錄放一個修改過的activemq-ra-4.1-incubator-SNAPSHOT.xsd和jencks-1.3.xsd。

    同樣修改 ClassPath 下面META-INF\spring.schemas 增加內容如下。這個spring.schemas是spring自定義scheam的配置文件,請注意"http:\://"部分寫法

    http\://people.apache.org/repository/org.apache.activemq/xsds/activemq-ra-4.1-incubator-SNAPSHOT.xsd=/activemq-ra-4.1-incubator-SNAPSHOT.xsd
    http\://repository.codehaus.org/org/jencks/jencks/1.3/jencks-1.3.xsd=/jencks-1.3.xsd

    3.2  配置方案

    3.2.1 基礎零件 

    1. 配置ActiveMQ Broker  參見 ActiveMQ+Spring

    2. 配置ActiveMQ Resource Adapter

    <amqra:managedConnectionFactory id="jmsManagedConnectionFactory" resourceAdapter="#resourceAdapter"/><amqra:resourceAdapter id="resourceAdapter" serverUrl="vm://localhost" />

    3. 配置Jencks 基礎配置

       具體的配置可以參見Jencks的XSD

    <!-- jencks PoolFactory config-->
    <jencks:singlePoolFactory id="poolingSupport" maxSize="16" minSize="5" blockingTimeoutMilliseconds="60" idleTimeoutMinutes="60" matchOne="true" matchAll="true" selectOneAssumeMatch="true" /> <!-- jencks XATransactionFactory -->
    <jencks:xATransactionFactory id="transactionSupport" useTransactionCaching="true" useThreadCaching="true" />  
    <!-- jencks ConnectionManagerFactory -->
    <jencks:connectionManagerFactory id="connectionManager" containerManagedSecurity="false"  poolingSupport="#poolingSupport" transactionSupport="#transactionSupport" /> <!-- jencks TransactionContextManagerFactory -->
    <jencks:transactionContextManagerFactory id="transactionContextManagerFactory"/>
      

    4. 配置給JmsTemplate使用的connectionFactory (主要是生成者/發(fā)送者 使用)

       這里注意下,在配置jmsTemplate的使用的targetConnectionFactory就是使用jencks配置的connectionManager

    <!-- spring config jms with jca-->
     <bean id="jmsManagerConnectionFactory" class="org.springframework.jca.support.LocalConnectionFactoryBean">
      <property name="managedConnectionFactory">
       <ref local="jmsManagedConnectionFactory" />
      </property>
      <property name="connectionManager">
       <ref local="connectionManager" />
      </property>
     </bean>
     
     <!--  Spring JmsTemplate config -->
     <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
      <property name="connectionFactory">
       <!--  lets wrap in a pool to avoid creating a connection per send -->
       <bean class="org.springframework.jms.connection.SingleConnectionFactory">
            <property name="targetConnectionFactory" ref="jmsManagerConnectionFactory" />
       </bean>
      </property>
      <!-- custom MessageConverter -->
      <property name="messageConverter" ref="orderMessageConverter" />
     </bean>  

    5. 配置Spring 2.0的MessageListenerAdapter,保證不需要用戶實現(xiàn)MessageListener

      ActiveMQ+Spring

     6.配置Jecnks 充當MDP的Container

      就是把上面的MessageListenerAdapter配置到Jencks里面,完成整個MDP的配置

     <!-- Jencks Container-->
     <jencks:jcaContainer>  	<jencks:bootstrapContext>
       		<jencks:bootstrapContextFactory threadPoolSize="25" />
      	</jencks:bootstrapContext>
      		<jencks:connectors>
       	   <!-- use jencks container (use spring MessageListenerAdapter)-->
       		<jencks:connector ref="messageListener">
        			<jencks:activationSpec>
         				<amqra:activationSpec destination="org.apache.activemq.spring.Test.spring.embedded" destinationType="javax.jms.Queue" />
        			</jencks:activationSpec>
       		</jencks:connector>  	</jencks:connectors> 		 <jencks:resourceAdapter>
       		<amqra:resourceAdapter serverUrl="vm://localhost" />
      	</jencks:resourceAdapter>
     </jencks:jcaContainer>

    posted @ 2008-04-12 01:37 hk2000c 閱讀(755) | 評論 (0)編輯 收藏

    主站蜘蛛池模板: 亚洲国产精品自在在线观看| 两性色午夜视频免费播放| 久久久久久99av无码免费网站 | 久久www免费人成看国产片| 午夜色a大片在线观看免费| 亚洲日本香蕉视频| 免费视频精品一区二区三区| 在线A亚洲老鸭窝天堂| 日本特黄特色AAA大片免费| 国产大片91精品免费观看男同| 久久亚洲国产最新网站| 国拍在线精品视频免费观看| 4480yy私人影院亚洲| 久草免费福利资源站| 亚洲国产a∨无码中文777| 久久久久久国产a免费观看不卡| 亚洲国产成人五月综合网 | 国产午夜无码视频免费网站| 亚洲欧美日韩自偷自拍| 成人免费一级毛片在线播放视频| 亚洲成在人线电影天堂色| 69视频免费观看l| 久久水蜜桃亚洲av无码精品麻豆| 国产激情免费视频在线观看| 亚洲不卡av不卡一区二区| 黄页免费在线观看 | aa级女人大片喷水视频免费| 国产成人精品亚洲精品| 九九九精品视频免费| 亚洲视频一区二区| 亚洲视频在线免费| 亚洲色成人中文字幕网站| 182tv免费视频在线观看| 亚洲AV无码专区国产乱码4SE | 日本最新免费网站| 91亚洲精品麻豆| 69成人免费视频无码专区| 亚洲乱人伦中文字幕无码| 国产精品久免费的黄网站 | 亚洲日本va午夜中文字幕一区| 特级无码毛片免费视频尤物|