redisson實(shí)現(xiàn)序列化的方法

這篇文章運(yùn)用簡(jiǎn)單易懂的例子給大家介紹redisson實(shí)現(xiàn)序列化的方法，代碼非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。

Redisson

是架設(shè)在Redis基礎(chǔ)上的一個(gè)Java駐內(nèi)存數(shù)據(jù)網(wǎng)格(In-Memory Data Grid)。

Redisson在基于NIO的Netty框架上，充分的利用了Redis鍵值數(shù)據(jù)庫(kù)提供的一系列優(yōu)勢(shì)，在Java實(shí)用工具包中常用接口的基礎(chǔ)上，為使用者提供了一系列具有分布式特性的常用工具類(lèi)。使得原本作為協(xié)調(diào)單機(jī)多線程并發(fā)程序的工具包獲得了協(xié)調(diào)分布式多機(jī)多線程并發(fā)系統(tǒng)的能力，大大降低了設(shè)計(jì)和研發(fā)大規(guī)模分布式系統(tǒng)的難度。同時(shí)結(jié)合各富特色的分布式服務(wù)，更進(jìn)一步簡(jiǎn)化了分布式環(huán)境中程序相互之間的協(xié)作。

兼容 Redis 2.6+ and JDK 1.6+，使用Apache License 2.0授權(quán)協(xié)議，閱讀 wiki 來(lái)獲取更多使用信息

序列化

Redisson的對(duì)象編碼類(lèi)是用于將對(duì)象進(jìn)行序列化和反序列化，以實(shí)現(xiàn)對(duì)該對(duì)象在Redis里的讀取和存儲(chǔ)。

由Redisson默認(rèn)的編碼器為JsonJacksonCodec，JsonJackson在序列化有雙向引用的對(duì)象時(shí)，會(huì)出現(xiàn)無(wú)限循環(huán)異常。而fastjson在檢查出雙向引用后會(huì)自動(dòng)用引用符$ref替換，終止循環(huán)。

在我的情況中，我序列化了一個(gè)service，這個(gè)service已被spring托管，而且和另一個(gè)service之間也相互注入了，用fastjson能 正常序列化到redis，而JsonJackson則拋出無(wú)限循環(huán)異常。

為了序列化后的內(nèi)容可見(jiàn)，所以不用redission其他自帶的二進(jìn)制編碼器，自行實(shí)現(xiàn)編碼器：

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializerFeature;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufAllocator;
import io.netty.buffer.ByteBufInputStream;
import io.netty.buffer.ByteBufOutputStream;
import org.redisson.client.codec.BaseCodec;
import org.redisson.client.protocol.Decoder;
import org.redisson.client.protocol.Encoder;

import java.io.IOException;

public class FastjsonCodec extends BaseCodec {

 private final Encoder encoder = in -> {
 ByteBuf out = ByteBufAllocator.DEFAULT.buffer();
 try {
 ByteBufOutputStream os = new ByteBufOutputStream(out);
 JSON.writeJSONString(os, in,SerializerFeature.WriteClassName);
 return os.buffer();
 } catch (IOException e) {
 out.release();
 throw e;
 } catch (Exception e) {
 out.release();
 throw new IOException(e);
 }
 };

 private final Decoder<Object> decoder = (buf, state) ->
 JSON.parseObject(new ByteBufInputStream(buf), Object.class);

 @Override
 public Decoder<Object> getValueDecoder() {
 return decoder;
 }

 @Override
 public Encoder getValueEncoder() {
 return encoder;
 }
}

關(guān)于redisson實(shí)現(xiàn)序列化的方法就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。