2. 程式人生 > 程式設計 >springboot接入cachecloud redis示例實踐

springboot接入cachecloud redis示例實踐

阿新 • • 發佈：2020-01-07

最近專案中需要接入 Redis CacheCloud，CacheCloud是一個開源的 Redis 運維監控雲平臺，功能十分強大，支援Redis 例項自動部署、擴容、碎片管理、統計、監控等功能， 特別是支援單機、sentinel 、cluster三種模式的自動部署，搭建redis叢集一步到位輕鬆搞定。

java專案中 接入 CacheCloud redis的方式主要有兩種。

第一種就是在 CacheCloud 上建立好redis例項後將對應的IP，埠直接配置以配置形式應用到專案中，優點是通用性好，原有專案改造成本低，不過萬一後期CacheCloud上對redis進行管理擴容，那隻能手動把每個專案的redis配置都改一遍了。

第二種CacheCloud 上建立好例項後有一個對應的appId,程式呼叫CacheCloud 平臺的rest介面通過 appId獲取redis相關配置，將程式中的redis配置 統一交給CacheCloud平臺去管理維護，後期管理和擴容及其方便，不過程式改造成本比較高。

現在採用第二種方式接入，工程採用springboot，redis採用哨兵模式，redis客戶端主要用spring-data-redis和redisson,接入流程如下:

新增配置到pom.xml檔案

  <!--cachecloud 相關jar包-->
    <dependency>
      <groupId>com.sohu.tv</groupId>
      <artifactId>cachecloud-open-client-redis</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
 
    <dependency>
      <groupId>com.sohu.tv</groupId>
      <artifactId>cachecloud-open-client-basic</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
 
    <dependency>
      <groupId>com.sohu.tv</groupId>
      <artifactId>cachecloud-open-common</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
  
  <!--spring redis 和 redisson-->
     <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-redis</artifactId>
      <exclusions>
        <exclusion>
          <artifactId>jedis</artifactId>
          <groupId>redis.clients</groupId>
        </exclusion>
      </exclusions>
    </dependency>
    <dependency>
      <groupId>org.redisson</groupId>
      <artifactId>redisson</artifactId>
      <version>3.9.0</version>
    </dependency>

準備配置檔案 cacheCloudClient.properties，啟動專案時 VM引數追加 -Dcachecloud.config= 配置檔案路徑

http_conn_timeout = 3000
http_socket_timeout = 5000
client_version = 1.0-SNAPSHOT
domain_url = http://192.168.33.221:8585  #cachecloud實際路徑
redis_cluster_suffix = /cache/client/redis/cluster/%s.json?clientVersion=
redis_sentinel_suffix = /cache/client/redis/sentinel/%s.json?clientVersion=
redis_standalone_suffix = /cache/client/redis/standalone/%s.json?clientVersion=
cachecloud_report_url = /cachecloud/client/reportData.json

基本思路是先通過cachecloud的restapi介面獲取並解析redis節點的配置資訊，然後就可以按照傳統的訪問redis的方式進行初始化，獲取RedisTemplate物件。

java程式碼如下:

import com.alibaba.fastjson.JSONObject;
import com.sohu.tv.cachecloud.client.basic.heartbeat.ClientStatusEnum;
import com.sohu.tv.cachecloud.client.basic.util.ConstUtils;
import com.sohu.tv.cachecloud.client.basic.util.HttpUtils;
import com.sohu.tv.cachecloud.client.jedis.stat.ClientDataCollectReportExecutor;
import lombok.Getter;
import lombok.Setter;
import org.apache.commons.lang3.tuple.Pair;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
 
import javax.annotation.PostConstruct;
import java.util.HashSet;
import java.util.Random;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
 
@Component
public class RedisProperties {
 
  public static Logger logger = LoggerFactory.getLogger(RedisProperties.class);
 
  /**
   * 構建鎖
   */
  private static final Lock LOCK = new ReentrantLock();
 
  @Value("${cacheCloud.appId}") //cahcecloud 開通redis例項 應用id
  private Integer appId;
 
  @Getter
  @Setter
  private String masterName;
 
  @Getter
  @Setter
  private Set<Pair<String,String>> sentinelSet = new HashSet<>();
 
  private Boolean clientStatIsOpen=true;
 
  @Getter
  @Setter
  private String password;
 
  private Boolean getConfigSuccess = false;
 
