15分钟玩转 Geode (1).docx

Apache Geode中国社区在Apache Geode网站上下载二进制安装包之后，在一台或几台机器上就可以安装 Geode了。从源码开始构建1. 设置 Java 环境变量JAVA_HOME=/usr/java/jdk1.8.0_60 export JAVA_HOME2. 从主站点下载源代码 ，解压缩。3. 在包含构建源码的目录下，执行不带测试的构建命令$ ./gradlew build -Dskip.tests=true4. 执行带有测试的构建命令$ ./gradlew build 5. 通过调用gfsh 来验证安装，打印出版本信息，版本信息类似于如下输出。$ cd geode-assembly/build/install/apache-geode $ bin/gfsh version v1.0.0-incubating从二进制文件安装1. 从发布页面下载.zip 或 .tar文件。2.对zip压缩文件进行解压缩。$ unzip apache-geode-1.0.0-incubating.zip -d path_to_product3.对 tar 压缩文件进行解压缩。$ tar -xvf apache-geode-1.0.0-incubating.tar -C path_to_product4.设置JAVA_HOME环境变量，在 Linux/Unix 平台上：JAVA_HOME=/usr/java/jdk1.8.0_60 export JAVA_HOME在 Windows 平台上：set JAVA_HOME=c:Program FilesJavajdk1.8.0_60 5.添加 Geode脚本到PATH 环境变量中，在 Linux/Unix 平台上：PATH=$PATH:$JAVA_HOME/bin:path_to_product/bin export PATH在 windows 平台上：set PATH=%PATH%;%JAVA_HOME%bin;path_to_productbin 验证是否安装成功，输入gfsh version 命令，输出如下安装版本信息：$ gfsh version v1.0.0-incubating使用如下的命令可以看到更详细的信息：$ gfsh version -fullGeode 进程的CLASSPATH设置为了简化CLASSPATH环境设置，Geode 已经组织了所有Geode 所需要的应用库，如*-dependencies.jar文件。所有依赖 JAR 文件都位于path_to_product/lib目录中。当开启一个服务器或一个 Locator 进程时，应用 JAR 文件会自动加载进入进程的CLASSPATH如下的表列出了依赖 JAR 文件与 Geode 相关的进程：GeodeProcessAssociated JAR Filesgfshgfsh-dependencies.jarserver and locatorgeode-dependencies.jarNote:Use this library for all standalone or embeddedGeodeprocesses (including Java clients) that host cache data.Pulsepulse-dependencies.jar (Pulse is not in apache-geode-1.0.0-incubating.M1.)在gfsh进程中修改CLASSPATH主要有两个选项来更新Geode 服务器和 Locator 的CLASSPATH，这两个都是以 gfsh 命令行启动的。选项1：指定classpath 参数，当进程启动时。例如，为了修改一个 Locator 上的 CLASSPATH：gfsh start locator -name=locator1 -classpath=/path/to/applications/classes.jar为了修改一个服务器上的CLASSPATH：gfsh start server -name=server1 -classpath=/path/to/applications/classes.jar选项2：在 OS 上定义 CLASSPATH 环境变量。然后指定-include-system-classpath参数。例如：gfsh start locator -name=locator1 -include-system-classpath=true类似的也能在 server 上执行此命令：gfsh start server -name=server1 -include-system-classpath=true此选项追加了一些系统 CLASSPATH 环境变量的内容到 locator 或者 server 的CLASSPATH上。为应用设置 CLASSPATH如果你使用程序启动 Geode 服务，那么我们推荐你指定 CLASSPATH，使用java -classpath或java -cp命令行。此方法被用于设置classpath作为一个环境变量，它也允许设置这个值为每个应用，与其他应用互相不影响。例如，为了启动一个 Geode locator 进程（使用 LocatorLauncher API），你能够执行如下的命令行：prompt# java -cp path_to_product/lib/geode-dependencies.jar com.gemstone.gemfire.distributed.LocatorLauncher start locator1 为了启动一个Geode 服务器进程（使用 LocatorLauncher API）：prompt# java -cp path_to_product/lib/geode-dependencies.jar:/path/to/your/applications/classes.jar com.gemstone.gemfire.distributed.ServerLauncher start server1 对于与此进程相关的*-dependencies.jar文件，你必须也指定自定义应用的 JARs。例如，如果你计划使用一个自定义的压缩器，你应该指定此应用 JAR，包含此压缩器应用。在一个嵌入式缓存中启动一个应用：java -cp path_to_product/lib/geode-dependencies.jar:/path/to/your/applications/classes.jar com.mycompany.package.ApplicationWithEmbeddedCache使用一个 gfsh 来启动一个locator在终端控制台，使用 gfsh 命令行接口来启动一个 locator。Geode gfsh 提供了一个直观的命令行接口，用于启动、管理和监控Apache Geode进程、数据和应用。Locator 是一个 Geode 进程，告诉新连接的成员，运行成员被定位，提供负载均衡。一个 locator 启动一个 JMX Manager，用于监控和管理 Geode 集群。集群配置服务使用 locator 来持久化和分布式集群配置到各个集群节点成员。1. 创建一个工作目录，更改目录。gfsh 保存 工作目录上的locator 、server和 log。2. 通过键入 gfsh 命令来启动 gfsh。3. 在 gfsh 中输入如下命令：gfshstart locator -name=locator1 Starting a GemFire Locator in /home/username/my_gemfire/locator1. . Locator in /home/username/my_gemfire/locator1 on ubuntu.local10334 as locator1 is currently online. Process ID: 3529 Uptime: 18 seconds GemFire Version: 8.2.0 Java Version: 1.8.0_60 Log File: /home/username/my_gemfire/locator1/locator1.log JVM Arguments: -Dgemfire.enable-cluster-configuration=true -Dgemfire.load-cluster-configuration-from-dir=false -Dgemfire.launcher.registerSignalHandlers=true -Djava.awt.headless=true -Dsun.rmi.dgc.server.gcInterval=9223372036854775806 Class-Path: /home/username/Pivotal_GemFire_820_b17919_Linux/lib/gemfire.jar: /home/username/Pivotal_GemFire_820_b17919_Linux/lib/locator-dependencies.jar Successfully connected to: host=ubuntu.local, port=1099 Cluster configuration service is up and running.启动 Geode Pulse启动基于浏览器的 Pulse 监控工具。Pulse 是一个 Web 应用，提供一个图形化的控制台，监控Geode 集群各个节点成员和 Region 的实时健康状态和性能。gfshstart pulse此命令行启动了 Pulse，自动连接到 JMX 管理器。在 Pulse 登录界面，输入默认的用户名 username 和 密码 admin。Pulse 应用现在显示了启动的locator:启动一个服务器。一个 Geode 服务器是一个进程，作为一个集群中长期运行、可配置成员。Geode 服务器主要用于管理长期运行的数据 Region，和标准的 Geode 进程，例如 C/S 结构的服务器。启动 CacheServer。gfshstart server -name=server1 -server-port=40411 此命令启动了一个 cache server 命名为”server1”，使用端口40411。在 Pulse 可查看到成员和服务器的变化。尝试拓展分布式系统用于查看 locator 和 cache server。创建一个复制的、持久化Region在此步骤上，你能够创建一个 region，带有 gfsh 命令行工具。Regions 是一个核心的模块，提供了组织内存中的数据能力。创建的 Region 跨集群节点来同步数据，利用持久化功能将内存中的数据保存到磁盘中。1.创建一个复制的、持久化 Region：gfshcreate region -name=regionA -type=REPLICATE_PERSISTENT Member | Status - | - server1 | Region /regionA created on server12. 使用 gfsh 命令行查看regions 的列表：gfshlist regions List of regions - regionA3.列出集群中的成员：gfshlist members Name | Id - | - locator1 | ubuntu(locator1:3529:locator):59926 server1 | ubuntu(server1:3883):653904.查看一个 region 的相关信息：gfshdescribe region -name=regionA . Name : regionA Data Policy : persistent replicate Hosting Members : server1 Non-Default Attributes Shared By Hosting Members Type | Name | Value - | - | - Region | size | 05.在 Pulse 中可以查看所有的成员和Regions。第六步.操作Region中的数据，详解持久化.Apache Geode 以KV 键值对儿的形式来管理数据。在大部分应用中，一个 Java 应用添加、删除或修改已经保存的数据。我们也能够使用gfsh 命令来添加和查询相关的数据。1. 运行如下的 put 命令来添加一些数据到 Region 中:gfshput -region=regionA -key=1 -value=one Result : true Key Class : java.lang.String Key : 1 Value Class : java.lang.String Old Value : gfshput -region=regionA -key=2 -value=two Result : true Key Class : java.lang.String Key : 2 Value Class : java.lang.String Old Value : 2. 运行如下的命令从Region中查询数据：gfshquery -query=select * from /regionA Result : true startCount : 0 endCount : 20 Rows : 2 Result - two one结果集显示了所创建的两个数据条目。3. 使用如下的命令来停止 Cache 服务器：gfshstop server -name=server1 Stopping Cache Server running in /home/username/my_gemfire/server1 on ubuntu.local40411 as server1. Process ID: 3883 Log File: /home/username/my_gemfire/server1/server1.log .4. 使用如下的使用如下的命令来重启 Cache 服务器：gfshstart server -name=server1 -server-port=40411 5. 运行如下的命令从 Region 中查询数据，此份数据仍然可用：gfshquery -query=select * from /regionA Result : true startCount : 0 endCount : 20 Rows : 2 Result - two one因为 RegionA 使用了持久化，它写了一份数据拷贝到磁盘中。当一个服务器启动时，数据加载进入到缓存中。其结果显示了两个创建的数据条目的值，在停止此服务器之前。第七步.检查同步的效果在这一步我们启动第二个缓存服务器，因为 regionA 是同步模式，此数据在任意一个节点上都是可用的。1. 启动第二个缓存服务器.gfshstart server -name=server2 -server-port=404122. 运行描述Region 命令来查看 regionA 的命令：gfshdescribe region -name=regionA . Name : regionA Data Policy : persistent replicate Hosting Members : server1 server2 Non-Default Attributes Shared By Hosting Members Type | Name | Value - | - | - Region | size | 2你不需要在 server2创建 regionA.命令输出显示了regionA同时被管理在 server1和 server2上。当 gfsh 启动了一个服务器，它从集群配置服务中请求配置，然后分发共享配置到新加入集群的任意新服务器上3. 添加第三个数据条目。gfshput -region=regionA -key=3 -value=three Result : true Key Class : java.lang.String Key : 3 Value Class : java.lang.String Old Value : 4. 打开 Pulse 应用，同时查看集群的拓扑结构。你能够差看到一个 locator 和两个服务器。点击数据来查看有关 regionA 的信息。5. 使用如下命令停止cache server：gfshstop server -name=server1 Stopping Cache Server running in /home/username/my_gemfire/server1 on ubuntu.local40411 as server1. Process ID: 4064 Log File: /home/username/my_gemfire/server1/server1.log .6. 从现有的 cache server 上查询数据。gfshquery -query=select * from /regionA Result : true startCount : 0 endCount : 20 Rows : 3 Result - two one three7. 添加第四个数据条目gfshput -region=regionA -key=4 -value=four Result : true Key Class : java.lang.String Key : 3 Value Class : java.lang.String Old Value : 仅有 server2正在运行。因为此数据是同步和持久化的，所有数据都是可用的。但是新的数据条目仅在 server2可用。gfshdescribe region -name=regionA . Name : regionA Data Policy : persistent replicate Hosting Members : server2 Non-Default Attributes Shared By Hosting Members Type | Name | Value - | - | - Region | size | 48. 停止剩下的缓存服务器：gfshstop server -name=server2 Stopping Cache Server running in /home/username/my_gemfire/server2 on ubuntu.local40412 as server2. Process ID: 4185 Log File: /home/username/my_gemfire/server2/server2.log .第八步.并行地重启缓存服务器在此步骤上，你能够重启缓存服务器。因为此数据是持久化的，当服务器重启时数据是可用的。因为数据是复制的，你必须并行重启此服务器，因此你能够在启动之前同步这些数据。1.启动 server1.因为 regionA 是复制的和持久化的，它需要从其他的服务器上启动和等待服务器启动：gfshstart server -name=server1 -server-port=40411 Starting a GemFire Server in /home/username/my_gemfire/server1. . .如果你查看server1.log的日志文件，那么你能够看到如下的日志消息：info 2015/01/14 09:08:13.610 PST server1 tid=0x1 Region /regionA has pot entially stale data. It is waiting for another member to recover the latest data. My persistent id: DiskStore ID: 8e2d99a9-4725-47e6-800d-28a26e1d59b1 Name: server1 Location: /45:/home/username/my_gemfire/server1/. Members with potentially new data: DiskStore ID: 2e91b003-8954-43f9-8ba9-3c5b0cdd4dfa Name: server2 Location: /45:/home/username/my_gemfire/server2/. Use the gemfire list-missing-disk-stores command to see all disk stores that are being waited on by other members.2.在第二个控制台，更改目录到工作路径(例如,my_gemfire) ，同时启动gfsh:usernamelocalhost /my_gemfire$ gfsh _ _ / _/ _/ _/ /_/ / / / _/ /_ /_ / _ / / /_/ / _/ _/ / / / / /_/_/ /_/_/ /_/ v8.2.0 Monitor and Manage GemFire3. 运行如下的命令连接到集群：gfshconnect -locator=localhost10334 Connecting to Locator at host=localhost, port=10334 . Connecting to Manager at host=ubuntu.local, port=1099 . Successfully connected to: host=ubuntu.local, port=10994. 启动 server2：gfshstart server -name=server2 -server-port=40412当 server2启动时，server1完成了它的启动：Server in /home/username/my_gemfire/server1 on ubuntu.local40411 as server1 is currently online. Process ID: 3402 Uptime: 1 minute 46 seconds GemFire Version: 8.2.0 Java Version: 1.8.0_60 Log File: /home/username/my_gemfire/server1/server1.log JVM Arguments: -Dgemfire.default.locators=4510334 -Dgemfire.use-cluster-configuration=true -XX:OnOutOfMemoryError=kill -KILL %p -Dgemfire.launcher.registerSignalHandlers=true -Djava.awt.headless=true -Dsun.rmi.dgc.server.gcInterval=9223372036854775806 Class-Path: /home/username/Pivotal_GemFire_820_b17919_Linux/lib/gemfire.jar: /home/username/Pivotal_GemFire_820_b17919_Linux/lib/server-dependencies.jar5. 验证 Locator 和两台servers 正在运行：gfshlist members Name | Id - | - server2 | ubuntu(server2:3992):21507 server1 | ubun