7.3 ?netty3基本使用

 1 package com.hulk.netty.server; 2 ?3 import org.jboss.netty.bootstrap.ServerBootstrap; 4 import org.jboss.netty.channel.*; 5 import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory; 6 import org.jboss.netty.handler.codec.string.StringDecoder; 7 import org.jboss.netty.handler.codec.string.StringEncoder; 8 ?9 import java.net.InetSocketAddress;10 import java.util.concurrent.Executors;11 12 public class Server {13 ????public void start(){14 ????????ChannelFactory factory = new NioServerSocketChannelFactory(15 ????????????????Executors.newCachedThreadPool(),//boss线程池16 ????????????????Executors.newCachedThreadPool(),//worker线程池17 ????????????????8//worker线程数18 ????????);19 ????????ServerBootstrap bootstrap = new ServerBootstrap(factory);20 ????????/**21 ?????????* 对于每一个连接channel, server都会调用PipelineFactory为该连接创建一个ChannelPipline22 ?????????*/23 ????????bootstrap.setPipelineFactory(new ChannelPipelineFactory() {24 ????????????public ChannelPipeline getPipeline() throws Exception {25 ????????????????ChannelPipeline pipeline = Channels.pipeline();26 ????????????????pipeline.addLast("decoder", new StringDecoder());27 ????????????????pipeline.addLast("encoder", new StringEncoder());28 ????????????????pipeline.addLast("handler", new ServerLogicHandler());29 ????????????????return pipeline;30 ????????????}31 ????????});32 33 ????????Channel channel = bootstrap.bind(new InetSocketAddress("127.0.0.1", 8080));34 ????????System.out.println("server start success!");35 ????}36 37 ????public static void main(String[] args) throws InterruptedException {38 ????????Server server = new Server();39 ????????server.start();40 ????????Thread.sleep(Integer.MAX_VALUE);41 ????}42 }

 1 package com.hulk.netty.server; 2 ?3 import org.jboss.netty.channel.Channel; 4 import org.jboss.netty.channel.ChannelHandlerContext; 5 import org.jboss.netty.channel.ChannelStateEvent; 6 import org.jboss.netty.channel.ExceptionEvent; 7 import org.jboss.netty.channel.MessageEvent; 8 import org.jboss.netty.channel.SimpleChannelHandler; 9 10 public class ServerLogicHandler extends SimpleChannelHandler {11 ????@Override12 ????public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {13 ????????System.out.println("连接成功, channel: " + e.getChannel().toString());14 ????}15 16 ????@Override17 ????public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {18 ????????String msg = (String) e.getMessage();19 ????????System.out.println("接收到了client的消息, msg: " + msg);20 21 ????????Channel channel = e.getChannel();22 ????????String str = "hi, client";23 24 ????????channel.write(str);//写消息发给client端25 ????????System.out.println("服务端发送数据: " + str + "完成");26 ????}27 28 ????@Override29 ????public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {30 ????????e.getCause().printStackTrace();31 ????????e.getChannel().close();32 ????}33 }

 1 package com.hulk.netty.client; 2 ?3 import org.jboss.netty.bootstrap.ClientBootstrap; 4 import org.jboss.netty.channel.ChannelFactory; 5 import org.jboss.netty.channel.ChannelPipeline; 6 import org.jboss.netty.channel.ChannelPipelineFactory; 7 import org.jboss.netty.channel.Channels; 8 import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory; 9 import org.jboss.netty.handler.codec.string.StringDecoder;10 import org.jboss.netty.handler.codec.string.StringEncoder;11 12 import java.net.InetSocketAddress;13 import java.util.concurrent.Executors;14 15 public class Client {16 ????public static void main(String[] args) {17 ????????ChannelFactory factory = new NioClientSocketChannelFactory(18 ????????????????Executors.newCachedThreadPool(),19 ????????????????Executors.newCachedThreadPool(),20 ????????????????821 ????????);22 ????????ClientBootstrap bootstrap = new ClientBootstrap(factory);23 ????????bootstrap.setPipelineFactory(new ChannelPipelineFactory() {24 ????????????public ChannelPipeline getPipeline() throws Exception {25 ????????????????ChannelPipeline pipeline = Channels.pipeline();26 ????????????????pipeline.addLast("decoder", new StringDecoder());27 ????????????????pipeline.addLast("encoder", new StringEncoder());28 ????????????????pipeline.addLast("handler", new ClientLogicHandler());29 ????????????????return pipeline;30 ????????????}31 ????????});32 33 ????????bootstrap.connect(new InetSocketAddress("127.0.0.1", 8080));34 ????????System.out.println("client start success!");35 ????}36 }

 1 package com.hulk.netty.client; 2 ?3 import org.jboss.netty.channel.ChannelHandlerContext; 4 import org.jboss.netty.channel.ChannelStateEvent; 5 import org.jboss.netty.channel.ExceptionEvent; 6 import org.jboss.netty.channel.MessageEvent; 7 import org.jboss.netty.channel.SimpleChannelHandler; 8 import org.jboss.netty.channel.WriteCompletionEvent; 9 10 public class ClientLogicHandler extends SimpleChannelHandler {11 ????@Override12 ????public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {13 ????????System.out.println("客户端连接成功!");14 ????????String str = "hi server!";15 ????????e.getChannel().write(str);//异步16 ????}17 18 ????@Override19 ????public void writeComplete(ChannelHandlerContext ctx, WriteCompletionEvent e) throws Exception {20 ????????System.out.println("客户端写消息完成");21 ????}22 23 ????@Override24 ????public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {25 ????????String msg = (String) e.getMessage();26 ????????System.out.println("客户端接收到消息, msg: " + msg);27 ????}28 29 ????@Override30 ????public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {31 ????????e.getCause().printStackTrace();32 ????????e.getChannel().close();33 ????}34 }