org.springframework.data.redis.connection.RedisConnection.stringCommands()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(4.8k)|赞(0)|评价(0)|浏览(149)

本文整理了Java中org.springframework.data.redis.connection.RedisConnection.stringCommands方法的一些代码示例,展示了RedisConnection.stringCommands的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RedisConnection.stringCommands方法的具体详情如下:
包路径:org.springframework.data.redis.connection.RedisConnection
类名称:RedisConnection
方法名:stringCommands

RedisConnection.stringCommands介绍

[英]Get RedisStringCommands.
[中]获取重新字符串命令。

代码示例

代码示例来源:origin: lord-of-code/loc-framework

@PostMapping(value = "/setRedis")
public Problem setRedis() {
 redisConnectionFactory.getConnection().stringCommands()
   .set("key".getBytes(), "value".getBytes());
 stringRedisTemplate.opsForValue().set("stringKey", "stringValue");
 return Problem.builder().with("data", "success").build();
}

代码示例来源:origin: lord-of-code/loc-framework

@GetMapping(value = "/getRedis")
public Problem getRedis() {
 redisConnectionFactory.getConnection().getNativeConnection();
 byte[] bytes = redisConnectionFactory.getConnection().stringCommands().get("key".getBytes());
 if (bytes != null) {
  String value = new String(bytes, StandardCharsets.UTF_8);
  String stringValue = stringRedisTemplate.opsForValue().get("stringKey");
  return Problem.builder().with("data", value + "_" + stringValue).build();
 } else {
  return Problem.valueOf(Status.BAD_REQUEST);
 }
}

代码示例来源:origin: keets2012/Auth-service

@Override
public void storeRefreshToken(OAuth2RefreshToken refreshToken, OAuth2Authentication authentication) {
  byte[] refreshKey = serializeKey(REFRESH + refreshToken.getValue());
  byte[] refreshAuthKey = serializeKey(REFRESH_AUTH + refreshToken.getValue());
  byte[] serializedRefreshToken = serialize(refreshToken);
  RedisConnection conn = getConnection();
  try {
    conn.openPipeline();
    conn.stringCommands().set(refreshKey, serializedRefreshToken);
    conn.stringCommands().set(refreshAuthKey, serialize(authentication));
    if (refreshToken instanceof ExpiringOAuth2RefreshToken) {
      ExpiringOAuth2RefreshToken expiringRefreshToken = (ExpiringOAuth2RefreshToken) refreshToken;
      Date expiration = expiringRefreshToken.getExpiration();
      if (expiration != null) {
        int seconds = Long.valueOf((expiration.getTime() - System.currentTimeMillis()) / 1000L)
            .intValue();
        conn.expire(refreshKey, seconds);
        conn.expire(refreshAuthKey, seconds);
      }
    }
    conn.closePipeline();
  } finally {
    conn.close();
  }
}

代码示例来源:origin: fangchunzao/SpringSecurityOauth2

@Override
public void storeRefreshToken(OAuth2RefreshToken refreshToken, OAuth2Authentication authentication) {
  byte[] refreshKey = serializeKey(REFRESH + refreshToken.getValue());
  byte[] refreshAuthKey = serializeKey(REFRESH_AUTH + refreshToken.getValue());
  byte[] serializedRefreshToken = serialize(refreshToken);
  RedisConnection conn = getConnection();
  try {
    conn.openPipeline();
    conn.stringCommands().set(refreshKey, serializedRefreshToken);
    conn.stringCommands().set(refreshAuthKey, serialize(authentication));
    if (refreshToken instanceof ExpiringOAuth2RefreshToken) {
      ExpiringOAuth2RefreshToken expiringRefreshToken = (ExpiringOAuth2RefreshToken) refreshToken;
      Date expiration = expiringRefreshToken.getExpiration();
      if (expiration != null) {
        int seconds = Long.valueOf((expiration.getTime() - System.currentTimeMillis()) / 1000L)
            .intValue();
        conn.expire(refreshKey, seconds);
        conn.expire(refreshAuthKey, seconds);
      }
    }
    conn.closePipeline();
  } finally {
    conn.close();
  }
}

代码示例来源:origin: keets2012/Auth-service

try {
  conn.openPipeline();
  conn.stringCommands().set(accessKey, serializedAccessToken);
  conn.stringCommands().set(authKey, serializedAuth);
  conn.stringCommands().set(authToAccessKey, serializedAccessToken);
  if (!authentication.isClientOnly()) {
    conn.rPush(approvalKey, serializedAccessToken);
    byte[] auth = serialize(token.getValue());
    byte[] refreshToAccessKey = serializeKey(REFRESH_TO_ACCESS + token.getRefreshToken().getValue());
    conn.stringCommands().set(refreshToAccessKey, auth);
    byte[] accessToRefreshKey = serializeKey(ACCESS_TO_REFRESH + token.getValue());
    conn.stringCommands().set(accessToRefreshKey, refresh);
    if (refreshToken instanceof ExpiringOAuth2RefreshToken) {
      ExpiringOAuth2RefreshToken expiringRefreshToken = (ExpiringOAuth2RefreshToken) refreshToken;

代码示例来源:origin: fangchunzao/SpringSecurityOauth2

try {
  conn.openPipeline();
  conn.stringCommands().set(accessKey, serializedAccessToken);
  conn.stringCommands().set(authKey, serializedAuth);
  conn.stringCommands().set(authToAccessKey, serializedAccessToken);
  if (!authentication.isClientOnly()) {
    conn.rPush(approvalKey, serializedAccessToken);
    byte[] auth = serialize(token.getValue());
    byte[] refreshToAccessKey = serializeKey(REFRESH_TO_ACCESS + token.getRefreshToken().getValue());
    conn.stringCommands().set(refreshToAccessKey, auth);
    byte[] accessToRefreshKey = serializeKey(ACCESS_TO_REFRESH + token.getValue());
    conn.stringCommands().set(accessToRefreshKey, refresh);
    if (refreshToken instanceof ExpiringOAuth2RefreshToken) {
      ExpiringOAuth2RefreshToken expiringRefreshToken = (ExpiringOAuth2RefreshToken) refreshToken;

相关文章

微信公众号

最新文章

更多

RedisConnection类方法