/*
?*?Copyright?2012?The?Netty?Project
?*
?*?The?Netty?Project?licenses?this?file?to?you?under?the?Apache?License
?*?version?2.0?（the?“License“）;?you?may?not?use?this?file?except?in?compliance
?*?with?the?License.?You?may?obtain?a?copy?of?the?License?at:
?*
?*???http://www.apache.org/licenses/LICENSE-2.0
?*
?*?Unless?required?by?applicable?law?or?agreed?to?in?writing?software
?*?distributed?under?the?License?is?distributed?on?an?“AS?IS“?BASIS?WITHOUT
?*?WARRANTIES?OR?CONDITIONS?OF?ANY?KIND?either?express?or?implied.?See?the
?*?License?for?the?specific?language?governing?permissions?and?limitations
?*?under?the?License.
?*/
package?org.angel_lee.io.client;

import?io.netty.bootstrap.Bootstrap;
import?io.netty.channel.ChannelFuture;
import?io.netty.channel.ChannelInitializer;
import?io.netty.channel.ChannelOption;
import?io.netty.channel.ChannelPipeline;
import?io.netty.channel.EventLoopGroup;
import?io.netty.channel.nio.NioEventLoopGroup;
import?io.netty.channel.socket.SocketChannel;
import?io.netty.channel.socket.nio.NioSocketChannel;
import?io.netty.handler.codec.bytes.ByteArrayEncoder;
import?io.netty.handler.ssl.SslContext;
import?io.netty.handler.ssl.util.InsecureTrustManagerFactory;
import?io.netty.handler.stream.ChunkedWriteHandler;

/**
?*?Sends?one?message?when?a?connection?is?open?and?echoes?back?any?received
?*?data?to?the?server.??Simply?put?the?echo?client?initiates?the?ping-pong
?*?traffic?between?the?echo?client?and?server?by?sending?the?first?message?to
?*?the?server.
?*/
public?final?class?EchoClient?{

????static?final?boolean?SSL?=?System.getProperty（“ssl“）?!=?null;
????static?final?String?HOST?=?System.getProperty（“host“?“127.0.0.1“）;
????static?final?int?PORT?=?Integer.parseInt（System.getProperty（“port“?“8007“））;
????static?final?int?SIZE?=?Integer.parseInt（System.getProperty（“size“?“256“））;

????public?static?void?main（String[]?args）?throws?Exception?{
????????//?Configure?SSL.git
????????final?SslContext?sslCtx;
????????if?（SSL）?{
????????????sslCtx?=?SslContext.newClientContext（InsecureTrustManagerFactory.INSTANCE）;
????????}?else?{
????????????sslCtx?=?null;
????????}

????????//?Configure?the?client.
????????EventLoopGroup?group?=?new?NioEventLoopGroup（）;
????????try?{
????????????Bootstrap?b?=?new?Bootstrap（）;
????????????b.group（group）
?????????????.channel（NioSocketChannel.class）
?????????????.option（ChannelOption.TCP_NODELAY?true）
?????????????.handler（new?ChannelInitializer（）?{
?????????????????@Override
?????????????????public?void?initChannel（SocketChannel?ch）?throws?Exception?{
?????????????????????ChannelPipeline?p?=?ch.pipeline（）;
?????????????????????if?（sslCtx?!=?null）?{
?????????????????????????p.addLast（sslCtx.newHandler（ch.alloc（）?HOST?PORT））;
?????????????????????}
?????????????????????p.addLast（
????????????????????		?new?ByteArrayEncoder（）
????????????????????		?new?ChunkedWriteHandler（）
????????????????????		?new?EchoClientHandler（））;
?????????????????}
?????????????}）;
?????

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????文件????????3311??2014-10-27?17:30??netty\src\org\angel_lee\io\client\EchoClient.java
?????文件????????2261??2014-10-29?10:13??netty\src\org\angel_lee\io\client\EchoClientHandler.java
?????文件????????2117??2014-10-29?10:07??netty\src\org\angel_lee\io\server\EchoServer.java
?????文件????????2785??2014-10-29?10:22??netty\src\org\angel_lee\io\server\EchoServerHandler.java