零雨其蒙's Blog

做优秀的程序员
随笔 - 59, 文章 - 13, 评论 - 58, 引用 - 0
数据加载中……

Oracle Coherence初啼

     昨天写了个Coherence的小例子,使用了Oracle Enterprise Pack for Eclipse,直接用它创建了一个ADF项目,连带创建了JPA项目,在Configuration里添加了Coherence,这样就有了配套的jar包了。
     Coherence利用多播自动组成集群,类可以不实现序列化接口,这是一个简单的例子:
public class Cat  {
 
    private String name;
    private int age;
    private String sex;
      

    public Cat() {
        super();

    }

    public Cat(String name, int age, String sex) {
        super();
        this.name = name;
        this.age = age;
        this.sex = sex;
    }
服务类:
public class CatService {
 

    
public Cat getCat(String name){
        NamedCache cache 
= CacheFactory.getCache("AnimalCache");
        Cat cat 
= (Cat) cache.get(name);
        
if(cat==null){
            
long age = Math.round(Math.random() * 10)+5;
            cat 
= new Cat(name,(int) age,"male");
            cache.put(name, cat);
        }
        
return cat;
    }
}


测试:
 
public class CatServiceTest {
    CatService catService
=new CatService();
    @Before
    
public void setUp() throws Exception {
        CacheFactory.ensureCluster();
    }

    @After
    
public void tearDown() throws Exception {
        CacheFactory.shutdown(); 
    }

    @Test
    
public void test() {
        Cat tomCat
=catService.getCat("tom");
        Cat tomCatFromCache
=catService.getCat("tom");
        System.out.println(tomCat);
        assertEquals(tomCat, tomCatFromCache);
    }

}
   Coherence推荐采用pof作为Serializer,这样不需要实现序列化接口,而且性能非常高,需要做以下几件事实现这个:
    1 创建Serializer类:
    
public class CatSerializer implements PofSerializer {

    @Override
    
public Object deserialize(PofReader pofReader) throws IOException {
         String sName
=pofReader.readString(0);
         Cat cat
=new Cat();
         cat.setName(sName);
         pofReader.registerIdentity(cat);
         cat.setAge(pofReader.readInt(
1));
         cat.setSex(pofReader.readString(
2));
         pofReader.readRemainder();
        
return cat;
    }

    @Override
    
public void serialize(PofWriter pofWriter, Object object) throws IOException {
         Cat cat
=(Cat)object;
         pofWriter.writeString(
0,cat.getName());
         pofWriter.writeInt(
1, cat.getAge());
         pofWriter.writeString(
2, cat.getSex());
         pofWriter.writeRemainder(
null);
    }

}
    2 创建一个coherence-config文件,指定serializer,共有三个级别的指定,针对特定service,针对所有service,针对jvm,下面是针对所有service。
  
<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-config http://xmlns.oracle.com/coherence/coherence-cache-config/1.1/coherence-cache-config.xsd">
    
<!-- The defaults element defines factory-wide default settings. -->
    
<defaults>
        
<!-- Note: This element defines the default serializer for all services 
            defined within this cache configuration descriptor. Valid values include 
            full serializer definitions, as well as named references to serializers defined 
            within the "serializers" element of the operational configuration. Example 
            values include: java, pof. Default value is java. 
-->
        
<!--<serializer system-property="tangosol.coherence.serializer" />-->
        
<serializer>
                
<instance>
                    
<class-name>com.tangosol.io.pof.ConfigurablePofContext</class-name>
                    
<init-params>
                        
<init-param>
                            
<param-type>String</param-type>
                            
<param-value>custom-pof-config.xml</param-value>
                        
</init-param>
                    
</init-params>
                
</instance>
            
</serializer>

   3 编写custom-pof-config.xml,注册serializer:
    
<?xml version="1.0"?>
<pof-config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns
="http://xmlns.oracle.com/coherence/coherence-pof-config"
    xsi:schemaLocation
="http://xmlns.oracle.com/coherence/coherence-pof-config http://xmlns.oracle.com/coherence/coherence-pof-config/1.1/coherence-pof-config.xsd">
    
<user-type-list>
        
<!-- include all "standard" Coherence POF user types -->
        
<include>coherence-pof-config.xml</include>
        
<user-type>
            
<type-id>1001</type-id>
            
<class-name>org.jport.coherence.demo.Cat</class-name>
            
<serializer>
                
<class-name>org.jport.coherence.demo.CatSerializer</class-name>
            
</serializer>
        
</user-type>

    
</user-type-list>
</pof-config>

