程序包 | 说明 |
---|---|
com.fr.cluster.message | |
com.fr.config | |
com.fr.register | |
com.fr.rpc.serialization | |
com.fr.serialization |
Created by juhaoyu on 2017/10/30.
|
com.fr.store |
状态存储功能上层接口
|
com.fr.store.impl | |
com.fr.store.impl.redis | |
com.fr.workspace.engine |
限定符和类型 | 方法和说明 |
---|---|
ClusterConnectionFactory.Builder<Request,Response> |
ClusterConnectionFactory.Builder.setRequestSerializer(Serializer<Request> serializer)
设置请求的序列化器,默认为SerializerSummary.getDefault()
|
ClusterConnectionFactory.Builder<Request,Response> |
ClusterConnectionFactory.Builder.setResponseSerializer(Serializer<Response> serializer)
设置响应的序列化器,默认为SerializerSummary.getDefault()
|
限定符和类型 | 类和说明 |
---|---|
class |
ConfigSerializer
Configuration序列化与反序列化,只需传递类名
|
class |
UniqueKeySerializer
uniqueKey序列化与反序列化
|
限定符和类型 | 类和说明 |
---|---|
class |
XMLableSerializer
Created by juhaoyu on 2018/6/12.
|
限定符和类型 | 类和说明 |
---|---|
class |
InvocationSerializer
Created by juhaoyu on 2017/12/18.
|
class |
ResultSerializer
Created by juhaoyu on 2017/12/18.
|
构造器和说明 |
---|
InvocationSerializer(Serializer<java.lang.Object> paramSerializer)
自定义参数序列化器
|
ResultSerializer(Serializer<java.lang.Object> returnSerializer)
自定义参数序列化器
|
限定符和类型 | 接口和说明 |
---|---|
interface |
CommonSerializer<T>
Created by juhaoyu on 2017/10/26.
|
限定符和类型 | 类和说明 |
---|---|
class |
AbstractCommonSerializer<T>
Created by juhaoyu on 2017/12/2.
|
class |
GZipSerializerWrapper<T>
Created by juhaoyu on 2018/9/12.
|
class |
SerializerSummaryAdaptor<T>
Created by juhaoyu on 2017/12/2.
|
限定符和类型 | 方法和说明 |
---|---|
static <T> Serializer<T> |
SerializerSummaryAdaptor.get() |
static Serializer<java.lang.Object> |
SerializerSummary.wrap(CommonSerializer<?>... commonSerializers)
将一组serializer包装起来,会继承默认的
|
static <T> Serializer<T> |
GZipSerializerWrapper.wrap(Serializer<T> serializer) |
限定符和类型 | 方法和说明 |
---|---|
static <T> T |
SerializerHelper.deserialize(byte[] bytes,
Serializer<T> serializer) |
static <T> byte[] |
SerializerHelper.serialize(T obj,
Serializer<T> serializer) |
static <T> Serializer<T> |
GZipSerializerWrapper.wrap(Serializer<T> serializer) |
限定符和类型 | 方法和说明 |
---|---|
<T> T |
StateHubServiceWrapper.get(java.lang.String key,
Serializer<T> serializer) |
<T> T |
StateHubService.get(java.lang.String key,
Serializer<T> serializer)
根据键获取存储的对象
|
java.lang.Object |
Store.get(java.lang.String tableName,
java.lang.String key,
Serializer serializer) |
<T> void |
StateHubServiceWrapper.put(java.lang.String key,
T object,
Serializer<T> serializer) |
<T> void |
StateHubService.put(java.lang.String key,
T object,
Serializer<T> serializer)
存储一个对象
|
<T> void |
StateHubServiceWrapper.put(java.lang.String key,
T object,
Serializer<T> serializer,
int activeTime) |
<T> void |
StateHubService.put(java.lang.String key,
T object,
Serializer<T> serializer,
int activeTime)
存储一个对象
|
void |
Store.save(java.lang.String tableName,
java.lang.String key,
java.lang.Object value,
Serializer serializer) |
void |
Store.save(java.lang.String tableName,
java.lang.String key,
java.lang.Object value,
Serializer serializer,
long activeTime) |
限定符和类型 | 方法和说明 |
---|---|
<T> T |
StandardStateHubService.get(java.lang.String key,
Serializer<T> serializer) |
java.lang.Object |
MemoryStore.get(java.lang.String tableName,
java.lang.String key,
Serializer serializer) |
<T> void |
StandardStateHubService.put(java.lang.String key,
T object,
Serializer<T> serializer) |
<T> void |
StandardStateHubService.put(java.lang.String key,
T object,
Serializer<T> serializer,
int activeTime) |
void |
MemoryStore.save(java.lang.String tableName,
java.lang.String key,
java.lang.Object value,
Serializer serializer) |
void |
MemoryStore.save(java.lang.String tableName,
java.lang.String key,
java.lang.Object value,
Serializer serializer,
long activeTime) |
限定符和类型 | 方法和说明 |
---|---|
java.lang.Object |
RedisStore.get(java.lang.String tableName,
java.lang.String key,
Serializer serializer) |
void |
RedisStore.save(java.lang.String tableName,
java.lang.String key,
java.lang.Object value,
Serializer serializer) |
void |
RedisStore.save(java.lang.String tableName,
java.lang.String key,
java.lang.Object value,
Serializer serializer,
long activeTime) |
限定符和类型 | 类和说明 |
---|---|
class |
InputStreamSerializer
Created by juhaoyu on 2018/7/3.
|