Uso del cliente de ElastiCache clúster para Java

El programa siguiente muestra cómo usar el cliente de ElastiCache clúster para conectarse a un punto final de configuración de clúster y agregar un elemento de datos a la caché. Con la función Auto Discovery, el programa se conectará a todos los nodos del clúster sin necesidad de ninguna intervención adicional.

package com.amazon.elasticache;

import java.io.IOException;
import java.net.InetSocketAddress;

// Import the &AWS;-provided library with Auto Discovery support 
import net.spy.memcached.MemcachedClient;  

public class AutoDiscoveryDemo {

    public static void main(String[] args) throws IOException {
            
        String configEndpoint = "mycluster.fnjyzo.cfg.use1.cache.amazonaws.com";
        Integer clusterPort = 11211;

        MemcachedClient client = new MemcachedClient(
                                 new InetSocketAddress(configEndpoint, 
                                                       clusterPort));       
        // The client will connect to the other cache nodes automatically.

        // Store a data item for an hour.  
        // The client will decide which cache host will store this item. 
        client.set("theKey", 3600, "This is the data value");
    }
}

ElastiCache Las cachés sin servidor siempre tienen activado el cifrado en tránsito (TLS). También puede habilitar el TLS en clústeres basados en nodos. Para conectarse a una TLS-enabled caché, configure el cliente con un SSLContext como se muestra en el siguiente ejemplo.

nota

El setSSLContext método solo está disponible en la AWS bifurcación del spymemcached cliente. Para ver la fuente, consulte aws-elasticache-cluster-client-memcached-for-java en el GitHub sitio web. Este método no forma parte de la spymemcached biblioteca estándar de código abierto.

import java.security.KeyStore;
import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManagerFactory;
import net.spy.memcached.AddrUtil;
import net.spy.memcached.ConnectionFactoryBuilder;
import net.spy.memcached.MemcachedClient;
public class TLSDemo {
    public static void main(String[] args) throws Exception {
        ConnectionFactoryBuilder connectionFactoryBuilder = new ConnectionFactoryBuilder();
        // Build SSLContext
        TrustManagerFactory tmf = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
        tmf.init((KeyStore) null);
        SSLContext sslContext = SSLContext.getInstance("TLS");
        sslContext.init(null, tmf.getTrustManagers(), null);
        // Create the client in TLS mode
        connectionFactoryBuilder.setSSLContext(sslContext);
        MemcachedClient client = new MemcachedClient(connectionFactoryBuilder.build(), AddrUtil.getAddresses("mycluster.fnjyzo.cfg.use1.cache.amazonaws.com:11211"));

        // Store a data item for an hour.
        client.set("theKey", 3600, "This is the data value");
    }
}

Para obtener más información sobre la conexión con TLS, consulte. Creación de un cliente TLS Memcached mediante Java Para una caché sin servidor, utilice el punto final sin servidor de la caché en el puerto 11211. El punto final sin servidor no contiene «.cfg» en la dirección. Para un clúster basado en nodos con TLS habilitado, utilice el punto final de configuración que contiene «.cfg».