   4 指定这个自定义的coherence-config.xml,在jvm启动参数里:
    
-Dtangosol.coherence.cacheconfig=C:\workspace\AdfprjModel\src\custom-coherence-cache-config.xml

      由于我是用JUnit进行测试,因此就是把这个写在run junit的configuration里了。
   
   如果属性是引用了其他的类也没问题:
   
public class Cat  {
 
    
private String name;
    
private int age;
    
private String sex;
    
private Owner owner;

public class Owner {
    
private String name;
    
private String phoneNumber;

    
public Owner(String name, String phoneNumber) {
        
super();
        
this.name = name;
        
this.phoneNumber = phoneNumber;
    }
   创建Owner的Serializer:
   
public class OwnerSerializer implements PofSerializer {

    @Override
    
public Object deserialize(PofReader pofReader) throws IOException {
         String sName
=pofReader.readString(0);
         Owner owner
=new Owner();
         owner.setName(sName);
         pofReader.registerIdentity(owner);
         owner.setPhoneNumber(pofReader.readString(
1));
         
         pofReader.readRemainder();
        
return owner;
    }

    @Override
    
public void serialize(PofWriter pofWriter, Object object) throws IOException {
        Owner owner
=(Owner)object;
         pofWriter.writeString(
0,owner.getName());         
         pofWriter.writeString(
1, owner.getPhoneNumber());
         pofWriter.writeRemainder(
null);
    }

}
  修改Cat的Serializer:
  
public class CatSerializer implements PofSerializer {

    @Override
    
public Object deserialize(PofReader pofReader) throws IOException {
         String sName
=pofReader.readString(0);
         Cat cat
=new Cat();
         cat.setName(sName);
         pofReader.registerIdentity(cat);
         cat.setAge(pofReader.readInt(
1));
         cat.setSex(pofReader.readString(
2));
         
cat.setOwner((Owner) pofReader.readObject(3));        
         pofReader.readRemainder();
return cat;
    }

    @Override
    
public void serialize(PofWriter pofWriter, Object object) throws IOException {
         Cat cat
=(Cat)object;
         pofWriter.writeString(
0,cat.getName());
         pofWriter.writeInt(
1, cat.getAge());
         pofWriter.writeString(
2, cat.getSex());
  
       pofWriter.writeObject(3, cat.getOwner());
         pofWriter.writeRemainder(
null);
    }

}
 
 然后在pof配置中新增该类型:
  
    <user-type>
            
<type-id>1002</type-id>
            
<class-name>org.jport.coherence.demo.Owner</class-name>
            
<serializer>
                
<class-name>org.jport.coherence.demo.OwnerSerializer</class-name>
            
</serializer>
        
</user-type>

   引用集合类:
  
public class Cat  {
 
    
private String name;
    
private int age;
    
private String sex;
    
private Owner owner;
    
private List<Cat> childrenCats;
  
   修改Cat服务类:
   
    public Cat getCat(String name){
        NamedCache cache 
= CacheFactory.getCache("AnimalCache");
        Cat cat 
= (Cat) cache.get(name);
        
if(cat==null){
            
int age =(int) Math.round(Math.random() * 10)+5;
            cat 
= new Cat(name,  age,"male");
            Owner owner 
= new Owner("sslaowan","1212554525");
            cat.setOwner(owner);
            List
<Cat> childrenCats=new ArrayList<Cat>();
            Cat child1 
= new Cat("tt",age-3,"female");
            child1.setOwner(owner);         
            Cat child2 
= new Cat("mm",age-3,"female");
            child2.setOwner(owner);
            childrenCats.add(child1);
            childrenCats.add(child2);
            cat.setChildrenCats(childrenCats);
            cache.put(name, cat);
        }
        
return cat;
    }
     修改Serializer:
     
public class CatSerializer implements PofSerializer {

