Java Connecting to Memcached Service

To connect to Memcached using a Java program, you need to add the Memcached jar package to your classpath.

Download the jar package from our site: spymemcached-2.10.3.jar.

Download the jar package from Google Code: spymemcached-2.10.3.jar (requires a VPN).

The following program assumes the Memcached service host is 127.0.0.1 and the port is 11211.

Connection Example

Java Connecting to Memcached

MemcachedJava.java file:

import net.spy.memcached.MemcachedClient;
import java.net.*;

public class MemcachedJava{
    public static void main(String[]args){
        try{
            MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            System.out.println("Connection to server successful.");
            mcc.shutdown();
        }catch(Exception ex){
            System.out.println(ex.getMessage());
        }
    }
}

In this program, we use InetSocketAddress to connect to the memcached service at IP 127.0.0.1 and port 11211.

Executing the above code, if the connection is successful, the following message will be output:

Connection to server successful.

set Operation Example

The following uses java.util.concurrent.Future to store data.

MemcachedJava.java file:

import java.net.InetSocketAddress;
import java.util.concurrent.Future;
import net.spy.memcached.MemcachedClient;

public class MemcachedJava{
    public static void main(String[]args){
        try{
            MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            System.out.println("Connection to server successful.");
            Future fo = mcc.set("", 900, "Free Education");
            System.out.println("set status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            mcc.shutdown();
        }catch(Exception ex){
            System.out.println(ex.getMessage());
        }
    }
}

Executing the program, the output result is:

Connection to server successful.
set status:true
 value in cache - Free Education

add Operation Example

MemcachedJava.java file:

import java.net.InetSocketAddress;
import java.util.concurrent.Future;
import net.spy.memcached.MemcachedClient;

public class MemcachedJava{
    public static void main(String[]args){
        try{
            MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            System.out.println("Connection to server successful.");
            Future fo = mcc.set("", 900, "Free Education");
            System.out.println("set status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            fo = mcc.add("", 900, "memcached");
            System.out.println("add status:" + fo.get());
            fo = mcc.add("", 900, "All Free Compilers");
            System.out.println("add status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            mcc.shutdown();
        }catch(Exception ex){
            System.out.println(ex.getMessage());
        }
    }
}

replace Operation Example

MemcachedJava.java file:

import java.net.InetSocketAddress;
import java.util.concurrent.Future;
import net.spy.memcached.MemcachedClient;

public class MemcachedJava{
    public static void main(String[]args){
        try{
            MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            System.out.println("Connection to server successful.");
            Future fo = mcc.set("", 900, "Free Education");
            System.out.println("add status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            fo = mcc.replace("", 900, "Largest Tutorials' Library");
            System.out.println("replace status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            mcc.shutdown();
        }catch(Exception ex){
            System.out.println(ex.getMessage());
        }
    }
}

append Operation Example

MemcachedJava.java file:

import java.net.InetSocketAddress;
import java.util.concurrent.Future;
import net.spy.memcached.MemcachedClient;

public class MemcachedJava{
    public static void main(String[]args){
        try{
            MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            System.out.println("Connection to server successful.");
            Future fo = mcc.set("", 900, "Free Education");
            System.out.println("set status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            fo = mcc.append("", 900, " for All");
            System.out.println("append status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            mcc.shutdown();
        }catch(Exception ex){
            System.out.println(ex.getMessage());
        }
    }
}

prepend Operation Example

MemcachedJava.java file:

import java.net.InetSocketAddress;
import java.util.concurrent.Future;
import net.spy.memcached.MemcachedClient;

public class MemcachedJava{
    public static void main(String[]args){
        try{
            MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            System.out.println("Connection to server successful.");
            Future fo = mcc.set("", 900, "Education for All");
            System.out.println("set status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            fo = mcc.prepend("", 900, "Free ");
            System.out.println("prepend status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            mcc.shutdown();
        }catch(Exception ex){
            System.out.println(ex.getMessage());
        }
    }
}

CAS Operation Example

MemcachedJava.java file:

import java.net.InetSocketAddress;
import java.util.concurrent.Future;
import net.spy.memcached.CASValue;
import net.spy.memcached.CASResponse;
import net.spy.memcached.MemcachedClient;

public class MemcachedJava{
    public static void main(String[]args){
        try{
            MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            System.out.println("Connection to server successful.");
            Future fo = mcc.set("", 900, "Free Education");
            System.out.println("set status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            CASValue casValue = mcc.gets("");
            System.out.println("CAS token - " + casValue);
            CASResponse casresp = mcc.cas("", casValue.getCas(), 900, "Largest Tutorials-Library");
            System.out.println("CAS Response - " + casresp);
            System.out.println(" value in cache - " + mcc.get(""));
            mcc.shutdown();
        }catch(Exception ex){
            System.out.println(ex.getMessage());
        }
    }
}

get Operation Example

MemcachedJava.java file:

import java.net.InetSocketAddress;
import java.util.concurrent.Future;
import net.spy.memcached.MemcachedClient;

public class MemcachedJava{
    public static void main(String[]args){
        try{
            MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            System.out.println("Connection to server successful.");
            Future fo = mcc.set("", 900, "Free Education");
            System.out.println("set status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            mcc.shutdown();
        }catch(Exception ex){
            System.out.println(ex.getMessage());
        }
    }
}

gets Operation Example, CAS

MemcachedJava.java file:

import java.net.InetSocketAddress;
import java.util.concurrent.Future;
import net.spy.memcached.CASValue;
import net.spy.memcached.CASResponse;
import net.spy.memcached.MemcachedClient;

public class MemcachedJava{
    public static void main(String[]args){
        try{
            MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            System.out.println("Connection to server successful.");
            Future fo = mcc.set("", 900, "Free Education");
            System.out.println("set status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            CASValue casValue = mcc.gets("");
            System.out.println("CAS value in cache - " + casValue);
            mcc.shutdown();
        }catch(Exception ex){
            System.out.println(ex.getMessage());
        }
    }
}

delete Operation Example

MemcachedJava.java file:

import java.net.InetSocketAddress;
import java.util.concurrent.Future;
import net.spy.memcached.MemcachedClient;

public class MemcachedJava{
    public static void main(String[]args){
        try{
            MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            System.out.println("Connection to server successful.");
            Future fo = mcc.set("", 900, "World's largest online tutorials library");
            System.out.println("set status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            fo = mcc.delete("");
            System.out.println("delete status:" + fo.get());
            System.out.println(" value in cache - " + mcc.get(""));
            mcc.shutdown();
        }catch(Exception ex){
            System.out.println(ex.getMessage());
        }
    }
}

Incr/Decr Operation Example

MemcachedJava.java file:

import java.net.InetSocketAddress;
import java.util.concurrent.Future;
import net.spy.memcached.MemcachedClient;

public class MemcachedJava{
    public static void main(String[]args){
        try{
            MemcachedClient mcc = new MemcachedClient(new InetSocketAddress("127.0.0.1", 11211));
            System.out.println("Connection to server successful.");
            Future fo = mcc.set("number", 900, "1000");
            System.out.println("set status:" + fo.get());
            System.out.println("value in cache - " + mcc.get("number"));
            System.out.println("value in cache after increment - " + mcc.incr("number", 111));
            System.out.println("value in cache after decrement - " + mcc.decr("number", 112));
            mcc.shutdown();
        }catch(Exception ex){
            System.out.println(ex.getMessage());
        }
    }
}