一种基于Netty的远程数据传输方法

摘要

本发明公开了一种基于Netty的远程数据传输方法，包括：发起RPC请求；在建立连接过程中，初始化线程组；分派NIO线程，并建立线程池；启动数据转发器，并处理I/O事件；处理包界限；构建连接服务器通道；把已连接通道放在队列中；将数据发送到缓冲区后刷新输出；接收到数据时，把数据接入kafka消息队列中；把数据封装成kafka的ProducerRecord；判断topic有没有指定分区；如果确定topic没有指定分区，则判断是否有指定key；如果确定有指定key，则根据key的value采用对应的hash算法为topic指定一个分区；接入到topic所对应的分区，并将数据依次保存到该分区所对应的缓冲池中。通过上述方式，本发明能够实现高吞吐量的数据传输，有效提高I/O事件处理效率，使得不会出现线程堆栈溢出导致服务器宕机的现象。