Netty之java序列化

简介: 版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/u010741376/article/details/46367701 通过一个实例来说明:Netty服务端接受到客户端的用户订购请求消息,服务端接受到请求消息,对用户名进行合法性校验,则构造订购成功的应答消息返回给客户端。
版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/u010741376/article/details/46367701

通过一个实例来说明:Netty服务端接受到客户端的用户订购请求消息,服务端接受到请求消息,对用户名进行合法性校验,则构造订购成功的应答消息返回给客户端。使用Netty的ObjectEncoder和ObjectDecoder对订购请求和应答消息进行序列化.

 订购请求POJO类的定义:

  

import java.io.Serializable;

/**
 * 客户端请求消息
 * @author Administrator
 *
 */
public class SubscribeReq implements Serializable{

	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
     
	private int subReqID;
	private String userName;
	private String productName;
	private String phoneNumber;
	private String address;
	public int getSubReqID() {
		return subReqID;
	}
	public void setSubReqID(int subReqID) {
		this.subReqID = subReqID;
	}
	public String getUserName() {
		return userName;
	}
	public void setUserName(String userName) {
		this.userName = userName;
	}
	public String getProductName() {
		return productName;
	}
	public void setProductName(String productName) {
		this.productName = productName;
	}
	public String getPhoneNumber() {
		return phoneNumber;
	}
	public void setPhoneNumber(String phoneNumber) {
		this.phoneNumber = phoneNumber;
	}
	public String getAddress() {
		return address;
	}
	public void setAddress(String address) {
		this.address = address;
	}
	@Override
	public String toString() {
		return subReqID+"-"+userName+"-"+productName+"-"+phoneNumber+"-"+address;
		
	}
	
	
	
	
	
}
订购应答POJO类:

/**
 * 服务端应答消息
 * @author Administrator
 *
 */
public class SubscribeResp implements Serializable{

	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
   
	private int subReqID;
	private int respCode;
	private String desc;
	public int getSubReqID() {
		return subReqID;
	}
	public void setSubReqID(int subReqID) {
		this.subReqID = subReqID;
	}
	public int getRespCode() {
		return respCode;
	}
	public void setRespCode(int respCode) {
		this.respCode = respCode;
	}
	public String getDesc() {
		return desc;
	}
	public void setDesc(String desc) {
		this.desc = desc;
	}
	@Override
	public String toString() {
		return subReqID+"-"+respCode+"-"+desc;
	}
	
	
}
订购服务端主函数:

  

public class SubReqServer {
         public void bind(int port)throws Exception{
        	 //配置服务端的NIO线程组
        	 EventLoopGroup bossGroup=new NioEventLoopGroup();
        	 EventLoopGroup workerGroup=new NioEventLoopGroup();
        	 
        	 try {
				ServerBootstrap b=new ServerBootstrap();
				b.group(bossGroup,workerGroup)
				.channel(NioServerSocketChannel.class)
				.option(ChannelOption.SO_BACKLOG,100)
				.handler(new LoggingHandler(LogLevel.INFO))
				.childHandler(new ChannelInitializer<SocketChannel>() {

					@Override
					protected void initChannel(SocketChannel ch)
							throws Exception {
						ch.pipeline().addLast(new ObjectDecoder(1024*1024, ClassResolvers.weakCachingConcurrentResolver(this.getClass().getClassLoader())));
						ch.pipeline().addLast(new ObjectEncoder());
						ch.pipeline().addLast(new SubReqServerHandler());
											
					}
					
				});
        		 
        		 //绑定端口,同步等待成功
				ChannelFuture f=b.bind(port).sync();
        		//等待服务端监听端口关闭 
				
				f.channel().closeFuture().sync();
        		 
			} finally{
				bossGroup.shutdownGracefully();
				workerGroup.shutdownGracefully();
			}
 
         }
         
         public static void main(String[] args) throws Exception {
			int port=8088;
			if(args!=null&&args.length>0){
				try {
					port=Integer.valueOf(args[0]);
				} catch (Exception e) {
					// TODO: handle exception
				}
			}
        	 
        	 new SubReqServer().bind(port);
        	 
        	 
        	 
		}
}

上述代码中,我们首先创建一个新的ObjectDecoder,它负责对实现Serializable的POJO对象进行解码,它有多个构造函数,支持不同的ClassResolver,在此我们使用weakCachingConcurrentResolver创建线程安全的WeakReferenceMap对类加载器进行缓存,它支持多线程并发访问,当虚拟机内存不足时,会释放缓存中的内存,防止内存泄露。

