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

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

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

    Sealyu

    --- 博客已遷移至: http://www.sealyu.com/blog

      BlogJava :: 首頁(yè) :: 新隨筆 :: 聯(lián)系 :: 聚合  :: 管理 ::
      618 隨筆 :: 87 文章 :: 225 評(píng)論 :: 0 Trackbacks
    TreeCache是一種結(jié)構(gòu)化的、基于復(fù)制的事務(wù)緩存。TreeCache是JBoss應(yīng)用服務(wù)器中集群服務(wù)—包括JNDI集群、HTTP和EJB的 Sesssion集群、JMS集群—的基礎(chǔ)框架。其可以單獨(dú)使用,可以集成到JBossAS應(yīng)用,也可以集成到其他的應(yīng)用服務(wù)器上。TreeCache是 一種樹(shù)狀結(jié)構(gòu),每個(gè)節(jié)點(diǎn)擁有一個(gè)名字和多個(gè)或者沒(méi)有子節(jié)點(diǎn),除跟節(jié)點(diǎn)沒(méi)有子節(jié)點(diǎn)其他節(jié)點(diǎn)有且只有一個(gè)父母節(jié)點(diǎn),可以通過(guò)路徑名來(lái)訪(fǎng)問(wèn)子節(jié)點(diǎn) (FQN:Full Qualified Name),在一個(gè)TreeCache中可以存在多棵樹(shù),,即可以有多個(gè)根節(jié)點(diǎn)。當(dāng)應(yīng)用于分布式環(huán)境時(shí),由于TreeCache是基于復(fù)制的,每個(gè)子節(jié)點(diǎn) 的值必須是可序列化的。
         在下面中,將通過(guò)例子來(lái)了解TreeCache的功能及其配置,使用JBossCache1.4和JDK5.0。首先是一個(gè)最基本使用TreeCache 的程序例子并配置一個(gè)TreeCache的配置骨架(各種常用的配置可參見(jiàn)jboss-cache-dist-1.4.0.CR1版本的etc目錄,如下 各種配置參考也可見(jiàn)該目錄下的范例配置,以下不再?gòu)?qiáng)調(diào)),見(jiàn)下:

    treecache.xml:


    <server>
        <mbean code="org.jboss.cache.TreeCache"
            name="jboss.cache:service=TreeCache">
            <depends>jboss:service=Naming</depends>
            <depends>jboss:service=TransactionManager</depends>
            <attribute name="ClusterName">TreeCache-Cluster</attribute>
            <attribute name="ClusterConfig">
                <config>
                    <UDP mcast_addr="228.1.2.3" mcast_port="48866"
                        ip_ttl="64" ip_mcast="true"
                        mcast_send_buf_size="150000" mcast_recv_buf_size="80000"
                        ucast_send_buf_size="150000" ucast_recv_buf_size="80000"
                        loopback="false"/>
                    <PING timeout="2000" num_initial_members="3"
                        up_thread="false" down_thread="false"/>
                    <MERGE2 min_interval="10000" max_interval="20000"/>
                    <FD_SOCK/>
                    <VERIFY_SUSPECT timeout="1500"
                        up_thread="false" down_thread="false"/>
                    <pbcast.NAKACK gc_lag="50" retransmit_timeout="600,1200,2400,4800"
                        max_xmit_size="8192" up_thread="false" down_thread="false"/>
                    <UNICAST timeout="600,1200,2400" window_size="100" min_threshold="10"
                        down_thread="false"/>
                    <pbcast.STABLE desired_avg_gossip="20000"
                        up_thread="false" down_thread="false"/>
                    <FRAG frag_size="8192"
                        down_thread="false" up_thread="false"/>
                    <pbcast.GMS join_timeout="5000" join_retry_timeout="2000"
                        shun="true" print_local_addr="true"/>
                    <pbcast.STATE_TRANSFER up_thread="true" down_thread="true"/>
                </config>
            </attribute>
        </mbean>
    </server>
       其中ClusterConfig配置在前面JavaGroups的介紹詳細(xì)介紹,其它配置比較簡(jiǎn)單,需要進(jìn)一步了解請(qǐng)參見(jiàn)TreeCache文檔。
       一、Cache分類(lèi)
       TreeCache按功能分為三類(lèi):本地(Local)Cache、復(fù)制(Replication)Cache和失效 (Invalidation)Cache。本地Cache只應(yīng)用于本地環(huán)境,后兩個(gè)Cache可應(yīng)用于分布式環(huán)境,其中,在分布式環(huán)境中,復(fù)制Cache 當(dāng)一個(gè)Cache實(shí)例的一個(gè)節(jié)點(diǎn)值發(fā)生變化時(shí)會(huì)將變化復(fù)制到其它實(shí)例中,而失效Cache是當(dāng)一個(gè)Cache實(shí)例的一個(gè)節(jié)點(diǎn)值發(fā)生變化時(shí)會(huì)將其它實(shí)例的相 應(yīng)節(jié)點(diǎn)的值設(shè)為空,讓其重新去獲得該值,可通過(guò)這種方式緩存大對(duì)象以減少在實(shí)例中復(fù)制對(duì)象的代價(jià)。分布式Cache(復(fù)制和失效Cache)又分為兩種, 同步(REPL_ASYNC)和異步(REPL_SYNC),同步Cache是在一個(gè)Cache實(shí)例做修改時(shí),等待變化應(yīng)用到其它實(shí)例后才返回,而異步 Cache是在一個(gè)Cache實(shí)例做修改時(shí),即刻返回。其配置見(jiàn)下:
    !--
      Valid modes are LOCAL
                      REPL_ASYNC
                      REPL_SYNC
                      INVALIDATION_ASYNC
                      INVALIDATION_SYNC
    ->
    attribute name="CacheMode">REPL_SYNC</attribute>

       二、事務(wù)和并行(Transaction And Concurrent)
       TreeCache是一種事務(wù)Cache,與JDBC一樣,其包括兩方面內(nèi)容:鎖和隔離級(jí)別。鎖分為悲觀(guān)鎖和樂(lè)觀(guān)鎖,當(dāng)使用悲觀(guān)鎖時(shí),分為五個(gè)隔離級(jí)別, 分別是SERIALIZABLE、REPEATABLE_READ (default)、READ_COMMITTED、READ_UNCOMMITTED和NONE,隔離級(jí)別逐步減弱。樂(lè)觀(guān)鎖也叫版本鎖,其對(duì)數(shù)據(jù)進(jìn)行操 作時(shí),將其復(fù)制到臨時(shí)區(qū),操作之后將版本與原有數(shù)據(jù)比較,如果一致則將遞增版本并寫(xiě)回,如果不一致則回滾,由于樂(lè)觀(guān)鎖僅在復(fù)制出數(shù)據(jù)和提交數(shù)據(jù)時(shí)對(duì)數(shù)據(jù)加 鎖,所以并行度更高,但如果寫(xiě)操作比較頻繁地話(huà)則容易出現(xiàn)沖突導(dǎo)致回滾。TreeCache默認(rèn)使用悲觀(guān)鎖。使用TreeCache時(shí),需要使用容器提供 的事務(wù)管理器,一般使JBossTransactionManagerLookup和GenericTransactionManagerLookup, 前者應(yīng)用于JBOSS服務(wù)器,后者應(yīng)用于其他服務(wù)器,也可使用DummyTransactionManagerLookup用于測(cè)試。如上介紹的配置如 下:
    attribute name="NodeLockingScheme">OPTIMISTIC</attribute>
          <attribute name="IsolationLevel">REPEATABLE_READ</attribute>
         <attribute name="TransactionManagerLookupClass">org.jboss.cache.DummyTransactionManagerLookup</attribute>


       三、逐出策略(Eviction Policy)
       由于內(nèi)存數(shù)量的局限,不可能將所有的Cache數(shù)據(jù)存放在內(nèi)存中,但使用內(nèi)存達(dá)到一定極限時(shí),會(huì)將部分?jǐn)?shù)據(jù)清除出內(nèi)存,保存到其它持久媒質(zhì)中,定義的什么 時(shí)候清除、如何清除的策略就是逐出策略。自定義一個(gè)逐出策略需要實(shí)現(xiàn)org.jboss.cache.eviction.EvictionPolicy、 org.jboss.cache.eviction.EvictionAlgorithm、
    g.jboss.cache.eviction.EvictionQueue 和org.jboss.cache.eviction.EvictionConfiguration四個(gè)接口,系統(tǒng)提供了LRU(Least recently used,最近最少使用)、LFU(Least Frequently Used最不經(jīng)常使用)、FIFO(First In First Out先進(jìn)先出)、MRU(Most Recently Used最近最經(jīng)常使用)四種實(shí)現(xiàn),詳細(xì)參見(jiàn)org.jboss.cache.eviction包的源代碼。配置如下:
    <attribute name="EvictionPolicyConfig">
       <config>
          <attribute name="wakeUpIntervalSeconds">5</attribute>
          <region name="/_default_">
            <attribute name="maxNodes">5000</attribute>
            <attribute name="timeToLiveSeconds">1000</attribute>
          </region>
          <region name="/org/jboss/data"
    policyClass="org.jboss.cache.eviction.FIFOPolicy">
            <attribute name="maxNodes">5000</attribute>
          </region>
          <region name="/test/" policyClass="org.jboss.cache.eviction.MRUPolicy">
            <attribute name="maxNodes">10000</attribute>
          </region>
          <region name="/maxAgeTest/">
            <attribute name="maxNodes">10000</attribute>
            <attribute name="timeToLiveSeconds">8</attribute>
            <attribute name="maxAgeSeconds">10</attribute>
          </region>
       </config>
    </attribute>
         四、Cache加載
      由于逐出策略的存在,那么當(dāng)我們重新需要獲得一個(gè)原來(lái)在緩存中但確由內(nèi)存原因被逐出的數(shù)據(jù)時(shí),就需要定義一種加載策略,使地可以重新找回?cái)?shù)據(jù),同 時(shí),Cache加載也肩負(fù)在將數(shù)據(jù)逐出時(shí)將數(shù)據(jù)保存到持久媒質(zhì)的責(zé)任。
      根據(jù)將數(shù)據(jù)保存媒質(zhì)的不同,Cache加載包括FileCacheLoader、JDBCCacheLoader等等,可以同時(shí)使用多種加載器來(lái)靈活定制 加載策略。例見(jiàn)下:
    <attribute name="CacheLoaderConfiguration">
        <config>
            <passivation>false</passivation>
            <preload>/</preload>
            <shared>true</shared>
            <cacheloader>
                <class>org.jboss.cache.loader.ClusteredCacheLoader</class>
                <properties>
                     timeout=1000
                </properties>
                <async>true</async>
                <fetchPersistentState>false</fetchPersistentState>
                ignoreModifications>false</ignoreModifications>
                <purgeOnStartup>false</purgeOnStartup>
            </cacheloader>
            <cacheloader>
                <class>org.jboss.cache.loader.JDBCCacheLoader</class>
                <properties>
                            cache.jdbc.table.name=jbosscache
                            cache.jdbc.table.create=true
                            cache.jdbc.table.drop=true
                            cache.jdbc.table.primarykey=jbosscache_pk
                            cache.jdbc.fqn.column=fqn
                            cache.jdbc.fqn.type=varchar(255)
                            cache.jdbc.node.column=node
                            cache.jdbc.node.type=longblob
                            cache.jdbc.parent.column=parent
                            cache.jdbc.driver=com.mysql.jdbc.Driver
                            cache.jdbc.url=jdbc:mysql://localhost:3306/jbossdb
                            cache.jdbc.user=root
                            cache.jdbc.password=
                 </properties>
                 <async>true</async>
                 <fetchPersistentState>false</fetchPersistentState>
                 <purgeOnStartup>false</purgeOnStartup>
             </cacheloader>
        </config>
    </attribute>

    我們將通過(guò)定制如上的配置信息以更有效地使用JBossCache。詳細(xì)情況可參考JBoss TreeCache參考文檔和范例。

    TreeCache tree = new TreeCache();
    tree.setClusterProperties("treecache.xml";
    tree.createService();
    tree.startService();
    tree.put("/a/b/c", "name", "Ben";
    tree.put("/a/b/c/d", "uid", new Integer(322649));
    Integer tmp = (Integer) tree.get("/a/b/c/d", "uid";
    tree.remove("/a/b";
    tree.stopService();
    tree.destroyService();
    posted on 2010-05-18 04:19 seal 閱讀(404) 評(píng)論(0)  編輯  收藏 所屬分類(lèi): web服務(wù)器
    主站蜘蛛池模板: 99久久久国产精品免费牛牛四川| 久久久久久国产精品免费无码| 免费人成在线观看网站品爱网| 国语成本人片免费av无码| 亚洲国产精品人人做人人爽 | 亚洲日韩中文字幕在线播放| 在线电影你懂的亚洲| 亚洲精品色在线网站| 另类免费视频一区二区在线观看| 18禁无遮挡无码网站免费| 亚洲欧洲无码AV电影在线观看 | 日本不卡高清中文字幕免费| 国产精品国产亚洲精品看不卡| 日韩亚洲不卡在线视频中文字幕在线观看 | 久久亚洲精品成人无码| 另类免费视频一区二区在线观看| 日韩免费福利视频| 日韩亚洲Av人人夜夜澡人人爽| 国产亚洲美女精品久久| 久久久久久国产精品免费免费男同 | 国产成人精品免费大全| 欧美男同gv免费网站观看| 亚洲精品无码乱码成人 | 亚洲精品日韩一区二区小说| 免费无码又爽又刺激一高潮| 日韩一品在线播放视频一品免费| 亚洲狠狠综合久久| 九九久久精品国产免费看小说| 国产va免费精品观看精品| 亚洲韩国精品无码一区二区三区| 亚洲国产AV一区二区三区四区| 久久A级毛片免费观看| 亚洲高清视频一视频二视频三| 亚洲日本乱码卡2卡3卡新区| 全免费a级毛片免费看| 亚洲国产中文字幕在线观看| 亚洲中文字幕久久无码| 18禁美女黄网站色大片免费观看| 亚洲综合国产一区二区三区| 亚洲av无码兔费综合| 日韩欧美一区二区三区免费观看|