备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

用java连接apache geode

2017-11-16 1274
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

昨天研究了半天apache geode，通过gfsh命令查询和操作比较简单，但是如何通过程序查询因为资历太少，没有搞懂，试验了半天才明白

1.创建测试region

1
create region --name=user -- type =REPLICATE_PERSISTENT


2.用eclipse创建maven工程

修改pom.xml,需要引入gemfire-8.2.0.jar,这个在

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
< project  xmlns = "http://maven.apache.org/POM/4.0.0"  xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation = "http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
   < modelVersion >4.0.0</ modelVersion >
 
   < groupId >io.proinsight</ groupId >
   < artifactId >hellogeode</ artifactId >
   < version >0.0.1-SNAPSHOT</ version >
   < packaging >jar</ packaging >
 
   < name >hellogeode</ name >
   < url >http://maven.apache.org</ url >
 
   < properties >
     < project.build.sourceEncoding >UTF-8</ project.build.sourceEncoding >
   </ properties >
 
   < dependencies >
   <!-- https://mvnrepository.com/artifact/org.apache.geode/geode-core -->
     < dependency >
         < groupId >org.apache.geode</ groupId >
         < artifactId >geode-core</ artifactId >
         < version >1.2.0</ version >
     </ dependency >
     
     <!-- https://mvnrepository.com/artifact/org.apache.geode/geode-json -->
< dependency >
     < groupId >org.apache.geode</ groupId >
     < artifactId >geode-json</ artifactId >
     < version >1.2.0</ version >
</ dependency >
     
     <!-- https://mvnrepository.com/artifact/org.apache.geode/geode-common -->
< dependency >
     < groupId >org.apache.geode</ groupId >
     < artifactId >geode-common</ artifactId >
     < version >1.2.0</ version >
</ dependency >
     < dependency >
             < groupId >log4j</ groupId >
             < artifactId >log4j</ artifactId >
             < version >1.2.17</ version >
         </ dependency >
         <!-- https://mvnrepository.com/artifact/org.apache.logging.log4j/log4j-core -->
< dependency >
     < groupId >org.apache.logging.log4j</ groupId >
     < artifactId >log4j-core</ artifactId >
     < version >2.8.2</ version >
</ dependency >
<!-- https://mvnrepository.com/artifact/org.apache.logging.log4j/log4j-api -->
< dependency >
     < groupId >org.apache.logging.log4j</ groupId >
     < artifactId >log4j-api</ artifactId >
     < version >2.8.2</ version >
</ dependency >
 
         <!-- https://mvnrepository.com/artifact/log4j/log4j -->
< dependency >
     < groupId >log4j</ groupId >
     < artifactId >log4j</ artifactId >
     < version >1.2.17</ version >
</ dependency >
< dependency >
             < groupId >commons-codec</ groupId >
             < artifactId >commons-codec</ artifactId >
             < version >1.10</ version >
         </ dependency >
         
         < dependency >
             < groupId >org.apache.commons</ groupId >
             < artifactId >commons-lang3</ artifactId >
             < version >3.4</ version >
         </ dependency >
         < dependency >
             < groupId >junit</ groupId >
             < artifactId >junit</ artifactId >
             < version >4.12</ version >
         </ dependency >
         
             < dependency >
             < groupId >com.alibaba</ groupId >
             < artifactId >fastjson</ artifactId >
             < version >1.2.13</ version >
         </ dependency >
   </ dependencies >
< build >
   < plugins >
               < plugin >
                 < groupId >org.apache.maven.plugins</ groupId >
                 < artifactId >maven-compiler-plugin</ artifactId >
                 < version >3.3</ version >
                 < configuration >
                     < source >1.8</ source >
                     < target >1.8</ target >
                 </ configuration >
             </ plugin >
         < plugin >  
             < groupId >org.apache.maven.plugins</ groupId >  
             < artifactId >maven-jar-plugin</ artifactId >  
             < version >2.6</ version >  
             < configuration >  
                 < archive >  
                     < manifest >  
                         < addClasspath >true</ addClasspath >  
                         < classpathPrefix >lib/</ classpathPrefix >  
                         < mainClass >io.proinsight.hellogeode.App</ mainClass >  
                     </ manifest > 
      
                 </ archive > 
     
             </ configuration >  
         </ plugin >  
         < plugin >  
             < groupId >org.apache.maven.plugins</ groupId >  
             < artifactId >maven-dependency-plugin</ artifactId >  
             < version >2.10</ version >  
             < executions >  
                 < execution >  
                     < id >copy-dependencies</ id >  
                     < phase >package</ phase >  
                     < goals >  
                         < goal >copy-dependencies</ goal >  
                     </ goals >  
                     < configuration >  
                         < outputDirectory >${project.build.directory}/lib</ outputDirectory >  
                     </ configuration >  
                 </ execution >  
             </ executions >  
         </ plugin >
     </ plugins >
   </ build >