订单处理类:

public class SubReqServerHandler extends ChannelHandlerAdapter{
    public void channelRead(ChannelHandlerContext ctx,Object msg){
    	SubscribeReq req=(SubscribeReq)msg;
    	if("yxs".equalsIgnoreCase(req.getUserName())){
    		System.out.println("Server accept client subscript req:["+req.toString()+"]");
    		ctx.writeAndFlush(resp(req.getSubReqID()));
    		
    	}
    	
    	
    }
	
	private SubscribeResp resp(int subReqID){
		SubscribeResp resp=new SubscribeResp();
		resp.setSubReqID(subReqID);
		resp.setRespCode(0);
		resp.setDesc("Netty book order succeed,3 days later ,sent to the designated address");
		return resp;
			
	}
	public void exceptionCaught(ChannelHandlerContext ctx,Throwable cause){
		cause.printStackTrace();
		ctx.close();
		
	}
	
}
客户端开发:将Netty对象解码器和编码器添加到ChannelPipline中,链路被激活的时候构造订购请求消息发送,为了检验Netty的java序列化功能是否支持TCP粘包/拆包,客户端一次构造10条订购请求,最后一次性发送给服务端,客户端订购处理handler将接受到的订购响应消息打印出来.

产品订购客户端:

public class SubReqClient {
     public void connect(int port,String host)throws Exception{
    	 //配置客户端NIO 线程组
    	 EventLoopGroup group=new NioEventLoopGroup();
    	 
    	 try {
    		  Bootstrap b=new Bootstrap();
        	  b.group(group).channel(NioSocketChannel.class)
        	  .option(ChannelOption.TCP_NODELAY,true)
        	  .handler(new ChannelInitializer<SocketChannel>() {

    			@Override
    			protected void initChannel(SocketChannel arg0) throws Exception {
    				arg0.pipeline().addLast(new ObjectDecoder(1024,ClassResolvers.cacheDisabled(this.getClass().getClassLoader())));
    				arg0.pipeline().addLast(new ObjectEncoder());
    				arg0.pipeline().addLast(new SubReqClientHandler());
    			}
        		  
    		});
        	  //发起异步链接操作
        	 ChannelFuture f=b.connect(host,port).sync();
        	  //等待客户端链路关闭
        	 f.channel().closeFuture().sync();
        	  
        	  
        	  
		} finally{
			//优雅的退出,释放NIO线程组
			group.shutdownGracefully();
		}
    	
    	 
    	 
    	 
    	 
     }
     public static void main(String[] args) throws Exception {
		int port=8088;
		if(args!=null&&args.length>0){
			try {
				port=Integer.valueOf(args[0]);
			} catch (Exception e) {
				// TODO: handle exception
			}
		}
    	 
    	 new SubReqClient().connect(port, "127.0.0.1");
    	 
    	 
	}
     
}
客户端处理类:

public class SubReqClientHandler extends ChannelHandlerAdapter{
       public SubReqClientHandler(){}
       
       
       public void channelActive(ChannelHandlerContext ctx){
    	   for(int i=0;i<10;i++){
    		   ctx.write(subReq(i));//写入10条记录
    	   }
    	   ctx.flush();//最后一次性发送 
       }
       private SubscribeReq subReq(int i){
    	   SubscribeReq req=new SubscribeReq();
    	   req.setAddress("武汉东湖新技术开发区");
    	   req.setPhoneNumber("121324343535");
    	   req.setProductName("Netty权威指南");
    	   req.setSubReqID(i);
    	   req.setUserName("Mryang");
    	   return req;
       }
       public void channelRead(ChannelHandlerContext ctx,Object msg)throws Exception{
    	   System.out.println("Receive server response:["+msg+"]");
    	   
       }
       public void channelReadComplete(ChannelHandlerContext ctx)throws Exception{
    	   ctx.flush();
       }
       public void exceptionCaght(ChannelHandlerContext ctx,Throwable cause){
    	   cause.printStackTrace();
    	   ctx.close();
       }
}





