Java Netty Codecs 程序「建议收藏」

服务端定义了一个Handler和三个Decoder。Handler接收客户端的信息,然后传递给decoder过滤处理。1.服务端packagecom.learn.netty.codecs;importio.netty.bootstrap.ServerBootstrap;importio.netty.channel.ChannelFuture;importio.netty.channel.ChannelInitializer;importio.netty.channel.E.

大家好,又见面了,我是你们的朋友全栈君。

服务端定义了一个Handler和三个Decoder。Handler接收客户端的信息,然后传递给decoder过滤处理。

 

1.服务端

package com.learn.netty.codecs;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.string.StringDecoder;

import java.net.InetSocketAddress;

public class Server {
    public static void main(String[] args) throws Exception {
        ServerBootstrap bootstrap = new ServerBootstrap();
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            bootstrap.group(group).channel(NioServerSocketChannel.class)
                    .localAddress(new InetSocketAddress(8888))
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel socketChannel) throws Exception {
                            socketChannel.pipeline().addFirst(new ReadHandler())
                                    .addLast(new FixedLengthDecoder())
                                    .addLast(new LoggingDecoder())
                                    .addLast(new LastDecoder());
                        }
                    });
            ChannelFuture future = bootstrap.bind().sync();
            future.channel().closeFuture().sync();
        } finally {
            group.shutdownGracefully().sync();
        }
    }
}

 

2.服务端Handler

package com.learn.netty.codecs;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

public class ReadHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        ByteBuf buf = (ByteBuf) msg;
        System.out.println("Received: " + buf.readableBytes());
        ctx.fireChannelRead(buf);
    }
}

 

3.服务端 FixedLengthDecoder

客户端传递的是数字,Java中每个int类型4字节,读取转成字符串,然后传递到下一个Decoder。

package com.learn.netty.codecs;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
import io.netty.util.CharsetUtil;

import java.util.List;

public class FixedLengthDecoder extends ByteToMessageDecoder {
    @Override
    protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {
        System.out.println("Fixed: " + byteBuf.readableBytes());
        StringBuilder sb = new StringBuilder();
        while (byteBuf.readableBytes() >= 4) {
            // 读取才能向后传递
            sb.append(byteBuf.readInt());
        }
        list.add(Unpooled.copiedBuffer(sb, CharsetUtil.UTF_8));
    }
}

 

4.服务端 LoggingDecoder

将所有信息记录下来,然后传递接收的数字并追加一个字符串。

package com.learn.netty.codecs;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
import io.netty.util.CharsetUtil;

import java.nio.charset.Charset;
import java.util.List;

public class LoggingDecoder extends ByteToMessageDecoder {
    @Override
    protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {
        System.out.println("Logging: " + byteBuf.readableBytes());
        String num = "";
        while (byteBuf.isReadable()) {
            // 读取才能向后传递
            num = byteBuf.readCharSequence(byteBuf.readableBytes(), Charset.defaultCharset()).toString();
            System.out.println(num);
        }
        list.add(Unpooled.copyInt(Integer.parseInt(num)));

        ByteBuf bf = Unpooled.copiedBuffer("Netty", CharsetUtil.UTF_8);
        list.add(bf);
    }
}

 

5.服务端 LastDecoder

读取接收的数字和字符串。

package com.learn.netty.codecs;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;

import java.nio.charset.Charset;
import java.util.List;

public class LastDecoder extends ByteToMessageDecoder {
    @Override
    protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {
        // Decoder没有读取会被调用多次
        // System.out.println("Last readable: " + byteBuf.readableBytes());
        // System.out.println(byteBuf.toString(Charset.defaultCharset()));

        System.out.println("Last readable: " + byteBuf.readableBytes());
        if (byteBuf.readableBytes() == 4) {
            int num = byteBuf.readInt();
            System.out.println("num: " + num);
        } else {
            ByteBuf buf = byteBuf.readBytes(byteBuf.readableBytes());
            System.out.println(buf.toString(Charset.defaultCharset()));
        }
    }
}

 

