Skip to content


NettyRpcEnv is an RpcEnv using Netty ("an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers & clients").

Creating Instance

NettyRpcEnv takes the following to be created:

  • [[conf]][]
  • [[javaSerializerInstance]] JavaSerializerInstance
  • [[host]] Host name
  • [[securityManager]] SecurityManager
  • [[numUsableCores]] Number of CPU cores

NettyRpcEnv is created when NettyRpcEnvFactory is requested to create an RpcEnv.

== [[streamManager]] NettyStreamManager

NettyRpcEnv creates a[] when <>.

NettyStreamManager is used for the following:

  • Create a NettyRpcHandler for the <>

  • As the[RpcEnvFileServer]

== [[transportContext]] TransportContext

NettyRpcEnv creates a[].

== [[startServer]] Starting Server


startServer( bindAddress: String, port: Int): Unit


startServer is used when NettyRpcEnvFactory is requested to[create an RpcEnv] (in server mode).

== [[deserialize]] deserialize Method


deserializeT: ClassTag: T


deserialize is used when:

  • RequestMessage utility is created

  • NettyRpcEnv is requested to <>

Last update: 2020-11-27