Redis常用操作

1：redis常用操作：

package com.shunaier.hhhh.biz.utils;import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.shunaier.hhhh.common.enums.SystemErrorEnum;
import com.shunaier.hhhh.common.exception.SNEBizException;
import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.RedisConnectionFailureException;
import org.springframework.data.redis.connection.DataType;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.connection.RedisStringCommands.SetOption;
import org.springframework.data.redis.core.DefaultTypedTuple;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.data.redis.core.types.Expiration;
import org.springframework.data.redis.support.atomic.RedisAtomicLong;
import org.springframework.stereotype.Component;import java.util.*;
import java.util.Map.Entry;
import java.util.concurrent.TimeUnit;@Component
@SuppressWarnings({"hiding", "rawtypes", "unchecked"})
public final class RedisUtils {private static RedisTemplate redisTemplate;private static RedissonClient redissonClient;private static String host;private static String password;private static Integer port;private static int databaseIndex;@Value("${redis.server.host}")public void setHost(String host) {RedisUtils.host = host;}@Value("${redis.server.password}")public void setPassword(String password) {RedisUtils.password = password;}@Value("${redis.server.port}")public void setPort(Integer port) {RedisUtils.port = port;}@Value("${redis.server.database:0}")public void setDatabaseIndex(int databaseIndex) {RedisUtils.databaseIndex = databaseIndex;}//锁private static RedissonClient redissonClient() {if (redissonClient == null) {Config config = new Config();config.useSingleServer().setAddress(String.format("redis://%s:%s", host, port)).setDatabase(databaseIndex).setPassword(password);redissonClient = Redisson.create(config);}return redissonClient;}@Autowiredpublic void setRedisTemplate(RedisTemplate redisTemplate) {RedisUtils.redisTemplate = redisTemplate;}/*** 存入字符串* @param key 键* @param value 值*/public static void set(Object key, Object value) {try {redisTemplate.opsForValue().set(key, value);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 不存在便存入字符串* @param key 键* @param value 值*/public static Boolean setIfAbsent(Object key, Object value) {try {return redisTemplate.opsForValue().setIfAbsent(key, value);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 批量存入字符串* @param map 键-值*/public static void setAll(Map<Object, Object> map) {try {redisTemplate.opsForValue().multiSet(map);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 存入字符串 并 设置过期时间* @param key 键* @param value 值* @param time 时间* @param unit 时间粒度*/public static void setAndTimeout(Object key, Object value, long time, TimeUnit unit) {try {redisTemplate.opsForValue().set(key, value, time, unit);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 不存在便存入字符串 并 设置过期时间* @param key 键* @param value 值* @param time 时间* @param TimeUnit unit 时间粒度*/public static Boolean setIfAbsentAndTimeout(Object key, Object value, long time, TimeUnit unit) {try {return redisTemplate.opsForValue().setIfAbsent(key, value, time, unit);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 批量存入 map* @param map* @return*/public static void setByPipelined(Map<String, String> map) {try {redisTemplate.executePipelined(new RedisCallback<Object>() {@Overridepublic String doInRedis(RedisConnection connection) throws DataAccessException {for (Entry<String, String> entry : map.entrySet()) {connection.set(entry.getKey().getBytes(), entry.getValue().getBytes());}return null;}});} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 批量存入-过期 map* @param map* @return*/public static void setByPipelinedAndTimeout(Map<String, String> map, long time, TimeUnit unit) {try {redisTemplate.executePipelined(new RedisCallback<Object>() {@Overridepublic String doInRedis(RedisConnection connection) throws DataAccessException {for (Entry<String, String> entry : map.entrySet()) {connection.set(entry.getKey().getBytes(), entry.getValue().getBytes(), Expiration.from(time, unit), SetOption.UPSERT);}return null;}});} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取所有的key*/public static Set<Object> keys() {try {return redisTemplate.keys("*");} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 关键字模糊获取所有的key* @param prex*/public static Set<Object> keys(String prex) {try {return redisTemplate.keys("*" + prex + "*");} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 修改key* @param oldKey* @param newKey*/public static void renameKey(Object oldKey, Object newKey) {try {redisTemplate.rename(oldKey, newKey);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 判断key的类型* @param key* @return*/public static String type(String key) {try {DataType dataType = redisTemplate.type(key);return dataType.code();} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取字符串* @param key 键* @return*/public static Object get(Object key) {try {return redisTemplate.opsForValue().get(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 批量获取字符串* @param keys 键* @return*/public static List<Object> multiGet(List<Object> keys) {try {return redisTemplate.opsForValue().multiGet(keys);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 批量获取* @param keys 键* @return*/public static List<Object> getByPipelined(List<Object> keys) {try {return redisTemplate.executePipelined(new RedisCallback<String>() {@Overridepublic String doInRedis(RedisConnection connection) throws DataAccessException {for (int i = 0; i < keys.size(); i++) {connection.get(keys.get(i).toString().getBytes());}return null;}});} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 批量获取 Map* @param key 键* @param hashKeys* @return*/public static List<Object> getMapValuesByPipelined(Object key, List<Object> hashKeys) {try {return redisTemplate.executePipelined(new RedisCallback<String>() {@Overridepublic String doInRedis(RedisConnection connection) throws DataAccessException {for (int i = 0; i < hashKeys.size(); i++) {connection.hGet(key.toString().getBytes(), hashKeys.get(i).toString().getBytes());}return null;}});} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 批量获取 Map* @param key 键* @param hashKeys* @return*/public static Map<Object, Object> getMapByPipelined(Object key, List<Object> hashKeys) {try {Map<Object, Object> result = new HashMap<Object, Object>();List<Object> values = getMapValuesByPipelined(key, hashKeys);if (!values.isEmpty()) {for (int i = 0; i < hashKeys.size(); i++) {result.put(hashKeys.get(i), values.get(i));}}return result;} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取原字符串 并 重新赋值* @param key 键* @param value 新值* @return*/public static Object getAndSet(Object key, Object value) {try {return redisTemplate.opsForValue().getAndSet(key, value);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 在原字符串末尾 追加字符串* @param key 键* @param value 值*/public static void append(Object key, String value) {try {redisTemplate.opsForValue().append(key, value);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 存入对象* @param key 键* @param entity 对象*/public static <T> void setEntity(Object key, T entity) {try {redisTemplate.opsForValue().set(key, JSONObject.toJSONString(entity));} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 存入对象  并 设置过期时间* @param key 键* @param entity 对象* @param time 时间* @param unit 时间粒度*/public static <T> void setEntityAndTimeout(Object key, T value, long time, TimeUnit unit) {try {redisTemplate.opsForValue().set(key, JSONObject.toJSONString(value), time, unit);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 存入对象集合* @param key 键* @param value 集合对象*/public static <T> void setEntityList(Object key, List<T> entityList) {try {redisTemplate.opsForValue().set(key, JSONObject.toJSONString(entityList));} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 存入对象集合 并 设置过期时间* @param key 键* @param entityList 对象集合* @param time 时间* @param unit 时间粒度*/public static <T> void setEntityListAndTimeout(Object key, List<T> entityList, long time, TimeUnit unit) {try {redisTemplate.opsForValue().set(key, JSONObject.toJSONString(entityList), time, unit);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取对象* @param key 键* @return*/public static <T> T getEntity(Object key, Class<T> clz) {try {Object obj = redisTemplate.opsForValue().get(key);if (obj != null) {return jsonToEntity((String) obj, clz);}return null;} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取对象集合* @param key 键* @return*/public static <T> List<T> getEntityList(Object key, Class<T> clz) {try {Object obj = redisTemplate.opsForValue().get(key);if (obj != null) {return jsonToList((String) obj, clz);}return new ArrayList<T>();} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取对象 并 重新赋值* @param key 键* @param newEntity 新对象* @return*/public static <T> T getEntityAndSet(Object key, T newEntity, Class<T> clz) {try {Object obj = redisTemplate.opsForValue().getAndSet(key, JSONObject.toJSONString(newEntity));if (obj != null) {return jsonToEntity((String) obj, clz);}return null;} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取对象集合 并 重新赋值* @param key 键* @param newEntityList 新对象集合* @return*/public static <T> List<T> getEntityListAndSet(Object key, List<T> newEntityList, Class<T> clz) {try {Object obj = redisTemplate.opsForValue().getAndSet(key, JSONObject.toJSONString(newEntityList));if (obj != null) {return jsonToList((String) obj, clz);}return new ArrayList<T>();} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 转换成 实体类对象* @param text JSON字符串* @param clz 对象的类型* @return*/public static <T> T jsonToEntity(String text, Class<T> clz) {try {return JSONArray.parseObject(text, clz);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 转换成 实体类对象集合* @param text JSON字符串* @param clz 对象的类型* @return*/public static <T> List<T> jsonToList(String text, Class<T> clz) {try {return JSONArray.parseArray(text, clz);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 对象 转换成 JSON字符串* @param obj* @return*/public static String toJSONString(Object obj) {try {return JSONArray.toJSONString(obj);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 判断key是否存在* @param key 键* @return*/public static Boolean exist(Object key) {try {return redisTemplate.hasKey(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 移除缓存数据* @param key 键*/public static void delete(Object key) {try {redisTemplate.delete(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 批量移除缓存数据* @param keys 键*/public static void deleteAll(List<Object> keys) {try {redisTemplate.delete(keys);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 存入Map* @param key 键* @param hashKey Map的key* @param value Map的value*/public static void put(Object key, Object hashKey, Object hashValue) {try {redisTemplate.opsForHash().put(key, hashKey, hashValue);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 不存在便存入Map、存在即存入失败* @param key 键* @param hashKey Map的key* @param value Map的value*/public static Boolean putIfAbsent(Object key, Object hashKey, Object hashValue) {try {return redisTemplate.opsForHash().putIfAbsent(key, hashKey, hashValue);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 存入Map* @param key 键* @param map*/public static void putAll(Object key, Map<? extends Object, ? extends Object> map) {try {redisTemplate.opsForHash().putAll(key, map);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 批量存入* @param key* @param map* @return*/public static void putByPipelined(String key, Map<String, String> map) {try {redisTemplate.executePipelined(new RedisCallback<Object>() {@Overridepublic String doInRedis(RedisConnection connection) throws DataAccessException {Map<byte[], byte[]> byteMap = new HashMap<byte[], byte[]>();for (Entry<String, String> entry : map.entrySet()) {byteMap.put(entry.getKey().getBytes(), entry.getValue().getBytes());}connection.hMSet(key.getBytes(), byteMap);return null;}});} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取Map* @param key 键*/public static Map<Object, Object> getMap(Object key) {try {return redisTemplate.opsForHash().entries(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取Map中指定的值* @param key 键* @param hashKey Map的key* @return*/public static Object getMapValue(Object key, Object hashKey) {try {return redisTemplate.opsForHash().get(key, hashKey);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取Map中所有的key* @param key 键* @return*/public static Set<Object> getMapKeys(Object key) {try {return redisTemplate.opsForHash().keys(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取Map中所有的值* @param key 键* @return*/public static List<Object> getMapValues(Object key) {try {return redisTemplate.opsForHash().values(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取Map的长度* @param key 键* @return*/public static long getMapSize(Object key) {try {return redisTemplate.opsForHash().size(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 判断Map中key是否存在* @param key 键* @param hashKey Map的key* @return*/public static Boolean existMapKey(Object key, Object hashKey) {try {return redisTemplate.opsForHash().hasKey(key, hashKey);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 移除Map中指定的key* @param key 键* @param hashKey Map的key* 单个haskKey 或 数组形式*/public static void deleteMapKey(Object key, Object... hashKey) {try {redisTemplate.opsForHash().delete(key, hashKey);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取Map中自增数字* @param key 键* @param hashKey Map的key* @param delta 递增的基数* @return*/public static long getAddNumberForMap(Object key, Object hashKey, long delta) {try {return redisTemplate.opsForHash().increment(key, hashKey, delta);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取自增数字* @param key 键* @param delta 递增的基数* @return*/public static long getAddNumber(String key, long delta) {try {RedisAtomicLong counter = new RedisAtomicLong(key, redisTemplate.getConnectionFactory());return counter.addAndGet(delta);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 向左添加元素* @param key 键* @param value 值*/public static void leftPush(Object key, Object value) {try {redisTemplate.opsForList().leftPush(key, value);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 向左添加元素-集合* @param key 键* @param values 值（集合）*/public static void leftPushAll(Object key, Collection<Object> values) {try {redisTemplate.opsForList().leftPushAll(key, values);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 向右添加元素* @param key 键* @param value 值*/public static void rightPush(Object key, Object value) {try {redisTemplate.opsForList().rightPush(key, value);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 向 pivot 右边添加元素* @param key 键* @param pivot 已存在的值* @param value 值*/public static void rightPush(Object key, Object pivot, Object value) {try {redisTemplate.opsForList().rightPush(key, pivot, value);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 向右添加元素-集合* @param key 键* @param values 值（集合）*/public static void rightPushAll(Object key, Collection<Object> values) {try {redisTemplate.opsForList().rightPushAll(key, values);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 向左弹出元素* @param key 键* @return*/public static Object leftPop(Object key) {try {return redisTemplate.opsForList().leftPop(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 向右弹出元素* @param key 键* @return*/public static Object rightPop(Object key) {try {return redisTemplate.opsForList().rightPop(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 将list中的元素截取，并存为新值* @param key* @param start* @param end -1代表全部* @return*/public static void listTrim(Object key, long start, long end) {try {redisTemplate.opsForList().trim(key, start, end);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取集合长度* @param key 键* @return*/public static long size(Object key) {try {return redisTemplate.opsForList().size(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取集合中指定下标的元素* @param key 键* @param index 下标* @return*/public static Object index(Object key, long index) {try {return redisTemplate.opsForList().index(key, index);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取指定区间的集合元素* @param key* @param start* @param end* @return*/public static List<Object> getList(Object key, long start, long end) {try {return redisTemplate.opsForList().range(key, start, end);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取集合元素* @param key* @return*/public static List<Object> getAllList(Object key) {try {return redisTemplate.opsForList().range(key, 0, -1);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 集合添加指定下表元素* @param key* @param index* @param value*/public static void addToList(Object key, int index, Object value) {try {redisTemplate.opsForList().set(key, index, value);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 删除List中的元素* @param key* @param value*/public static void removeToList(Object key, Object value) {try {redisTemplate.opsForList().remove(key, 0, value);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 锁* @param key* @return*/public static RLock getLock(String key) {return redissonClient().getLock(key);}/* Set *//*** 添加Set元素* @param key* @param value 单个或多个...*/public static void addToSet(Object key, Object value) {try {redisTemplate.opsForSet().add(key, value);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取Set集合* @param key* @return*/public static Set getToSet(Object key) {try {return redisTemplate.opsForSet().members(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 移除Set中的元素* @param key* @param values*/public static void deleteToSet(Object key, Object values) {try {redisTemplate.opsForSet().remove(key, values);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取Set长度* @param key* @return*/public static Long sizeToSet(Object key) {try {return redisTemplate.opsForSet().size(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 添加ZSet元素* @param key* @param value* @param score*/public static void addToZSet(Object key, Object value, double score) {try {redisTemplate.opsForZSet().add(key, value, score);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 添加所有ZSet元素* @param key* @param datas key-score 所有元素*/public static void addToZSetAll(Object key, Map<String, Double> datas) {try {if (datas != null && !datas.isEmpty()) {Set<ZSetOperations.TypedTuple<Object>> tupleDatas = new HashSet<>();for (Entry<String, Double> entry : datas.entrySet()) {ZSetOperations.TypedTuple<Object> item = new DefaultTypedTuple<>(entry.getKey(), entry.getValue());tupleDatas.add(item);}redisTemplate.opsForZSet().add(key, tupleDatas);}} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 合并多个ZSet集合，存入新的集合* @param key 当前集合Key* @param otherKeys 需要合并的即可Keys* @param destKey 合并之后存入的新集合Key*/public static void unionMoreZSet(Object key, Collection<Object> otherKeys, Object destKey) {try {redisTemplate.opsForZSet().unionAndStore(key, otherKeys, destKey);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取多个ZSet集合的交集，存入新的集合* @param key 当前集合Key* @param otherKeys 需要合并的即可Keys* @param destKey 合并之后存入的新集合Key*/public static void intersectMoreZSet(Object key, Collection<Object> otherKeys, Object destKey) {try {redisTemplate.opsForZSet().intersectAndStore(key, otherKeys, destKey);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取ZSet长度* @param key*/public static Long sizeToZSet(Object key) {try {return redisTemplate.opsForZSet().size(key);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取指定区间ZSet集合元素(可用作分页查询)* @param key* @param start* @param end -1代表全部* @return*/public static Set<Object> getSubZSet(Object key, long start, long end) {try {return redisTemplate.opsForZSet().range(key, start, end);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 倒序获取指定区间ZSet集合元素(可用作分页查询)* @param key* @param start* @param end -1代表全部* @return*/public static Set<Object> getSubZSetDesc(Object key, long start, long end) {try {return redisTemplate.opsForZSet().reverseRange(key, start, end);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取ZSet集合元素* @param key* @return*/public static Set<Object> getAllZSet(Object key) {try {return redisTemplate.opsForZSet().range(key, 0, -1);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取指定分值区间的ZSet集合元素* @param key* @param min* @param max* @return*/public static Set<Object> getRangeScoreToZSet(Object key, double min, double max) {try {return redisTemplate.opsForZSet().rangeByScore(key, min, max);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 获取ZSet集合元素的Score* @param key* @param eo 元素* @return*/public static double getZSetItemScore(Object key, Object eo) {try {return redisTemplate.opsForZSet().score(key, eo);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 移除ZSet集合元素* @param key* @return*/public static void removeToZSet(Object key, Object values) {try {redisTemplate.opsForZSet().remove(key, values);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}/*** 设置key过期时间* @param key* @return*/public static void setTimeOut(Object key, long timeout, TimeUnit unit) {try {redisTemplate.expire(key, timeout, unit);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}//#################################################################################//#################################################################################//##################                    Redis简易版消息队列                                          ##################//#################################################################################//#################################################################################/*** 生成消息* @param channel 频道* @param message 消息对象*/public static void convertAndSend(String channel, Object message) {try {redisTemplate.convertAndSend(channel, message);} catch (Exception e) {e.printStackTrace();if (e instanceof RedisConnectionFailureException) {throw new SNEBizException(SystemErrorEnum.REDIS_NOT_CONNECTION);} else {throw new SNEBizException(SystemErrorEnum.REDIS_CACHE_ERROR);}}}public static Long increment(String key, Long incr) {return redisTemplate.opsForValue().increment(key, incr);}}

2：redis分布式锁

package com.oceania.b2b.framework.redis.service;import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RFuture;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.stereotype.Component;import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Supplier;/*** Redisson 分布式锁工具类（增强版）** ✅ 支持 Runnable / Supplier 模板执行* ✅ 支持重入标识（当前线程多次加锁）* ✅ 支持重试机制（自动尝试获取锁）* ✅ 支持异步锁（异步执行任务）*/
@Slf4j
@Component
public class RedissonDistributedLocker {private final RedissonClient redissonClient;// 当前线程内已持有的锁 key -> count（用于记录当前线程内是否已经持有某个锁（以及重入次数））private final ThreadLocal<Map<String, AtomicInteger>> reentrantLockHolder =ThreadLocal.withInitial(ConcurrentHashMap::new);public RedissonDistributedLocker(RedissonClient redissonClient) {this.redissonClient = redissonClient;}// ------------------ 基础方法 ------------------/*** 尝试获取锁（等待 + 自动释放）*  1：如果当前线程已持有该锁，则只是递增计数*  2：否则调用 Redisson 的 tryLock()。*  3：如果获取成功，记录锁信息。*/public boolean tryLock(String key, long waitTime, long leaseTime, TimeUnit unit) {try {if (isReentrant(key)) {incrementReentrant(key);// 支持重入return true;}RLock lock = redissonClient.getLock(key);boolean locked = lock.tryLock(waitTime, leaseTime, unit); // 尝试获取锁if (locked) {incrementReentrant(key);// 成功则计入当前线程}return locked;} catch (InterruptedException e) {Thread.currentThread().interrupt();log.warn("线程中断，获取锁失败，key={}", key, e);return false;}}/*** 阻塞加锁（自动释放）* 同样支持重入。* 若当前线程未持有，则调用 Redisson 的 lock() 方法（阻塞直到成功）。*/public void lock(String key, long leaseTime, TimeUnit unit) {if (isReentrant(key)) {incrementReentrant(key);return;}RLock lock = redissonClient.getLock(key);lock.lock(leaseTime, unit);incrementReentrant(key);}/*** 解锁* 检查当前线程是否持有该锁（通过 ThreadLocal）* 递减锁引用计数，只有降为 0 时才真正执行 unlock()*/public void unlock(String key) {if (!isReentrant(key)) {return;}decrementOrRemove(key);if (!isReentrant(key)) {RLock lock = redissonClient.getLock(key);if (lock.isHeldByCurrentThread()) {lock.unlock();}}}/*** 解锁（传入 RLock）* 提供更底层的 RLock 解锁接口，用于异步锁释放时调用。*/public void unlock(RLock lock) {if (lock != null && lock.isHeldByCurrentThread()) {lock.unlock();}}// ------------------ 可重入支持 ------------------/*** 当前线程是否持有 key 对应的锁* @param key* @return*/private boolean isReentrant(String key) {return reentrantLockHolder.get().containsKey(key);}/*** 加锁时计数 +1* @param key*/private void incrementReentrant(String key) {reentrantLockHolder.get().computeIfAbsent(key, k -> new AtomicInteger(0)).incrementAndGet();}/***  解锁时计数 -1，归零后移除（释放锁）* @param key*/private void decrementOrRemove(String key) {Map<String, AtomicInteger> map = reentrantLockHolder.get();AtomicInteger counter = map.get(key);if (counter != null) {if (counter.decrementAndGet() <= 0) {map.remove(key);}}if (map.isEmpty()) {reentrantLockHolder.remove();}}// ------------------ 执行模板（同步） ------------------/*** 封装：加锁 + 执行 + 解锁* 避免业务层忘记释放锁，提升代码安全性* @param key* @param leaseTime* @param unit* @param task*/public void lock(String key, long leaseTime, TimeUnit unit, Runnable task) {lock(key, leaseTime, unit);try {task.run();} finally {unlock(key);}}/*** 加锁执行有返回值的逻辑，适合用于 ID 生成、缓存初始化等* @param key* @param leaseTime* @param unit* @param task* @return* @param <T>*/public <T> T lockAndReturn(String key, long leaseTime, TimeUnit unit, Supplier<T> task) {lock(key, leaseTime, unit);try {return task.get();} finally {unlock(key);}}// ------------------ 支持重试机制 ------------------public boolean tryLockWithRetry(String key, long leaseTime, long totalWaitTime, long retryInterval, TimeUnit unit) {long deadline = System.currentTimeMillis() + unit.toMillis(totalWaitTime);while (System.currentTimeMillis() < deadline) {if (tryLock(key, 0, leaseTime, unit)) {return true;}try {Thread.sleep(unit.toMillis(retryInterval));} catch (InterruptedException e) {Thread.currentThread().interrupt();break;}}return false;}/*** 若初次未获取锁，可自动等待重试* 常用于不想立刻失败的场景，如资源初始化、消息消费* @param key* @param leaseTime* @param totalWaitTime* @param retryInterval* @param unit* @return*/public void tryLockWithRetry(String key, long leaseTime, long totalWaitTime, long retryInterval, TimeUnit unit, Runnable task) {boolean locked = tryLockWithRetry(key, leaseTime, totalWaitTime, retryInterval, unit);if (!locked) {throw new RuntimeException("无法获取锁: " + key);}try {task.run();} finally {unlock(key);}}// ------------------ 异步锁支持 ------------------/*** Redisson 的异步锁封装* 用于异步任务执行时保护共享资源（非阻塞）* @param key* @param leaseTime* @param unit* @param task* @return*/public CompletableFuture<Void> lockAsync(String key, long leaseTime, TimeUnit unit, Runnable task) {RLock lock = redissonClient.getLock(key);RFuture<Void> future = lock.lockAsync(leaseTime, unit);return future.toCompletableFuture().thenRunAsync(() -> {try {task.run();} finally {unlock(lock);}});}public <T> CompletableFuture<T> lockAsync(String key, long leaseTime, TimeUnit unit, Supplier<T> supplier) {RLock lock = redissonClient.getLock(key);RFuture<Void> future = lock.lockAsync(leaseTime, unit);return future.toCompletableFuture().thenApplyAsync(ignored -> {try {return supplier.get();} finally {unlock(lock);}});}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若转载，请注明出处：http://www.pswp.cn/bicheng/87671.shtml
繁体地址，请注明出处：http://hk.pswp.cn/bicheng/87671.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

mybatis-plus-01-环境初始化及简单应用

mybatis-plus-01-环境初始化及简单应用

文章目录 【README】【1】springboot集成mybatis-plus配置【1.1】目录结构【相关说明】 【1.2】代码示例【pom.xml】【application.properties】【MybatisPlusNoteController】【UserAppService】【UserMapper】【UserPO】【建表语句】 【2】演示 【README】 本文代码参见&…
阅读更多...
VR小鼠解剖虚拟仿真：开启生命科学教育新视野​

VR小鼠解剖虚拟仿真：开启生命科学教育新视野​

VR 小鼠解剖虚拟仿真&#xff0c;是一项将虚拟现实(VR)技术深度融入小鼠解剖学习与研究过程的创新应用&#xff0c;即 VR 小鼠解剖虚拟仿真。其核心原理在于&#xff0c;借助 VR 技术所构建的高度逼真的虚拟环境&#xff0c;突破了传统小鼠解剖在时间、空间以及实体操作上的诸多…
阅读更多...
计算机网络（网页显示过程，TCP三次握手，HTTP1.0，1.1，2.0，3.0，JWT cookie）

计算机网络（网页显示过程，TCP三次握手，HTTP1.0，1.1，2.0，3.0，JWT cookie）

前言 最近一直在后端开发的面经&#x1f64c;&#xff0c;里面涉及到了好多计算机网络的知识&#x1f601;&#xff0c;在这里以问题的形式写一个学习笔记&#xff08;其中参考了: JavaGuide 和 小林coding 这两个很好的学习网站&#x1f618;&#xff09; 1.当键入网址后&am…
阅读更多...
Redis 消息的发布和订阅

Redis 消息的发布和订阅

Redis 消息的发布和订阅 1、什么是发布和订阅 Redis 发布订阅 (pub/sub) 是一种消息通信模式&#xff1a;发送者 (pub) 发送消息&#xff0c;订阅者 (sub) 接收消息。 Redis 客户端可以订阅任意数量的频道。 2、Redis的发布和订阅示意 1、客户端可以订阅频道如下图 2、当…
阅读更多...
python优先队列使用

python优先队列使用

heapq 是 Python 的一个内置模块&#xff0c;提供了堆队列算法的实现&#xff0c;也称为优先队列算法。以下是关于 heapq 模块的详细使用说明。 基本概念 堆&#xff1a;一种特殊的二叉树结构&#xff0c;满足父节点总是小于或等于其子节点&#xff08;最小堆&#xff09;特性…
阅读更多...
在 Windows 机器上安装和配置 RabbitMQ

在 Windows 机器上安装和配置 RabbitMQ

RabbitMQ 它是一款基于 AMQP&#xff08;高级消息队列协议&#xff09;的流行消息代理。RabbitMQ 适用于 Windows、Linux 和 macOS&#xff0c;易于安装和使用&#xff0c;并提供一系列强大的消息队列和路由功能。要在 Windows 计算机上使用 RabbitMQ&#xff0c;您必须先安装 …
阅读更多...
第十五节：第六部分：日志技术：logback的核心配置文件详解、日志级别

第十五节：第六部分：日志技术：logback的核心配置文件详解、日志级别

核心配置文件logback.xml 什么是日志级别&#xff0c;为什么要学日志级别
阅读更多...
从入门到精通：数据库全攻略

从入门到精通：数据库全攻略

目录一、数据库基础概念1.1 数据库定义1.2 数据库与文件系统的区别1.3 数据库系统组成部分1.4 关系型数据库与非关系型数据库二、数据库安装与配置2.1 下载 MySQL2.2 安装 MySQL2.3 初始化数据库服务器2.4 启动和停止 MySQL 服务2.5 登录 MySQL2.6 创建数据库2.7 创建数据表三、…
阅读更多...
【JAVA】消息队列（MQ）是个好东西

【JAVA】消息队列（MQ）是个好东西

一、前言再JAVA系统开发中&#xff0c;再高并发的场景经常需要使用到消息队列&#xff0c;有时候是不得不使用到消息对了。特别是大数据量的并发处理。对数据实时性要求又没那么高的情况下。用户请求 → 接入层(Nginx) → 限流 → 消息队列 → 订单服务 → 库存服务 → 支付服务…
阅读更多...
【Golang面试题】Go结构体的特点，与其它语言的区别

【Golang面试题】Go结构体的特点，与其它语言的区别

Go 结构体深度解析&#xff1a;与 C/C、Java 的全面对比 一、核心概念对比特性Go 结构体 (struct)C/C 结构体 (struct)Java 类 (class)本质值类型复合数据类型值类型复合数据类型引用类型内存分配栈或堆 (编译器决定)栈 (显式控制)堆 (JVM管理)默认访问权限首字母大写导出publi…
阅读更多...
CppCon 2018 学习:OOP is dead, long live Data-oriented design

CppCon 2018 学习:OOP is dead, long live Data-oriented design

探讨了面向对象编程&#xff08;OOP&#xff09;的一些根本性问题深入理解&#xff1a; 标题&#xff1a;What is so wrong with OOP? 什么是面向对象的问题&#xff1f; 这不是说 OOP “绝对错误”&#xff0c;而是指出它在实践中经常引发的问题&#xff0c;尤其是在性能敏…
阅读更多...
科学的第五范式：人工智能如何重塑发现之疆

科学的第五范式：人工智能如何重塑发现之疆

在人类探索未知的壮阔史诗中&#xff0c;科学方法的演进如同照亮迷雾的灯塔。从基于经验的第一范式&#xff08;描述自然现象&#xff09;&#xff0c;到以理论推演为核心的第二范式&#xff08;牛顿定律、麦克斯韦方程&#xff09;&#xff0c;再到以计算机模拟为标志的第三范…
阅读更多...
tmux 左下角会话名显示不全的解决方法

tmux 左下角会话名显示不全的解决方法

在 tmux 中显示完整的会话名 有时候我们要在服务器上长时间跑某个任务&#xff0c;但不可能时时刻刻保持终端模拟器开启&#xff0c;这时候就需要用到 tmux &#xff0c;可以在关闭会话的同时让任务继续在后台跑&#xff0c;后续还可以连回来。但在 tmux 会话中&#xff0c;左…
阅读更多...
【期末分布式】分布式的期末考试资料大题整理

【期末分布式】分布式的期末考试资料大题整理

&#x1f9f8;安清h&#xff1a;个人主页 &#x1f3a5;个人专栏&#xff1a;【Spring篇】【计算机网络】【Mybatis篇】 &#x1f3af;大题 ✨一.Nacos的服务注册与发现 &#x1f6a6;1.怎么来进行服务的注册与发现的这样的一个流程&#xff0c;描述一下。 &#x1f383;描述…
阅读更多...
Android手机无网离线使用FunASR识别麦克风语音内容

Android手机无网离线使用FunASR识别麦克风语音内容

手机断网离线使用FunASR识别麦克风语音内容 --本地AI电话机器人 上一篇&#xff1a;阿里FunASR本地断网离线识别模型简析 下一篇&#xff1a;手机无网离线使用FunASR识别手机历史通话录音 一、前言 继上一篇《阿里FunASR本地断网离线识别模型简析》和前面几篇ASR相关理论的…
阅读更多...
Stable Diffusion 项目实战落地：从0到1 掌握ControlNet 第五篇 线稿到高清修复：一步步教你用AI做出完美IP形象

Stable Diffusion 项目实战落地：从0到1 掌握ControlNet 第五篇 线稿到高清修复：一步步教你用AI做出完美IP形象

大家好！上一篇，我们一起玩转了字体风格变换 ，让文字根据提示词进行自如变换，个性十足又充满创意! 如果你错过了那篇文章，别担心，赶紧点这里补课：Stable Diffusion 项目实战落地：从0到1 掌握ControlNet 第四篇 风格化字体大揭秘：从线稿到涂鸦，ControlNet让文字焕发新生…
阅读更多...
Java网络编程：TCP/UDP套接字通信详解

Java网络编程：TCP/UDP套接字通信详解

TCP客户端套接字创建与使用 Socket类基础概念 Socket类的对象代表TCP客户端套接字&#xff0c;用于与TCP服务器套接字进行通信。与服务器端通过accept()方法获取Socket对象不同&#xff0c;客户端需要主动执行三个关键步骤&#xff1a;创建套接字、绑定地址和建立连接。 客户端…
阅读更多...
VMware vSphere 9与ESXi 9正式发布：云原生与AI驱动的虚拟化平台革新

VMware vSphere 9与ESXi 9正式发布：云原生与AI驱动的虚拟化平台革新

2025年6月18日&#xff0c;VMware正式推出其旗舰虚拟化平台vSphere 9及配套的ESXi 9操作系统&#xff0c;标志着企业级虚拟化技术迈入以云原生、人工智能&#xff08;AI&#xff09;和硬件加速为核心的新纪元。此次更新不仅在功能层面实现突破&#xff0c;更通过授权模式革新为…
阅读更多...
汽车功能安全概念阶段开发【相关项定义HARA】2

汽车功能安全概念阶段开发【相关项定义HARA】2

文章目录 1 浅谈概念阶段开发2 功能安全概念阶段开发2.1 相关项定义2.2 危害分析与风险评估&#xff08;HARA-Hazard Analysis and Risk Assessment&#xff09; 3 关键输出与对后续阶段的影响4 总结 1 浅谈概念阶段开发 概念阶段开发是整个研发流程的起点和基石。它发生在任何…
阅读更多...
WPF中依赖属性和附加属性

WPF中依赖属性和附加属性

依赖属性&#xff08;DependencyProperty&#xff09; 依赖属性是WPF中的一种特殊属性&#xff0c;它的实现依赖于DependencyObject类提供的基础设施。与普通的.NET属性不同&#xff0c;依赖属性的值可以通过多种方式确定&#xff0c;包括继承、样式、数据绑定和动画等。 主要特…
阅读更多...
最新文章

Copyright @ 2022~2023