</ project >


新建UserBean.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
package  io.proinsight.hellogeode;
 
import  java.io.DataInput;
import  java.io.DataOutput;
import  java.io.IOException;
 
import  java.util.Date;
 
import  org.apache.geode.DataSerializable;
import  org.apache.geode.DataSerializer;
 
public  class  UserBean  implements  DataSerializable{
     /**
      * 必须有这个方法，否则查询会报没有init()这个方法
      * */
     public  UserBean() {
         
     }
     public  UserBean( int  id2,  int  i, String string, Date date) {
         // TODO Auto-generated constructor stub
         this .id=id2;
         this .age=i;
         this .name=string;
         this .createTime=date;
     }
     /**
      * id
      * */
     private  int  id;
     
     /**
      * 年龄
      * */
     private  int  age;
     /**
      * 姓名
      * */
     private  String name;
     /**
      * 创建时间
      * */
     private  Date createTime;
 
     public  int  getId() {
         return  id;
     }
 
     public  void  setId( int  id) {
         this .id = id;
     }
 
     public  int  getAge() {
         return  age;
     }
 
     public  void  setAge( int  age) {
         this .age = age;
     }
 
     public  String getName() {
         return  name;
     }
 
     public  void  setName(String name) {
         this .name = name;
     }
 
     public  Date getCreateTime() {
         return  createTime;
     }
     
     public  void  setCreateTime(Date createTime) {
         this .createTime = createTime;
     }
     public  void  fromData(DataInput in)  throws  IOException, ClassNotFoundException {
         this .id = in.readInt();
         this .age=in.readInt();
          this .name = in.readUTF();
          this .createTime = DataSerializer.readDate(in);
         
     }
     public  void  toData(DataOutput out)  throws  IOException {
          out.writeInt( this .id);
          out.writeInt( this .age);
          out.writeUTF( this .name);
          DataSerializer.writeDate( this .createTime, out);
         
     }
}


修改App.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
package  io.proinsight.hellogeode;
 
import  java.util.Date;
import  java.util.HashMap;
import  java.util.Iterator;
import  java.util.Map;
 
import  org.apache.geode.DataSerializer;
import  org.apache.geode.cache.Region;
import  org.apache.geode.cache.RegionFactory;
import  org.apache.geode.cache.client.ClientCache;
import  org.apache.geode.cache.client.ClientCacheFactory;
import  org.apache.geode.cache.client.ClientRegionFactory;
import  org.apache.geode.cache.client.ClientRegionShortcut;
import  org.apache.geode.cache.query.internal.ResultsBag;
 
import  com.alibaba.fastjson.JSON;
 
/**
  * Hello world!
  *
  */
public  class  App 
{
     String regionName= "user" ;
     int  userNum= 10 ;
     public  static  void  main( String[] args )
     {
         new  App().test();
     }
     
     public  void  test(){
         Region region =  null ;
       ClientCache cache =  new  ClientCacheFactory().addPoolLocator( "192.168.60.50" ,  10334 ).create();
  
       ClientRegionFactory rf = cache.createClientRegionFactory(ClientRegionShortcut.CACHING_PROXY);
       //打开user表
        region = rf.create(regionName);
         
        System.out.println( "开始创建用户" );
         create(region);
         select(region);
         System.out.println( "完成创建用户" );
         
         
         System.out.println( "开始修改用户" );
         update(region);
         select(region);
         System.out.println( "完成修改用户" );
         
         
         System.out.println( "开始删除用户" );
         delete(region, 108 );
         select(region);
         System.out.println( "完成删除用户" );
         
         
         System.out.println( "开始清空表" );
         truncate(region);
         select(region);
         System.out.println( "完成清空表" );
         
         //关闭表
         region.close();
     }
     
