1）在IDEA中新建一个maven工程
2）在pom.xml文件中添加如下的依赖
<dependency>
<groupId>org.apache.geode</groupId>
<artifactId>geode-core</artifactId>
<version>1.3.0</version>
</dependency>
<dependency>
<groupId>org.apache.geode</groupId>
<artifactId>geode-common</artifactId>
<version>1.1.0</version>
</dependency>
3)新建一个实体类
public class UserBean implements DataSerializable {
private int id;
private int age;
private String name;
private Date createDate;
public UserBean() {
}
public UserBean(int id, int age, String name, Date createDate) {
this.id = id;
this.age = age;
this.name = name;
this.createDate = createDate;
}
@Override
public void fromData(DataInput in) throws IOException, ClassNotFoundException {
this.id = in.readInt();
this.age = in.readInt();
this.name = in.readUTF();
this.createDate = DataSerializer.readDate(in);
}
@Override
public void toData(DataOutput out) throws IOException {
out.writeInt(this.id);
out.writeInt(this.age);
out.writeUTF(this.name);
DataSerializer.writeDate(this.createDate, out);
}
@Override
public String toString() {
return "用户的信息为：id：" + id + " 年龄为：" + age + " 名字为： " + name + " 创建日期为：" + createDate + "!";
}
//此处省略set，get方法~
}
4)新建一个GeodeDemo类
public class FeodeDemo {
String regionName = "user";
int userNum = 10;
public static void main( String[] args )
{
new FeodeDemo().test();
}
public void test() {
Region region = null;
//使用池连接的方式创建一个定位器
ClientCache cacheS = new ClientCacheFactory().addPoolLocator("node1", 10334).create();
//在已有的缓存服务器上连接一个region，CACHING_PROXY表示允许本地数据存储还可以参照官方文档动态创建region
ClientRegionFactory rf = cacheS.createClientRegionFactory(ClientRegionShortcut.CACHING_PROXY);
region = rf.create(regionName);
//获取当前的分布式服务器
System.out.println(cacheS.getCurrentServers());
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的信息： "+ obj.toString());
}
} catch (FunctionDomainException e) {
e.printStackTrace();
} catch (TypeMismatchException e) {
e.printStackTrace();
} catch (NameResolutionException e) {
e.printStackTrace();
} catch (QueryInvocationTargetException e) {
e.printStackTrace();
}
}
//增加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(userBean));
user108.setAge(12);
region.put(user108.getId(),user108);
}
}
//删除某个用户
public void delete(Region region,int id){
region.remove(id);
}
//清空表
public void truncate(Region region){
region.clear();
}
}
动态创建region示例
启动工程，成功如下所示：
Tips：
代码中的region = rf.create(regionName); 并不能真正在服务器上创建一个新的region,只是在客户端创建一个和服务端类似的，相当于我们的数据库工具连接了远程的数据库，复制了相同的表结构在本地。综上，我们在put objec之前，要把项目打包放到服务器上，用deploy命令引用jar包，put，query对应代码里的object才
不会报错！
下面是pulse的查询结果：
常见错误
1）java.net.ConnectException: Connection timed out: connect
如果你们公司用的是阿里服务器，10334这个端口之前没有用过，可以使用一下命令开通端口:
/sbin/iptables -I INPUT -p tcp --dport 10334 -j ACCEPT
开通完毕，可以使用：
telnet ip port 测试端口是否可以访问
2)Exception in thread "main" org.apache.geode.cache.client.NoAvailableServersException
gfsh 只开启了locator,没有一个server在运行，启动至少一个server
客户端 服务器连接的工作原理
Apache Geode的客户端与服务器连接有2种方式：池连接和订阅连接
1）池连接
上诉java代码就是以连接池的形式实现连接：
每个池连接都会转到服务器正在监听的主机：端口位置，服务器在同意连接上相应请求，通常，客户端线程使用池连接进行单独操作，然后将连接返回到池以供重用，也可以多线程连接。
连接池可以从服务器定位器（池随机选择要使用的定位器，并且池会附带一个定位器，直到连接失败）和静态服务器列表（静态服务器列表没有负载平衡或动态服务器发现）中获取服务器连接信息。
2）订阅连接
订阅连接用于将缓存事件从服务器传输到客户端。要使用它，请将client属性设置subscription-enabled为true。服务器建立一个队列来异步发送订阅事件，并建立一个订阅连接来处理传入的消息。发送的事件取决于客户如何订阅。
程序媛小白一枚，如有错误，烦请批评指正！(#.#)
