Geode 快速入门

Geode 快速入门

相关资料

下载地址：http://geode.apache.org/releases/ 

官方文档：http://geode.apache.org/docs/guide/about_geode.html 

Github：https://github.com/apache/geode 

环境需求

1.JDK8或最新版本 

2.系统时钟设置为正确的时间和时间同步服务 

3.机器的主机名和主机文件必须配置正确，主机名和主机文件配置会影响gfsh命令和脉冲功能 

安装

1.设置JAVA_HOME 

JAVA_HOME=/usr/java/jdk1.8.0_60 

export JAVA_HOME 

2.源码安装 

在源码解压后的目录中，以非测试方式编译 

$ ./gradlew build -Dskip.tests=true 

3.解压安装 

下载二进制格式.zip或是.tar文件解压即可 

4.检查安装 

编译或解压后进入bin目录 

$ gfsh version 

v1.0.0-incubating 

5.配置环境变量 

$ vi /etc/profile 

export JAVA_HOME=/usr/java/jdk1.8.0_60 

export GEODE_HOME=/usr/local/geode 

export PATH=$JAVA_HOME/bin:$GEODE_HOME/bin:$PATH 

export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$GEODE_HOME/lib/geode-dependencies.jar 

使配置立即生效 

$ . /etc/profile 

快速入门

http://geode.apache.org/docs/guide/getting_started/15_minute_quickstart_gfsh.html 
*所有gfsh命令后面的参数名是有“–“两个英文中划线开始的*

 ln -s /usr/local/geode/bin/gfsh /usr/bin

1.创建一个工作目录 

$ mkdir ~/geode
$ cd ~/geode

2.启动gfsh 

$ gfsh

3.Starting a GemFire Locator 

gfsh>start locator --name=locator1

4.打开Pulse，一个Web应用程序，它提供了一个图形仪表板，用于监控Geode集群，成员和regions的重要的实时健康和性能。 
http://localhost:7070/pulse/clusterDetail.html 

5.启动一个缓存服务器 

gfsh>start server --name=server1 --server-port=40411

6.创建一个region 

gfsh>create region --name=region1 --type=REPLICATE_PERSISTENT

region是Geode集群的核心构建块，并提供了组织数据的方法。在此次练习中创建的region在集群成员之间复制数据（replicated），并利用持久性将数据保存到磁盘（persistent）。 

7.查看集群上的region列表 

gfsh>list regions

8.查看集群成员列表。启动的locator,server都在该列表中。

gfsh>list members

9.describe region 

gfsh>describe region --name=region1

10.put数据 

gfsh>put --region=region1 --key="1" --value="one"

11.query 

gfsh>query --query="select * from /region1"

12.启动第二个server 

gfsh>start server --name=server2 --server-port=40412

当gfsh启动服务器时，它会从群集配置服务请求配置，集群配置服务会将共享配置分发到加入群集的任何新服务器。 

当stop server —name=server1后region1所有数据仍可用 

13.关闭server（数据会写入磁盘，再次使用仍将被写入缓存中） 

gfsh>stop server --name=server1

14. 关闭集群 

gfsh>shutdown --include-locators=true

Java Application

1.创建HelloWold.java

import java.util.Map;
import org.apache.geode.cache.Region;
import org.apache.geode.cache.client.*;

public class HelloWorld {
public static void main(String[] args) throws Exception {
ClientCache cache = new ClientCacheFactory()
.addPoolLocator("localhost", 10334)
.create();
Region<String, String> region = cache
.<String, String>createClientRegionFactory(ClientRegionShortcut.CACHING_PROXY)
.create("region1");

region.put("1", "Hello");
region.put("2", "World");

for (Map.Entry<String, String>  entry : region.entrySet()) {
System.out.format("key = %s, value = %s\n", entry.getKey(), entry.getValue());
}
cache.close();
}
}

2.编译运行 

javac -cp /some/path/geode/geode-assembly/build/install/apache-geode/lib/geode-dependencies.jar HelloWorld.java 

java -cp .:/some/path/geode/geode-assembly/build/install/apache-geode/lib/geode-dependencies.jar HelloWorld 

因为前面配置了CLASSPATH,可以直接用 

javac HelloWorld.java 

java HelloWorld