Java NIO框架Netty教程（四）- ChannelBuffer

1/**
2 * @author lihzh
3 * @alia OneCoder
4 * @blog http://www.coderli.com
5 */
6public class ServerBufferHandler extends SimpleChannelHandler {
7	
8	/**
9	 * 用户接受客户端发来的消息，在有客户端消息到达时触发
10	 * 
11	 * @author lihzh
12	 * @alia OneCoder
13	 */
14	@Override
15	public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
16		ChannelBuffer buffer = (ChannelBuffer) e.getMessage();
17		// 五位读取
18		while (buffer.readableBytes() >= 5) {
19			ChannelBuffer tempBuffer = buffer.readBytes(5);
20			System.out.println(tempBuffer.toString(Charset.defaultCharset()));
21		}
22		// 读取剩下的信息
23		System.out.println(buffer.toString(Charset.defaultCharset()));
24	}
25
26}
27

1/**
2 * @author lihzh
3 * @alia OneCoder
4 * @blog http://www.coderli.com
5 */
6public class ClientBufferHandler extends SimpleChannelHandler {
7
8	/**
9	 * 当绑定到服务端的时候触发，给服务端发消息。
10	 * 
11	 * @alia OneCoder
12	 * @author lihzh
13	 */
14	@Override
15	public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) {
16		// 分段发送信息
17		sendMessageByFrame(e);
18	}
19
20	/**
21	 * 将<b>"Hello, I'm client."</b>分成三份发送。 <br>
22	 * Hello, <br>
23	 * I'm<br>
24	 * client.<br>
25	 * 
26	 * @param e
27	 *            Netty事件
28	 * @author lihzh
29	 */
30	private void sendMessageByFrame(ChannelStateEvent e) {
31		String msgOne = "Hello, ";
32		String msgTwo = "I'm ";
33		String msgThree = "client.";
34		e.getChannel().write(tranStr2Buffer(msgOne));
35		e.getChannel().write(tranStr2Buffer(msgTwo));
36		e.getChannel().write(tranStr2Buffer(msgThree));
37	}
38
39	/**
40	 * 将字符串转换成{@link ChannelBuffer}，私有方法不进行字符串的非空判断。
41	 * 
42	 * @param str
43	 *            待转换字符串，要求非null
44	 * @return 转换后的ChannelBuffer
45	 * @author lihzh
46	 */
47	private ChannelBuffer tranStr2Buffer(String str) {
48		ChannelBuffer buffer = ChannelBuffers.buffer(str.length());
49		buffer.writeBytes(str.getBytes());
50		return buffer;
51	}
52
53}
54

1Hello
2, I'm
3 clie
4nt.
5