當(dāng)前位置：
首頁(yè) >
前端技术
> javascript
>内容正文
javascript
在Oracle Coherence中分发Spring Bean
生活随笔
收集整理的這篇文章主要介紹了
在Oracle Coherence中分发Spring Bean
小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
本文展示了如何通過(guò)使用Oracle Coherence中的EntryProcessor和可移植對(duì)象格式（POF）功能來(lái)分發(fā)Spring Bean。
Coherence通過(guò)EntryProcessor API支持無(wú)鎖編程模型。 此功能通過(guò)減少網(wǎng)絡(luò)訪問(wèn)并在條目上執(zhí)行隱式的低級(jí)鎖定來(lái)提高系統(tǒng)性能。 此隱式低級(jí)鎖定功能與ConcurrentMap API提供的顯式lock（key）不同。
顯式鎖定，Transaction Framework API和Coherence資源適配器是其他作為入口處理器的Coherence事務(wù)選項(xiàng)。 有關(guān)Coherence交易選項(xiàng)的詳細(xì)信息，請(qǐng)參閱參考部分。 另外，對(duì)于Coherence顯式鎖定實(shí)現(xiàn)，可以建議使用Oracle Coherence文章中的分布式數(shù)據(jù)管理 。
可移植對(duì)象格式（POF）是獨(dú)立于平臺(tái)的序列化格式。 它允許將等效的Java，.NET和C ++對(duì)象編碼為相同的字節(jié)序列。 建議使用POF來(lái)提高系統(tǒng)性能，因?yàn)镻OF的序列化和反序列化性能要優(yōu)于Standart Java序列化（根據(jù)Coherence參考文檔，在具有String，long和3個(gè)整數(shù)的簡(jiǎn)單測(cè)試類(lèi)中，（反序列化）為7比Standart Java序列化快十倍）。
Coherence提供了多種緩存類(lèi)型，例如分布式（或分區(qū)），復(fù)制，樂(lè)觀，近，本地和遠(yuǎn)程緩存。 分布式緩存定義為在任意數(shù)量的群集節(jié)點(diǎn)之間分布（或分區(qū)）的數(shù)據(jù)的集合，這樣，群集中的一個(gè)節(jié)點(diǎn)就對(duì)緩存中的每個(gè)數(shù)據(jù)負(fù)責(zé)，并且責(zé)任是分布式的（或，負(fù)載均衡）。 請(qǐng)注意，本文中使用了分布式緩存類(lèi)型。 由于其他緩存類(lèi)型不在本文范圍之內(nèi)，請(qǐng)查看“參考”部分或“ Coherence參考”文檔。 它們的配置與分布式緩存配置非常相似。
如何通過(guò)使用覆蓋顯式鎖定的 Coherence文章分發(fā)Spring Bean –建議將Java Standart序列化比較兩個(gè)不同的實(shí)現(xiàn)（ EntryProcessor –便攜式對(duì)象格式（POF）和顯式鎖定– Java Standart序列化 ）。
在本文中，創(chuàng)建了一個(gè)名為OTV的新集群，并通過(guò)使用一個(gè)名為user-cache的緩存對(duì)象分發(fā)了一個(gè)spring bean。 它已分布在集群的兩個(gè)成員之間。
讓我們看一下實(shí)現(xiàn)AbsctractProcessor的實(shí)現(xiàn)， 該實(shí)現(xiàn)為集群中JVM之間的Spring Bean分配實(shí)現(xiàn)EntryProcessor接口和PortableObject接口 。
二手技術(shù)：
JDK 1.6.0_31
春天3.1.1
連貫性3.7.0 SolarisOS 5.10 Maven的3.0.2
步驟1：建立已完成的專(zhuān)案
創(chuàng)建一個(gè)Maven項(xiàng)目，如下所示。 （可以使用Maven或IDE插件來(lái)創(chuàng)建它）。
第2步：相干套餐
通過(guò)Coherence軟件包下載Coherence
步驟3：圖書(shū)館
首先，將Spring依賴項(xiàng)添加到Maven的pom.xml中。 請(qǐng)注意，Coherence庫(kù)已安裝到Local Maven Repository，并且其描述如下添加到pom.xml中。 另外，如果未使用Maven，則可以將coherence.jar文件添加到classpath。
<properties><spring.version>3.1.1.RELEASE</spring.version></properties><dependencies><!-- Spring 3 dependencies --><dependency><groupId>org.springframework</groupId><artifactId>spring-core</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>${spring.version}</version></dependency><!-- Coherence library(from local repository) --><dependency><groupId>com.tangosol</groupId><artifactId>coherence</artifactId><version>3.7.0</version></dependency><!-- Log4j library --><dependency><groupId>log4j</groupId><artifactId>log4j</artifactId><version>1.2.16</version></dependency></dependencies>以下maven插件可用于創(chuàng)建runnable-jar。
<plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-shade-plugin</artifactId><version>1.3.1</version><executions><execution><phase>package</phase><goals><goal>shade</goal></goals><configuration><transformers><transformerimplementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer"><mainClass>com.otv.exe.Application</mainClass></transformer><transformerimplementation="org.apache.maven.plugins.shade.resource.AppendingTransformer"><resource>META-INF/spring.handlers</resource></transformer><transformerimplementation="org.apache.maven.plugins.shade.resource.AppendingTransformer"><resource>META-INF/spring.schemas</resource></transformer></transformers></configuration></execution></executions></plugin> 步驟4：建立otv-pof-config.xml
otv-pof-config.xml涵蓋了使用可移植對(duì)象格式（POF）功能進(jìn)行序列化的類(lèi)。 在這個(gè)例子中； User，UpdateUserProcessor和DeleteUserProcessor類(lèi)實(shí)現(xiàn)com.tangosol.io.pof.PortableObject接口。
-Dtangosol.pof.config參數(shù)可用于在啟動(dòng)腳本中定義otv-pof-config.xml路徑。
<?xml version="1.0"?> <!DOCTYPE pof-config SYSTEM "pof-config.dtd"> <pof-config><user-type-list><!-- coherence POF user types --><include>coherence-pof-config.xml</include><!-- The definition of classes which use Portable Object Format --><user-type><type-id>1001</type-id><class-name>com.otv.user.User</class-name></user-type><user-type><type-id>1002</type-id><class-name>com.otv.user.processor.UpdateUserProcessor</class-name></user-type><user-type><type-id>1003</type-id><class-name>com.otv.user.processor.DeleteUserProcessor</class-name></user-type></user-type-list><allow-interfaces>true</allow-interfaces><allow-subclasses>true</allow-subclasses> </pof-config>步驟5：創(chuàng)建otv-coherence-cache-config.xml
otv-coherence-cache-config.xml包含（分布式或復(fù)制的）緩存方案和緩存方案映射配置。 創(chuàng)建的緩存配置應(yīng)添加到coherence-cache-config.xml中 。
<?xml version="1.0"?><cache-config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns="http://xmlns.oracle.com/coherence/coherence-cache-config"xsi:schemaLocation="http://xmlns.oracle.com/coherence/coherence-cache-configcoherence-cache-config.xsd"><caching-scheme-mapping><cache-mapping><cache-name>user-cache</cache-name><scheme-name>UserDistributedCacheWithPof</scheme-name></cache-mapping></caching-scheme-mapping><caching-schemes><distributed-scheme><scheme-name>UserDistributedCacheWithPof</scheme-name><service-name>UserDistributedCacheWithPof</service-name><serializer><instance><class-name>com.tangosol.io.pof.SafeConfigurablePofContext</class-name><init-params><init-param><param-type>String</param-type><param-value><!-- pof-config.xml path should be set-->otv-pof-config.xml</param-value></init-param></init-params></instance></serializer><backing-map-scheme><local-scheme /></backing-map-scheme><autostart>true</autostart></distributed-scheme></caching-schemes></cache-config>步驟6：創(chuàng)建tangosol-coherence-override.xml
tangosol-coherence-override.xml涵蓋了集群，成員身份和可配置的緩存工廠配置。 另外，以下配置xml文件顯示了群集的第一個(gè)成員。 -Dtangosol.coherence.override參數(shù)可用于在啟動(dòng)腳本中定義tangosol-coherence-override.xml路徑。
集群的第一個(gè)成員的tangosol-coherence-override.xml：
<?xml version='1.0'?><coherence xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns="http://xmlns.oracle.com/coherence/coherence-operational-config"xsi:schemaLocation="http://xmlns.oracle.com/coherence/coherence-operational-config coherence-operational-config.xsd"><cluster-config><member-identity><cluster-name>OTV</cluster-name><!-- Name of the first member of the cluster --><role-name>OTV1</role-name></member-identity><unicast-listener><well-known-addresses><socket-address id="1"><!-- IP Address of the first member of the cluster --><address>x.x.x.x</address><port>8089</port></socket-address><socket-address id="2"><!-- IP Address of the second member of the cluster --><address>y.y.y.y</address><port>8089</port></socket-address></well-known-addresses><!-- Name of the first member of the cluster --><machine-id>OTV1</machine-id><!-- IP Address of the first member of the cluster --><address>x.x.x.x</address><port>8089</port><port-auto-adjust>true</port-auto-adjust></unicast-listener></cluster-config><configurable-cache-factory-config><init-params><init-param><param-type>java.lang.String</param-type><param-value system-property="tangosol.coherence.cacheconfig"><!-- coherence-cache-config.xml path should be set-->otv-coherence-cache-config.xml</param-value></init-param></init-params></configurable-cache-factory-config></coherence>集群的第二個(gè)成員的tangosol-coherence-override.xml：
<?xml version='1.0'?><coherence xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns="http://xmlns.oracle.com/coherence/coherence-operational-config"xsi:schemaLocation="http://xmlns.oracle.com/coherence/coherence-operational-config coherence-operational-config.xsd"><cluster-config><member-identity><cluster-name>OTV</cluster-name><!-- Name of the second member of the cluster --><role-name>OTV2</role-name></member-identity><unicast-listener> <well-known-addresses><socket-address id="1"><!-- IP Address of the first member of the cluster --><address>x.x.x.x</address><port>8089</port></socket-address><socket-address id="2"><!-- IP Address of the second member of the cluster --><address>y.y.y.y</address><port>8089</port></socket-address></well-known-addresses><!-- Name of the second member of the cluster --><machine-id>OTV2</machine-id><!-- IP Address of the second member of the cluster --><address>y.y.y.y</address><port>8089</port><port-auto-adjust>true</port-auto-adjust></unicast-listener></cluster-config><configurable-cache-factory-config><init-params><init-param><param-type>java.lang.String</param-type><param-value system-property="tangosol.coherence.cacheconfig"><!-- coherence-cache-config.xml path should be set-->otv-coherence-cache-config.xml</param-value></init-param></init-params></configurable-cache-factory-config></coherence>步驟7：創(chuàng)建applicationContext.xml
applicationContext.xml已創(chuàng)建。
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-3.0.xsd"><!-- Beans Declaration --><bean id="User" class="com.otv.user.User" scope="prototype" /><bean id="UserCacheService" class="com.otv.user.cache.srv.UserCacheService" /><bean id="CacheUpdaterTask" class="com.otv.cache.updater.task.CacheUpdaterTask"><property name="userCacheService" ref="UserCacheService" /></bean> </beans>步驟8：建立SystemConstants類(lèi)別
SystemConstants類(lèi)已創(chuàng)建。 此類(lèi)涵蓋所有系統(tǒng)常數(shù)。
package com.otv.common;/*** System Constants** @author onlinetechvision.com* @since 2 Jun 2012* @version 1.0.0**/ public class SystemConstants {public static final String APPLICATION_CONTEXT_FILE_NAME = "applicationContext.xml";//Named Cache Definition...public static final String USER_CACHE = "user-cache";//Bean Names...public static final String BEAN_NAME_CACHE_UPDATER_TASK = "CacheUpdaterTask";public static final String BEAN_NAME_USER = "User";}步驟9：創(chuàng)建用戶豆
創(chuàng)建了一個(gè)新的User Spring bean。 該bean將分布在OTV集群中的兩個(gè)節(jié)點(diǎn)之間。 可以實(shí)現(xiàn)PortableObject進(jìn)行序列化。 PortableObject Interface有兩個(gè)未實(shí)現(xiàn)的方法，如readExternal和writeExternal 。 必須定義僅序列化的屬性。 在此示例中，所有屬性（用戶的id，名稱和姓氏）都已序列化。
package com.otv.user;import java.io.IOException;import com.tangosol.io.pof.PofReader; import com.tangosol.io.pof.PofWriter; import com.tangosol.io.pof.PortableObject;/*** User Bean** @author onlinetechvision.com* @since 2 Jun 2012* @version 1.0.0**/ public class User implements PortableObject {private String id;private String name;private String surname;/*** Gets User Id** @return String id*/public String getId() {return id;}/*** Sets User Id** @param String id*/public void setId(String id) {this.id = id;}/*** Gets User Name** @return String name*/public String getName() {return name;}/*** Sets User Name** @param String name*/public void setName(String name) {this.name = name;}/*** Gets User Surname** @return String surname*/public String getSurname() {return surname;}/*** Sets User Surname** @param String surname*/public void setSurname(String surname) {this.surname = surname;}@Overridepublic String toString() {StringBuilder strBuilder = new StringBuilder();strBuilder.append("Id : ").append(id);strBuilder.append(", Name : ").append(name);strBuilder.append(", Surname : ").append(surname);return strBuilder.toString();}/*** Restore the contents of a user type instance by reading its state* using the specified PofReader object.** @param PofReader in*/public void readExternal(PofReader in) throws IOException {this.id = in.readString(0);this.name = in.readString(1);this.surname = in.readString(2);}/*** Save the contents of a POF user type instance by writing its state* using the specified PofWriter object.** @param PofWriter out*/public void writeExternal(PofWriter out) throws IOException {out.writeString(0, id);out.writeString(1, name);out.writeString(2, surname);} }步驟10：建立IUserCacheService接口
創(chuàng)建了一個(gè)新的IUserCacheService接口以執(zhí)行緩存操作。
package com.otv.user.cache.srv;import com.otv.user.User; import com.otv.user.processor.DeleteUserProcessor; import com.otv.user.processor.UpdateUserProcessor; import com.tangosol.net.NamedCache;/*** User Cache Service Interface** @author onlinetechvision.com* @since 2 Jun 2012* @version 1.0.0**/ public interface IUserCacheService {/*** Gets Distributed User Cache** @return NamedCache User Cache*/NamedCache getUserCache();/*** Adds user to cache** @param User user*/void addUser(User user);/*** Updates user on the cache** @param String userId* @param UpdateUserProcessor processor**/void updateUser(String userId, UpdateUserProcessor processor);/*** Deletes user from the cache** @param String userId* @param DeleteUserProcessor processor**/void deleteUser(String userId, DeleteUserProcessor processor);}步驟11：創(chuàng)建UserCacheService類(lèi)
通過(guò)實(shí)現(xiàn)IUserCacheService接口創(chuàng)建UserCacheService類(lèi)。
package com.otv.user.cache.srv;import com.otv.cache.listener.UserMapListener; import com.otv.common.SystemConstants; import com.otv.user.User; import com.otv.user.processor.DeleteUserProcessor; import com.otv.user.processor.UpdateUserProcessor; import com.tangosol.net.CacheFactory; import com.tangosol.net.NamedCache;/*** User Cache Service** @author onlinetechvision.com* @since 2 Jun 2012* @version 1.0.0**/ public class UserCacheService implements IUserCacheService {private NamedCache userCache = null; public UserCacheService() {setUserCache(CacheFactory.getCache(SystemConstants.USER_CACHE));//UserMap Listener is registered to listen user-cache operationsgetUserCache().addMapListener(new UserMapListener());} /*** Adds user to cache** @param User user*/public void addUser(User user) {getUserCache().put(user.getId(), user);}/*** Deletes user from the cache** @param String userId* @param DeleteUserProcessor processor**/public void deleteUser(String userId, DeleteUserProcessor processor) {getUserCache().invoke(userId, processor);}/*** Updates user on the cache** @param String userId* @param UpdateUserProcessor processor**/public void updateUser(String userId, UpdateUserProcessor processor) {getUserCache().invoke(userId, processor);}/*** Gets Distributed User Cache** @return NamedCache User Cache*/public NamedCache getUserCache() {return userCache;}/*** Sets User Cache** @param NamedCache userCache*/public void setUserCache(NamedCache userCache) {this.userCache = userCache;} }步驟12：建立USERMAPLISTENER類(lèi)別
創(chuàng)建一個(gè)新的UserMapListener類(lèi)。 該偵聽(tīng)器接收分布式用戶緩存事件。
package com.otv.cache.listener;import org.apache.log4j.Logger;import com.tangosol.util.MapEvent; import com.tangosol.util.MapListener;/*** User Map Listener** @author onlinetechvision.com* @since 2 Jun 2012* @version 1.0.0**/ public class UserMapListener implements MapListener {private static Logger logger = Logger.getLogger(UserMapListener.class);/*** This method is invoked when an entry is deleted from the cache...** @param MapEvent me*/public void entryDeleted(MapEvent me) {logger.debug("Deleted Key = " + me.getKey() + ", Value = " + me.getOldValue());}/*** This method is invoked when an entry is inserted to the cache...** @param MapEvent me*/public void entryInserted(MapEvent me) {logger.debug("Inserted Key = " + me.getKey() + ", Value = " + me.getNewValue());}/*** This method is invoked when an entry is updated on the cache...** @param MapEvent me*/public void entryUpdated(MapEvent me) {logger.debug("Updated Key = " + me.getKey() + ", New_Value = " + me.getNewValue() + ", Old Value = " + me.getOldValue());} }步驟13：創(chuàng)建UpdateUserProcessor類(lèi)
AbstractProcessor是位于com.tangosol.util.processor包下的抽象類(lèi)。 它實(shí)現(xiàn)EntryProcessor接口。
創(chuàng)建UpdateUserProcessor類(lèi)以處理緩存上的用戶更新操作。 當(dāng)為密鑰調(diào)用UpdateUserProcessor時(shí) ，首先在集群中找到包含該密鑰的成員。 之后，從包含相關(guān)鍵的成員中調(diào)用UpdateUserProcessor ，并更新其值（用戶對(duì)象）。 因此，減少了網(wǎng)絡(luò)流量。
package com.otv.user.processor;import java.io.IOException;import org.apache.log4j.Logger;import com.otv.user.User; import com.tangosol.io.pof.PofReader; import com.tangosol.io.pof.PofWriter; import com.tangosol.io.pof.PortableObject; import com.tangosol.util.InvocableMap.Entry; import com.tangosol.util.processor.AbstractProcessor;/*** Update User Processor** @author onlinetechvision.com* @since 2 Jun 2012* @version 1.0.0**/ public class UpdateUserProcessor extends AbstractProcessor implements PortableObject { private static Logger logger = Logger.getLogger(UpdateUserProcessor.class);private User newUser;/*** This empty constructor is added for Portable Object Format(POF).**/public UpdateUserProcessor() {}public UpdateUserProcessor(User newUser) {this.newUser = newUser;}/*** Processes a Map.Entry object.** @param Entry entry* @return Object newUser*/public Object process(Entry entry) {Object newValue = null;try {newValue = getNewUser();entry.setValue(newValue);} catch (Exception e) {logger.error("Error occured when entry was being processed!", e);}return newValue;}/*** Gets new user** @return User newUser*/public User getNewUser() {return newUser;}/*** Sets new user** @param User newUser*/public void setNewUser(User newUser) {this.newUser = newUser;}/*** Restore the contents of a user type instance by reading its state* using the specified PofReader object.** @param PofReader in*/public void readExternal(PofReader in) throws IOException {setNewUser((User) in.readObject(0));}/*** Save the contents of a POF user type instance by writing its state* using the specified PofWriter object.** @param PofWriter out*/public void writeExternal(PofWriter out) throws IOException {out.writeObject(0, getNewUser());} }步驟14：創(chuàng)建DeleteUserProcessor類(lèi)別
創(chuàng)建DeleteUserProcessor類(lèi)以處理緩存上的用戶刪除操作。 當(dāng)為密鑰調(diào)用DeleteUserProcessor時(shí) ，首先在集群中找到包含該密鑰的成員。 然后，從包含相關(guān)密鑰的成員中調(diào)用DeleteUserProcessor 。 因此，減少了網(wǎng)絡(luò)流量。
package com.otv.user.processor;import java.io.IOException;import org.apache.log4j.Logger;import com.otv.user.User; import com.tangosol.io.pof.PofReader; import com.tangosol.io.pof.PofWriter; import com.tangosol.io.pof.PortableObject; import com.tangosol.util.InvocableMap.Entry; import com.tangosol.util.processor.AbstractProcessor;/*** Delete User Processor** @author onlinetechvision.com* @since 2 Jun 2012* @version 1.0.0**/ public class DeleteUserProcessor extends AbstractProcessor implements PortableObject { private static Logger logger = Logger.getLogger(DeleteUserProcessor.class);/*** Processes a Map.Entry object.** @param Entry entry* @return Object user*/public Object process(Entry entry) {User user = null;try {user = (User) entry.getValue();entry.remove(true);} catch (Exception e) {logger.error("Error occured when entry was being processed!", e);}return user;}/*** Restore the contents of a user type instance by reading its state* using the specified PofReader object.** @param PofReader in*/public void readExternal(PofReader in) throws IOException {}/*** Save the contents of a POF user type instance by writing its state* using the specified PofWriter object.** @param PofWriter out*/public void writeExternal(PofWriter out) throws IOException {} }步驟15：創(chuàng)建CacheUpdaterTask類(lèi)別
創(chuàng)建CacheUpdaterTask類(lèi)以執(zhí)行緩存操作（添加，更新和刪除）并監(jiān)視緩存內(nèi)容。
package com.otv.cache.updater.task;import java.util.Collection;import org.apache.log4j.Logger; import org.springframework.beans.BeansException; import org.springframework.beans.factory.BeanFactory; import org.springframework.beans.factory.BeanFactoryAware;import com.otv.common.SystemConstants; import com.otv.user.User; import com.otv.user.cache.srv.IUserCacheService; import com.otv.user.processor.DeleteUserProcessor; import com.otv.user.processor.UpdateUserProcessor;/*** Cache Updater Task** @author onlinetechvision.com* @since 2 Jun 2012* @version 1.0.0**/ public class CacheUpdaterTask implements BeanFactoryAware, Runnable {private static Logger log = Logger.getLogger(CacheUpdaterTask.class);private IUserCacheService userCacheService;private BeanFactory beanFactory;public void run() {try {while(true) {/*** Before the project is built for the first member,* this code block should be used instead of* method processRequestsOnSecondMemberOfCluster.*/processRequestsOnFirstMemberOfCluster();/*** Before the project is built for the second member,* this code block should be used instead of* method processRequestsOnFirstMemberOfCluster.*/ // processRequestsOnSecondMemberOfCluster();}} catch (InterruptedException e) {e.printStackTrace();}}/*** Processes the cache requests on the first member of cluster...** @throws InterruptedException*/private void processRequestsOnFirstMemberOfCluster() throws InterruptedException {//Entry is added to cache...getUserCacheService().addUser(getUser("1", "Bruce", "Willis"));//Cache Entries are being printed...printCacheEntries();Thread.sleep(10000);User newUser = getUser("1", "Client", "Eastwood");//Existent Entry is updated on the cache...getUserCacheService().updateUser(newUser.getId(), new UpdateUserProcessor(newUser));//Cache Entries are being printed...printCacheEntries();Thread.sleep(10000);//Entry is deleted from cache...getUserCacheService().deleteUser(newUser.getId(), new DeleteUserProcessor());//Cache Entries are being printed...printCacheEntries();Thread.sleep(10000);}/*** Processes the cache requests on the second member of cluster...** @throws InterruptedException*/private void processRequestsOnSecondMemberOfCluster() throws InterruptedException {//Entry is added to cache...getUserCacheService().addUser(getUser("2", "Nathalie", "Portman"));Thread.sleep(15000);User newUser = getUser("2", "Sharon", "Stone");//Existent Entry is updated on the cache...getUserCacheService().updateUser(newUser.getId(), new UpdateUserProcessor(newUser));User newUser2 = getUser("1", "Maria", "Sharapova");//Existent Entry is updated on the cache...getUserCacheService().updateUser(newUser2.getId(), new UpdateUserProcessor(newUser2));Thread.sleep(15000);//Entry is deleted from cache...getUserCacheService().deleteUser(newUser.getId(), new DeleteUserProcessor());Thread.sleep(15000);}/*** Prints cache entries**/private void printCacheEntries() {Collection<User> userCollection = (Collection<User>)getUserCacheService().getUserCache().values();for(User user : userCollection) {log.debug("Cache Content : "+user);}}/*** Gets new user instance** @param String user id* @param String user name* @param String user surname* @return User user*/private User getUser(String id, String name, String surname) {User user = getNewUserInstance();user.setId(id);user.setName(name);user.setSurname(surname);return user;}/*** Gets user cache service...** @return IUserCacheService userCacheService*/public IUserCacheService getUserCacheService() {return userCacheService;}/*** Sets user cache service...** @param IUserCacheService userCacheService*/public void setUserCacheService(IUserCacheService userCacheService) {this.userCacheService = userCacheService;}/*** Gets a new instance of User Bean** @return User*/public User getNewUserInstance() {return (User) getBeanFactory().getBean(SystemConstants.BEAN_NAME_USER);}/*** Gets bean factory** @return BeanFactory*/public BeanFactory getBeanFactory() {return beanFactory;}/*** Sets bean factory** @param BeanFactory beanFactory* @throws BeansException*/public void setBeanFactory(BeanFactory beanFactory) throws BeansException {this.beanFactory = beanFactory;} }步驟16：創(chuàng)建應(yīng)用程序類(lèi)
創(chuàng)建應(yīng)用程序類(lèi)以運(yùn)行應(yīng)用程序。
package com.otv.exe;import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext;import com.otv.cache.updater.task.CacheUpdaterTask; import com.otv.common.SystemConstants;/*** Application Class** @author onlinetechvision.com* @since 2 Jun 2012* @version 1.0.0**/ public class Application {/*** Starts the application** @param String[] args**/public static void main(String[] args) {ApplicationContext context = new ClassPathXmlApplicationContext(SystemConstants.APPLICATION_CONTEXT_FILE_NAME);CacheUpdaterTask cacheUpdaterTask = (CacheUpdaterTask) context.getBean(SystemConstants.BEAN_NAME_CACHE_UPDATER_TASK);Thread cacheUpdater = new Thread(cacheUpdaterTask);cacheUpdater.start();} }步驟17：建立專(zhuān)案
在構(gòu)建OTV_Spring_Coherence_With_Processor_and_POF項(xiàng)目之后，將創(chuàng)建OTV_Spring_Coherence-0.0.1-SNAPSHOT.jar 。
請(qǐng)注意，集群成員的Coherence配置不同，因此應(yīng)為每個(gè)成員分別構(gòu)建項(xiàng)目。
步驟18：在集群的第一個(gè)成員上運(yùn)行項(xiàng)目
在集群成員上運(yùn)行了已創(chuàng)建的OTV_Spring_Coherence-0.0.1-SNAPSHOT.jar文件后，以下輸出日志將顯示在第一個(gè)成員的控制臺(tái)上：
--After A new cluster is created and First Member joins the cluster, a new entry is added to the cache. 02.06.2012 14:21:45 DEBUG (UserMapListener.java:33) - Inserted Key = 1, Value = Id : 1, Name : Bruce, Surname : Willis 02.06.2012 14:21:45 DEBUG (CacheUpdaterTask.java:116) - Cache Content : Id : 1, Name : Bruce, Surname : Willis ....... --After Second Member joins the cluster, a new entry is added to the cache. 02.06.2012 14:21:45 DEBUG (UserMapListener.java:33) - Inserted Key = 2, Value = Id : 2, Name : Nathalie, Surname : Portman ....... --Cache operations go on both first and second members of the cluster: 02.06.2012 14:21:55 DEBUG (UserMapListener.java:42) - Updated Key = 1, New_Value = Id : 1, Name : Client, Surname : Eastwood,Old Value = Id : 1, Name : Bruce, Surname : Willis02.06.2012 14:21:55 DEBUG (CacheUpdaterTask.java:116) - Cache Content : Id : 2, Name : Nathalie, Surname : Portman 02.06.2012 14:21:55 DEBUG (CacheUpdaterTask.java:116) - Cache Content : Id : 1, Name : Client, Surname : Eastwood02.06.2012 14:22:00 DEBUG (UserMapListener.java:42) - Updated Key = 2, New_Value = Id : 2, Name : Sharon, Surname : Stone,Old Value = Id : 2, Name : Nathalie, Surname : Portman02.06.2012 14:22:00 DEBUG (UserMapListener.java:42) - Updated Key = 1, New_Value = Id : 1, Name : Maria, Surname : Sharapova,Old Value = Id : 1, Name : Client, Surname : Eastwood02.06.2012 14:22:05 DEBUG (UserMapListener.java:24) - Deleted Key = 1, Value = Id : 1, Name : Maria, Surname : Sharapova 02.06.2012 14:22:05 DEBUG (CacheUpdaterTask.java:116) - Cache Content : Id : 2, Name : Sharon, Surname : Stone 02.06.2012 14:22:15 DEBUG (UserMapListener.java:24) - Deleted Key = 2, Value = Id : 2, Name : Sharon, Surname : Stone 02.06.2012 14:22:15 DEBUG (UserMapListener.java:33) - Inserted Key = 1, Value = Id : 1, Name : Bruce, Surname : Willis 02.06.2012 14:22:15 DEBUG (CacheUpdaterTask.java:116) - Cache Content : Id : 1, Name : Bruce, Surname : Willis步驟19：下載
OTV_Spring_Coherence_With_Processor_and_POF
進(jìn)一步閱讀：
連貫地執(zhí)行交易
在一致性中使用可移植對(duì)象格式
Spring Framework參考3.x
參考： Online Technology Vision博客上來(lái)自JCG合作伙伴 Eren Avsarogullari的Oracle Coherence中的EntryProcessor和PortableObject特性如何分發(fā)Spring Bean 。
翻譯自: https://www.javacodegeeks.com/2012/06/distribute-spring-beans-in-oracle.html
總結(jié)
以上是生活随笔為你收集整理的在Oracle Coherence中分发Spring Bean的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： 江苏银行是什么性质的银行？
- 下一篇： Spring和JSF集成：分页