首页 > 编程语言 >Netty中集成Protobuf实现Java对象数据传递

Netty中集成Protobuf实现Java对象数据传递

时间:2023-03-23 11:02:35浏览次数:45  
标签:Netty pipeline Java Protobuf netty io new import channel


在上面两篇博客基础上,对于Socket搭建服务端和客户端进行通信以及

在Java中Protobuf的使用已经有了初步的理解。

那么怎样使用Netty进行服务端和客户端的通信时使用protobuf进行数据传递。

注:

关注公众号
霸道的程序猿
获取编程相关电子书、教程推送与免费下载。

实现

在src下新建protobuf目录,目录下新建Person.prpto描述文件

syntax = "proto3";

package com.badao.protobuf;

option optimize_for =SPEED;
option java_package = "com.badao.NettyProtobuf";
option java_outer_classname = "BadaoDataInfo";

message Person {
    string name = 1;
    int32 age = 2;
    string address = 3;
}

具体的讲解可以见上面的博客。

然后在src/main/java下新建包com.badao.NettyProtobuf

打开终端Ternimal,使用protoc进行编译代码

protoc --java_out=src/main/java src/protobuf/Person.proto

然后就会在上面NettyProtobuf包下生成BadaoDataInfo类

上面具体的流程与讲解参照上面的博客。

然后新建服务端类NettyProtobufServer

package com.badao.NettyProtobuf;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.logging.LogLevel;
import io.netty.handler.logging.LoggingHandler;

public class NettyProtobufServer {
    public static void main(String[] args) throws  Exception
    {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try{
            ServerBootstrap serverBootstrap = new ServerBootstrap();
            serverBootstrap.group(bossGroup,workerGroup).channel(NioServerSocketChannel.class)
                    .handler(new LoggingHandler(LogLevel.INFO))
                    .childHandler(new NettyProtobufInitializer());
            //绑定端口
            ChannelFuture channelFuture = serverBootstrap.bind(70).sync();
            channelFuture.channel().closeFuture().sync();
        }finally {
            //关闭事件组
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
}

其中用到了自定义的初始化器NettyProtoInitilizer

package com.badao.NettyProtobuf;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.protobuf.ProtobufDecoder;
import io.netty.handler.codec.protobuf.ProtobufEncoder;
import io.netty.handler.codec.protobuf.ProtobufVarint32FrameDecoder;
import io.netty.handler.codec.protobuf.ProtobufVarint32LengthFieldPrepender;

public class NettyProtobufInitializer extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();

        pipeline.addLast(new ProtobufVarint32FrameDecoder());
        pipeline.addLast(new ProtobufDecoder(BadaoDataInfo.Person.getDefaultInstance()));
        pipeline.addLast(new ProtobufVarint32LengthFieldPrepender());
        pipeline.addLast(new ProtobufEncoder());

        pipeline.addLast(new NettyProtobufHandler());
    }
}

注意这里不同的是添加的处理器是Netty自带的关于Protobuf的解码编码的处理器。

其中Decode处理器的参数就是上面生成的代码的默认的实例。

然后最后又添加了自定义的处理器NettyProtobufHandler

package com.badao.NettyProtobuf;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

public class NettyProtobufHandler extends SimpleChannelInboundHandler<BadaoDataInfo.Person> {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, BadaoDataInfo.Person msg) throws Exception {
        System.out.println(msg.getName());
        System.out.println(msg.getAge());
        System.out.println(msg.getAddress());
    }
}

自定义处理器中在收到发送的消息时将消息进行输出,这里这里在继承SimpleChannelInboundHandler

的泛型就是上面生成的类。

然后新建客户端类

package com.badao.NettyProtobuf;

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;

public class NettyProtobufClient {
    public static void main(String[] args) throws  Exception {
        EventLoopGroup eventLoopGroup = new NioEventLoopGroup();
        try {

            Bootstrap bootstrap = new Bootstrap();

            bootstrap.group(eventLoopGroup).channel(NioSocketChannel.class)
                    .handler(new NettyProtoBufClientInitializer());
            //绑定端口
            ChannelFuture channelFuture = bootstrap.connect("localhost", 70);
            channelFuture.channel().closeFuture().sync();
        } finally {
            //关闭事件组
            eventLoopGroup.shutdownGracefully();

        }
    }
}

编写其用到的初始化器

