zoukankan      html  css  js  c++  java
  • netty channel的线程安全性与@Sharable

    1. Bootstrap中直接添加sb.childHandler(new MySimpleChannelInboundHandler())

    这个childHandler都是同一个实例,也就说会导致不同的channel用了同一个handler

    2. netty的一大好处就是每一个channel都有自己绑定的eventloop和channelHandler,这样可以保证代码串行执行,不必考虑并发同步的问题。

    3. 只要写个类继承ChannelInitializer就行了,ChannelInitializer这个类比较特殊,你可以把它想象成是很多channelhandler的集合体,而且这个类就是@Shareable的,继承了这个类之后你可以为每一个channel单独创建handler,甚至是多个handler。

    虽然所有的channel都共享了ChannelInitializerImpl这个实例,但是这个实例却能为每一个channel new出新的handler实例,这就是区别。

     

    https://www.fanyeong.com/2016/10/24/netty-channelhandler%E4%BD%BF%E7%94%A8%E6%8A%A5%E9%94%99/

    4. 也并不是说ChannelInitializer就可以不用@Sharable了,要视具体情况而看,如果ChannelInitializer中还是同一个handler实例,就不行

    https://blog.csdn.net/supper10090/article/details/78431948

    5. 为了安全地被用于多个并发的Channel(即连接),sharable注解的ChannelHandler必须是线程安全的。

    每一个新创建的Channel都将会被分配一个新的ChannelPipeline,但其中的handler未必是

    https://www.jianshu.com/p/b241e3800fc0

    6. 如果ChannelHandler被注解为 @Sharable,全局只有一个handler实例,它会被多个Channel的Pipeline共享,会被多线程并发调用,因此它不是线程安全的;如果存在跨ChannelHandler的实例级变量共享,需要特别注意,它可能不是线程安全的。

    在整个ChannelPipeline执行过程中,可能会发生线程切换。此时,如果同一个对象在多个ChannelHandler中被共享,可能会被多线程并发操作

    https://blog.csdn.net/y_xianjun/article/details/48341749

    7. 总之,只应该在确定了你的 ChannelHandler 是线程安全的时才使用@Sharable 注解 

    http://www.cnblogs.com/krcys/p/9297092.html

    8. 新建一个Channel时会自动新建一个ChannelPipeline,也就是说他们之间是一对一的关系。另外需要注意的是:ChannelPipeline是线程安全的,也就是说,我们可以动态的添加、删除其中的ChannelHandler。考虑这样的场景:服务器需要对用户登录信息进行加密,而其他信息不加密,则可以首先将加密Handler添加到ChannelPipeline,验证完用户信息后,主动从ChnanelPipeline中删除,从而实现该需求。

    netty tcp(ws)鉴权2个方案 中即有一个鉴权后,remove from pipeline的案例

    我的理解:channel属于一个线程,ChannelPipeline属于一个channel,所以对ChannelPipeline的操作始终在一个线程内

    Sharable注解的使用是有限制的,多个ChannelPipeline共用一个handler实例,所以该Handler要求无状态。不能使用或改变本身的私有变量,因为ChannelHandler是非线程安全的,使用私有变量会造成线程竞争而产生错误结果。


    链接:https://www.jianshu.com/p/7dc5da98694c

    9. 看书

    channelpipeline 始终在一个线程操作

    红色框划重点

    归纳就是:

    (1)channel-1vs 1 pipeline-new handler

    (2)channel-1vs 1 pipeline-common handler,需要@Sharable,且确保线程安全无成员变量

    (3)channel始终在一个线程中,pipeline也是,但handler未必是

    下面补充一个关于channel与线程的实践  9.6

    https://www.cnblogs.com/silyvin/articles/9599778.html

    2019.12.17 补充

    Sharable不仅是要开发者重视该handler需要是一个线程安全的,更重要的,应该是一个关于连接无状态的,比如,对于拆包沾包handler,每个连接都应该有一个自己的对象,否则比如连接A-handlerA,连接B-handlerA,handlerA的确可以强行加锁配置为线程安全的,事实上对于nio,只要设置,也能做到只有一个线程去调用HandlerA,纵使它是线程安全的,但它不是关于连接无状态的,故不能在各连接复用一个这样的Sharable的handler

    对于netty粘包(一)消息定长 实践,FixedLengthFrameDecoder不是连接无状态的,而StringDecoder确是连接无状态的,因为哪个连接都可以用一个公用的StringDecoder来反序列化字符串,只要将byte[]传入;但拆包就不行,每个连接各自handler需要保存一个状态-读了多少字节,还要读多少字节,应有各自的FrameDecoder,实践位于:netty(十九)ChannelInitializer 使用公共handler

    对于连接无关的,各连接就能共用一个handler对象,当然要用@Sharble注解

  • 相关阅读:
    windows中80端口被System占用,PID=4的问题
    SpringBoot中动态加载(热部署)
    eclipse中Cannot change version of project facet Dynamic Web Module to 3.0的问题解决
    Eclipse启动tomcat后404错误
    Eclipse在当前行之上插入一行
    Java中==规则
    简明log4j配置教程
    CentOS7 配置静态IP
    CentOS7 mini安装后没有ifconfig命令的解决办法
    shell编程学习笔记之sed编辑器
  • 原文地址:https://www.cnblogs.com/silyvin/p/9593368.html
Copyright © 2011-2022 走看看