• 鞋子特大号
    2019-12-11
    如何切到netty通信呢,
    看到官方文档上写着:NIO continues to be the default, however Netty based communication can be used in place of NIO by setting the environment variable "zookeeper.serverCnxnFactory" to "org.apache.zookeeper.server.NettyServerCnxnFactory".

    默认情况下,zkServer.sh start 启动后,查看zk的日志,可以看到:
    2019-12-11 00:12:40,842 [myid:] - INFO [main:ServerCnxnFactory@135] - Using org.apache.zookeeper.server.NIOServerCnxnFactory as server connection factory

    小弟花了半个小时才实验成功,分享给大家。
    【服务端zkServer.sh】
    在 $ZK_HOME/conf 目录下创建一个 java.env文件,并配置:
    JVMFLAGS="-Dzookeeper.serverCnxnFactory=org.apache.zookeeper.server.NettyServerCnxnFactory
    -Dzookeeper.clientCnxnSocket=org.apache.zookeeper.ClientCnxnSocketNetty
    "
    如果使用zkCli.sh访问时想使用netty,就加上clientCnxnSocket的配置,如上。

    通过zkServer.sh start 启动后,查看zk启动日志,检查是否使用Netty通讯:

    2019-12-11 00:37:14,230 [myid:] - INFO [main:ServerCnxnFactory@135] - Using org.apache.zookeeper.server.NettyServerCnxnFactory as server connection factory

    【客户端使用IDEA】
    在VM options中添加下面配置即可:
    -Dzookeeper.clientCnxnSocket=org.apache.zookeeper.ClientCnxnSocketNetty

    如果仅调试netty在zookeeper 客户端执行流程中的使用,只配置客户端为netty即可。

    如果使用SSL的话。则必须使用netty通信。
    SSL is only supported on top of Netty communication, which means if you want to use SSL you have to enable Netty.
    展开

    作者回复: 赞

    
    
  • 飞翔
    2019-11-01
    老师 也就是eventthread 只在异步调用的时候存在是吧

    作者回复: 它除了您说的用处,还有很多其他用处,比方说处理API注册的watch,比如https://zookeeper.apache.org/doc/r3.5.5/api/org/apache/zookeeper/ZooKeeper.html#getData-java.lang.String-boolean-org.apache.zookeeper.AsyncCallback.DataCallback-java.lang.Object-注册的watch。

    eventThread一直运行。ClientCnxn的start会启动这个thread,https://github.com/apache/zookeeper/blob/release-3.5.5/zookeeper-server/src/main/java/org/apache/zookeeper/ClientCnxn.java#L408。在创建一个ZooKeeper是会调用cnxn.start()。

    
    
我们在线,来聊聊吧