正文 

当前位置： 首页 > java > java示例

java示例代码_在处理程序使用Netty接收事件之前，如何将对象附加到通道

     2022-03-26     186

关键词：

java示例代码_在处理程序使用Netty接收事件之前，如何将对象附加到通道

       // Configure the client.
    final NioClientSocketChannelFactory clientSocketChannelFactory = new NioClientSocketChannelFactory(
            Executors.newCachedThreadPool());


    // Set up the pipeline factory.
    final ChannelPipelineFactory channelPipelineFactory = new ChannelPipelineFactory() 
        public ChannelPipeline getPipeline() throws Exception 
            return Channels.pipeline(
                    new MyClientHandler());
        
    ;

    ChannelPipeline pipeline = channelPipelineFactory.getPipeline();
    final Channel channel = clientSocketChannelFactory.newChannel(pipeline);

    channel.getConfig().setPipelineFactory(channelPipelineFactory);
    channel.getConfig().setOption("tcpNoDelay", true);
    channel.getConfig().setOption("receiveBufferSize", 1048576);
    channel.getConfig().setOption("sendBufferSize", 1048576);

    ChannelFuture boundFuture = Channels.future(channel);

    boundFuture.addListener(new ChannelFutureListener() 
        @Override
        public void operationComplete(ChannelFuture future) throws Exception 
            if (future.isSuccess()) 
                future.getChannel().setAttachment(new Object());// set the channel attachment
            
        
    );


    channel.getPipeline().sendDownstream(new DownstreamChannelStateEvent(channel, boundFuture, ChannelState.BOUND, new InetSocketAddress(host, 0)));

    ChannelFuture connectFuture = Channels.future(channel); 
    channel.getPipeline().sendDownstream(new DownstreamChannelStateEvent(channel, connectFuture, ChannelState.CONNECTED, new InetSocketAddress(host, port)));

    channel.getCloseFuture().awaitUninterruptibly();

    clientSocketChannelFactory.releaseExternalResources();// do not forget to do this

java示例代码_使用鼠标拖动事件在java小程序上绘制矩形

java示例代码_使用鼠标拖动事件在java小程序上绘制矩形 查看详情

java示例代码_在Android应用程序的事件侦听器回调中使用标志

java示例代码_在Android应用程序的事件侦听器回调中使用标志 查看详情

java示例代码_如何在java中处理Jcombobox的按键事件

java示例代码_如何在java中处理Jcombobox的按键事件 查看详情

Java 自定义事件处理程序和侦听器

...些消息时触发事件，这就是我感到困惑的地方。这是我的代码：server.addE 查看详情

java示例代码_将事件处理程序附加到JavaFX阶段/窗口最小化按钮

java示例代码_将事件处理程序附加到JavaFX阶段/窗口最小化按钮 查看详情

java示例代码_在使用java日志API时禁用默认控制台处理程序

java示例代码_在使用java日志API时禁用默认控制台处理程序 查看详情

java示例代码_使用JAX RPC在处理程序中获取WS操作名称

java示例代码_使用JAX RPC在处理程序中获取WS操作名称 查看详情

java示例代码_在Android中处理触摸或按下事件

java示例代码_在Android中处理触摸或按下事件 查看详情

java示例代码_处理地图视图'；s单击事件并打开谷歌地图应用程序

java示例代码_处理地图视图'；s单击事件并打开谷歌地图应用程序 查看详情

java示例代码_在ExpandableListView子级的一行中处理不同视图的事件

java示例代码_在ExpandableListView子级的一行中处理不同视图的事件 查看详情

java示例代码_在拖放过程中接收关键事件&；滴

java示例代码_在拖放过程中接收关键事件&；滴 查看详情

netty——nio（selector处理read事件）代码示例(代码片段)

目录一、服务端代码示例二、客户端代码示例三、工具类四、启动一个客户端测试五、启动2个客户端测试六、服务端示例代码中为何要使用iter.remove()七、服务端示例代码中cancel()的作用一、服务端代码示例服务端代码示例packagec... 查看详情

netty——nio（selector处理read事件）代码示例(代码片段)

目录一、服务端代码示例二、客户端代码示例三、工具类四、启动一个客户端测试五、启动2个客户端测试六、服务端示例代码中为何要使用iter.remove()七、服务端示例代码中cancel()的作用一、服务端代码示例服务端代码示例packagec... 查看详情

java示例代码_在netty中设置不关闭连接的读取超时

java示例代码_在netty中设置不关闭连接的读取超时 查看详情

java示例代码_使用VERTX处理程序获取POST表单数据

java示例代码_使用VERTX处理程序获取POST表单数据 查看详情

java示例代码_通常在CXF请求处理程序中处理输入参数

java示例代码_通常在CXF请求处理程序中处理输入参数 查看详情

java示例代码_当另一方使用readUTF/writeUTF时，用netty读/写

java示例代码_当另一方使用readUTF/writeUTF时，用netty读/写 查看详情

netty——网络编程nio（selector处理read事件）代码示例(代码片段)

目录一、服务端代码示例二、客户端代码示例三、工具类四、启动一个客户端测试五、启动2个客户端测试六、服务端示例代码中为何要使用iter.remove()七、服务端示例代码中cancel()的作用一、服务端代码示例服务端代码示例packagec... 查看详情