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

RedisConnection.incr介绍

暂无

代码示例

代码示例来源：origin: spring-projects/spring-data-redis

@Override
public Long incr(byte[] key) {
  return convertAndReturn(delegate.incr(key), identityConverter);
}

代码示例来源：origin: spring-projects/spring-data-redis

@Override
public Long increment(K key) {
  byte[] rawKey = rawKey(key);
  return execute(connection -> connection.incr(rawKey), true);
}

代码示例来源：origin: zhangxd1989/springboot-dubbox

/**
 * 对某个主键对应的值加一,value值必须是全数字的字符串
 *
 * @param key the key
 * @return the long
 */
public long incr(final String key) {
  return redisTemplate.execute((RedisCallback<Long>) connection -> {
    RedisSerializer<String> redisSerializer = getRedisSerializer();
    return connection.incr(redisSerializer.serialize(key));
  });
}

代码示例来源：origin: 1991wangliang/tx-lcn

@Override
public Long incr(byte[] key) {
  return redisConnection.incr(key);
}

代码示例来源：origin: souyunku/SpringBootExamples

/**
 * @param key
 * @return
 * @Description: 根据key增长 ，计数器
 * @author clg
 * @date 2016年6月30日 下午2:37:52
 */
public static long incr(String key) {
  return cacheUtils.redisTemplate.execute((RedisCallback<Long>) connection -> {
    return connection.incr(key.getBytes());
  });
}

代码示例来源：origin: souyunku/SpringBootExamples

/**
 * 取得序列值的下一个
 *
 * @param key
 * @return
 */
public static Long getSeqNext(String key) {
  return cacheUtils.redisTemplate.execute((RedisCallback<Long>) connection -> {
    return connection.incr(key.getBytes());
  });
}

代码示例来源：origin: org.springframework.data/spring-data-redis

@Override
public Long incr(byte[] key) {
  return convertAndReturn(delegate.incr(key), identityConverter);
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public Long incr(byte[] key) {
  return convertAndReturn(delegate.incr(key), identityConverter);
}

代码示例来源：origin: org.springframework.data/spring-data-redis

@Override
public Long increment(K key) {
  byte[] rawKey = rawKey(key);
  return execute(connection -> connection.incr(rawKey), true);
}

代码示例来源：origin: sofn/app-engine

public long incrCount(TimeUnit time, Calendar calendar, String params) {
  String key = RATE_KEY_PREFIX + StringUtils.substring(time.name(), 0, 1).toLowerCase() + "_" + getCurrentTimeNum(calendar, time) + "_" + params;
  Long result = redis.execute((RedisConnection redisConnection) -> {
    return redisConnection.incr(key.getBytes());
  });
  if (result != null && result <= 2) {
    redis.expire(key, time.toSeconds(1) + 10, TimeUnit.SECONDS);
  }
  return result != null ? result : 0;
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public Long increment(K key) {
  byte[] rawKey = rawKey(key);
  return execute(connection -> connection.incr(rawKey), true);
}

代码示例来源：origin: luyunfeng/soulcoder

public Object doInRedis(RedisConnection connection) {
    byte[] paramBytes = stringRedisTemplate.getStringSerializer().serialize(paramStringTmp);
    connection.incr(paramBytes);
    return null;
  }
}, true);

代码示例来源：origin: org.hsweb/hsweb-web-concurrent-cache

@Override
public ValueWrapper get(Object key) {
  String localCacheKey = "cache-".concat(String.valueOf(key));
  ValueWrapper localCache = ThreadLocalUtils.get(localCacheKey);
  if (localCache != null) {
    return localCache;
  }
  ValueWrapper wrapper = super.get(key);
  redisOperations.execute((RedisCallback) connection -> {
    connection.incr(totalTimeKey);
    if (wrapper != null) {
      connection.incr(hitTimeKey);
    }
    return null;
  });
  if (wrapper != null) {
    ThreadLocalUtils.put(localCacheKey, wrapper);
  }
  return wrapper;
}

代码示例来源：origin: org.hsweb/hsweb-web-concurrent-cache

@Override
public <T> T get(Object key, Class<T> type) {
  String localCacheKey = "cache-".concat(String.valueOf(key));
  T localCache = ThreadLocalUtils.get(localCacheKey);
  if (localCache != null) {
    return localCache;
  }
  T v = super.get(key, type);
  redisOperations.execute((RedisCallback) connection -> {
    connection.incr(totalTimeKey);
    if (v != null) {
      connection.incr(hitTimeKey);
    }
    return null;
  });
  if (v != null) {
    ThreadLocalUtils.put(localCacheKey, v);
  }
  return v;
}

代码示例来源：origin: com.y3tu/y3tu-tool-web

/**
 * 对某个主键对应的值加一,value值必须是全数字的字符串
 *
 * @param key the key
 * @return the long
 */
public long incr(final String key) {
  return redisTemplate.execute((RedisCallback<Long>) connection -> {
    RedisSerializer<String> redisSerializer = getRedisSerializer();
    return connection.incr(redisSerializer.serialize(key));
  });
}

代码示例来源：origin: liuht777/Taroco

/**
 * 对某个主键对应的值加一,value值必须是全数字的字符串
 *
 * @param key the key
 * @return the long
 */
public long incr(final String key) {
  return redisTemplate.execute((RedisCallback<Long>) connection -> {
    RedisSerializer<String> redisSerializer = getRedisSerializer();
    return connection.incr(redisSerializer.serialize(key));
  });
}

代码示例来源：origin: org.hsweb/hsweb-web-concurrent-cache

@Override
public void put(Object key, Object value) {
  super.put(key, value);
  redisOperations.execute((RedisCallback) connection -> {
    connection.multi();
    connection.incr(putTimeKey);
    connection.sAdd(keySetKey, ((String) key).getBytes());
    if (expiration != 0) connection.expire(keySetKey, expiration);
    connection.exec();
    return null;
  });
}