外行人也能看懂的Netty开发教程(1)-第一次接触

package io.netty.example.discard;

import io.netty.buffer.ByteBuf;

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

/**
 * 处理服务端的channel.
 *
 * DiscardServerHandler继承ChannelInboundHandlerAdapter(ChannelInboundHandler的实现)
 * ChannelInboundHandler提供了可重写的各种事件处理器方法
 * 现在，仅扩展ChannelInboundHandlerAdapter即可，而不是自己实现处理器接口
 */
public class DiscardServerHandler extends ChannelInboundHandlerAdapter { /** * 当有事件发生时，会调用 * 这里重写channelRead事件处理器方法。每当从客户端接收到新数据时，就使用接收到的消息来调用此方法 * 此示例中，接收到的消息的类型为ByteBuf */ @Override public void channelRead(ChannelHandlerContext ctx, Object msg) { /** * ByteBuf是个引用计数对象，必须通过release显式释放。 * 释放传递给处理程序的引用计数对象都是处理程序的责任！！！ * * 一般channelRead处理器方法的实现如下： * @Override * public void channelRead(ChannelHandlerContext ctx, Object msg) { * try { * // 处理 msg * } finally { * ReferenceCountUtil.release(msg); * } * } */ ByteBuf byteBuf = (ByteBuf) msg; try { int count = byteBuf.readableBytes(); byte[] content = new byte[count]; byteBuf.readBytes(content); System.out.println(new String(content)); } finally { byteBuf.release(); } } /** * 当Netty由于I/O错误、处理器的实现类处理事件时抛异常 * 将使用Throwable调用exceptionCaught事件处理器方法 * 在大多数情况下，应该记录捕获的异常并在此处关闭其关联的通道，尽管此方法的实现可能会有所不同，具体取决于您要处理特殊情况时要采取的措施 * 例如，您可能想在关闭连接之前发送带有错误代码的响应消息。 */ @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { // 引发异常时关闭连接 cause.printStackTrace(); ctx.close(); }
}

  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
  
30
  
31
  
32
  
33
  
34
  
35
  
36
  
37
  
38
  
39
  
40
  
41
  
42
  
43
  
44
  
45
  
46
  
47
  
48
  
49
  
50
  
51
  
52
  
53
  
54
  
55
  
56
  
57
  
58
  
59
  
60
  
61
 

文章来源: javaedge.blog.csdn.net，作者：JavaEdge.，版权归原作者所有，如需转载，请联系作者。

原文链接：javaedge.blog.csdn.net/article/details/117401188