码迷，mamicode.com
首页 > 其他好文 > 详细

Esper学习之二：事件类型

时间：2015-10-12 20:48:41      阅读：175      评论：0      收藏：0      [点我收藏+]

标签：

Esper对事件有特殊的数据结构约定。能处理的事件结构有：POJO，java.util.Map，Object Array，XML

1.POJO

       对于POJO，Esper要求对每一个私有属性要有getter方法。Esper允许不必按照JavaBean规定的格式，但是getter方法是必须的。又或者可以在配置文件中配置可访问的方法来代替getter。简单示例如下

 

[java] view plaincopy
 
  1. public class Person  
  2. {  
  3.     String name;  
  4.     int age;  
  5.   
  6.     public String getName()  
  7.     {  
  8.         return name;  
  9.     }  
  10.   
  11.     public int getAge()  
  12.     {  
  13.         return age;  
  14.     }  
  15. }  

Esper同样也能支持复杂的数据类型以及嵌套。稍微复杂的Person如下

 

 

[java] view plaincopy
 
  1. import java.util.List;  
  2. import java.util.Map;  
  3.   
  4. public class Person  
  5. {  
  6.     String name;  
  7.     int age;  
  8.     List<Child> children;  
  9.     Map<String, Integer> phones;  
  10.     Address address;  
  11.   
  12.     public String getName()  
  13.     {  
  14.         return name;  
  15.     }  
  16.   
  17.     public int getAge()  
  18.     {  
  19.         return age;  
  20.     }  
  21.   
  22.     public List<Child> getChildren()  
  23.     {  
  24.         return children;  
  25.     }  
  26.   
  27.     public Map<String, Integer> getPhones()  
  28.     {  
  29.         return phones;  
  30.     }  
  31.   
  32.     public Address getAddress()  
  33.     {  
  34.         return address;  
  35.     }  
  36.       
  37. }  
  38.   
  39. class Child  
  40. {  
  41.     String name;  
  42.     int gender;  
  43.     // 省略getter方法  
  44. }  
  45.   
  46. class Address  
  47. {  
  48.     String road;  
  49.     String street;  
  50.     int houseNo;  
  51.     // 省略getter方法  
  52. }  

如上所示，Esper能支持包含了集合类型和嵌套类的POJO，示例的EPL语句如下

 

 

[sql] view plaincopy
 
  1. // 当Person类型的事件中name为luonanqin时，Esper能得到对应的age,children和address  
  2. select age,children,address from Person where name="luonanqin"   

 

如果我不想要所有的child，而是想要第二个。并且我想得到家里的电话号码，那么Person需要改动一下

 

[java] view plaincopy
 
  1. import java.util.List;  
  2. import java.util.Map;  
  3.   
  4. public class Person  
  5. {  
  6.     String name;  
  7.     int age;  
  8.     List<Child> children;  
  9.     Map<String, Integer> phones;  
  10.     Address address;  
  11.   
  12.     public String getName()  
  13.     {  
  14.         return name;  
  15.     }  
  16.   
  17.     public int getAge()  
  18.     {  
  19.         return age;  
  20.     }  
  21.   
  22.     public Child getChildren(int index)  
  23.     {  
  24.         return children.get(index);  
  25.     }  
  26.   
  27.     public int getPhones(String name)  
  28.     {  
  29.         return phones.get(name);  
  30.     }  
  31.   
  32.     public Address getAddress()  
  33.     {  
  34.         return address;  
  35.     }  
  36.     // Address，Child不变  
  37. }  

对应的EPL如下

 

 

[java] view plaincopy
 
  1. // 当Person类型的事件中name为luonanqin时，Esper能得到对应的第二个孩子,家里的电话和家庭住址在哪条路上  
  2. select children[1], phones(‘home‘), address.road where Person where name="luonanqin"  

 

 

Esper支持事件的更新，对此Esper要求提供对应的setter方法。Person需要再有点小该度。示例如下

 

[java] view plaincopy
 
  1. import java.util.List;  
  2. import java.util.Map;  
  3.   
  4. public class Person  
  5. {  
  6.     String name;  
  7.     int age;  
  8.     List<Child> children;  
  9.     Map<String, Integer> phones;  
  10.     Address address;  
  11.   
  12.     public String getName()  
  13.     {  
  14.         return name;  
  15.     }  
  16.   
  17.     public int getAge()  
  18.     {  
  19.         return age;  
  20.     }  
  21.   
  22.     public Child getChildren(int index)  
  23.     {  
  24.         return children.get(index);  
  25.     }  
  26.       
  27.     // 此方法用于phones属性的更新  
  28.     public void setPhones(String name, Integer number){  
  29.         phones.put(name, number);  
  30.     }  
  31.   
  32.     public int getPhones(String name)  
  33.     {  
  34.         return phones.get(name);  
  35.     }  
  36.   
  37.     public Address getAddress()  
  38.     {  
  39.         return address;  
  40.     }  
  41.     // Address，Child不变  
  42. }  

