copy from websocketClient/src/main/java/org/example/util/RedisUtil.java
copy to websocketSerivce/src/main/java/org/example/util/RedisUtil.java
| File was copied from websocketClient/src/main/java/org/example/util/RedisUtil.java |
| | |
| | | package org.example.util; |
| | | |
| | | import redis.clients.jedis.*; |
| | | import redis.clients.jedis.Jedis; |
| | | import redis.clients.jedis.JedisPool; |
| | | import redis.clients.jedis.JedisPoolConfig; |
| | | import redis.clients.jedis.Protocol; |
| | | |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.Set; |
| | | |
| | | public class RedisUtil { |
| | | private static JedisPool jedisPool; |
| | | |
| | | static { |
| | | jedisPool = new JedisPool(new JedisPoolConfig(), "localhost", 6379); |
| | | jedisPool = new JedisPool(new JedisPoolConfig(), "localhost", 6379, Protocol.DEFAULT_TIMEOUT, null, 0); |
| | | } |
| | | |
| | | // 私有构造方法,防止实例化 |
| | |
| | | } |
| | | } |
| | | |
| | | public static Set<String> keys(String key) { |
| | | try (Jedis jedis = jedisPool.getResource()) { |
| | | return jedis.keys("*"+key+"*"); |
| | | } |
| | | } |
| | | |
| | | public static void hset(String key, String field, String value) { |
| | | try (Jedis jedis = jedisPool.getResource()) { |
| | | jedis.hset(key, field, value); |