首页 > Web开发 > 详细

netty socket 客服端编程

时间:2016-11-29 21:25:42      阅读:261      评论:0      收藏:0      [点我收藏+]
package com.ming.netty.nio;
 2 
 3 import io.netty.bootstrap.Bootstrap;
 4 import io.netty.channel.ChannelFuture;
 5 import io.netty.channel.ChannelInitializer;
 6 import io.netty.channel.ChannelOption;
 7 import io.netty.channel.EventLoopGroup;
 8 import io.netty.channel.nio.NioEventLoopGroup;
 9 import io.netty.channel.socket.SocketChannel;
10 import io.netty.channel.socket.nio.NioSocketChannel;
11 
12 /**
13  * netty 客户端模拟
14  * @author mingge
15  *
16  */
17 public class TimeClient {
18     
19     
20     public static void main(String[] args) throws Exception{
21         new TimeClient().connect("127.0.0.1", 8400);
22     }
23 
24     public void connect(String addr,int port) throws Exception{
25         EventLoopGroup group=new NioEventLoopGroup();
26         try {
27             Bootstrap b=new Bootstrap();
28             b.group(group).channel(NioSocketChannel.class)
29             .option(ChannelOption.TCP_NODELAY, true)
30             .handler(new ChannelInitializer<SocketChannel>() {
31                 public void initChannel(SocketChannel ch) throws Exception{
32                     ch.pipeline().addLast(new TimeClientHandler());
33                 }
34             });
35             ChannelFuture f=b.connect(addr,port);
36             f.channel().closeFuture().sync();//等待客户端关闭连接
37         } catch (Exception e) {
38             // TODO: handle exception
39         }finally{
40             group.shutdownGracefully();
41         }
42     }
43 }
技术分享
技术分享
 1 package com.ming.netty.nio;
 2 
 3 import io.netty.buffer.ByteBuf;
 4 import io.netty.buffer.Unpooled;
 5 import io.netty.channel.ChannelHandlerAdapter;
 6 import io.netty.channel.ChannelHandlerContext;
 7 
 8 public class TimeClientHandler extends ChannelHandlerAdapter {
 9     
10     private final ByteBuf byteMsg;
11     
12     public TimeClientHandler() {
13         byte[] req="我是请求数据哦".getBytes();
14         byteMsg=Unpooled.buffer(req.length);
15         byteMsg.writeBytes(req);
16     }
17 
18     @Override
19     public void channelActive(ChannelHandlerContext ctx) throws Exception {
20         ctx.writeAndFlush(byteMsg);
21     }
22 
23     @Override
24     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
25         ByteBuf buf=(ByteBuf)msg;
26         byte[] req=new byte[buf.readableBytes()];
27         buf.readBytes(req);
28         String body=new String(req,"GBK");
29         System.out.println("body:"+body);
30     }
31 
32     @Override
33     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
34         //释放资源
35         ctx.close();
36     }
37 
38     
39 }

netty socket 客服端编程

原文:http://www.cnblogs.com/kabi/p/6115105.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!