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示例
启动工程，成功如下所示：

run.png

Tips：
代码中的region = rf.create(regionName); 并不能真正在服务器上创建一个新的region,只是在客户端创建一个和服务端类似的，相当于我们的数据库工具连接了远程的数据库，复制了相同的表结构在本地。综上，我们在put objec之前，要把项目打包放到服务器上，用deploy命令引用jar包，put，query对应代码里的object才
不会报错！

下面是pulse的查询结果：

query.png

常见错误

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代码就是以连接池的形式实现连接：

pool.png

每个池连接都会转到服务器正在监听的主机：端口位置，服务器在同意连接上相应请求，通常，客户端线程使用池连接进行单独操作，然后将连接返回到池以供重用，也可以多线程连接。

连接池可以从服务器定位器（池随机选择要使用的定位器，并且池会附带一个定位器，直到连接失败）和静态服务器列表（静态服务器列表没有负载平衡或动态服务器发现）中获取服务器连接信息。

2）订阅连接

订阅连接用于将缓存事件从服务器传输到客户端。要使用它，请将client属性设置subscription-enabled为true。服务器建立一个队列来异步发送订阅事件，并建立一个订阅连接来处理传入的消息。发送的事件取决于客户如何订阅。

sub.png

程序媛小白一枚，如有错误，烦请批评指正！(#^.#)