求指导：如何使用Java开发Couchbase缓存应用？附示例链接需求

Hey there! 作为常年在Java项目里集成Couchbase做缓存的开发者，我给你梳理下靠谱的开发方向，附上实用的代码示例供你参考：

首先得引入Couchbase的Java SDK，如果你用Maven，直接在pom.xml里加这段依赖：

<dependency>
    <groupId>com.couchbase.client</groupId>
    <artifactId>java-client</artifactId>
    <version>3.4.10</version> <!-- 建议用官方最新稳定版 -->
</dependency>

Gradle项目的话，在build.gradle里添加：

implementation 'com.couchbase.client:java-client:3.4.10'

1. 建立集群连接 #

连接是性能关键，推荐用单例模式管理Cluster实例，避免频繁创建销毁连接：

import com.couchbase.client.java.Cluster;
import com.couchbase.client.java.env.ClusterEnvironment;

public class CouchbaseCacheManager {
    private static Cluster cluster;

    public static void initCluster() {
        ClusterEnvironment env = ClusterEnvironment.builder()
                .bootstrapHttpDirectPort(8091)
                .bootstrapCarrierDirectPort(11210)
                .build();

        cluster = Cluster.connect("localhost", "your-username", "your-password", env);
    }

    public static Cluster getCluster() {
        if (cluster == null) {
            initCluster();
        }
        return cluster;
    }
}

2. 缓存的基本读写操作 #

Couchbase新版推荐用Collection操作数据（替代旧版直接操作Bucket），这里给你写个完整的读写删示例：

import com.couchbase.client.java.Bucket;
import com.couchbase.client.java.Collection;
import com.couchbase.client.java.json.JsonObject;
import com.couchbase.client.java.kv.GetResult;
import com.couchbase.client.java.kv.UpsertOptions;
import java.time.Duration;

public class CacheOperations {
    public static void main(String[] args) {
        // 获取目标Bucket和默认Collection
        Bucket cacheBucket = CouchbaseCacheManager.getCluster().bucket("my-cache-bucket");
        Collection defaultCollection = cacheBucket.defaultCollection();

        // 写入缓存：设置键、值，以及1小时的过期时间
        JsonObject userCache = JsonObject.create()
                .put("userId", 1001)
                .put("username", "avi_dev")
                .put("email", "avi@example.com");
        
        defaultCollection.upsert("user:1001", userCache, UpsertOptions.upsertOptions().expiry(Duration.ofHours(1)));

        // 读取缓存
        GetResult cachedResult = defaultCollection.get("user:1001");
        if (cachedResult != null) {
            JsonObject cachedUser = cachedResult.contentAsObject();
            System.out.println("读取到缓存用户：" + cachedUser.getString("username"));
        }

        // 删除缓存
        defaultCollection.remove("user:1001");
    }
}

• 连接管理：必须用单例维护Cluster实例，每次操作新建连接会直接拖垮性能
• 过期策略：给所有缓存键设置合理的TTL（过期时间），避免无效缓存堆积占用存储空间
• 异常处理：封装缓存操作时一定要捕获CouchbaseException，处理连接超时、键不存在等场景
• 批量操作：有大量读写需求时，用bulkUpsert、bulkGet这类批量API，减少网络往返开销
• 查询优化：如果需要通过非key字段查询缓存，提前创建N1QL索引，比如：

  cluster.query("CREATE PRIMARY INDEX ON `my-cache-bucket`");
  

  之后就可以用N1QL灵活查询缓存数据：

  cluster.query("SELECT * FROM `my-cache-bucket` WHERE username = 'avi_dev'")
          .rowsAsObject()
          .forEach(row -> System.out.println(row));
  

内容的提问来源于stack exchange，提问作者Avi