-
Notifications
You must be signed in to change notification settings - Fork 15
off heap
Tony Shen edited this page Feb 8, 2019
·
3 revisions
在 Java 中,与堆外内存相对的是堆内存。堆内存遵守 JVM 的内存管理机制,而堆外内存不受到此限制,它由操作系统进行管理。
堆外内存更适合:
- 存储生命周期长的对象
- 可以在进程间可以共享,减少 JVM 间的对象复制,使得 JVM 的分割部署更容易实现。
- 本地缓存,减少磁盘缓存或者分布式缓存的响应时间。
在 RxCache 中使用 DirectBufferMemoryImpl 支持堆外内存,并采用 FIFO 的方式。
import com.safframework.rxcache.RxCache;
import com.safframework.rxcache.domain.Record;
import com.safframework.rxcache.offheap.DirectBufferMemoryImpl;
import domain.User;
import io.reactivex.Observable;
import io.reactivex.functions.Consumer;
/**
* Created by tony on 2018-12-22.
*/
public class TestOffHeap {
public static void main(String[] args) {
RxCache.config(new RxCache.Builder().memory(new DirectBufferMemoryImpl(3)));
RxCache rxCache = RxCache.getRxCache();
User u1 = new User();
u1.name = "tony1";
u1.password = "123456";
rxCache.save("test1",u1);
User u2 = new User();
u2.name = "tony2";
u2.password = "123456";
rxCache.save("test2",u2);
User u3 = new User();
u3.name = "tony3";
u3.password = "123456";
rxCache.save("test3",u3);
User u4 = new User();
u4.name = "tony4";
u4.password = "123456";
rxCache.save("test4",u4);
Observable<Record<User>> observable = rxCache.load2Observable("test1", User.class);
if (observable!=null) {
observable.subscribe(new Consumer<Record<User>>() {
@Override
public void accept(Record<User> record) throws Exception {
User user = record.getData();
System.out.println(user.name);
System.out.println(user.password);
}
});
}
}
}
- General
- Memory
- Persistence
-
Disk
-
Serialization
- Gson
- Fastjson
- Moshi
- Kryo
- Hessian
- FST
- Protobuf
-
Encryption
- AES 128
- DES
-
Serialization
-
Disk
- Cache Statistics
- Spring