package com.badao.NettyProtobuf;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.protobuf.ProtobufDecoder;
import io.netty.handler.codec.protobuf.ProtobufEncoder;
import io.netty.handler.codec.protobuf.ProtobufVarint32FrameDecoder;
import io.netty.handler.codec.protobuf.ProtobufVarint32LengthFieldPrepender;

public class NettyProtoBufClientInitializer extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();

        pipeline.addLast(new ProtobufVarint32FrameDecoder());
        pipeline.addLast(new ProtobufDecoder(BadaoDataInfo.Person.getDefaultInstance()));
        pipeline.addLast(new ProtobufVarint32LengthFieldPrepender());
        pipeline.addLast(new ProtobufEncoder());

        pipeline.addLast(new NettyProtobufClientHandler());
    }
}

和服务端的初始化器用到的处理器一致,最后也要有自定义的处理器

package com.badao.NettyProtobuf;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

public class NettyProtobufClientHandler extends SimpleChannelInboundHandler<BadaoDataInfo.Person> {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, BadaoDataInfo.Person msg) throws Exception {

    }

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        BadaoDataInfo.Person person = BadaoDataInfo.Person.newBuilder()
                .setName("公众号:霸道的程序猿")
                .setAge(100)
                .setAddress("中国").build();
        ctx.channel().writeAndFlush(person);
    }
}

在与服务端建立连接即通道激活的回调方法中向服务端发送数据。

然后运行服务端的main方法再运行客户端的main方法。

 

Netty中集成Protobuf实现Java对象数据传递_Netty


标签:Netty,pipeline,Java,Protobuf,netty,io,new,import,channel
From: https://blog.51cto.com/BADAOLIUMANGQZ/6144516

相关文章

  • Netty中使用WebSocket实现服务端与客户端的长连接通信发送消息
    上面讲了使用使用Socket搭建多客户端的连接与通信。那么如果在Netty中使用WebSocket进行长连接通信要怎么实现。WebSocket现在,很多网站为了实现推送技术,所用的技术都是Ajax......
  • java正则
    正则常见用法(例子来源:hutool文档):Stringcontent="ZZZaaabbbccc中文1234";Patternpattern=Pattern.compile(regex,Pattern.DOTALL);Matchermatcher=pattern.m......
  • #Java程序设计实践
    Java程序设计实践Java训练集1~3总结与心得训练集链接前言:本次训练集1~3主要考察了对java基础语法的掌握,内容包括基础程序的设计,类设计,编程规则的掌握等等,学习的重点在......
  • java学习日记20230320-类变量和类方法
    类变量和类方法static修饰的静态变量或者方法静态变量是类共享的,当class运行时。jdk8之前时放在方法区,静态域,jdk8之后放在堆中,会生成class对象在堆中;在类加载中生成;st......
  • 20.(行为型模式)java设计模式之迭代器模式
    一、什么是迭代器模式(IteratorPattern)   提供—种方法顺序访问一个聚合对象中各个元素,而又无须暴露该对象的内部实现,属于行为型模式。应用场景:   —般来说,迭......
  • Java之size()>0 和isEmpt()性能考量
    为何要写这篇呢?主要是要纠正一个长期以来的误区:size()>0一定比isEmpt()性能差。以下内容是社区里的结论:方法一(数据量大,效率低):if(list!=null&&list.size()>0){}方法......
  • BDD之Java Testing with Spock
    为何会专门写这篇BDD呢?之前我发表过一篇《代码重构之TDD的思考》,有童靴联系到我,探讨之余,感觉这几年集成化方面的测试方案产出太少了,优秀的也太少了。今天带大家了解一个新东......
  • Java运算符
    Java运算符Java运算符有:算术运算符、关系运算符、位运算符、逻辑运算符、赋值运算符、其他运算符算术运算符A=10,B=20操作符描述例子+加法,运算符两侧的值相加......
  • 【Javaweb】html frame标签的使用 | 导航栏右侧内容的实现
    问题的产生:是我和同伴做了一个导航栏,但是我们不知道怎么实现右侧内容的切换    然后我们查了很多资料,但是有一些是垂直的,但是就如图可见,我们是水平的,那么怎么实......
  • Java入门_一维数组_第二题_随机生成数
    前提小白一个,啥都不会,欢迎指点。题目随机生成10个整数(1-100的范围),保存到数组,并倒序打印以及求平均值,求最大值和最大值的下标,并查找里面知否有8。思路随机生成--......