# oceanet
基于netty源码启发的学习性质的java非阻塞网络库
* 基于Eventloop模型做到了读写串行化，尽可能减少了锁的开销，实现了消息驱动的socket读写和基于最小堆的定时器
* 实现了三级内存池，降低每次都需要获取堆外内存的开销，Eventloop线程优先从本线程私有的分配器分配池化内存，若不足再去全局公有的分配器分配内存，再不足则分配非池化内存，同样允许设置最大和最小内存池上限保证大小可控
* 仿照netty的pipeline实现了无锁化的线程安全可插拔handler
* 只依赖与jdk系统库标准API，不依赖于反射,无额外第三方依赖，对jdk升级和native-image友好
基于eventloop的java非阻塞网络库，实现了事件驱动，无锁的基于最小堆的定时器，便于扩展的pipeline机.zip
版权申诉
70 浏览量
2024-03-23
23:48:14
上传
评论
收藏 29KB ZIP 举报
基于eventloop的java非阻塞网络库，实现了事件驱动，无锁的基于最小堆的定时器，便于扩展的pipeline机.zip （40个子文件） 
java0323 
pom.xml 811B src test java com dreamlike ocean Util AllocatorUtilTest.java 1KB ByteMsg Allocator Impl ThreadPoolByteMsgAllocatorTest.java 2KB main java com dreamlike ocean Channel Channel.java 3KB NioByteChannel.java 2KB NioServerChannel.java 2KB Handler ChannelReadHandler.java 312B Impl SimpleChannelWriteHandler.java 631B ChannelInitHandler.java 479B ChannelWriteHandler.java 330B ChannelHandler.java 584B EventLoop NioEventLoop.java 7KB NioEventLoopGroup.java 699B Util EventLoopUtil.java 581B AllocatorUtil.java 1KB Exception ByteMsgOverflowBound.java 102B UnCaughtException.java 201B Pipeline Pipeline.java 3KB DefaultMessageHandlerContext.java 4KB PlainNode.java 767B Interface MessageHandlerContext.java 483B HandlerNode.java 1KB TailNode.java 4KB HeadNode.java 1KB Sever Tcpserver.java 1KB Main.java 451B ByteMsg Allocator ByteMsgAllocator.java 207B Impl SharedByteMsgAllocator.java 3KB ThreadPoolByteMsgAllocator.java 5KB UnpooledByteMsgAllocator.java 770B PoolByteMsgAllocator.java 135B Msg AbstractByteMsg.java 3KB impl CombinedFixedByteMsg.java 7KB UnpoolByteMsg.java 4KB FixedPoolByteMsg.java 6KB FlexPoolByteMsg.java 2KB FileMsg.java 71B ExtendableByteMsg.java 100B ByteMsg.java 1KB README.md 726B资源评论
Kwan的解忧杂货铺
- 粉丝: 1w+
- 资源: 3633
下载权益
C知道特权
VIP文章
课程特权
VIP享7折，此内容立减5.97元 开通VIP
