package teacherclub.util;
import java.io.File;
import java.io.InputStream;
import java.util.Date;
import java.util.Properties;
import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;
/**
* @author Chergen
*
*/
public class MCCUtil {
/**
* @param args
*/
protected static MemCachedClient mcc = new MemCachedClient();
/**�Ƿ���� MCC*/
private static boolean IS_DISABLED = false;
/**Ĭ��ʧЧʱ��*/
private static long DEF_EXPIRE = 10000;
/**���� �Ƿ���� MCC<br>true:���ã�false:����*/
public static void setDisable(boolean isDisable){
IS_DISABLED = isDisable;
if(!IS_DISABLED)
init();
}
/**���� Ĭ��ʧЧʱ��*/
public static void setDefExpire(long expire){
DEF_EXPIRE = expire;
}
static {
init();
}
private static void init(){
Properties props = new Properties();
try{
String path = WebUtil.getWebinfPath()+File.separatorChar+"properties"+File.separatorChar+"mcc.properties";
File file = new File(path);
InputStream is = new java.io.FileInputStream(file);
props.load(is);
is.close();
System.out.println("Successfully initialize MCC!");
}catch(Exception e){
IS_DISABLED = true;
System.out.println("Failed to initialize MCC!\nPleanse check out the mcc.properties.");
e.printStackTrace();
return ;
}
String[] servers = props.getProperty("mcc.servers", "localhost:11211").split(",");//{ "mcc.host:11211" };
String[] weightsStr = props.getProperty("mcc.weights", "3").split(",");
Integer[] weights = new Integer[weightsStr.length];//{ 3 };
for (int i = 0; i < weightsStr.length; i++) {
try{
weights[i] = Integer.parseInt(weightsStr[i]);
}catch(Exception e){weights[i] = 3;}
}
// ����һ��ʵ�����SockIOPool
SockIOPool pool = SockIOPool.getInstance();
// set the servers and the weights
// ����Memcached Server
pool.setServers(servers);
pool.setWeights(weights);
// set some basic pool settings
// 5 initial, 5 min, and 250 max conns
// and set the max idle time for a conn
// to 6 hours
pool.setInitConn(5);
pool.setMinConn(5);
pool.setMaxConn(250);
pool.setMaxIdle(1000 * 60 * 60 * 12);
// set the sleep for the maint thread
// it will wake up every x seconds and
// maintain the pool size
pool.setMaintSleep(30);
// Tcp�Ĺ�������ڷ���һ���֮ǰ�����ػ����ȴ�Զ�����
// ����һ�η��͵İ��ȷ����Ϣ��4�������Ϳ��Թر����ֵĻ��棬
// �������������˾ͷ���
pool.setNagle(false);
// l�ӽ�b��Գ�ʱ�Ŀ���
pool.setSocketTO(3000);
// l�ӽ�bʱ�Գ�ʱ�Ŀ���
pool.setSocketConnectTO(0);
// initialize the connection pool
// ��ʼ��һЩֵ����MemcachedServer�ν�bl��
pool.initialize();
// lets set some compression on for the client
// compress anything larger than 64k
mcc.setCompressEnable(true);
mcc.setCompressThreshold(64 * 1024);
}
/**�������*/
public static void inputData(String key, Object Data){
inputData(key, Data, DEF_EXPIRE);
}
/**�������*/
public static void inputData(String key, Object Data, long expire){
if(!IS_DISABLED)
mcc.set(key, Data, new Date(expire));
}
/**ȡ�����*/
public static Object outputData(String key){
if(IS_DISABLED)
return null;
return mcc.get(key);
}
private static void bulidCache() {
// set(key,value,Date) ,Date��һ�����ʱ�䣬�������������ʱ����Ч�Ļ������ﴫ�ݵ�new Date(long
// date) �в���date����Ҫ�Ǹ���ڻ����1000��ֵ��
// ��Ϊjava client��ʵ��Դ����������ʵ�ֵ� expiry.getTime() / 1000 ��Ҳ����˵�����
// С��1000��ֵ������1000�Ժ���0�����2�����
mcc.set("test", "This is a test String", new Date(10000)); // ʮ������
}
private static void output() {
// ��cache��ȡֵ
String value = (String) mcc.get("test");
System.out.println(value);
}
public static void main(String[] args) {
bulidCache();
output();
}
}
