extreme scale util class (一)

2014-11-24 08:24:25 · 作者: · 浏览: 0

The util class to get the object that exists in object grid.
package org.duke.xs;

import java.io.File;
import java.util.ArrayList;
import java.util.List;

import com.fmr.pzn.bo.TagProfileData;
import com.fmr.pzn.bo.UserProfile;
import com.ibm.websphere.objectgrid.BackingMap;
import com.ibm.websphere.objectgrid.ClientClusterContext;
import com.ibm.websphere.objectgrid.ConnectException;
import com.ibm.websphere.objectgrid.ObjectGrid;
import com.ibm.websphere.objectgrid.ObjectGridManager;
import com.ibm.websphere.objectgrid.ObjectGridManagerFactory;
import com.ibm.websphere.objectgrid.ObjectGridRuntimeException;
import com.ibm.websphere.objectgrid.ObjectMap;
import com.ibm.websphere.objectgrid.Session;
import com.ibm.websphere.objectgrid.UndefinedMapException;
import com.ibm.websphere.objectgrid.security.config.ClientSecurityConfiguration;
import com.ibm.websphere.objectgrid.security.config.ClientSecurityConfigurationFactory;

/**
* To retrieve tag from XS.
*/
public class XSUtil {
private static String connectionString = null;
private static String gridName = null;
private static String mapName = null;
private static String uniqueId = null;
private static ObjectGrid grid = null;

/**
* @param args
* @throws Exception
*/
public static void main(String[] args) throws Exception {
connectionString = "AAAtest1.fmr.com:17000,AAAtest1.fmr.com:17001";

gridName = "volatileGrid";
// gridName = "Grid";
mapName = "XXXMap";
uniqueId = "0001000001811";

grid = getGrid(connectionString, gridName, "configs/pzn-int/ogClient.properties");
System.out.println(grid.getMap(mapName).getTimeToLive());

// System.out.println("**********Start to delete entry**********");
// deleteEntry(grid, mapName, uniqueId);
//
// System.out.println("**********Start to create entry**********");
// createEntry(grid, mapName, uniqueId);

System.out.println("**********Start to query entry**********");
queryEntry(grid, mapName, uniqueId);
}

/**
* @param connectionString
* @param gridName
* @param csConfigFile
* @return
* @throws Exception
* @throws ConnectException
*/
public static ObjectGrid getGrid(String connectionString, String gridName,
String csConfigFile) throws Exception, ConnectException {
if (connectionString != null && connectionString.length() > 0
&& connectionString.indexOf(":") > 0) {
if (grid == null) {
ClientClusterContext ccc = null;
ObjectGridManager ogManager = null;
try {
ogManager = ObjectGridManagerFactory.getObjectGridManager();
System.out.println(" >>> ObjectGridManager obtained, " + ogManager);

// uncomment these lines to unable ORB/SSL tracing
// ogManager.setTraceFileName("logs/client.log");
// ogManager.setTraceSpecification("ObjectGrid*=all=enabled:ORBRas=all=enabled:SASRas=all=enabled:com.ibm.ws.security.*=all=enabled");

//ccc = ogManager.connect(connectionString, null, null);

ClientS