  @PostConstruct
  public void init() {
 
    while (true) {
      try {
        LOCK.tryLock(10,TimeUnit.MILLISECONDS);
        if (!getConfigSuccess) {
          /**
           * http請求返回的結果是空的；
           */
          String response = HttpUtils.doGet(String.format(ConstUtils.REDIS_SENTINEL_URL,appId));
          if (response == null || response.isEmpty()) {
            logger.warn("get response from remote server error,appId: {},continue...",appId);
            continue;
          }
 
          /**
           * http請求返回的結果是無效的；
           */
          JSONObject jsonObject = null;
          try {
            jsonObject = JSONObject.parseObject(response);
          } catch (Exception e) {
            logger.error("heartbeat error,appId: {}. continue...",appId,e);
          }
          if (jsonObject == null) {
            logger.error("get sentinel info for appId: {} error. continue...",appId);
            continue;
          }
          int status = jsonObject.getIntValue("status");
          String message = jsonObject.getString("message");
 
          /** 檢查客戶端版本 **/
          if (status == ClientStatusEnum.ERROR.getStatus()) {
            throw new IllegalStateException(message);
          } else if (status == ClientStatusEnum.WARN.getStatus()) {
            logger.warn(message);
          } else {
            logger.info(message);
          }
 
          /**
           * 有效的請求：取出masterName和sentinels；
           */
          masterName = jsonObject.getString("masterName");
          String sentinels = jsonObject.getString("sentinels");
          for (String sentinelStr : sentinels.split(" ")) {
            String[] sentinelArr = sentinelStr.split(":");
            if (sentinelArr.length == 2) {
              sentinelSet.add(Pair.of(sentinelArr[0],sentinelArr[1]));
            }
          }
 
          //收集上報資料
          if (clientStatIsOpen) {
            ClientDataCollectReportExecutor.getInstance();
          }
          password = jsonObject.getString("password");
          getConfigSuccess = true;
          return;
        }
      } catch (Throwable e) {//容錯
        logger.error("error in build,appId: {}",e);
      } finally {
        LOCK.unlock();
      }
      try {
        TimeUnit.MILLISECONDS.sleep(200 + new Random().nextInt(1000));//活鎖
      } catch (InterruptedException e) {
        logger.error(e.getMessage(),e);
      }
    }
  }
}
import com.shunwang.buss.dispatchPay.provider.config.PropertiesUtil;
import org.apache.commons.lang3.StringUtils;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.config.ReadMode;
import org.redisson.config.SentinelServersConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisNode;
import org.springframework.data.redis.connection.RedisSentinelConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import redis.clients.jedis.JedisPoolConfig;
 
import java.net.UnknownHostException;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
 
import static java.util.stream.Collectors.toList;
 
 
@Configuration
public class RedisConfig {
 
  /**
   * JedisPoolConfig 連線池
   */
  @Bean
  public JedisPoolConfig jedisPoolConfig(RedisProperties properties) {
    JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
    // 最大空閒數
    jedisPoolConfig.setMaxIdle(20);
    // 連線池的最大資料庫連線數
    jedisPoolConfig.setMaxTotal(20);
    // 最大建立連線等待時間
    jedisPoolConfig.setMaxWaitMillis(3000);
    return jedisPoolConfig;
  }
 
  /**
   * 配置redis的哨兵
   */
  @Bean
  public RedisSentinelConfiguration sentinelConfiguration(RedisProperties properties) {
    RedisSentinelConfiguration redisSentinelConfiguration = new RedisSentinelConfiguration();
    // 配置redis的哨兵sentinel
    Set<RedisNode> redisNodeSet = properties.getSentinelSet().stream()
        .map(pair -> new RedisNode(pair.getLeft(),Integer.parseInt(pair.getRight())))
        .collect(Collectors.toSet());
    redisSentinelConfiguration.setSentinels(redisNodeSet);
    redisSentinelConfiguration.setMaster(properties.getMasterName());
    return redisSentinelConfiguration;
  }
 
  /**
   * 配置工廠
   */
  @Bean
  public RedisConnectionFactory jedisConnectionFactory(JedisPoolConfig jedisPoolConfig,RedisSentinelConfiguration sentinelConfig) {
    JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(sentinelConfig,jedisPoolConfig);
    return jedisConnectionFactory;
  }
 
 
  @Bean
  public RedisTemplate<Object,Object> redisTemplate(RedisConnectionFactory redisConnectionFactory)
      throws UnknownHostException {
    RedisTemplate template = new RedisTemplate();
    template.setConnectionFactory(redisConnectionFactory);
    FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class);
    // 設定值（value）的序列化採用FastJsonRedisSerializer。
    template.setValueSerializer(fastJsonRedisSerializer);
    template.setHashValueSerializer(fastJsonRedisSerializer);
    // 設定鍵（key）的序列化採用StringRedisSerializer。
    template.setKeySerializer(new StringRedisSerializer());
    template.setHashKeySerializer(new StringRedisSerializer());
    template.afterPropertiesSet();
    return template;
  }
 
  /**
   * Redisson 配置
   */
  @Bean
  public RedissonClient redissonClient(RedisProperties properties) {
    Config config = new Config();
    List<String> newNodes = properties.getSentinelSet().stream()
        .map(pa -> "redis://" + pa.getLeft() + ":" + pa.getRight()).collect(toList());
    SentinelServersConfig serverConfig = config.useSentinelServers()
        .addSentinelAddress(newNodes.toArray(new String[newNodes.size()]))
        .setMasterName(properties.getMasterName())
        .setReadMode(ReadMode.SLAVE);
 
    if (StringUtils.isNotBlank(properties.getPassword())){
      serverConfig.setPassword(properties.getPassword());
    }
    return Redisson.create(config);
  }
}

到這裡我們已經在Spring中 生成了RedisTemplate 和RedissonClient 物件，無論是基本資料結構操作 還是分散式鎖 都已經輕鬆支援了，具體使用就不展開了

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。

