今夜不加班，從緊張的工作節奏中釋放了下，打開微信跟之前美女同事（未婚）嘮嗑了兩下，哎呦沒話題，那搞點啥呢？無聊中..........- 算了 記錄下這段時間的辛酸旅程，總結下物聯網的基礎，以此紀念9年的編程生活。
編程俠
（springboot版）netty服務端創建:
開啟netty線程
public class BootNettyServer {
public void bind(int port) {
/**
* 配置服務端的NIO線程組
* NioEventLoopGroup 是用來處理I/O操作的Reactor線程組
* bossGroup：用來接收進來的連接，workerGroup：用來處理已經被接收的連接,進行socketChannel的網絡讀寫，
* bossGroup接收到連接後就會把連接信息註冊到workerGroup
* workerGroup的EventLoopGroup默認的線程數是CPU核數的二倍
*/
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
/**
* ServerBootstrap 是一個啟動NIO服務的輔助啟動類
*/
ServerBootstrap serverBootstrap = new ServerBootstrap();
/**
* 設置group，將bossGroup， workerGroup線程組傳遞到ServerBootstrap
*/
serverBootstrap = serverBootstrap.group(bossGroup, workerGroup);
/**
* ServerSocketChannel是以NIO的selector為基礎進行實現的，用來接收新的連接，這裡告訴Channel通過NioServerSocketChannel獲取新的連接
*/
serverBootstrap = serverBootstrap.channel(NioServerSocketChannel.class);
/**
* option是設置 bossGroup，childOption是設置workerGroup
* netty 默認數據包傳輸大小為1024字節, 設置它可以自動調整下一次緩衝區建立時分配的空間大小，避免內存的浪費 最小 初始化 最大 (根據生產環境實際情況來定)
* 使用對象池，重用緩衝區
*/
serverBootstrap = serverBootstrap.option(ChannelOption.RCVBUF_ALLOCATOR, new AdaptiveRecvByteBufAllocator(64, 10496, 1048576));
serverBootstrap = serverBootstrap.childOption(ChannelOption.RCVBUF_ALLOCATOR, new AdaptiveRecvByteBufAllocator(64, 10496, 1048576));
/**
* 設置 I/O處理類,主要用於網絡I/O事件，記錄日誌，編碼、解碼消息
*/
serverBootstrap = serverBootstrap.childHandler(new BootNettyChannelInitializer());
/**
* 綁定端口，同步等待成功
*/
ChannelFuture f = serverBootstrap.bind(port).sync();
/**
* 等待服務器監聽端口關閉
*/
f.channel().closeFuture().sync();
} catch (InterruptedException e) {
} finally {
/**
* 退出，釋放線程池資源
*/
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}
/**
* 通道初始化
* @author Administrator
*
*/
public class BootNettyChannelInitializer extends ChannelInitializer<channel>{/<channel>
@Override
protected void initChannel(Channel ch) throws Exception {
// TODO Auto-generated method stub
// ChannelOutboundHandler，依照逆序執行
ch.pipeline().addLast("encoder", new StringEncoder());
// 屬於ChannelInboundHandler，依照順序執行
ch.pipeline().addLast("decoder", new StringDecoder());
/**
* 自定義ChannelInboundHandlerAdapter
*/
ch.pipeline().addLast(new BootNettyChannelInboundHandlerAdapter());
}
}
/**
* handler 過濾器
* @author Administrator
*
*/
public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandlerAdapter{
/**
* 從客戶端收到新的數據時，這個方法會在收到消息時被調用
*
* @param ctx
* @param msg
*/
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception, IOException
{
System.out.println("channelRead:read msg:"+msg.toString());
//回應客戶端
ctx.write("I got it");
}
/**
* 從客戶端收到新的數據、讀取完成時調用
*
* @param ctx
*/
@Override
public void channelReadComplete(ChannelHandlerContext ctx) throws IOException
{
System.out.println("channelReadComplete");
ctx.flush();
}
/**
* 當出現 Throwable 對象才會被調用，即當 Netty 由於 IO 錯誤或者處理器在處理事件時拋出的異常時
*
* @param ctx
* @param cause
*/
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws IOException
{
System.out.println("exceptionCaught");
cause.printStackTrace();
ctx.close();//拋出異常，斷開與客戶端的連接
}
/**
* 客戶端與服務端第一次建立連接時 執行
*
* @param ctx
* @throws Exception
*/
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception, IOException
{
super.channelActive(ctx);
ctx.channel().read();
InetSocketAddress insocket = (InetSocketAddress) ctx.channel().remoteAddress();
String clientIp = insocket.getAddress().getHostAddress();
//此處不能使用ctx.close()，否則客戶端始終無法與服務端建立連接
System.out.println("channelActive:"+clientIp+ctx.name());
}
/**
* 客戶端與服務端 斷連時 執行
*
* @param ctx
* @throws Exception
*/
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception, IOException
{
super.channelInactive(ctx);
InetSocketAddress insocket = (InetSocketAddress) ctx.channel().remoteAddress();
String clientIp = insocket.getAddress().getHostAddress();
ctx.close(); //斷開連接時，必須關閉，否則造成資源浪費，併發量很大情況下可能造成宕機
System.out.println("channelInactive:"+clientIp);
}
/**
* 服務端當read超時, 會調用這個方法
*
* @param ctx
* @param evt
* @throws Exception
*/
@Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception, IOException
{
super.userEventTriggered(ctx, evt);
InetSocketAddress insocket = (InetSocketAddress) ctx.channel().remoteAddress();
String clientIp = insocket.getAddress().getHostAddress();
ctx.close();//超時時斷開連接
System.out.println("userEventTriggered:"+clientIp);
}
}
以上是netty的服務端創建內容，應用場景: 當多傳感器(支持多規約)向服務器端傳遞，接收數據類。下一篇將講述netty下 如果處理 tcp 拆包的問題。
閱讀更多 編程俠 的文章
