《Netty权威指南》(一)简单的时间服务器P69

由于该书是基于Netty5编写的样例代码,而Netty5已经被官方废弃。

目前基于推荐版的4.1.12.Final在学习过程中,可能会出现个别接口不一致的情况。所以记录可在4.1.12下编译通过的代码

  1. package net.xjdsz.n;
  2. import io.netty.bootstrap.ServerBootstrap;
  3. import io.netty.buffer.ByteBuf;
  4. import io.netty.buffer.Unpooled;
  5. import io.netty.channel.*;
  6. import io.netty.channel.nio.NioEventLoopGroup;
  7. import io.netty.channel.socket.SocketChannel;
  8. import io.netty.channel.socket.nio.NioServerSocketChannel;
  9. import java.util.Date;
  10. /**
  11. * Created by dingshuo on 2017/6/14.
  12. */
  13. public class TimeServer {
  14. public void bind(int port) throws Exception{
  15. EventLoopGroup bossGroup=new NioEventLoopGroup();
  16. EventLoopGroup workerGroup=new NioEventLoopGroup();
  17. try{
  18. ServerBootstrap b=new ServerBootstrap();
  19. b.group(bossGroup,workerGroup)
  20. .channel(NioServerSocketChannel.class)
  21. .option(ChannelOption.SO_BACKLOG,1024)
  22. .childHandler(new ChannelInitializer<SocketChannel>() {
  23. @Override
  24. protected void initChannel(SocketChannel socketChannel) throws Exception {
  25. socketChannel.pipeline().addLast(new ChannelInboundHandlerAdapter(){
  26. @Override
  27. public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
  28. ByteBuf buf=(ByteBuf)msg;
  29. byte[] req=new byte[buf.readableBytes()];
  30. buf.readBytes(req);
  31. String body=new String(req,"UTF-8");
  32. System.out.println("收到数据:"+body);
  33. String currentTime=new Date(System.currentTimeMillis()).toString();
  34. ByteBuf resp= Unpooled.copiedBuffer(currentTime.getBytes());
  35. ctx.write(resp);
  36. }
  37. @Override
  38. public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
  39. ctx.flush();
  40. }
  41. @Override
  42. public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
  43. ctx.close();
  44. }
  45. });
  46. }
  47. });
  48. //绑定端口,同步等待成功
  49. ChannelFuture f=b.bind(port).sync();
  50. //等待服务端监听端口关闭
  51. f.channel().closeFuture().sync();
  52. }finally {
  53. //退出,释放资源
  54. bossGroup.shutdownGracefully();
  55. workerGroup.shutdownGracefully();
  56. }
  57. }
  58. public static void main(String[] args) throws Exception{
  59. TimeServer timeServer=new TimeServer();
  60. timeServer.bind(2000);
  61. }
  62. }
时间: 2024-10-21 03:20:18

《Netty权威指南》(一)简单的时间服务器P69的相关文章

Netty权威指南

Netty权威指南(异步非阻塞通信领域的经典之作,国内首本深入剖析Netty的著作,全面系统讲解原理.实战和源码,带你完美进阶Netty工程师.) 李林锋 著   ISBN 978-7-121-23343-2 2014年6月出版 定价:79.00元 524页 16开 编辑推荐 - 资深一线专家诚意之作,总结多年实践经验,带你全面掌握Java高并发异步通信的首选框架——Netty. - Facebook.阿里巴巴.1号店.并发编程网.JBoss等多位资深技术专家联名力荐. <Netty权威指南>

《Netty权威指南》私有协议开发的可运行源代码分享

之前看了<Netty权威指南>一书,第14章用整个章节介绍了如何设计和实现一个简单的私有协议,内容很好,但是作者提供的代码片段有很多错误,根本不可能正确编译. 比如MarshallingEncoder这个类是Netty提供了JBoss Marshalling的一个适配类,它的encode方法是protected,不是public,并且其中用到的ChannelBufferByteOutput类是包类可见,外部无法引用的.Netty只所以这么设计,是因为这个工具类不能直接被外部使用,只是给它内部

电子书 netty权威指南第2版.pdf

<Netty quanwei指南(第2 版)>是异步非阻塞通信领域的经典之作,基于全新版本的Netty 5.0 编写,是国内首本深入介绍Netty 原理和架构的书籍,也是作者多年实战经验的总结和浓缩.内容不仅包含Java NIO入门知识.Netty 的基础功能开发指导.编解码框架定制等,还包括私有协议栈定制和开发.Netty 核心类库源码分析,以及Netty 的架构剖析. 作者简介 李林峰,Netty中国推广者,现华为技术有限公司平台中间件架构与设计部设计师,公司总裁技术创新奖获得者.长期从事

基于netty的一个简单的时间服务器的实现(netty学习)

基本功能:与客户端建立连接后立刻发送当前时间 先建立一个时间的类 package timeExample; import java.sql.Date; public class UnixTime { private final long value; public UnixTime() { this(System.currentTimeMillis()/1000L); } public UnixTime(long value) { this.value = value; } public lon

netty权威指南 ---------第三章 入门应用

要实现的功能: client端发送请求,server端接受请求,返回当前时间,client端将当前时间打印出来. A :server端服务器 package com.xiaobing.netty.third; import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelInitializer; import io.netty.cha

《Netty权威指南》

一.基础篇 走进Java NIO 1. Java 的 I/O 演进之路 2. NIO 入门 2.1. 传统的 BIO 编程 2.2. 伪异步 I/O 编程 2.3. NIO 编程 2.4. AIO 编程 二.入门篇 Netty NIO 开发指南 3. Netty 入门应用 4. TCP 粘包/拆包问题的解决之道 5. 分隔符和定长解码器的应用 三.中级篇 Netty 编解码技术开发指南 6. 编解码技术 7. MessagePack 8. Google Protobuf 9. JBoss Mar

Netty权威指南之BIO通信模型

网络编程的基本模型是Client/Server模型,也就是两个进程之间进行相互通信,其中服务端提供位置信息(绑定的IP地址和监听端口),客户端通过连接操作向服务端监听的地址发起连接请求,通过三次握手建立连接,如果连接建立成功,双方就可以通过网络套接字(Socket)进行通信. 采用BIO通信模型的服务端,通常由一个独立的Acceptor线程负责监听客户端的连接,它接收到客户端连接请求之后为每个客户端创建一个新的线程进行链路处理,处理完成之后,通过输出流返回应答给客户,线程销毁. 该模型下,服务端

netty权威指南--------第四章TCP粘包/拆包问题

第三章中的示例用于功能测试一般没有问题,但当压力上来或者发送大报文时,就会存在粘包/拆包问题. 这时就需要使用LineBasedFrameDecoder+StringDecoder client端请求改为连续的100次 package com.xiaobing.netty.fourth; import java.net.SocketAddress; import org.omg.CORBA.Request; import io.netty.buffer.ByteBuf; import io.ne

Netty权威指南之Netty入门程序

package com.hjp.netty.netty; import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelOption; import io.netty.channel.EventLoopGroup; import io.netty.