    @Override
    
public Object deserialize(PofReader pofReader) throws IOException {
         String sName
=pofReader.readString(0);
         Cat cat
=new Cat();
         cat.setName(sName);
         pofReader.registerIdentity(cat);
         cat.setAge(pofReader.readInt(
1));
         cat.setSex(pofReader.readString(
2));
         cat.setOwner((Owner) pofReader.readObject(
3));
       
  cat.setChildrenCats((List<Cat>) pofReader.readCollection(4new ArrayList<Cat>()));        
         pofReader.readRemainder();
        return cat;
    }

    @Override
    
public void serialize(PofWriter pofWriter, Object object) throws IOException {
         Cat cat
=(Cat)object;
         pofWriter.writeString(
0,cat.getName());
         pofWriter.writeInt(
1, cat.getAge());
         pofWriter.writeString(
2, cat.getSex());
         pofWriter.writeObject(
3, cat.getOwner());
       
  pofWriter.writeCollection(4, cat.getChildrenCats(), Cat.class);
         pofWriter.writeRemainder(
null);
    }

}

      测试结果如下:
   
Cat [name=tom, age=6, sex=male, owner=Owner [name=sslaowan, phoneNumber=1212554525],
    childrenCats
=[Cat [name=tt, age=3, sex=female, owner=Owner [name=sslaowan, phoneNumber=1212554525], childrenCats=null],
                       Cat 
[name=mm, age=3, sex=female, owner=Owner [name=sslaowan, phoneNumber=1212554525], childrenCats=null]]]

    运行多个节点加入集群,可以让JUnit测试
    
Group{Address=224.3.7.0, Port=37000, TTL=4}

MasterMemberSet(
  ThisMember
=Member(Id=4, Timestamp=2012-05-23 17:44:27.749, Address=192.168.56.1:8094, MachineId=14169, Location=site:,machine:wanxing-PC,process:12444, Role=EclipseJdtRemoteTestRunner)
  OldestMember
=Member(Id=1, Timestamp=2012-05-23 17:35:23.01, Address=192.168.56.1:8088, MachineId=14169, Location=site:,machine:wanxing-PC,process:14536, Role=EclipseJdtRemoteTestRunner)
  ActualMemberSet
=MemberSet(Size=4
    Member(Id
=1, Timestamp=2012-05-23 17:35:23.01, Address=192.168.56.1:8088, MachineId=14169, Location=site:,machine:wanxing-PC,process:14536, Role=EclipseJdtRemoteTestRunner)
    Member(Id
=2, Timestamp=2012-05-23 17:35:28.781, Address=192.168.56.1:8090, MachineId=14169, Location=site:,machine:wanxing-PC,process:13692, Role=EclipseJdtRemoteTestRunner)
    Member(Id
=3, Timestamp=2012-05-23 17:36:06.641, Address=192.168.56.1:8092, MachineId=14169, Location=site:,machine:wanxing-PC,process:14964, Role=EclipseJdtRemoteTestRunner)
    Member(Id
=4, Timestamp=2012-05-23 17:44:27.749, Address=192.168.56.1:8094, MachineId=14169, Location=site:,machine:wanxing-PC,process:12444, Role=EclipseJdtRemoteTestRunner)
    )
  MemberId|ServiceVersion|ServiceJoined|MemberState
    
1|3.7.1|2012-05-23 17:35:23.01|JOINED,
    
2|3.7.1|2012-05-23 17:35:28.781|JOINED,
    
3|3.7.1|2012-05-23 17:36:06.641|JOINED,
    
4|3.7.1|2012-05-23 17:44:27.769|JOINED
  RecycleMillis
=1200000
  RecycleSet
=MemberSet(Size=0
    )
  )

TcpRing{Connections
=[3]}
IpMonitor{AddressListSize
=0}
关于pof的更多内容看这个:
  

posted on 2012-05-23 16:41 零雨其蒙 阅读(1913) 评论(0)  编辑  收藏 所属分类: 学习笔记


只有注册用户登录后才能发表评论。


网站导航: