Memcached Java Client Example

Pankaj 18 Comments

Today we will look into Memcached java client example. Earlier we learned about telnet commands for memcached with sample execution terminal logs. But most of the times we want to connect to the Memcached server through some other programming languages, such as Java and PHP.

Memcached Java Client

There are three most widely used memcached java client API.

xmemcached
spymemcached
gwhalin memcached client

Memcached Java Example

I have used Greg Whalin Memcached client and found it easy to understand and use. It provides all the basic functionalities with thread pooling. Below is the maven dependency to include this into your project.

Copy
<dependency>
    <groupId>com.whalin</groupId>
    <artifactId>Memcached-Java-Client</artifactId>
    <version>3.0.2</version>
</dependency>

To help you get started quickly, I am providing a sample program to showcase the usage of basic functions that can be performed with the Memcached server.

Copy
package com.journaldev.memcached.test;

import java.util.HashMap;
import com.whalin.MemCached.MemCachedClient;
import com.whalin.MemCached.SockIOPool;

public class MemcachedJavaClient {

	/**
	 * MemcachedJavaClient program to show the usage of different functions
	 * that can be performed on Memcached server with Java Client
	 * @param args
	 */
	public static void main(String[] args) {
		//initialize the SockIOPool that maintains the Memcached Server Connection Pool
		String[] servers = {"localhost:11111"};
		SockIOPool pool = SockIOPool.getInstance("Test1");
		pool.setServers( servers );
		pool.setFailover( true );
		pool.setInitConn( 10 );
		pool.setMinConn( 5 );
		pool.setMaxConn( 250 );
		pool.setMaintSleep( 30 );
		pool.setNagle( false );
		pool.setSocketTO( 3000 );
		pool.setAliveCheck( true );
		pool.initialize();
		//Get the Memcached Client from SockIOPool named Test1
		MemCachedClient mcc = new MemCachedClient("Test1");
		//add some value in cache
		System.out.println("add status: "+mcc.add("1", "Original"));
		//Get value from cache
		System.out.println("Get from Cache: "+mcc.get("1"));

		System.out.println("add status: "+mcc.add("1", "Modified"));
		System.out.println("Get from Cache: "+mcc.get("1"));

		//use set function to add/update value, use replace to update and not add
		System.out.println("set status: "+mcc.set("1","Modified"));
		System.out.println("Get from Cache after set: "+mcc.get("1"));

		//use delete function to delete key from cache
		System.out.println("remove status: "+mcc.delete("1"));
		System.out.println("Get from Cache after delete: "+mcc.get("1"));

		//Use getMulti function to retrieve multiple keys values in one function
		// Its helpful in reducing network calls to 1
		mcc.set("2", "2");
		mcc.set("3", "3");
		mcc.set("4", "4");
		mcc.set("5", "5");
		String [] keys = {"1", "2","3","INVALID","5"};
		HashMap<String,Object> hm = (HashMap<String, Object>) mcc.getMulti(keys);

		for(String key : hm.keySet()){
			System.out.println("KEY: "+key+" VALUE: "+hm.get(key));
		}
	}

}

The output of the above Memcache java client program is:

Copy
add status: true
Get from Cache: Original
add status: false
Get from Cache: Original
set status: true
Get from Cache after set: Modified
remove status: true
Get from Cache after delete: null
KEY: 3 VALUE: 3
KEY: 2 VALUE: 2
KEY: 1 VALUE: null
KEY: INVALID VALUE: null
KEY: 5 VALUE: 5

If you want to connect to multiple memcached servers then you will have to create multiple SockIOPool instances and then use the same name while getting the MemcacheClient instance.

WhatsApp Reddit Twitter Facebook Linkedin Email

About Pankaj

I love Open Source technologies and writing about my experience about them is my passion. You can connect with me directly on Facebook, Twitter, and YouTube.

« Memcached Telnet Commands Example

How to install Memcached Server on Windows as Service »

Comments

saratha.A says
April 28, 2014 at 6:17 am
Why Java memcached does not support multi key delete action?
Reply
Ravi says
March 5, 2014 at 5:57 am
Hi Pankaj,
I have some queries regarding key value expiration, please help me.
1. Is there any automatic expiration of key from memcache?
2. What is the default expiration-time for key in memcache?
3. When i stop memcache server and restarted, what is the liability of already stored key values in memcache? Can I able to get those key values from memcache?
Kindly clarify the above points please, Thanks for your support from your previous posts.
Kind Regards,
Ravi
Reply
Silvio says
March 4, 2014 at 9:08 am
Thanks mate, cann’t find any other example on the internet nor the official website.. painful.
Thanks!
Reply
Ravi says
February 27, 2014 at 9:53 am
Hi Pankaj,
I am working on windows environment could you please help me, how to install memcached server on Windows operating system
Kind Regards,
Ravi
Reply
Bhadresh Shiroya says
January 2, 2014 at 8:44 am
Any Example Memcache spymemcache.jar because i have to used internet reffer example AddrUtil Class not identify in my project
Reply
Bhawani says
July 17, 2013 at 4:42 am
btw are those Pool property settings necessary ?
Reply
Bhawani says
July 17, 2013 at 4:32 am
Very helpful post. simple and clean
Thank you
Reply
Archana says
May 16, 2011 at 12:34 pm
Hi, Thanks for nice article.
I used the same example on windows machine and its able to read write values in cache on same server.
But when i am trying to connect to two memcached server, its not able to connect to other windows machine.
I have used same code as you mentioned, i only changes the server as below:-
String[] servers = { “localhost:11211”, “server2IP:11211” };
But it still accessing only local cache.
I ran same apps on other server and i am not able to get the value which i set from first server.
Also, i am getting the below error:-
63 [main] DEBUG com.meetup.memcached.SockIOPool – ++++ added server2IP:11211 to server bucket
63 [main] DEBUG com.meetup.memcached.SockIOPool – +++ creating initial connections (1) for host: server2IP:11211
3063 [main] ERROR com.meetup.memcached.SockIOPool – ++++ failed to get SockIO obj for: server2IP:11211
3063 [main] ERROR com.meetup.memcached.SockIOPool –
java.net.SocketTimeoutException
at sun.nio.ch.SocketAdaptor.connect(Unknown Source)
at com.meetup.memcached.SockIOPool$SockIO.getSocket(SockIOPool.java:1610)
at com.meetup.memcached.SockIOPool$SockIO.(SockIOPool.java:1583)
at com.meetup.memcached.SockIOPool.createSocket(SockIOPool.java:780)
at com.meetup.memcached.SockIOPool.populateBuckets(SockIOPool.java:669)
at com.meetup.memcached.SockIOPool.initialize(SockIOPool.java:632)
at com.meetup.memcached.test.TestMemcached.main(TestMemcached.java:39)
3079 [main] DEBUG com.meetup.memcached.SockIOPool – ++++ ignoring dead host: server2IP:11211 for 1000 ms
3079 [main] ERROR com.meetup.memcached.SockIOPool – ++++ failed to create connection to: server2IP:11211 — only 0 created.
Am i doing something wrong?
Please help me to resolve this.
Thanks in advance!
Regards
Archana
Reply
- Pankaj says
  May 16, 2011 at 2:29 pm
  Dear Archana,
  Try first with Telnet command to check whether you are able to access the other memcache server or not. I believe the other machine is under some firewall and that’s why connection is getting refused.
  I have worked on Unix/Linux servers and it works fine.
  Reply
  - Ravi says
    February 27, 2014 at 6:16 am
    Hi Pankaj,
    I have tried same thing but i am getting below result please help me.
    log4j:WARN No appenders could be found for logger (com.meetup.memcached.SockIOPool).
    log4j:WARN Please initialize the log4j system properly.
    add status:false
    Get from Cache:null
    add status:false
    Get from Cache:null
    set status:false
    Get from Cache after set:null
    remove status:false
    Get from Cache after delete:null
    KEY:2 VALUE:null
    KEY:3 VALUE:null
    KEY:5 VALUE:null
    KEY:INVALID VALUE:null
    KEY:1 VALUE:null
    my client program is:
    package com.meetup.memcached.test;
    /**
    * Created with IntelliJ IDEA.
    * User: ravi
    * Date: 27/2/14
    * Time: 11:30 AM
    * To change this template use File | Settings | File Templates.
    */
    import java.util.HashMap;
    import com.meetup.memcached.MemcachedClient;
    import com.meetup.memcached.SockIOPool;
    public class MemcachedJavaClient {
    /**
    * MemcachedJavaClient program to show the usage of different functions
    * that can be performed on Memcached server with Java Client
    * @param args
    */
    public static void main(String[] args) {
    //initialize the SockIOPool that maintains the Memcached Server Connection Pool
    String[] servers = {“localhost:11211”};
    SockIOPool pool = SockIOPool.getInstance(“test”);
    pool.setServers( servers );
    pool.setFailover( true );
    pool.setInitConn( 10 );
    pool.setMinConn( 5 );
    pool.setMaxConn( 250 );
    pool.setMaintSleep( 30 );
    pool.setNagle( false );
    pool.setSocketTO( 3000 );
    pool.setAliveCheck( true );
    pool.initialize();
    //Get the Memcached Client from SockIOPool named Test1
    MemcachedClient mcc = new MemcachedClient(“test”);
    //add some value in cache
    System.out.println(“add status:”+mcc.add(“1”, “Original”));
    //Get value from cache
    System.out.println(“Get from Cache:”+mcc.get(“1”));
    System.out.println(“add status:”+mcc.add(“1”, “Modified”));
    System.out.println(“Get from Cache:”+mcc.get(“1”));
    //use set function to add/update value, use replace to update and not add
    System.out.println(“set status:”+mcc.set(“1″,”Modified”));
    System.out.println(“Get from Cache after set:”+mcc.get(“1”));
    //use delete function to delete key from cache
    System.out.println(“remove status:”+mcc.delete(“1”));
    System.out.println(“Get from Cache after delete:”+mcc.get(“1”));
    //Use getMulti function to retrieve multiple keys values in one function
    // Its helpful in reducing network calls to 1
    mcc.set(“2”, “2”);
    mcc.set(“3”, “3”);
    mcc.set(“4”, “4”);
    mcc.set(“5”, “5”);
    String [] keys = {“1”, “2”,”3″,”INVALID”,”5″};
    HashMap hm = (HashMap) mcc.getMulti(keys);
    for(String key : hm.keySet()){
    System.out.println(“KEY:”+key+” VALUE:”+hm.get(key));
    }
    }
    }
    Reply
    - Pankaj says
      February 27, 2014 at 7:47 am
      is ur memcached server running fine, can you connect via telnet and run some commands?
      Reply
      - Ravi says
        February 27, 2014 at 9:04 am
        did same thing it was able to connect.
      - Ravi says
        February 27, 2014 at 9:10 am
        could you please tell me the steps, how to make memcached server, i have down loaded Memcached-Java-Client-master.zip file in my local system and loaded in intelliJ IDE and testing through IDE
      - Ravi says
        February 27, 2014 at 9:54 am
        Hi Pankaj,
        I am working on windows environment could you please help me, how to install memcached server on Windows operating system
        Kind Regards,
        Ravi
      - Pankaj says
        February 27, 2014 at 6:04 pm
        Please check https://www.journaldev.com/42/how-to-install-memcached-server-on-windows-as-service
      - Ravi says
        March 5, 2014 at 5:58 am
        Hi Pankaj,
        I have some queries regarding key value expiration, please help me.
        1. Is there any automatic expiration of key from memcache?
        2. What is the default expiration-time for key in memcache?
        3. When i stop memcache server and restarted, what is the liability of already stored key values in memcache? Can I able to get those key values from memcache?
        Kindly clarify the above points please, Thanks for your support from your previous posts.
        Kind Regards,
        Ravi
      - Ravi says
        March 10, 2014 at 10:34 am
        Hi Pankaj,
        Memcached for object storage. Default is 64MB, i want to increase the size, how can i proceed for this, how to increase this size in windows based memcache server?
        Kind Regards,
        Ravi.