相關推薦

springboot接入cachecloud redis示例實踐

最近專案中需要接入 Redis CacheCloud，CacheCloud是一個開源的 Redis 運維監控雲平臺，功能十分強大，支援Redis 例項自動部署、擴容、碎片管理、統計、監控等功能， 特別是支援單機、sentinel 、cluster三種模式的自

SpringBoot接入JaCoCo實踐教程

靜態接入和動態接入 SpingBoot可以通過2種方式接入JaCoCo：Maven和Agent。Maven方式是靜態接入，在編譯時計算程式碼覆蓋率。Agent方式是動態接入，服務啟起來以後，能實時根據程式碼命中情況計算程式碼覆蓋率。

springboot 接入redis作為快取

1.pom <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-redis</artifactId>

Springboot如何操作redis資料

StringRedisTemplate與RedisTemplate區別點 兩者的關係是StringRedisTemplate繼承RedisTemplate。

Vue專案接入Paypal實現示例詳解

一、支付流程 在paypal的官網上給出了這個按鈕內部封裝的流程，整個流程只需要使用者點選按鈕，觸發建立訂單事件，然後我們再監聽使用者支付成功的回撥，拿到訂單id傳給後端，讓後端再進行一次校驗。

springboot 監聽redis過期

redis.conf配置檔案設定 notify-keyspace-events Ex預設notify-keyspace-events \"\" pom.xml: <?xml version=\"1.0\" encoding=\"UTF-8\"?>

springboot專案連線Redis操作

基於快取的資料庫儲存，C語言開發，支援網路、可基於記憶體亦可持久化的日誌型、Key-Value資料庫，並提供多種語言的API，操作很是舒服，我們先來跑通Redis服務，並連上springboot專案

SpringBoot 整合 JMSTemplate的示例程式碼

1.1 新增依賴   可以手動在 SpringBoot 專案新增依賴，也可以在專案建立時選擇使用 ActiveMQ 5 自動新增依賴。高版本 SpringBoot (2.0 以上) 在新增 activemq 連線池依賴啟動時會報 Error creating bean

SpringBoot(三)——整合redis

springboot2.3.2+redis5.0.9 1.依賴包 <dependency> <groupId>org.springframework.boot</groupId>

SpringBoot中使用Redis的完整例項

一.在SpringBoot中使用Redis的一套軍體拳 1.導包 <dependency> <groupId>org.springframework.boot</groupId>

多個SpringBoot專案採用redis實現Session共享功能

有時我們可能有多個不同的Web應用，可以相互呼叫，這時如果每個應用都有自己的session，那使用者跳轉到另一個應用時就又需要登陸一次，這樣會帶來很不好的體驗，因此我們需要在不同的應用中共享session。這裡，我們採

專案總結68：Springboot整合動態資料來源示例

專案總結68：Springboot整合動態資料來源示例 START 程式碼示例 　　POM檔案 <dependency>

四、Spring 框架中接入單機Redis的兩種方式

1、Redis的簡單介紹1）Redis 是一個開源（BSD許可）的，記憶體中的資料結構儲存系統，它可以用作資料庫、快取和訊息中介軟體。 它支援多種型別的資料結構，如 字串（strings）， 雜湊（hashes）， 列表（lists）， 集

SpringBoot中使用redis做分散式鎖的方法

一.模擬問題 最近在公司遇到一個問題,掛號系統是做的叢集,比如啟動了兩個相同的服務,病人掛號的時候可能會出現同號的情況,比如兩個病人掛出來的號都是上午2號.這就出現了問題,由於是叢集部署的,所以單純在程式碼中的

記錄springboot 接入飛鵝雲印表機

使用RestTemplate請求 一直賬號有誤，後來請求頭加入APPLICATION_FORM_URLENCODED 才能訪問成功

IDEA SpringBoot+JPA+MySql+Redis秒殺系統

先放上github地址：[spike-system](https://github.com/ghdefe/spike-system)，可以直接下載完整專案執行測試

SpringBoot專案整合Retrofit最佳實踐，這才是最優雅的HTTP客戶端工具！

大家都知道okhttp是一款由square公司開源的java版本http客戶端工具。實際上，square公司還開源了基於okhttp進一步封裝的retrofit工具，用來支援通過介面的方式發起http請求。

SpringBoot如何整合redis實現過期key監聽事件

可以用於簡單的過期訂單取消支付、7天自動收貨場景中 1、Spring Boot整合redis 參考

SpringBoot-07-整合Redis

3、SpringBoot整合Redis 3.1、自動配置類，RedisAutoConfiguration @Configuration(proxyBeanMethods = false)@ConditionalOnClass(RedisOperations.class)@EnableConfigurationProperties(RedisProperties.class)@I

Spring框架接入單機Redis兩種實現方式解析

1、Redis的簡單介紹 1）Redis 是一個開源（BSD許可）的，記憶體中的資料結構儲存系統，它可以用作資料庫、快取和訊息中介軟體。 它支援多種型別的資料結構，如 字串（strings）， 雜湊（hashes）， 列表（lists），