相关文章
|
5月前
|
存储 Java
【IO面试题 四】、介绍一下Java的序列化与反序列化
Java的序列化与反序列化允许对象通过实现Serializable接口转换成字节序列并存储或传输,之后可以通过ObjectInputStream和ObjectOutputStream的方法将这些字节序列恢复成对象。
|
1月前
|
JSON 算法 Java
Nettyの网络聊天室&扩展序列化算法
通过本文的介绍,我们详细讲解了如何使用Netty构建一个简单的网络聊天室,并扩展序列化算法以提高数据传输效率。Netty的高性能和灵活性使其成为实现各种网络应用的理想选择。希望本文能帮助您更好地理解和使用Netty进行网络编程。
41 12
|
2月前
|
消息中间件 缓存 Java
java nio,netty,kafka 中经常提到“零拷贝”到底是什么?
零拷贝技术 Zero-Copy 是指计算机执行操作时,可以直接从源(如文件或网络套接字)将数据传输到目标缓冲区, 而不需要 CPU 先将数据从某处内存复制到另一个特定区域,从而减少上下文切换以及 CPU 的拷贝时间。
java nio,netty,kafka 中经常提到“零拷贝”到底是什么?
|
2月前
|
存储 安全 Java
🌟Java零基础-反序列化:从入门到精通
【10月更文挑战第21天】本文收录于「滚雪球学Java」专栏,专业攻坚指数级提升,希望能够助你一臂之力,帮你早日登顶实现财富自由🚀;同时,欢迎大家关注&&收藏&&订阅!持续更新中,up!up!up!!
104 5
|
2月前
|
存储 缓存 安全
🌟Java零基础:深入解析Java序列化机制
【10月更文挑战第20天】本文收录于「滚雪球学Java」专栏,专业攻坚指数级提升,希望能够助你一臂之力,帮你早日登顶实现财富自由🚀;同时,欢迎大家关注&&收藏&&订阅!持续更新中,up!up!up!!
39 3
|
2月前
|
存储 安全 Java
Java编程中的对象序列化与反序列化
【10月更文挑战第22天】在Java的世界里,对象序列化和反序列化是数据持久化和网络传输的关键技术。本文将带你了解如何在Java中实现对象的序列化与反序列化,并探讨其背后的原理。通过实际代码示例,我们将一步步展示如何将复杂数据结构转换为字节流,以及如何将这些字节流还原为Java对象。文章还将讨论在使用序列化时应注意的安全性问题,以确保你的应用程序既高效又安全。
|
4月前
|
JSON NoSQL Java
redis的java客户端的使用(Jedis、SpringDataRedis、SpringBoot整合redis、redisTemplate序列化及stringRedisTemplate序列化)
这篇文章介绍了在Java中使用Redis客户端的几种方法,包括Jedis、SpringDataRedis和SpringBoot整合Redis的操作。文章详细解释了Jedis的基本使用步骤,Jedis连接池的创建和使用,以及在SpringBoot项目中如何配置和使用RedisTemplate和StringRedisTemplate。此外,还探讨了RedisTemplate序列化的两种实践方案,包括默认的JDK序列化和自定义的JSON序列化,以及StringRedisTemplate的使用,它要求键和值都必须是String类型。
redis的java客户端的使用(Jedis、SpringDataRedis、SpringBoot整合redis、redisTemplate序列化及stringRedisTemplate序列化)
|
3月前
|
存储 Java
Java编程中的对象序列化与反序列化
【10月更文挑战第9天】在Java的世界里,对象序列化是连接数据持久化与网络通信的桥梁。本文将深入探讨Java对象序列化的机制、实践方法及反序列化过程,通过代码示例揭示其背后的原理。从基础概念到高级应用,我们将一步步揭开序列化技术的神秘面纱,让读者能够掌握这一强大工具,以应对数据存储和传输的挑战。
|
3月前
|
存储 安全 Java
Java编程中的对象序列化与反序列化
【10月更文挑战第3天】在Java编程的世界里,对象序列化与反序列化是实现数据持久化和网络传输的关键技术。本文将深入探讨Java序列化的原理、应用场景以及如何通过代码示例实现对象的序列化与反序列化过程。从基础概念到实践操作,我们将一步步揭示这一技术的魅力所在。
|
3月前
|
消息中间件 存储 Java
大数据-58 Kafka 高级特性 消息发送02-自定义序列化器、自定义分区器 Java代码实现
大数据-58 Kafka 高级特性 消息发送02-自定义序列化器、自定义分区器 Java代码实现
80 3

热门文章

最新文章