6.客户端

向服务端传递 6 个 int。

package com.learn.netty.codecs;


import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.Unpooled;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;

import java.net.InetSocketAddress;

public class Client {
    public static void main(String[] args) throws Exception {
        Bootstrap bootstrap = new Bootstrap();
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            bootstrap.group(group);
            bootstrap.channel(NioSocketChannel.class).handler(new ChannelInitializer<SocketChannel>() {
                @Override
                protected void initChannel(SocketChannel socketChannel) throws Exception {
                    socketChannel.pipeline().addFirst(new ChannelInboundHandlerAdapter(){
                        @Override
                        public void channelActive(ChannelHandlerContext ctx) throws Exception {
                            System.out.println("client active");
                            ctx.writeAndFlush(Unpooled.copyInt(1));
                            ctx.writeAndFlush(Unpooled.copyInt(2));
                            ctx.writeAndFlush(Unpooled.copyInt(3));
                            ctx.writeAndFlush(Unpooled.copyInt(4));
                            ctx.writeAndFlush(Unpooled.copyInt(5));
                            ctx.writeAndFlush(Unpooled.copyInt(6));
                        }
                    });
                }
            }).remoteAddress(new InetSocketAddress("127.0.0.1", 8888));
            ChannelFuture future = bootstrap.connect().sync();
            future.channel().close().sync();
        } finally {
            group.shutdownGracefully().sync();
        }
    }
}

 

结果:

Received: 24
Fixed: 24
Logging: 6
123456
Last readable: 4
num: 123456
Last readable: 5
Netty

 

原文地址: https://www.zhblog.net/go/java/tutorial/java-netty-codecs?t=597

 

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/128663.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 网站ssl证书申请_证书注册需要什么材料

    网站ssl证书申请_证书注册需要什么材料HTTPS是指网站在地址栏显示的加密协议,这个协议称作为HTTPS,但实现HTTPS必须要用HTTPS证书才可以,这就告诉大家任何申请HTTPS证书。申请HTTPS方法1、HTTPS证书申请之前我们需要准备:域名、邮箱(用于接收证书)。2、然后将域名确定后提交至Gworg进行申请。3、根据要求完成域名认证,可选认证方式DNS解析、文件认证、邮箱。4、大约十几分钟就可以获得SSL证书文件。5、配置到指定的服务器或者CDN等产品。6、HTTPS证书只需几分钟就可以完成。如果对申请

  • python lambda表达式详解_lambda python

    python lambda表达式详解_lambda pythonlambda表达式是现代编程语言争相引入的一种语法,如果说函数是命名的、方便复用的代码块,那么lambda表达式则是功能更灵活的代码块,它可以在程序中被传递和调用。回顾局部函数回顾《Python函数高级用法》一节中,get_math_func()函数将返回三个局部函数之一。该函数代码如下:defget_math_func(type):#定义三个局部函数…#返回局部函数ifty…

  • 时滞模型的matlab编程_如何用matlab仿真

    时滞模型的matlab编程_如何用matlab仿真Matlab仿真含时滞多智体一致性分析,附代码Matlab仿真含时滞多智体一致性分析,附代码Matlab仿真含时滞多智体一致性分析,附代码系统结构如下图所示:clear;clc;%2014_多智能体网络的一致性问题研究_纪良浩%此为Paper中的示例代码%例2.1:A=[0,0,0.1,0,0;0.1,0,0,0,0;0,0.15,0,0…

  • Swift的属性,方法,下标脚本以及继承

    Swift的属性,方法,下标脚本以及继承

    2021年12月16日
  • 解读windows认证

    0x00前言dll劫持的近期忙,没时间写,先给大家写个windows认证的水文。0x01windows认证协议windows上的认证大致分为本地认证,ntlm协议,和Kerberos协议。

    2021年12月11日
  • string转map_map转bean对象

    string转map_map转bean对象前提:String为Json类型字符串maven<dependency><groupId>com.google.code.gson</groupId><artifactId>gson</artifactId><version>2.8.0</version></dependency>转换

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号