依赖JAR：

org.apache.geode

geode-core

1.1.0

com.gemstone.gemfire

gemfire

8.2.2

org.apache.geode

geode-json

1.1.0

org.apache.geode

geode-common

1.1.0

代码示例：

public class UserEntity implements Serializable{

private int id;

private int age;

private String name;

private Date registerdDate;

//getter and setter...

}

public class DataClient {

private final static Logger logger = Logger.getLogger(DataClient.class);

Region region = null;

@Before

public void init(){

ClientCache cache = new ClientCacheFactory().addPoolLocator("db", 10334).create();

ClientRegionFactory rf = cache.createClientRegionFactory(ClientRegionShortcut.CACHING_PROXY);

region = rf.create( "user");

}

@Test

public void saveUserEntity(){

region.putAll(newUserEntity(10));

}

@Test

public void clear(){

region.clear();

}

@Test

public void delele(){

region.remove("");

}

@Test

public void update(){

Object obj = region.get("108");

Map map = new HashMap();

UserEntity data= ((UserEntity)obj);

data.setAge(12);

map.put("108",data);

region.putAll(map);

}

@Test

public void getUserEntity(){

try {

Object objList = region.query("select * from /user u where u.age > 10");

Object obj = region.get("108");

if(objList != null && objList instanceof ResultsBag){

Iterator iter = ((ResultsBag) objList).iterator();

while(iter.hasNext()){

UserEntity UserEntity = (UserEntity) iter.next();

System.out.println("UserEntity"+UserEntity);

}

}

if(obj != null && obj instanceof UserEntity){

System.out.println("UserEntity"+(UserEntity)obj);

}

}catch (Exception e){

logger.error("error occured.", e);

}

}

@After

public void done(){

region.close();

}

private Map newUserEntity(int size){

Map map = new HashMap();

for (int i = 0; i < size; i++) {

int id = i+100;

map.put(id,new UserEntity(id,10+i,"username:"+id,new Date()));

}

return map;

}

}