Java NIO框架Netty课程(三) 字符串消息收发（转）

Java NIO框架Netty教程(三) 字符串消息收发（转）

?

?

Netty中的消息传递，都必须以字节的形式，以ChannelBuffer为载体传递。简单的说，就是你想直接写个字符串过去，对不起，抛异常。虽然，Netty定义的writer的接口参数是Object的，这可能也是会给新上手的朋友容易造成误会的地方。Netty源码中，是这样判断的：

?所以，我们要想传递字符串，那么就必须转换成ChannelBuffer。明确了这一点，接下来我们上代码：
?
/*** @author lihzh* @alia OneCoder* @blog http://www.coderli.com*/public class MessageServer { public static void main(String args[]) {// Server服务启动器ServerBootstrap bootstrap = new ServerBootstrap(new NioServerSocketChannelFactory(Executors.newCachedThreadPool(),Executors.newCachedThreadPool()));// 设置一个处理客户端消息和各种消息事件的类(Handler)bootstrap.setPipelineFactory(new ChannelPipelineFactory() {@Overridepublic ChannelPipeline getPipeline() throws Exception {return Channels.pipeline(new MessageServerHandler());}});// 开放8000端口供客户端访问。bootstrap.bind(new InetSocketAddress(8000));} private static class MessageServerHandler extends SimpleChannelHandler { /*** 用户接受客户端发来的消息，在有客户端消息到达时触发** @author lihzh* @alia OneCoder*/@Overridepublic void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {ChannelBuffer buffer = (ChannelBuffer) e.getMessage();System.out.println(buffer.toString(Charset.defaultCharset()));} }}/*** @author lihzh* @alia OneCoder* @blog http://www.coderli.com*/public class MessageClient { public static void main(String args[]) {// Client服务启动器ClientBootstrap bootstrap = new ClientBootstrap(new NioClientSocketChannelFactory(Executors.newCachedThreadPool(),Executors.newCachedThreadPool()));// 设置一个处理服务端消息和各种消息事件的类(Handler)bootstrap.setPipelineFactory(new ChannelPipelineFactory() {@Overridepublic ChannelPipeline getPipeline() throws Exception {return Channels.pipeline(new MessageClientHandler());}});// 连接到本地的8000端口的服务端bootstrap.connect(new InetSocketAddress("127.0.0.1", 8000));} private static class MessageClientHandler extends SimpleChannelHandler { /*** 当绑定到服务端的时候触发，给服务端发消息。** @alia OneCoder* @author lihzh*/@Overridepublic void channelConnected(ChannelHandlerContext ctx,ChannelStateEvent e) {// 将字符串，构造成ChannelBuffer，传递给服务端String msg = "Hello, I'm client.";ChannelBuffer buffer = ChannelBuffers.buffer(msg.length());buffer.writeBytes(msg.getBytes());e.getChannel().write(buffer);}} }
?
与 “Hello World(http://www.it165.net/pro/html/201207/3142.html)” 样例代码不同的是，客户端在channel连通后，不是在本地打印，而是将消息转换成ChannelBuffer传递给服务端，服务端接受到ChannelBuffer后，解码成字符串打印出来。

同时，通过对比可以发现，变动的只是Handler里的代码，启动服务和绑定服务的代码没有变化，也就是我们在概念介绍里提到了，关注Handler，在Handler里处理我们自己的业务。所以，以后我们会只给出业务中关键代码，不会在上重复的代码：）

由于在Netty中消息的收发全依赖于ChannelBuffer，所以，下一章我们将会详细的介绍ChannelBuffer的使用。我们一起学习。