membase 服务器到 couchbase 服务器迁移：Java 客户端

Question

我使用 aspymemcached 客户端连接到我的 membase 服务器。 代码如下：

public static MemcachedClient MemcachedClient(String bucketName){
        URI server1 = new URI("http://192.168.100.111:8091/pools");
        URI server2 = new URI("http://127.0.0.1:8091/pools");
        ArrayList<URI> serverList = new ArrayList<URI>();
        serverList.add(server1);
        serverList.add(server2);
        return  new MemcachedClient(serverList, bucketName, "");
}

用于将对象放入缓存：

public static void makeMembaseCacheEntry(final String key, final int expiryTime, final Object value, final String bucketName) {
    MemcachedClient client = getMembaseClient(bucketName);
    if (client != null) {
        client.set(key, expiryTime, value);       
}

从缓存中获取对象：

   public static Object getMembaseCacheEntry(String key) {
        Object value = null;
         try {
            MemcachedClient client = getMembaseClient(bucketName);
            if (client != null) {
                value = client.get(key);
            }
        } catch (Exception e) {
        }
        return value;
}

现在我计划将 membase 服务器升级到 couchbase 服务器，因此我必须使用 couchbase 客户端 java API（参考：http://docs.couchbase.com/developer/java-2.1/java-intro.html）。 在 cousebase 客户端中，所有操作都在 JsonObject ref 上执行：

http://docs.couchbase.com/developer/java-2.0/documents-basics.html

那么如何将以上两种方法迁移到couchbase客户端

Answer 1

如果您存储的是序列化的Object，Java SDK 提供SerializableDocument 类型（请参阅https://developer.couchbase.com/documentation/server/4.6/sdk/java/document-operations.html#story-h2-10）。

它与构建在 spymemcached 之上的 1.x 客户端存储的对象兼容，但它使用标志元数据，我不确定从 Memcached 迁移到 Couchbase 会如何影响这些（因此您可能必须编写一些迁移代码）。

与 Spymemcached 相比，Couchbase SDK 2.x 有一个更接近 Couchbase 集群组织的 API：您开始连接到 Cluster，在其上打开 Bucket，您可以在其上执行 key/像get、update、insert、upsert这样的值操作。

在您的第一个 sn-p 中，您只需要至少一个 couchbase 节点的 IP。从中你会得到一个Cluster（使用CouchbaseCluster.create(...)）。 然后使用cluster.openBucket(bucketName) 打开Bucket。这应该很像：

//TODO make both of these singletons
Cluster cluster = CouchbaseCluster.create("192.168.100.111", "127.0.0.1:8091"); 
Bucket bucket = cluster.openBucket(bucketName, bucketPassword);

注意Cluster 和Bucket 是线程安全的，应该用作单例，而不是像在makeMembaseCacheEntry 和getMembaseCacheEntry 中那样在每次调用时重新打开... p>

为了让你需要包装你的value：

Document doc = SerializableDocument.create(key, expiry, value);
bucket.upsert(doc);

（如果您想创建或替换，请使用upsert，请参阅文档了解其他类型的 kv 操作）

对于获取，您需要告诉存储桶它反序列化一个对象：

SerializableDocument doc = bucket.get(key, SerializableDocument.class);
Object value = doc.content();