对应的EPL如下

 

 

[sql] view plaincopy
 
  1. // 当Person类型的事件中name为luonanqin时，更新家里的电话  
  2. update Person set phones(‘home‘) = 123456789 where name="luonanqin"  

Esper对POJO的支持基本上就是上面所说的，另外他还支持实现了多个接口类或者抽象类的POJO，使用方法和普通的POJO没什么区别，这里就不列举了。

 

 

2.Map

Esper支持原生Java Map结构的事件。相对于POJO来说，Map的结构更利于事件类型的热加载，毕竟不是class，所以不需要重启JVM。所以如果系统对重启比较敏感，建议使用Map来定义事件的结构。Map的结构很简单，主要分为事件定义名和事件属性列表。我们继续拿Person来讲解

 

[java] view plaincopy
 
  1. import java.util.HashMap;  
  2. import java.util.List;  
  3. import java.util.Map;  
  4.   
  5. import com.espertech.esper.client.EPAdministrator;  
  6. import com.espertech.esper.client.EPServiceProvider;  
  7. import com.espertech.esper.client.EPServiceProviderManager;  
  8.   
  9.   
  10. public class PersonMap  
  11. {  
  12.     public static void main(String[] args)  
  13.     {  
  14.         EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();  
  15.         EPAdministrator admin = epService.getEPAdministrator();  
  16.           
  17.         // Person定义  
  18.         Map<String,Object> person = new HashMap<String,Object>();  
  19.         person.put("name", String.class);  
  20.         person.put("age", int.class);  
  21.         person.put("children", List.class);  
  22.         person.put("phones", Map.class);  
  23.           
  24.         // 注册Person到Esper  
  25.         admin.getConfiguration().addEventType("Person", person);  
  26.     }  
  27. }  

如上所示，Map结构的事件需要将属性名作为key，属性的数据类型作为value保存到Map中，然后再通过Esper的接口注册到Esper。其中addEventType的两个参数分别代表事件定义的名称和所定义的结构。

 

对应的EPL和POJO的没有区别

 

[sql] view plaincopy
 
  1. // 当Person类型的事件中name为luonanqin时，Esper能得到对应的age,children  
  2. select age,children from Person where name="luonanqin"   

Map对于嵌套类的定义比较特别。如果嵌套的类是POJO，那就如上面所示。如果嵌套的还是Map，那么定义方式就需要改变。我们为Person加上Address，示例如下

 

[java] view plaincopy
 
  1. import java.util.HashMap;  
  2. import java.util.List;  
  3. import java.util.Map;  
  4.   
  5. import com.espertech.esper.client.EPAdministrator;  
  6. import com.espertech.esper.client.EPServiceProvider;  
  7. import com.espertech.esper.client.EPServiceProviderManager;  
  8.   
  9. public class PersonMap  
  10. {  
  11.     public static void main(String[] args)  
  12.     {  
  13.         EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();  
  14.         EPAdministrator admin = epService.getEPAdministrator();  
  15.   
  16.         // Address定义  
  17.         Map<String, Object> address = new HashMap<String, Object>();  
  18.         address.put("road", String.class);  
  19.         address.put("street", String.class);  
  20.         address.put("houseNo", int.class);  
  21.   
  22.         // Person定义  
  23.         Map<String, Object> person = new HashMap<String, Object>();  
  24.         person.put("name", String.class);  
  25.         person.put("age", int.class);  
  26.         person.put("children", List.class);  
  27.         person.put("phones", Map.class);  
  28.         person.put("address", "Address");  
  29.   
  30.         // 注册Address到Esper  
  31.         admin.getConfiguration().addEventType("Address", address);  
  32.         // 注册Person到Esper  
  33.         admin.getConfiguration().addEventType("Person", person);  
  34.     }  
  35. }  

如上所示，有两个关键点：

 

1.Person在定义Address属性时，map的value不是Address.class，而是Address字符串，而这就代表引擎里的Address对应的Map结构定义

2.事件定义注册必须是Address先于Person，因为Person用到了Address，而引擎是根据Address注册时用的名字去查找Address定义的，所以如果名字写错，引擎就找不到Address了

如果Person有多个Address，则以数组方式定义Person的多个Address时，代码又变成下面的样子了

 

[java] view plaincopy
 
  1. person.put("addresses", "Address[]");  

 

 

