Quarkus集成redis操作Redisson实现数据互通_Redis_

io.quarkusquarkus-redis-client

quarkus.redis.hosts=127.0.0.1:6379 quarkus.redis.database=0 quarkus.redis.timeout=10s quarkus.redis.password=sasa

/** * 和Redisson的序列化数据互相反序列化的编解码器 * @author keking */ public class JsonJacksonCodec{ public static final JsonJacksonCodec INSTANCE = new JsonJacksonCodec(); @JsonIdentityInfo(generator=ObjectIdGenerators.IntSequenceGenerator.class, property="@id") @JsonAutoDetect(fieldVisibility = Visibility.ANY, getterVisibility = Visibility.PUBLIC_ONLY, setterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE) public static class ThrowableMixIn { } protected final ObjectMapper mapObjectMapper; public JsonJacksonCodec() { this(new ObjectMapper()); } public JsonJacksonCodec(ObjectMapper mapObjectMapper) { this.mapObjectMapper = mapObjectMapper.copy(); init(this.mapObjectMapper); initTypeInclusion(this.mapObjectMapper); } protected void initTypeInclusion(ObjectMapper mapObjectMapper) { TypeResolverBuilder mapTyper = new DefaultTypeResolverBuilder(DefaultTyping.NON_FINAL) { @Override public boolean useForType(JavaType t) { switch (_appliesFor) { case NON_CONCRETE_AND_ARRAYS: while (t.isArrayType()) { t = t.getContentType(); } // fall through case OBJECT_AND_NON_CONCRETE: return (t.getRawClass() == Object.class) || !t.isConcrete(); case NON_FINAL: while (t.isArrayType()) { t = t.getContentType(); } // to fix problem with wrong long to int conversion if (t.getRawClass() == Long.class) { return true; } if (t.getRawClass() == XMLGregorianCalendar.class) { return false; } return !t.isFinal(); // includes Object.class default: // case JAVA_LANG_OBJECT: return t.getRawClass() == Object.class; } } }; mapTyper.init(JsonTypeInfo.Id.CLASS, null); mapTyper.inclusion(JsonTypeInfo.As.PROPERTY); mapObjectMapper.setDefaultTyping(mapTyper); } protected void init(ObjectMapper objectMapper) { objectMapper.setSerializationInclusion(Include.NON_NULL); objectMapper.setVisibility(objectMapper.getSerializationConfig() .getDefaultVisibilityChecker() .withFieldVisibility(JsonAutoDetect.Visibility.ANY) .withGetterVisibility(JsonAutoDetect.Visibility.NONE) .withSetterVisibility(JsonAutoDetect.Visibility.NONE) .withCreatorVisibility(JsonAutoDetect.Visibility.NONE)); objectMapper.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES); objectMapper.enable(Feature.WRITE_BIGDECIMAL_AS_PLAIN); objectMapper.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS); objectMapper.enable(MapperFeature.SORT_PROPERTIES_ALPHABETICALLY); objectMapper.addMixIn(Throwable.class, ThrowableMixIn.class); } /** * 解码器 * @param val * @return */ public Object decoder(String val){ try { ByteBuf buf = ByteBufAllocator.DEFAULT.buffer(); try (ByteBufOutputStream os = new ByteBufOutputStream(buf)) { os.write(val.getBytes()); } return mapObjectMapper.readValue((InputStream) new ByteBufInputStream(buf), Object.class); } catch (IOException e) { e.printStackTrace(); } return null; } /** * 编码器 * @param obj * @return */ public String encoder(Object obj){ ByteBuf out = ByteBufAllocator.DEFAULT.buffer(); try { ByteBufOutputStream os = new ByteBufOutputStream(out); mapObjectMapper.writeValue((OutputStream) os, obj); return os.buffer().toString(StandardCharsets.UTF_8); } catch (IOException e) { out.release(); } return null; } }

@Dependent @Startup public class Test { @Inject RedisClient redisClient; @Inject Logger logger; void initializeApp(@Observes StartupEvent ev) { //使用JsonJacksonCodec编解码，保持和redisson互通 JsonJacksonCodec codec = JsonJacksonCodec.INSTANCE; Map map = new HashMap<>(); map.put("key","666"); redisClient.set(Arrays.asList("AAAKEY", codec.encoder(map))); String str = redisClient.get("AAAKEY").toString(StandardCharsets.UTF_8); Map getVal = (Map) codec.decoder(str); logger.info(getVal.get("key")); } }