108 lines
3.5 KiB
Java
108 lines
3.5 KiB
Java
package org.gcube.portlet.user.my_vres.server;
|
|
|
|
import static org.gcube.resources.discovery.icclient.ICFactory.clientFor;
|
|
import static org.gcube.resources.discovery.icclient.ICFactory.queryFor;
|
|
|
|
import java.io.IOException;
|
|
import java.net.InetSocketAddress;
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
|
|
import org.gcube.common.portal.PortalContext;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint.AccessPoint;
|
|
import org.gcube.common.resources.gcore.utils.Group;
|
|
import org.gcube.common.scope.api.ScopeProvider;
|
|
import org.gcube.resources.discovery.client.api.DiscoveryClient;
|
|
import org.gcube.resources.discovery.client.queries.api.SimpleQuery;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import net.spy.memcached.MemcachedClient;
|
|
|
|
/**
|
|
* @author Massimiliano Assante at ISTI-CNR
|
|
*/
|
|
public class DistributedCacheClient {
|
|
|
|
// Logger
|
|
private static final org.slf4j.Logger logger = LoggerFactory.getLogger(DistributedCacheClient.class);
|
|
|
|
private static final String MEMCACHED_RESOURCE_NAME = "Memcached";
|
|
private static final String CATEGORY = "Database";
|
|
|
|
private MemcachedClient mClient;
|
|
|
|
/**
|
|
* Singleton object
|
|
*/
|
|
private static DistributedCacheClient singleton = new DistributedCacheClient();
|
|
|
|
/**
|
|
* Build the singleton instance
|
|
*/
|
|
private DistributedCacheClient(){
|
|
List<InetSocketAddress> addrs = discoverHostOfServiceEndpoint();
|
|
try {
|
|
mClient = new MemcachedClient(addrs);
|
|
} catch (IOException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Retrieve the singleton instance
|
|
*/
|
|
public static DistributedCacheClient getInstance(){
|
|
if (singleton == null) {
|
|
singleton = new DistributedCacheClient();
|
|
}
|
|
return singleton;
|
|
}
|
|
|
|
public MemcachedClient getMemcachedClient() {
|
|
return mClient;
|
|
}
|
|
|
|
/**
|
|
* Retrieve endpoint resoruce from IS
|
|
* @return List of InetSocketAddresses
|
|
* @throws Exception
|
|
*/
|
|
private static List<InetSocketAddress> discoverHostOfServiceEndpoint(){
|
|
|
|
String currentScope = ScopeProvider.instance.get();
|
|
String infrastructure = "/"+PortalContext.getConfiguration().getInfrastructureName();
|
|
ScopeProvider.instance.set(infrastructure);
|
|
List<InetSocketAddress> toReturn = new ArrayList<InetSocketAddress>();
|
|
try{
|
|
SimpleQuery query = queryFor(ServiceEndpoint.class);
|
|
query.addCondition("$resource/Profile/Name/text() eq '"+ MEMCACHED_RESOURCE_NAME +"'");
|
|
query.addCondition("$resource/Profile/Category/text() eq '"+ CATEGORY +"'");
|
|
DiscoveryClient<ServiceEndpoint> client = clientFor(ServiceEndpoint.class);
|
|
List<ServiceEndpoint> ses = client.submit(query);
|
|
if (ses.isEmpty()) {
|
|
logger.error("There is no Memcached cluster having name: " + MEMCACHED_RESOURCE_NAME + " and Category " + CATEGORY + " on root context in this infrastructure: ");
|
|
return null;
|
|
}
|
|
for (ServiceEndpoint se : ses) {
|
|
Group<AccessPoint> aps = se.profile().accessPoints();
|
|
for (AccessPoint ap : aps.asCollection()) {
|
|
String address = ap.address(); //e.g. socialnetworking-d-d4s.d4science.org:11211
|
|
String[] splits = address.split(":");
|
|
String hostname = splits[0];
|
|
int port = Integer.parseInt(splits[1]);
|
|
toReturn.add(new InetSocketAddress(hostname, port));
|
|
}
|
|
break;
|
|
}
|
|
} catch(Exception e){
|
|
logger.error("Error while retrieving hosts for the Memcached cluster having name: " + MEMCACHED_RESOURCE_NAME + " and Category " + CATEGORY + " on root context");
|
|
}finally{
|
|
ScopeProvider.instance.set(currentScope);
|
|
}
|
|
ScopeProvider.instance.set(currentScope);
|
|
return toReturn;
|
|
}
|
|
|
|
}
|