另外对于Map，Esper只支持增量更新，也就是说只能增加Map中的属性定义，而不能修改或者删除某个属性（实际上属性增多并不影响其处理性能，所以没有删除在我看来也没什么。至于修改，也只能是先注销再注册了）。我们为Person增加一个gender属性，示例如下

 

[java] view plaincopy
 
  1. import java.util.Arrays;  
  2. import java.util.HashMap;  
  3. import java.util.List;  
  4. import java.util.Map;  
  5.   
  6. import com.espertech.esper.client.EPAdministrator;  
  7. import com.espertech.esper.client.EPServiceProvider;  
  8. import com.espertech.esper.client.EPServiceProviderManager;  
  9. import com.espertech.esper.client.EventType;  
  10.   
  11. public class PersonMap  
  12. {  
  13.     public static void main(String[] args)  
  14.     {  
  15.         EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();  
  16.         EPAdministrator admin = epService.getEPAdministrator();  
  17.   
  18.         // Address定义  
  19.         Map<String, Object> address = new HashMap<String, Object>();  
  20.         address.put("road", String.class);  
  21.         address.put("street", String.class);  
  22.         address.put("houseNo", int.class);  
  23.   
  24.         // Person定义  
  25.         Map<String, Object> person = new HashMap<String, Object>();  
  26.         person.put("name", String.class);  
  27.         person.put("age", int.class);  
  28.         person.put("children", List.class);  
  29.         person.put("phones", Map.class);  
  30.         person.put("address", "Address");  
  31.   
  32.         // 注册Address到Esper  
  33.         admin.getConfiguration().addEventType("Address", address);  
  34.         // 注册Person到Esper  
  35.         admin.getConfiguration().addEventType("Person", person);  
  36.   
  37.         // 新增一个gender属性  
  38.         person.put("gender", int.class);  
  39.         admin.getConfiguration().updateMapEventType("Person", person);  
  40.           
  41.         /** 输出结果： 
  42.          * Person props: [address, age, name, children, phones, gender] 
  43.          */  
  44.         EventType event = admin.getConfiguration().getEventType("Person");  
  45.         System.out.println("Person props: " + Arrays.asList(event.getPropertyNames()));  
  46.     }  
  47. }  

 

 

3.Object Array

对象数组和Map很像，基本没有差别。只是定义方式不一样，Esper同样也只支持增量更新。这里继续用Person为大家做例子

 

[java] view plaincopy
 
  1. import java.util.Arrays;  
  2. import java.util.Map;  
  3.   
  4. import com.espertech.esper.client.EPAdministrator;  
  5. import com.espertech.esper.client.EPServiceProvider;  
  6. import com.espertech.esper.client.EPServiceProviderManager;  
  7. import com.espertech.esper.client.EventType;  
  8.   
  9. public class PersonArray  
  10. {  
  11.   
  12.     /** 
  13.      * @param args 
  14.      */  
  15.     public static void main(String[] args)  
  16.     {  
  17.         EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();  
  18.         EPAdministrator admin = epService.getEPAdministrator();  
  19.   
  20.         // Address定义  
  21.         String[] addressPropNames = { "road", "street", "houseNo" };  
  22.         Object[] addressPropTypes = { String.class, String.class, int.class };  
  23.   
  24.         // Child定义  
  25.         String[] childPropNames = { "name", "age" };  
  26.         Object[] childPropTypes = { String.class, int.class };  
  27.   
  28.         // Person定义  
  29.         String[] personPropNames = { "name", "age", "children", "phones", "address" };  
  30.         Object[] personPropTypes = { String.class, int.class, "Child[]", Map.class, "Address" };  
  31.   
  32.         // 注册Address到Esper  
  33.         admin.getConfiguration().addEventType("Address", addressPropNames, addressPropTypes);  
  34.         // 注册Child到Esper  
  35.         admin.getConfiguration().addEventType("Child", childPropNames, childPropTypes);  
  36.         // 注册Person到Esper  
  37.         admin.getConfiguration().addEventType("Person", personPropNames, personPropTypes);  
  38.   
  39.         // 新增一个gender属性  
  40.         admin.getConfiguration().updateObjectArrayEventType("Person", new String[] { "gender" }, new Object[] { int.class });  
  41.   
  42.         /** 输出结果： 
  43.          * Person props: [name, age, children, phones, address, gender] 
  44.          */  
  45.         EventType event = admin.getConfiguration().getEventType("Person");  
  46.         System.out.println("Person props: " + Arrays.asList(event.getPropertyNames()));  
  47.     }  
  48. }  

上面的例子包含了对象数组这种事件格式的所有特性，我就不多加解释了。

 

4.XML

待续

Esper学习之二：事件类型

标签：

原文地址：http://www.cnblogs.com/yudar/p/4872563.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！