     /**
      * 查询user表
      * */
     public  void  select(Region region){
         try  {
             Object objList = region.query( "select * from /" +regionName+ " u where u.age > 15" );
            
             if (objList !=  null  && objList  instanceof  ResultsBag){
                 Iterator iter = ((ResultsBag) objList).iterator();
                 while (iter.hasNext()){
                     UserBean userBean = (UserBean) iter.next();
                     System.out.println( "User信息：" +JSON.toJSONString(userBean));
                 }
             }
             Object obj = region.get( 108 );
             if (obj !=  null  && obj  instanceof  UserBean){
                 System.out.println( "User108信息" +JSON.toJSONString(obj));
             }
         } catch  (Exception e){
             e.printStackTrace();
//            logger.error("error occured.", e);
         }
     }
    
     
     /**
      * 增加10个
      * */
     public  void  create(Region region){
         for  ( int  i =  0 ; i < userNum; i++) {
             int  id = i+ 100 ;
             region.put(id,  new  UserBean(id, 10 +i, "username:" +id, new  Date()));
         }
     }
     
     
     /**
      * 修改
      * */
     public  void  update(Region region){
         UserBean user108= (UserBean) region.get( 108 );
         if (user108 !=  null  && user108  instanceof  UserBean){
             System.out.println( "User108信息" +JSON.toJSONString(user108));
           //修改年龄为
             user108.setAge( 12 );
             region.put(user108.getId(), user108);
         }
         
     }
     
     /**
      * 删除某个用户
      * */
     public  void  delete(Region region,Integer id){
         region.remove(id);
     }
     
     
     /**
      * 清空表
      * */
     public  void  truncate(Region region){
         region.clear();
     }
     
    
}



3.打包

maven install一下

在target目录下有对应的jar包

然后把hellogeode-0.0.1-SNAPSHOT.jar拷贝到geode服务器上某个目录例如/tmp/t/下

4.发布Jar到geode里

为啥要发布到geode里呢？因为我们用UserBean的序列化和反序列化作为表结构，因此deode查询时需要UserBean.class，因此我们发布hellogeode-0.0.1-SNAPSHOT.jar到geode，主要是为了把UserBean.class导入到geode里；

1
2
3
4
gfsh>deploy  --jar= /tmp/t/hellogeode-0 .0.1-SNAPSHOT.jar 
  Member  |         Deployed JAR          | Deployed JAR Location
-------- | ----------------------------- | -----------------------------------------------------------------
server50 | hellogeode-0.0.1-SNAPSHOT.jar |  /opt/apache-geode-1 .2.1 /server50/hellogeode-0 .0.1-SNAPSHOT.v1.jar

若是我们对UserBean有修改的话，需要先卸载jar,然后再重新发布

1
2
3
4
5
6
7
8
9
gfsh>undeploy  --jar=hellogeode-0.0.1-SNAPSHOT.jar 
  Member  |        Un-Deployed JAR        | Un-Deployed From JAR Location
-------- | ----------------------------- | -----------------------------------------------------------------
server50 | hellogeode-0.0.1-SNAPSHOT.jar |  /opt/apache-geode-1 .2.1 /server50/hellogeode-0 .0.1-SNAPSHOT.v1.jar
 
gfsh>deploy  --jar= /tmp/t/hellogeode-0 .0.1-SNAPSHOT.jar 
  Member  |         Deployed JAR          | Deployed JAR Location
-------- | ----------------------------- | -----------------------------------------------------------------
server50 | hellogeode-0.0.1-SNAPSHOT.jar |  /opt/apache-geode-1 .2.1 /server50/hellogeode-0 .0.1-SNAPSHOT.v1.jar

5.测试

测试程序在eclipse里运行即可，不需要放到服务器上运行

在eclipse运行app.java

测试结果

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
开始创建用户
[info 2017 /09/27  13:09:13.422 CST <poolTimer-DEFAULT-2> tid=0x17] AutoConnectionSource discovered new locators [slave1 /211 .98.71.195:10334]
 
[info 2017 /09/27  13:09:13.511 CST <main> tid=0x1] Updating membership port.  Port changed from 0 to 51,084.  ID is now bogon(92040:loner):0:0c29bdc1
 
