add sasl connection support

Support Binary Protocol SASL Connection

add three properties
org.mybatis.caches.memcached.sasl=[true|false]
org.mybatis.caches.memcached.username=[username]
org.mybatis.caches.memcached.password=[password]

Author: guodong000

src/main/java/org/mybatis/caches/memcached/MemcachedClientWrapper.java

@@ -21,8 +21,11 @@
 import java.util.Set;
 import java.util.concurrent.Future;
 
+import net.spy.memcached.ConnectionFactoryBuilder;
 import net.spy.memcached.MemcachedClient;
 
+import net.spy.memcached.auth.AuthDescriptor;
+import net.spy.memcached.auth.PlainCallbackHandler;
 import org.apache.ibatis.cache.CacheException;
 import org.apache.ibatis.logging.Log;
 import org.apache.ibatis.logging.LogFactory;
@@ -44,7 +47,14 @@ final class MemcachedClientWrapper {
     public MemcachedClientWrapper() {
         configuration = MemcachedConfigurationBuilder.getInstance().parseConfiguration();
         try {
-            client = new MemcachedClient(configuration.getConnectionFactory(), configuration.getAddresses());
+            if (configuration.isUsingSASL()) {
+                AuthDescriptor ad = new AuthDescriptor(new String[]{"PLAIN"}, new PlainCallbackHandler(configuration.getUsername(), configuration.getPassword()));
+                client = new MemcachedClient(new ConnectionFactoryBuilder()
+                        .setProtocol(ConnectionFactoryBuilder.Protocol.BINARY)
+                        .setAuthDescriptor(ad).build(), configuration.getAddresses());
+            } else {
+                client = new MemcachedClient(configuration.getConnectionFactory(), configuration.getAddresses());
+            }
         } catch (IOException e) {
             String message = "Impossible to instantiate a new memecached client instance, see nested exceptions";
             log.error(message, e);

src/main/java/org/mybatis/caches/memcached/MemcachedConfiguration.java

@@ -71,6 +71,21 @@ final class MemcachedConfiguration {
      */
     private TimeUnit timeUnit;
 
+    /**
+     * The flag to enable SASL Connection
+     */
+    private boolean usingSASL;
+
+    /**
+     * The Memcached SASL username
+     */
+    private String username;
+
+    /**
+     * The Memcached SASL password
+     */
+    private String password;
+
     /**
      * @return the keyPrefix
      */
@@ -183,12 +198,42 @@ public void setTimeUnit(TimeUnit timeUnit) {
         this.timeUnit = timeUnit;
     }
 
+    /**
+     * @return the usingSASL
+     */
+    public boolean isUsingSASL() { return usingSASL; }
+
+    /**
+     * @param usingSASL the usingSASL to set
+     */
+    public void setUsingSASL(boolean usingSASL) { this.usingSASL = usingSASL; }
+
+    /**
+     * @return the username
+     */
+    public String getUsername() { return username; }
+
+    /**
+     * @param username the username to set
+     */
+    public void setUsername(String username) { this.username = username; }
+
+    /**
+     * @return the password
+     */
+    public String getPassword() { return password; }
+
+    /**
+     * @param password the password to set
+     */
+    public void setPassword(String password) { this.password = password; }
+
     /**
      * {@inheritDoc}
      */
     @Override
     public int hashCode() {
-        return hash(1, 31, addresses, compressionEnabled, connectionFactory, expiration, keyPrefix, timeUnit, timeout, usingAsyncGet);
+        return hash(1, 31, addresses, compressionEnabled, connectionFactory, expiration, keyPrefix, timeUnit, timeout, usingAsyncGet, usingSASL, username, password);
     }
 
     /**
@@ -227,7 +272,10 @@ && eq(expiration, other.expiration)
             && eq(keyPrefix, other.keyPrefix)
             && eq(timeUnit, other.timeUnit)
             && eq(timeout, other.timeout)
-            && eq(usingAsyncGet, other.usingAsyncGet);
+            && eq(usingAsyncGet, other.usingAsyncGet)
+            && eq(usingSASL, other.usingSASL)
+            && eq(username, other.username)
+            && eq(password, other.password);
     }
 
     /**
@@ -246,8 +294,8 @@ private static <O> boolean eq( O o1, O o2 ) {
      */
     @Override
     public String toString() {
-        return format( "MemcachedConfiguration [addresses=%s, compressionEnabled=%s, connectionFactory=%s, , expiration=%s, keyPrefix=%s, timeUnit=%s, timeout=%s, usingAsyncGet=%s]",
-                       addresses, compressionEnabled, connectionFactory, expiration, keyPrefix, timeUnit, timeout, usingAsyncGet );
+        return format( "MemcachedConfiguration [addresses=%s, compressionEnabled=%s, connectionFactory=%s, , expiration=%s, keyPrefix=%s, timeUnit=%s, timeout=%s, usingAsyncGet=%s, usingSASL=%s, username=%s, password=%s]",
+                       addresses, compressionEnabled, connectionFactory, expiration, keyPrefix, timeUnit, timeout, usingAsyncGet, usingSASL, username, password );
     }
 
 }

src/main/java/org/mybatis/caches/memcached/MemcachedConfigurationBuilder.java

@@ -63,13 +63,16 @@ private MemcachedConfigurationBuilder() {
         memcachedPropertiesFilename = System.getProperty(SYSTEM_PROPERTY_MEMCACHED_PROPERTIES_FILENAME, MEMCACHED_RESOURCE);
 
         settersRegistry.add(new StringPropertySetter("org.mybatis.caches.memcached.keyprefix", "keyPrefix", "_mybatis_"));
+        settersRegistry.add(new StringPropertySetter("org.mybatis.caches.memcached.username", "username", ""));
+        settersRegistry.add(new StringPropertySetter("org.mybatis.caches.memcached.password", "password", ""));
 
         settersRegistry.add(new IntegerPropertySetter("org.mybatis.caches.memcached.expiration", "expiration", 60 * 60 * 24 * 30));
         settersRegistry.add(new IntegerPropertySetter("org.mybatis.caches.memcached.timeout", "timeout", 5));
         settersRegistry.add(new TimeUnitSetter());
 
         settersRegistry.add(new BooleanPropertySetter("org.mybatis.caches.memcached.asyncget", "usingAsyncGet", false));
         settersRegistry.add(new BooleanPropertySetter("org.mybatis.caches.memcached.compression", "compressionEnabled", false));
+        settersRegistry.add(new BooleanPropertySetter("org.mybatis.caches.memcached.sasl", "usingSASL", true));
 
         settersRegistry.add(new InetSocketAddressListPropertySetter());
         settersRegistry.add(new ConnectionFactorySetter());