除了用于简化对List, Set, Map等集合类型的操作外,java stream其实还可以抽象很多其他数据类型,然后在这一抽象的基础上做一些非常规操作。这些另类操作用好了...
除了用于简化对List, Set, Map等集合类型的操作外,java stream其实还可以抽象很多其他数据类型,然后在这一抽象的基础上做一些非常规操作。这些另类操作用好了...
AbstractApplicationContext#refresh() AbstractApplicationContext#obtainFreshBeanFactory(...
顺序消息的实现 顺序消息进行消费时,若是第一次消费失败,可以返回SUSPEND_CURRENT_QUEUE_A_MOMENT,下一次会继续消费此消息。 顺序消息的消费失败时的...
提出疑问 第一次pullMessage时是不是根据offset去获取呢 offset从远程获取到还是存在本地呢 consumer端在启动时会开启负载均衡服务Rebalance...
客户端管理Channel 因为客户端要主动发起请求,以consumer为例,在对topic进行消费时,不同的topic可能在不同的broker上,因此consumer端需要对...
消息中间价存储一般都是利用磁盘,在廉价的PC机上一般是使用机械硬盘,但机械硬盘的速度比访问内存慢了n个数量级,但一款优秀的消息中间件必然会将硬件资源压榨到极致,接下来看看...
项目地址使用和rocket相似 后期准备做的 完善客户端channel管理。 broker分布式。这依赖于客户端的负载均衡,将topic分片存储。由于目前无持久化,因此使用同...
netty在rocket中的使用 client和server都是使用netty通信 client在创建BootStrap时的简化代码如下 在处理消息的时候进行request和...
有一张财务流水表,未分库分表,目前的数据量为9555695,分页查询使用到了limit,优化之前的查询耗时16 s 938 ms (execution: 16 s 831 m...
raincat项目地址 源码分析 本地事务部分依赖于spring事务 @TxTransactional注解和spring自带的Transactional注解没联系,是手动调用...
几个重要的类 DubboNamespaceHandler。该类继承NamespaceHandlerSupport,即通过spring对扩展标签的支持,对dubbo自定义的标签...
首先定义公共的接口 服务提供者进行接口的实现部分 实现rpc,主要为socket通信和协议的商定 服务提供者暴露需要调用的方法实现 服务消费者调用rpc
加锁方式 无锁方式
该文章是再次读《深入理解java虚拟机》6.3章class类文件的结构的学习记录 使用javac -target 1.6将下列代码编译为字节码文件 字节码文件可以通过vsco...
创建Bean的步骤在org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory的...
Channel,ChannelHandler,ChannelPipeline,ChannelHandlerContext这些组件都有write,flush等方法,这些有什么区...
最近在闲暇时刻仔细查看了HashMap的代码,对于一些不常用的方法如iterator,spliterator等以及树节点的部分做了仔细阅读,对于不好理解的部分做了较为详细的注...
写在前面 当在10亿数据进行不到30次比较就能查找到目标时,不禁感叹编程之魅力!人类之伟大呀! —— 学红黑树有感。 终于,在学习了几天的红黑树相关的知识后,我想把我所学所想...