User信息：{ "age" :12, "createTime" :1506488953578, "id" :102, "name" : "username:102" }
User信息：{ "age" :15, "createTime" :1506488953592, "id" :105, "name" : "username:105" }
User信息：{ "age" :14, "createTime" :1506488953588, "id" :104, "name" : "username:104" }
User信息：{ "age" :10, "createTime" :1506488953405, "id" :100, "name" : "username:100" }
User信息：{ "age" :19, "createTime" :1506488953611, "id" :109, "name" : "username:109" }
User信息：{ "age" :13, "createTime" :1506488953583, "id" :103, "name" : "username:103" }
User信息：{ "age" :18, "createTime" :1506488953606, "id" :108, "name" : "username:108" }
User信息：{ "age" :11, "createTime" :1506488953573, "id" :101, "name" : "username:101" }
User信息：{ "age" :16, "createTime" :1506488953597, "id" :106, "name" : "username:106" }
User信息：{ "age" :17, "createTime" :1506488953602, "id" :107, "name" : "username:107" }
User108信息{ "age" :18, "createTime" :1506488953606, "id" :108, "name" : "username:108" }
完成创建用户
开始修改用户
User108信息{ "age" :18, "createTime" :1506488953606, "id" :108, "name" : "username:108" }
User信息：{ "age" :17, "createTime" :1506488953602, "id" :107, "name" : "username:107" }
User信息：{ "age" :12, "createTime" :1506488953578, "id" :102, "name" : "username:102" }
User信息：{ "age" :15, "createTime" :1506488953592, "id" :105, "name" : "username:105" }
User信息：{ "age" :12, "createTime" :1506488953606, "id" :108, "name" : "username:108" }
User信息：{ "age" :13, "createTime" :1506488953583, "id" :103, "name" : "username:103" }
User信息：{ "age" :19, "createTime" :1506488953611, "id" :109, "name" : "username:109" }
User信息：{ "age" :16, "createTime" :1506488953597, "id" :106, "name" : "username:106" }
User信息：{ "age" :11, "createTime" :1506488953573, "id" :101, "name" : "username:101" }
User信息：{ "age" :14, "createTime" :1506488953588, "id" :104, "name" : "username:104" }
User信息：{ "age" :10, "createTime" :1506488953405, "id" :100, "name" : "username:100" }
User108信息{ "age" :12, "createTime" :1506488953606, "id" :108, "name" : "username:108" }
完成修改用户
开始删除用户
User信息：{ "age" :15, "createTime" :1506488953592, "id" :105, "name" : "username:105" }
User信息：{ "age" :12, "createTime" :1506488953578, "id" :102, "name" : "username:102" }
User信息：{ "age" :16, "createTime" :1506488953597, "id" :106, "name" : "username:106" }
User信息：{ "age" :10, "createTime" :1506488953405, "id" :100, "name" : "username:100" }
User信息：{ "age" :13, "createTime" :1506488953583, "id" :103, "name" : "username:103" }
User信息：{ "age" :19, "createTime" :1506488953611, "id" :109, "name" : "username:109" }
User信息：{ "age" :11, "createTime" :1506488953573, "id" :101, "name" : "username:101" }
User信息：{ "age" :17, "createTime" :1506488953602, "id" :107, "name" : "username:107" }
User信息：{ "age" :14, "createTime" :1506488953588, "id" :104, "name" : "username:104" }
完成删除用户
开始清空表
完成清空表









     本文转自yifangyou 51CTO博客，原文链接：http://blog.51cto.com/yifangyou/1969114，如需转载请自行联系原作者

