elasticsearch官网建议生产环境需要设置bootstrap.memory_lock: true 重新启动elasticsearch,报错信息如下: [baoshan@test-43.dev.rokid-inc.com /home/baoshan/elk/elasticsearch-5.3. ...
分类:
其他好文 时间:
2019-08-15 21:11:45
阅读次数:
135
前两节我们分别看了FastThreadLocal和ThreadLocal的源码分析,并且在第八节的时候讲到了处理一个客户端的接入请求,一个客户端是接入进来的,是怎么注册到多路复用器上的。那么这一节我们来一起看下客户端接入完成之后,是怎么实现读写操作的?我们自己想一下,应该就是为刚刚读取的数据分配一块 ...
分类:
Web程序 时间:
2019-08-15 13:01:58
阅读次数:
132
springContextStati是一个实现了Applicationcontextaware的类的名字,可以getBean(..)RegistryTask是一个在RegistryServer调用netty封装的channelinitializer时候,的clienthandler被触发读事件的时候... ...
分类:
移动开发 时间:
2019-08-14 21:55:20
阅读次数:
219
在Spark中定义了通信框架的接口,这些接口中调用了Netty的具体方法(在spark2.x前,使用的是Akka)。各接口和实现类的关系如下图所示。 将终端(EndPoint)注册到Rpc环境中: 在各个模块中,如DriverEndPoint、ClientEndPoint、Master、Worker ...
分类:
其他好文 时间:
2019-08-13 13:33:56
阅读次数:
122
Nio 的ByteBuffer 和 Netty 的 ByteBuf 的区别: 1、ByteBuf 将 ByteBuffer的position 分解为:readIndex , writeIndex 因此,使用ByteBuf 就不再需要使用 filp 进行读写状态的切换,随时可以进行读写。 2、jdk ...
分类:
其他好文 时间:
2019-08-11 23:15:35
阅读次数:
115
什么是拆包/粘包: TCP 粘包/拆包: TCP 是一个“流”协议,所谓流,就是没有界限的一长串二进制数据。TCP 作为传输层协议并不了解上层业务数据的具体含义,它会根据TCP 缓冲区的实际情况进行数据包的划分,所以在业务上认为是一个完整的包,可能会被TCP 拆分成多个包进行发送,也有可能把多个小的 ...
分类:
Web程序 时间:
2019-08-11 17:22:57
阅读次数:
451
一、创建Personproto.proto 创建Personproto.proto文件 2、重新生成 D:\workspace\study\basic\netty_demo>protoc --java_out=src/main/java src/protobuf/Person.proto 二、创建N ...
分类:
Web程序 时间:
2019-08-10 21:39:10
阅读次数:
194
为了更好地探讨Netty的内存模型,后面会用到,这里我还是决定跟大家一起看下ThreadLocal和FastThreadLocal的源码,有的时候我们在看源码的时候会一层层的遇到很多之前没有看过的内容,我觉得有的时候为了更好地理解大牛的思想,还是去跟一下源码比较好。ThreadLocal我想大家应该 ...
分类:
Web程序 时间:
2019-08-04 19:57:20
阅读次数:
140
Netty+WebSocket 获取火币交易所时时数据项目 先附上项目 项目GitHub地址 "spring boot netty websocket huobi" 本项目使用 SpringBoot+Netty来开发WebSocket服务器,与火币交易所Websocket建立连接,时时获取火币网交易 ...
分类:
Web程序 时间:
2019-08-01 21:23:47
阅读次数:
466