gemfire java_gemfire基本使用以及spring-data-gemfire的使用
1.安装程序的使用
locator
启动locator
gfsh>start locator --name=locator1
指定端口启动
gfsh>start locator --name=locator1 --port=12105
指定端口和绑定ip启动
gfsh>start locator --name=locator1 --port=12105 --bind-address=10.10.10.110
查看locator状态
gfsh>status locator --name=locator1
gfsh>status locator --host=localhost --port=10334
连接locator
gfsh>connect
gfsh>connect --locator=localhost[10335]
关闭locator
gfsh>stop locator --name=locator1
关闭整个集群
gfsh>shutdown --include-locators=true
server
启动server
gfsh>start server --name=server1
指定locator启动
gfsh>start server --name=server1 --locators=localhost[10334]
指定端口和locator启动
gfsh>start server --name=server1 --server-port=12104 --locators=10.10.10.110[12105]
停止server
gfsh>stop server --name=server1
region
创建region
gfsh>create region --name=test --type=REPLICATE_PERSISTENT
存储kv值
gfsh>put --region=test --key="a" --value="A"
查询信息
gfsh>query --query="select * from /test"
查看region信息
gfsh>describe region --name=test
销毁region
gfsh>destroy region --name=test
部署jar包(deploy)
gemfire中部署jar包分为实体类和计算类两种情况:
1.实体类: 实体类需要部署到gemfire程序的classpath路径下面；
2.计算类: 对于计算类，可以通过deploy命令手动部署;
部署jar包
gfsh>deploy --jars=/data/local/gemfire/apache-geode-1.5.0/lib/geode-demo-1.0-SNAPSHOT.jar
查看已部署jar包
gfsh>list deployed
卸载jar包
gfsh>undeploy --jar=geode-demo-1.0-SNAPSHOT.jar
2. 结合spring-data的使用
maven依赖:
org.springframework.data
spring-data-gemfire
2.0.6.RELEASE
io.pivotal.gemfire
geode-lucene
2.1 客户端模式(client)
配置文件:
ClientContext.xml
通过spring-data接口CrudRepository实现OQL查询region:
MessageReposirory.java
@Repository
@DependsOn("gemfireCache")
public interface MessageReposirory extends CrudRepository{
@Query("SELECT * FROM /messages m WHERE m.message = $1")
List findByMessage(String message);
@Query("SELECT * FROM /messages m WHERE m.message IN SET $1")
List findByMessages(List messages);
}
ClientTestController.java
...
List c1 = reposirory.findByMessage("C");
c1.stream().forEach(System.out::println);
...
结论: 客户端模式更多的是对集群中数据的查询，而对集群中region的管理有限；
2.2 服务端嵌入模式(server)
配置文件:
ServerContext.xml
application.properties
#server端口和绑定地址
spring.data.gemfire.cache.server.port=41414
spring.data.gemfire.cache.server.bind-address=localhost
#locator端口和地址
spring.data.gemfire.locator.host=localhost
spring.data.gemfire.locator.port=10335
gemfire.properties
#开启jmx
jmx-manager=true
jmx-manager-start=true
#指定访问locator集群
locators=localhost[10334],localhost[10335]
启动类注解:
ServerApplication.java
@SpringBootApplication
@CacheServerApplication(name = "embedServer")
@EnableLocator
@EnableGemfireRepositories(basePackages = "com.cord.demo.dao")
@ImportResource(locations = {"classpath:ServerContext.xml"})
public class ServerApplication implements CommandLineRunner {
...
}
动态创建region:
ServerTestController.java
...
@Autowired
private Cache gemfireCache; //系统默认的cache名
...
/**获取region工厂*/
RegionFactory rf = gemfireCache.createRegionFactory(RegionShortcut.REPLICATE);
/**创建region*/
Region region = rf.create("test");
...