Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- try {
- EventLoopGroup group = new NioEventLoopGroup();
- Bootstrap b = new Bootstrap();
- b.group(group)
- .channel(NioSocketChannel.class)
- .handler(new ChannelInitializer<SocketChannel>() {
- @Override
- public void initChannel(SocketChannel ch) throws Exception {
- ChannelPipeline p = ch.pipeline();
- p.addLast(new ObjectEncoder());
- p.addLast(new ObjectDecoder(ClassResolvers.cacheDisabled(null)));
- p.addLast(new ChannelHandler());
- }
- });
- Channel channel = b.connect("127.0.0.1", 5000).sync().channel();
- } catch(InterruptedException e) {
- System.out.println("suchka");
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement