`
bewithme
  • 浏览: 430656 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

Apache Geode 创建和使用群集配置教程

阅读更多

 

使用单机演示如何为一个Geode集群使用gfsh命令来创建集群配置。

 

gfsh命令行工具允许你创建和启动Geode集群,集群配置服务使用定位器(locator)以组级别和集群级别来存储配置并且为新的成员在启动时提供服务。定位器将配置存储在一个隐藏的区域中,它可以被所有的定位器使用,并且以xml形式将配置写入碰盘。当gfsh命令执行时,配置会被更新。

 

本节提供了一个简短的例子,配置一个简单的Apache Geode集群,并在新的上下文中重用。

 

1.创建一个工作目录 (例如:/home/username/my_gemfire) 然后切换到此目录。此目录将为你的集群存储配置。

2.启动gfsh命令行工具。例如:

 

$ gfsh

gfsh命令提示显示

 

 

    _________________________     __
   / _____/ ______/ ______/ /____/ /
  / /  __/ /___  /_____  / _____  /
 / /__/ / ____/  _____/ / /    / /
/______/_/      /______/_/    /_/    1.0.0

Monitor and Manage Apache Geode
gfsh>

3.使用如下命令启动一个定位器

 

 

gfsh>start locator --name=locator1
Starting a GemFire Locator in /Users/username/my_gemfire/locator1...
.............................
Locator in /Users/username/my_gemfire/locator1 on 192.0.2.0[10334] as locator1 is currently online.
Process ID: 5203
Uptime: 15 seconds
GemFire Version: 8.1.0
Java Version: 1.7.0_71
Log File: /Users/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: /Users/username/Pivotal_GemFire_810_b50582_Linux/lib/gemfire.jar
:/Users/username/Pivotal_GemFire_810_b50582_Linux/lib/locator-dependencies.jar

Successfully connected to: [host=192.0.2.0, port=1099]

Cluster configuration service is up and running.

 注意到gfsh的响应为一条指示集群配置服务已经运行的消息。如果你看到一条消息指出存在的问题,检查定位器的日志文件查看可能的错误。日志文件的路径显示在了gfsh的输出中。

 

4.使用如下命令启动Apache Geode服务器

 

gfsh>start server --name=server1 --group=group1
Starting a GemFire Server in /Users/username/my_gemfire/server1...
.....
Server in /Users/username/my_gemfire/server1 on 192.0.2.0[40404] as server1 is currently online.
Process ID: 5627
Uptime: 2 seconds
GemFire Version: 8.1.0
Java Version: 1.7.0_71
Log File: /Users/username/my_gemfire/server1/server1.log
JVM Arguments: -Dgemfire.default.locators=192.0.2.0[10334] -Dgemfire.groups=group1
-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: /Users/username/Pivotal_GemFire_810_b50582_Linux/lib/gemfire.jar
:/Users/username/Pivotal_GemFire_810_b50582_Linux/lib/server-dependencies.jar

gfsh>start server --name=server2 --group=group1 --server-port=40405
Starting a GemFire Server in /Users/username/my_gemfire/server2...
.....
Server in /Users/username/my_gemfire/server2 on 192.0.2.0[40405] as server2 is currently online.
Process ID: 5634
Uptime: 2 seconds
GemFire Version: 8.1.0
Java Version: 1.7.0_71
Log File: /Users/username/my_gemfire/server2/server2.log
JVM Arguments: -Dgemfire.default.locators=192.0.2.0[10334] -Dgemfire.groups=group1
-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: /Users/username/Pivotal_GemFire_810_b50582_Linux/lib/gemfire.jar
:/Users/username/Pivotal_GemFire_810_b50582_Linux/lib/server-dependencies.jar

gfsh>start server --name=server3 --server-port=40406
Starting a GemFire Server in /Users/username/my_gemfire/server3...
.....
Server in /Users/username/my_gemfire/server3 on 192.0.2.0[40406] as server3 is currently online.
Process ID: 5637
Uptime: 2 seconds
GemFire Version: 8.1.0
Java Version: 1.7.0_71
Log File: /Users/username/my_gemfire/server3/server3.log
JVM Arguments: -Dgemfire.default.locators=192.0.2.0[10334]
-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: /Users/username/Pivotal_GemFire_810_b50582_Linux/lib/gemfire.jar
:/Users/username/Pivotal_GemFire_810_b50582_Linux/lib/server-dependencies.jar

 注意到你使用的用来启动server1和server2gfsh命令指定了一个组,名字为group1,然而你没有为server3指定组名。

 

5.使用以下指令创建一些区域:

 

gfsh>create region --name=region1 --group=group1 --type=REPLICATE
Member  | Status
------- | --------------------------------------
server2 | Region "/region1" created on "server2"
server1 | Region "/region1" created on "server1"

gfsh>create region --name=region2 --type=REPLICATE
Member  | Status
------- | --------------------------------------
server1 | Region "/region2" created on "server1"
server2 | Region "/region2" created on "server2"
server3 | Region "/region2" created on "server3"

 注意到当缓存服务器(server1server2,在本例中)启动时region1指定了组名为group1被创建在所有的缓存服务器中。region2被创建在所有成员中,因为没有指定组名。

 

 

6.部署jar文件。使用gfsh布署命令来布署应用jar文件到所有的成员或到一个指定的组成员。如下的例子从Pivotal GemFire分布式第统中布署mail.jar和mx4j.jar文件。(注意:这只是一个例子,你没有必要使用集群配置服务布署这些文件。或者,您可以使用任何两个jar文件用于此演示)。

gfsh>deploy --group=group1 --jar=${SYS_GEMFIRE_DIR}/lib/mail.jar
Post substitution: deploy --group=group1 --jar=/Users/username/Pivotal_GemFire_810_b50582_Linux/lib/mail.jar
Member  | Deployed JAR | Deployed JAR Location
------- | ------------ | -------------------------------------------------
server1 | mail.jar     | /Users/username/my_gemfire/server1/vf.gf#mail.jar#1
server2 | mail.jar     | /Users/username/my_gemfire/server2/vf.gf#mail.jar#1

gfsh>deploy --jar=${SYS_GEMFIRE_DIR}/lib/mx4j.jar
Post substitution: deploy --jar=/Users/username/Pivotal_GemFire_810_b50582_Linux/lib/mx4j.jar
Member  | Deployed JAR | Deployed JAR Location
------- | ------------ | -------------------------------------------------
server1 | mx4j.jar     | /Users/username/my_gemfire/server1/vf.gf#mx4j.jar#1
server2 | mx4j.jar     | /Users/username/my_gemfire/server2/vf.gf#mx4j.jar#1
server3 | mx4j.jar     | /Users/username/my_gemfire/server3/vf.gf#mx4j.jar#1

注意到mail.jar只布署到了group1组成员中而mx4j.jar布署到了所有成员中。

 

7.导出集群配置。你可以使用gfsh命令导出集群配置来创建一个包括集群配置的zip文件。这个zip文件包括了

cluster_config目录中的内容考贝。例如:

gfsh>export cluster-configuration --zip-file-name=myClusterConfig.zip --dir=/Users/username

 Apache Geode会把集群配置写到指定的zip文件中

Downloading cluster configuration : /Users/username/myClusterConfig.zip

 剩余部份内容演示如何使用你创建的集群配置

8.用如下命令关闭集群

gfsh>shutdown --include-locators=true
As a lot of data in memory will be lost, including possibly events in queues, do you
really want to shutdown the entire distributed system? (Y/n): Y
Shutdown is triggered

gfsh>
No longer connected to 192.0.2.0[1099].
gfsh>

 9.退出gfsh命令

gfsh>quit
Exiting...

 10.创建工作目录 (例如: new_gemfire) 并切换到新的目录。

11.启动gfsh

$ gfsh

 12.启动一个新定位器,例如

gfsh>start locator --name=locator2 --port=10335
Starting a GemFire Locator in /Users/username/new_gemfire/locator2...
.............................
Locator in /Users/username/new_gemfire/locator2 on 192.0.2.0[10335] as locator2 is currently online.
Process ID: 5749
Uptime: 15 seconds
GemFire Version: 8.1.0
Java Version: 1.7.0_71
Log File: /Users/username/new_gemfire/locator2/locator2.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: /Users/username/Pivotal_GemFire_810_b50582_Linux/lib/gemfire.jar
:/Users/username/Pivotal_GemFire_810_b50582_Linux/lib/locator-dependencies.jar

Successfully connected to: [host=192.0.2.0, port=1099]

Cluster configuration service is up and running.

 13.使用import cluster-configuration命令导入集群配置,例如

gfsh>import cluster-configuration --zip-file-name=/Users/username/myClusterConfig.zip
Cluster configuration successfully imported

 注意到 locator2 目录现在包括了 cluster_config 子目录。

14.不引用组启动一个服务器

gfsh>start server --name=server4 --server-port=40414
Starting a GemFire Server in /Users/username/new_gemfire/server4...
........
Server in /Users/username/new_gemfire/server4 on 192.0.2.0[40414] as server4 is currently online.
Process ID: 5813
Uptime: 4 seconds
GemFire Version: 8.1.0
Java Version: 1.7.0_71
Log File: /Users/username/new_gemfire/server4/server4.log
JVM Arguments: -Dgemfire.default.locators=192.0.2.0[10335]
-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: /Users/username/Pivotal_GemFire_810_b50582_Linux/lib/gemfire.jar
:/Users/username/Pivotal_GemFire_810_b50582_Linux/lib/server-dependencies.jar

 15.引用group1组启动服务器

gfsh>start server --name=server5 --group=group1 --server-port=40415
Starting a GemFire Server in /Users/username/new_gemfire/server5...
.....
Server in /Users/username/new_gemfire/server2 on 192.0.2.0[40415] as server5 is currently online.
Process ID: 5954
Uptime: 2 seconds
GemFire Version: 8.1.0
Java Version: 1.7.0_71
Log File: /Users/username/new_gemfire/server5/server5.log
JVM Arguments: -Dgemfire.default.locators=192.0.2.0[10335] -Dgemfire.groups=group1
-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: /Users/username/Pivotal_GemFire_810_b50582_Linux/lib/gemfire.jar
:/Users/username/Pivotal_GemFire_810_b50582_Linux/lib/server-dependencies.jar

 16.使用list regions命令显示已配置的区域。注意到被配置为原始的集群级别的region1 和 region2是可用的。

gfsh>list regions
List of regions
---------------
region1
region2

 17.使用describe region命令来查看每个区域属于哪个成员。注意到region1仅属于server5因为server5启动时使用了group1配置。region2属于server4 和 server5,因为region2创建时没有指定组。

gfsh>describe region --name=region1
..........................................................
Name            : region1
Data Policy     : replicate
Hosting Members : server5

Non-Default Attributes Shared By Hosting Members

 Type  | Name | Value
------ | ---- | -----
Region | size | 0

gfsh>describe region --name=region2
..........................................................
Name            : region2
Data Policy     : replicate
Hosting Members : server5
                  server4

Non-Default Attributes Shared By Hosting Members

 Type  | Name | Value
------ | ---- | -----
Region | size | 0

这个集群使用了与最初的系统一样的配置。你可以使用这个配置启动任何一个成员。所有的服务器都会收到集群级别的配置。 被指定为group1的服务器也会收到group1的配置。

18.用以下命令停止集群。

gfsh>shutdown --include-locators=true
As a lot of data in memory will be lost, including possibly events in queues,
  do you really want to shutdown the entire distributed system? (Y/n): Y
Shutdown is triggered

gfsh>
No longer connected to 192.0.2.0[1099].

 

 

0
3
分享到:
评论
3 楼 bewithme 2017-06-21  
有以下几种拓扑

Embedded  嵌入式

Peer-To-Peer  点对点对等式

Client/Server 客户端与服务器端

Multi-site/WAN Gateway  多站点广域网网关

一般情况下使用客户端与服务器端拓扑,这样的话你需要使用定位器,参考
http://geode.apache.org/docs/guide/11/topologies_and_comm/cs_configuration/client_server_example_configurations.html


2 楼 surpassno 2017-04-11  
this_is_it 写道
大神,您好!
     请问多台主机之间如何搭建geode集群,求解!比如我想在192.168.169.1和192.168.169.2两台主机搭建一个geode集群。

同求,找了半天没有找到。不知楼上解决了没?
1 楼 this_is_it 2017-02-15  
大神,您好!
     请问多台主机之间如何搭建geode集群,求解!比如我想在192.168.169.1和192.168.169.2两台主机搭建一个geode集群。

相关推荐

    linux基础进阶笔记

    linux基础进阶笔记,配套视频:https://www.bilibili.com/list/474327672?sid=4493093&spm_id_from=333.999.0.0&desc=1

    IMG20241115211541.jpg

    IMG20241115211541.jpg

    Sen2_ARI_median.txt

    GEE训练教程——Landsat5、8和Sentinel-2、DEM和各2哦想指数下载

    毕业设计&课设_基于 flask-whoosh-jieba 的代码,涉及文件管理及问题修复.zip

    该资源内项目源码是个人的课程设计、毕业设计,代码都测试ok,都是运行成功后才上传资源,答辩评审平均分达到96分,放心下载使用! ## 项目备注 1、该资源内项目代码都经过严格测试运行成功才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.md文件(如有),仅供学习参考, 切勿用于商业用途。

    基于springboot家政预约平台源码数据库文档.zip

    基于springboot家政预约平台源码数据库文档.zip

    Ucharts添加stack和折线图line的混合图

    Ucharts添加stack和折线图line的混合图

    基于springboot员工在线餐饮管理系统源码数据库文档.zip

    基于springboot员工在线餐饮管理系统源码数据库文档.zip

    2015-2021年新能源汽车分地区、分类型、分级别销量逐月数据和进出口数据-最新出炉.zip

    新能源汽车进出口数据 1、时间跨度:2018-2020年 2、指标说明:包含如下指标的进出口数据:混合动力客车(10座及以上)、纯电动客车(10座及以上)、非插电式混合动力乘用车、插电式混合动力乘用车、纯电动乘用车 二、新能源汽车进出口月销售数据(分地区、分类型、分 级别) 1、数据来源:见资料内说明 2、时间跨度:2014年1月-2021年5月 4、指标说明: 包含如下指标 2015年1月-2021年5月新能源乘用车终端月度销量(分类型)部分内容如下: 新能源乘用车(单月值、累计值 )、插电式混合动力 月度销量合计(狭义乘用车轿车、SUV、MPV、交叉型乘用车); 月度销量同比增速(狭义乘用车轿车、SUV、MPV、交叉型乘用车); 累计销量合计(狭义乘用车轿车、SUV、IPV、交叉型乘用车); 累计销量同比增速(狭义乘用车轿车、SUV、MPV、交叉型乘用车); 累计结构变化(狭义乘用车轿车、SUV、IPV、交叉型乘用车); 2015年1月-2021年5月新能源乘用车终端月度销量(分地区)内容如下: 更多见资源内

    中心主题-241121215200.pdf

    中心主题-241121215200.pdf

    蓝奏云下载链接与密码整理

    内容概要:本文档提供了多个蓝奏云下载链接及其对应解压密码,帮助用户快速获取所需文件。 适合人群:需要从蓝奏云下载文件的互联网用户。 使用场景及目标:方便地记录并分享蓝奏云上文件的下载地址和密码,提高下载效率。 阅读建议:直接查看并使用提供的链接和密码即可。若遇到失效情况,请尝试联系上传者确认更新后的链接。

    Javaweb仓库管理系统项目源码.zip

    基于Java web 实现的仓库管理系统源码,适用于初学者了解Java web的开发过程以及仓库管理系统的实现。

    Python-文件重命名-自定义添加文字-重命名

    资源名称:Python-文件重命名-自定义添加文字-重命名 类型:windows—exe可执行工具 环境:Windows10或以上系统 功能: 1、点击按钮 "源原文"【浏览】表示:选择重命名的文件夹 2、点击按钮 "保存文件夹"【浏览】表示:保存的路径(为了方便可选择保存在 源文件中 ) 3、功能①:在【头部】添加自定义文字 4、功能②:在【尾部】添加自定义文字 5、功能③:输入源字符 ;输入替换字符 可以将源文件中的字符替换自定义的 6、功能④:自动加上编号_1 _2 _3 优点: 1、非常快的速度! 2、已打包—双击即用!无需安装! 3、自带GUI界面方便使用!

    JDK8安装包,为各位学习的朋友免费提供

    JDK8安装包

    Centos-7yum的rpm包

    配合作者 一同使用 作者地址没有次下载路径 https://blog.csdn.net/weixin_52372189/article/details/127471149?fromshare=blogdetail&sharetype=blogdetail&sharerId=127471149&sharerefer=PC&sharesource=weixin_45375332&sharefrom=from_link

    setup_python_geospatial_analysis.ipynb

    GEE训练教程

    毕业设计&课设_文成公主微信公众号全栈工程,含技术栈、架构及部署流程等内容.zip

    该资源内项目源码是个人的课程设计、毕业设计,代码都测试ok,都是运行成功后才上传资源,答辩评审平均分达到96分,放心下载使用! ## 项目备注 1、该资源内项目代码都经过严格测试运行成功才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.md文件(如有),仅供学习参考, 切勿用于商业用途。

    基于springboot交通感知与车路协同系统源码数据库文档.zip

    基于springboot交通感知与车路协同系统源码数据库文档.zip

    基于springboot+vue 雅妮电影票购买系统源码数据库文档.zip

    基于springboot+vue 雅妮电影票购买系统源码数据库文档.zip

    使用 HTML5 实现拖放交互:音效与提示功能的完整实现

    为了更好地理解 HTML5 的拖放功能,我们设计了一个简单有趣的示例:将水果从水果区拖放到购物笼中,实时更新数量和价格,并在所有水果被成功放置后,播放音效并显示提示。

    毕业设计&课设_基于 SSM 的大学生综合成绩测评系统(含信息及数据库脚本,体现系统架构及功能设计).zip

    该资源内项目源码是个人的课程设计、毕业设计,代码都测试ok,都是运行成功后才上传资源,答辩评审平均分达到96分,放心下载使用! ## 项目备注 1、该资源内项目代码都经过严格测试运行成功才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.md文件(如有),仅供学习参考, 切勿用于商业用途。

Global site tag (gtag.js) - Google Analytics