了解了Netty的基本概念(http://www.it165.net/pro/html/201207/3173.html)，开发起来应该会顺手很多。 在“Hello World(http://www.it165.net/pro/html/201207/3142.html)”代码中，我们只是在完成绑定的时候，在各自的本地打印了简单的信息，并没有客户端和服务端的消息传递。这个肯定是最基本的功能。在上代码之前，先补充一个Netty中重要的概念，ChannelBuffer.
ChannelBuffer
Netty中的消息传递，都必须以字节的形式，以ChannelBuffer为载体传递。简单的说，就是你想直接写个字符串过去，对不起，抛异常。虽然，Netty定义的writer的接口参数是Object的，这可能也是会给新上手的朋友容易造成误会的地方。Netty源码中，是这样判断的：
Java代码
SendBuffer acquire(Object message) {
1.
1.
if (message
instanceof ChannelBuffer) {
1.
1.
return acquire((ChannelBuffer) message);
1.
1.
}
else
if (message
instanceof FileRegion) {
1.
1.
return acquire((FileRegion) message);
1.
1.
}
1.
1.
1.
1.
throw
new IllegalArgumentException(
1.
1.
"unsupported message type: " + message.getClass());
1.
1.
}
所以，我们要想传递字符串，那么就必须转换成ChannelBuffer。明确了这一点，接下来我们上代码：
Java代码
/**
1.
1.
* @author lihzh
1.
1.
* @alia OneCoder
1.
1.
* @blog http://www.coderli.com
1.
1.
*/
1.
1.
public
class MessageServer {
1.
1.
1.
1.
public
static
void main(String args[]) {
1.
1.
// Server服务启动器
1.
1.
ServerBootstrap bootstrap =
new ServerBootstrap(
1.
1.
new NioServerSocketChannelFactory(
1.
1.
Executors.newCachedThreadPool(),
1.
1.
Executors.newCachedThreadPool()));
1.
1.
// 设置一个处理客户端消息和各种消息事件的类(Handler)
1.
1.
bootstrap.setPipelineFactory(
new ChannelPipelineFactory() {
1.
1.
@Override
1.
1.
public ChannelPipeline getPipeline()
throws Exception {
1.
1.
return Channels.pipeline(
new MessageServerHandler());
1.
1.
}
1.
1.
});
1.
1.
// 开放8000端口供客户端访问。
1.
1.
bootstrap.bind(
new InetSocketAddress(
8000));
1.
1.
}
1.
1.
1.
1.
private
static
class MessageServerHandler
extends SimpleChannelHandler {
1.
1.
1.
1.
/**
1.
1.
* 用户接受客户端发来的消息，在有客户端消息到达时触发
1.
1.
*
1.
1.
* @author lihzh
1.
1.
* @alia OneCoder
1.
1.
*/
1.
1.
@Override
1.
1.
public
void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
1.
1.
ChannelBuffer buffer = (ChannelBuffer) e.getMessage();
1.
1.
System.out.println(buffer.toString(Charset.defaultCharset()));
1.
1.
}
1.
1.
1.
1.
}
1.
1.
}
1.
1.
/**
1.
1.
* @author lihzh
1.
1.
* @alia OneCoder
1.
1.
* @blog http://www.coderli.com
1.
1.
*/
1.
1.
public
class MessageClient {
1.
1.
1.
1.
public
static
void main(String args[]) {
1.
1.
// Client服务启动器
1.
1.
ClientBootstrap bootstrap =
new ClientBootstrap(
1.
1.
new NioClientSocketChannelFactory(
1.
1.
Executors.newCachedThreadPool(),
1.
1.
Executors.newCachedThreadPool()));
1.
1.
// 设置一个处理服务端消息和各种消息事件的类(Handler)
1.
1.
bootstrap.setPipelineFactory(
new ChannelPipelineFactory() {
1.
1.
@Override
1.
1.
public ChannelPipeline getPipeline()
throws Exception {
1.
1.
return Channels.pipeline(
new MessageClientHandler());
1.
1.
}
1.
1.
});
1.
1.
// 连接到本地的8000端口的服务端
1.
1.
bootstrap.connect(
new InetSocketAddress(
"127.0.0.1",
8000));
1.
1.
}
1.
1.
1.
1.
private
static
class MessageClientHandler
extends SimpleChannelHandler {
1.
1.
1.
1.
/**
1.
1.
* 当绑定到服务端的时候触发，给服务端发消息。
1.
1.
*
1.
1.
* @alia OneCoder
1.
1.
* @author lihzh
1.
1.
*/
1.
1.
@Override
1.
1.
public
void channelConnected(ChannelHandlerContext ctx,
1.
1.
ChannelStateEvent e) {
1.
1.
// 将字符串，构造成ChannelBuffer，传递给服务端
1.
1.
String msg =
"Hello, I'm client.";
1.
1.
ChannelBuffer buffer = ChannelBuffers.buffer(msg.length());
1.
1.
buffer.writeBytes(msg.getBytes());
1.
1.
e.getChannel().write(buffer);
1.
1.
}
1.
1.
}
1.
1.
1.
1.
}
与 “Hello World(http://www.it165.net/pro/html/201207/3142.html)” 样例代码不同的是，客户端在channel连通后，不是在本地打印，而是将消息转换成ChannelBuffer传递给服务端，服务端接受到ChannelBuffer后，解码成字符串打印出来。
同时，通过对比可以发现，变动的只是Handler里的代码，启动服务和绑定服务的代码没有变化，也就是我们在概念介绍里提到了，关注Handler，在Handler里处理我们自己的业务。所以，以后我们会只给出业务中关键代码，不会在上重复的代码：） 由于在Netty中消息的收发全依赖于ChannelBuffer，所以，下一章我们将会详细的介绍ChannelBuffer的使用。我们一起学习。
