快捷導(dǎo)航

springboot整合couchbase集群的步驟

更新時(shí)間：2025年03月31日 11:29:24 作者：風(fēng)也溫柔

couchbase是一款開源的,分布式的nosql數(shù)據(jù)庫(kù),主要用于分布式緩存和數(shù)據(jù)存儲(chǔ)領(lǐng)域,本文給大家介紹springboot整合couchbase集群的步驟,感興趣的朋友一起看看吧

1、Couchbase

1.1、介紹

1.2、Bucket

在 Couchbase 中，bucket 是一個(gè)重要的概念，類似于傳統(tǒng)數(shù)據(jù)庫(kù)中的數(shù)據(jù)庫(kù)或表。它是 Couchbase 存儲(chǔ)數(shù)據(jù)的基本單位，主要用于組織和管理數(shù)據(jù)。

Bucket 是 Couchbase 中存儲(chǔ)文檔的容器。每個(gè) bucket 可以包含多個(gè)文檔，文檔可以是 JSON 格式的數(shù)據(jù)。

1.3、Couchbase SDK

Couchbase SDK（Software Development Kit）是一個(gè)用于與 Couchbase數(shù)據(jù)庫(kù)進(jìn)行交互的開發(fā)工具包。
它提供了一組 API 和工具，允許開發(fā)者通過(guò)編程語(yǔ)言（如 Java、Python 等）與Couchbase數(shù)據(jù)庫(kù)進(jìn)行連接、數(shù)據(jù)操作、查詢、集群管理等操作。

2、(key,value)寫入couchbase集群

2.1、總體圖

2.2、依賴

couchbase服務(wù)器的版本是4.0

 <dependency>
            <groupId>com.fasterxml.jackson.datatype</groupId>
            <artifactId>jackson-datatype-jsr310</artifactId>
            <version>2.13.0</version> 
        </dependency>
        <dependency>
            <groupId>com.couchbase.client</groupId>
            <artifactId>java-client</artifactId>
            <version>2.7.23</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-couchbase</artifactId>
            <version>4.2.0</version> 
</dependency>

2.3、CouchbaseConfig 配置文件

package com.baafs.amtiot.couchbase;
import com.baafs.amtiot.Models.VehiclePosition;
import com.couchbase.client.java.Bucket;
import com.couchbase.client.java.CouchbaseCluster;
import com.couchbase.client.java.document.JsonDocument;
import com.couchbase.client.java.document.json.JsonObject;
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
import com.fasterxml.jackson.databind.ObjectMapper;
public class CouchbaseUtils {
    private static final ObjectMapper objectMapper = new ObjectMapper()
            .registerModule(new JavaTimeModule());
    public static void couchbaseVehiclePosition(String vmeid, VehiclePosition vehiclePosition) {
        // 創(chuàng)建 cluster
// 連接 couchbase集群
  //<couchbase> C#中couchbase集群配置文件，免密碼登錄
        // 重點(diǎn) =====   ip:端口:池   buckets
  //   <servers>
  //     <add uri="http://192.168.23.37:8091/pools" />
  //     <add uri="http://192.168.23.38:8091/pools" />
  //   </servers>
  //   <buckets>
  //     <add name="default" useSsl="false">
  //     </add>
  //   </buckets>
  //</couchbase>
// 1、自動(dòng)選擇端口(池)：CouchbaseCluster.create() 會(huì)自動(dòng)使用 8091 端口與集群進(jìn)行通信，不需要顯式指定端口號(hào)或 pools
///2、集群發(fā)現(xiàn)和負(fù)載均衡：Couchbase SDK 會(huì)自動(dòng)進(jìn)行集群拓?fù)浒l(fā)現(xiàn)并且會(huì)自動(dòng)負(fù)載均衡。
        CouchbaseCluster cluster = CouchbaseCluster.create("192.168.23.37,192.168.23.38");
        // 連接 bucket 并打開
        Bucket bucket = cluster.openBucket("default");
        System.out.println("Connected to bucket: " + bucket.name());
        try {
            // 將 VehiclePosition 對(duì)象轉(zhuǎn)換為 JSON
            JsonObject content = JsonObject.fromJson(objectMapper.writeValueAsString(vehiclePosition));
            JsonDocument inserted = bucket.upsert(JsonDocument.create(vmeid, content));
            // 確認(rèn)插入成功,獲取一下
            System.out.println("Document inserted with ID: " + inserted.id());
            // content
            JsonDocument found = bucket.get("SA21009005");
            System.out.println("Couchbase is the best database in the " + found.content().toString());
        } catch (Exception e) {
            System.out.println("Error processing vehicle position: " + e.getMessage());
        } finally {
            cluster.disconnect();
        }
    }
}