文章标签：
Java
Apache
Android开发
关键词：
Java Apache
Apache java
Java连接
Apache连接
Apache geode
技术小胖子
目录
相关文章
言1
|
1月前
|
数据采集 Java 关系型数据库
Java代码高效连接数据库
Java代码高效连接数据库
言1
19 2
SarPro
|
2月前
|
IDE 关系型数据库 MySQL
【Java+MySQL】前后端连接小白教程
【Java+MySQL】前后端连接小白教程
SarPro
37 0
yuanzhengme
|
1月前
|
Shell
Flume【问题记录 01】【at org.apache.flume.node.Application.main(Application.java:xxx) 类问题整理+其他类型问题总结】【避坑指南】
【2月更文挑战第17天】Flume【问题记录 01】【at org.apache.flume.node.Application.main(Application.java:xxx) 类问题整理+其他类型问题总结】【避坑指南】
yuanzhengme
53 2
一只牛博
|
2月前
|
Dubbo Java 应用服务中间件
Serialized class org.apache.catalina.core.ApplicationPart must implement java.io.Serializable
Serialized class org.apache.catalina.core.ApplicationPart must implement java.io.Serializable
一只牛博
49 0
亚丁号
|
3月前
|
Java Maven
java.lang.NoSuchMethodError: org.apache.maven.model.validation.DefaultModelValidator
java.lang.NoSuchMethodError: org.apache.maven.model.validation.DefaultModelValidator
亚丁号
22 1
从未止步..
|
3月前
|
Linux Windows
FinalShell连接Linux虚拟机报错java.net.ConnectException: Connection timed out: connect(亲测有效)
FinalShell连接Linux虚拟机报错java.net.ConnectException: Connection timed out: connect(亲测有效)
从未止步..
164 0
yuanzhengme
|
5天前
|
Java API Apache
ZooKeeper【基础 03】Java 客户端 Apache Curator 基础 API 使用举例（含源代码）
【4月更文挑战第11天】ZooKeeper【基础 03】Java 客户端 Apache Curator 基础 API 使用举例（含源代码）
yuanzhengme
23 11
一百减一是零
|
6天前
|
前端开发 NoSQL JavaScript
java域控连接AD遇到的问题
java域控连接AD遇到的问题
一百减一是零
14 1
桃李春风一杯酒
|
8天前
|
消息中间件 存储 Java
深度探索：使用Apache Kafka构建高效Java消息队列处理系统
【4月更文挑战第17天】本文介绍了在Java环境下使用Apache Kafka进行消息队列处理的方法。Kafka是一个分布式流处理平台，采用发布/订阅模型，支持高效的消息生产和消费。文章详细讲解了Kafka的核心概念，包括主题、生产者和消费者，以及消息的存储和消费流程。此外，还展示了Java代码示例，说明如何创建生产者和消费者。最后，讨论了在高并发场景下的优化策略，如分区、消息压缩和批处理。通过理解和应用这些策略，可以构建高性能的消息系统。
桃李春风一杯酒
16 1
风水道人
|
27天前
|
Java Spring
上传文件出现 aximum upload size exceeded； nested exception is java.lang.IllegalStateException: org.apache.
上传文件出现 aximum upload size exceeded； nested exception is java.lang.IllegalStateException: org.apache.
风水道人
10 0

热门文章

最新文章

  • 1
    ZooKeeper【基础 03】Java 客户端 Apache Curator 基础 API 使用举例（含源代码）
  • 2
    Apache服务器安装SSL证书
  • 3
    SpringBoot启动报错：org.apache.catalina.LifecycleException: Protocol handler start failed
  • 4
    linux下apache2更换目录
  • 5
    Java中的多线程编程：概念、实现与性能优化
  • 6
    org.apache.jasper.JasperException...(line: 15, column: 16) quote symbol expected和处理办法
  • 7
    深度探索：使用Apache Kafka构建高效Java消息队列处理系统
  • 8
    ZooKeeper【搭建 03】apache-zookeeper-3.6.0 伪集群版（一台服务器实现三个节点的ZooKeeper集群）
  • 9
    CentOS 7 源码安装LAMP环境源 和apache监听别的端口
  • 10
    基于 java + Springboot + vue +mysql 大学生实习管理系统（含源码）
  • 1
    Java基础知识整理，驼峰规则、流程控制、自增自减
    31
  • 2
    Java基础知识整理，注释、关键字、运算符
    36
  • 3
    滚雪球学Java(19)：JavaSE中的内存管理：你所不知道的秘密
    24
  • 4
    Java VisualVM远程监控JVM
    7
  • 5
    【Linux】bash: /home/stefan/jdk1.7.0_55/bin/java: /lib/ld-linux.so.2: bad ELF interpreter
    7
  • 6
    JAVA变量类型
    9
  • 7
    Java日期与时间
    11
  • 8
    JAVA注解
    9
  • 9
    Java配置环境
    7
  • 10
    Java线程：深入理解与实战应用
    15

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Apache Flink技术进阶
  • Apache Spark: Cloud and On-Prem
  • Hybrid Cloud and Apache Spark

    • 相关实验场景

    更多
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • Elasticsearch Java API Client 开发
  • 手动部署Java Web环境（Alibaba Cloud Linux 2）
  • 搭建Java Web开发环境（Anolis OS）
  • RocketMQ中使用Java客户端发送消息和消费的应用

    • 推荐镜像

    更多
  • apache
  • packman
  • CPAN
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）