cache inmemory and diskstore both together not working linux.

Greenhorn

Posts: 8

posted 7 years ago

Number of slices to send:

Optional 'thank-you' note:

Send

Hi Every one,

I am using ehcache-1.5 and jdk-1.4 and websphere application server for my project.

I have tested these in my local with windows environment. every thing works fine.
In windows environment it's storing data into heap as well as diskstore.
But it's not happening in linux environment.

I used Ehcache.flush() after object insertion, this is causing that flushing data into the diskstore from heap in linux , but it is available in both the places in windows.

Here is my ehcache.xml configuration file.

<?xml version="1.0" encoding="UTF-8"?>
<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:noNamespaceSchemaLocation="ehcache-1.5.xsd" updateCheck="false" monitoring="off"
         dynamicConfig="true">

</ehcache>

Here is my singleton class for Cache Operations.

/*
 * Created on Oct 17, 2016
 *
 * TODO To change the template for this generated file go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
package com.priyatham.cache;

import java.io.IOException;
import java.io.InputStream;

import org.apache.log4j.Logger;

import net.sf.ehcache.CacheException;
import net.sf.ehcache.CacheManager;
import net.sf.ehcache.Ehcache;
import net.sf.ehcache.Element;

/**
 * @author kotapr
 *
 * TODO To change the template for this generated type comment go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
public class CacheUtils {

private final static String CLASS_NAME = CacheUtils.class.getName();
//	protected static Trace tr = new Trace(CLASS_NAME);
	private static Logger tr = Logger.getLogger(CLASS_NAME);

private static CacheUtils cacheUtils = null;
    public CacheManager cacheMgr = null;
    
    private CacheUtils(){}
    
    public static CacheUtils getInstance(){
    	if(cacheUtils == null){
    		cacheUtils = new CacheUtils();
    	}
    	return cacheUtils;
    }

private Ehcache getCache(String cacheName){
        Ehcache cache = null;
        initiateCacheManager();
        if(cacheMgr != null){
			cache = cacheMgr.getEhcache(cacheName);
		}
		return cache;
	}
	
	
	
	private void initiateCacheManager() {
		String EHCACHE_XML_FILE_NAME = "rnecache.xml";
		try{
	        InputStream XML_FILE_PATH = getResourceAsStream(EHCACHE_XML_FILE_NAME); // comment this for local deployment
			if(cacheMgr == null){
             cacheMgr= new CacheManager(XML_FILE_PATH); // comment this for local deployment
//				cacheMgr=CacheManager.newInstance("C:\\apache-tomcat-6.0.43\\conf\\ehcache.xml"); // uncomment this for local deployment
			}
        }catch(IOException ioException) {
        	tr.info("file path specified is not correct");
        	tr.info(ioException.toString());
        }
	}

/* method to retrieve the object from cache
	@Key - lookup key
	@cacheName - name of the cache in which the values need to be stored
	 */
	public Object getResponseFromCache( String key,String cacheName){
		tr.info("retrieving from cache " +cacheName +" for key " +key);
			
		Ehcache cache = getCache(cacheName);
		Element element = null;
		if(cache!=null){
			element = cache.get(key);
		}

if(element==null){
			return null;
		}else{
			return element.getObjectValue();
			
		}
	}

/* method to add object to cache
	@Key - lookup key
	@value - object to be cached
	@cacheName - name of the cache in which the values need to be stored
	 */

public void addObjectToCache(String key, Object value, String cacheName) {
    	tr.info("adding to cache " +cacheName +" for key " +key);
		Ehcache cache = getCache(cacheName);
		
		try {
			cache.put(new Element(key, value));
			cache.flush();
        } catch (CacheException e) {
			tr.error(e.toString());
		}

}
    
    public boolean isKeyinCache(String key, String cacheName) {
    	Ehcache cache = getCache(cacheName);
    	return cache.isKeyInCache(key);
    }

public static InputStream getResourceAsStream(String file)throws IOException {
//		String filePath = B2BInitialise.getPropertyValue(file);
		String filePath = file;
		return Thread.currentThread().getContextClassLoader().getResourceAsStream(filePath);
	
	}

public int getDiskStoreSize(String cacheName) {
		// TODO Auto-generated method stub
		return getCache(cacheName).getDiskStoreSize();
	}

public long getInMemorySize(String cacheName) {
		// TODO Auto-generated method stub
		return getCache(cacheName).calculateInMemorySize();
	}

}

TestCacheUtils.java to test cache.

package com.priyatham.cache;

import com.priyatham.util.NumberToWord;

public class TestCacheUtils {
	
	private static CacheUtils cacheUtils = CacheUtils.getInstance();
	
	private static String EHCACHE_NAME = "RNECache";
	
	private static int SIZE = 3;

public static void main(String[] args) {
		insertObjects();
		System.out.println("disk size: " + cacheUtils.getDiskStoreSize(EHCACHE_NAME) + " In memory size: " + cacheUtils.getInMemorySize(EHCACHE_NAME));
		populateObjects();
		System.out.println("disk size: " + cacheUtils.getDiskStoreSize(EHCACHE_NAME) + " In memory size: " + cacheUtils.getInMemorySize(EHCACHE_NAME));
	}

private static void insertObjects() {
		NumberToWord numberToWord = NumberToWord.getInstance();
		for(int i=1; i<=SIZE; i++){
			cacheUtils.addObjectToCache(String.valueOf(i), new Number(numberToWord.convertNumberToWords(i)), EHCACHE_NAME);
			System.out.println("disk size: " + cacheUtils.getDiskStoreSize(EHCACHE_NAME) + " In memory size: " + cacheUtils.getInMemorySize(EHCACHE_NAME));
			try {
				if(i == 1){
					Thread.sleep(3000);
				}
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

private static void populateObjects() {
		for(int i =1 ; i<= SIZE ; i++){
			Object num = cacheUtils.getResponseFromCache(String.valueOf(i), EHCACHE_NAME);
			if(num != null){
				Number number = (Number)num;
				System.out.println(number.getNumToWord());
			}else {
				System.out.println(i + " not found in cache");
			}
			
		}
	}

}

Logs in windows environment.
disk size: 2 In memory size: 200

Logs in linux environment.
disk size: 2 In memory size: (if i use cache.flush())
disk size: In memoru size: 200(if i didn't use cache.flush())

Thanks in advance for your help.