码迷，mamicode.com
首页 > 编程语言 > 详细

用java连接apache geode

时间：2017-09-27 20:38:34      阅读：160      评论：0      收藏：0      [点我收藏+]

标签：geode   java   apache   分布式   cache   

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

1.创建测试region

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


2.用eclipse创建maven工程

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

<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

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

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里；

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,然后再重新发布

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

测试结果

开始创建用户
[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"}
完成删除用户
开始清空表
完成清空表


本文出自 “一方有” 博客，请务必保留此出处http://yifangyou.blog.51cto.com/900206/1969114

用java连接apache geode

标签：geode   java   apache   分布式   cache   

原文地址：http://yifangyou.blog.51cto.com/900206/1969114
踩
(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
迷上了代码！