0

我正在使用 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客户端

4

1 回答 1

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：您开始连接到 a Cluster，在其上打开 a Bucket，您可以在其上执行键/值操作，如get、update、insert、upsert。

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

//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);

注意ClusterandBucket是线程安全的，应该作为单例使用，而不是像你在makeMembaseCacheEntryand getMembaseCacheEntry...

对于 make 你需要包装你的value：

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

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

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

SerializableDocument doc = bucket.get(key, SerializableDocument.class);
Object value = doc.content();
于 2017-03-22T10:36:55.820 回答