Netty权威指南-NIO实现TimeClient客户端源代码
2016-01-23 18:19
281 查看
package com.jianweigang.NIO; import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.channels.SocketChannel; import java.util.Iterator; import java.util.Set; public class TimeClient { private static int DEFAULT_PORT = 8080; public static void main(String[] args) throws IOException { int port = 8080; if(args != null && args.length > 0 ) { try { port = Integer.valueOf(args[0]); }catch(NumberFormatException e){ //如果没有传,那我们就使用默认的端口 port = DEFAULT_PORT; } } //单独启动一个线程 new Thread(new TimeClientHandle("127.0.0.1", port), "TimeClient-001").start(); } } class TimeClientHandle implements Runnable{ private String host; private int port; private Selector selector; private SocketChannel socketChannel; private volatile boolean stop; public TimeClientHandle(String host, int port) { this.host = host == null ? "127.0.0.1" : host; this.port = port; try { selector = Selector.open(); socketChannel = SocketChannel.open(); socketChannel.configureBlocking(false); // socketChannel.register(selector, SelectionKey.OP_READ); } catch (IOException e) { e.printStackTrace(); System.exit(1); } } public void run() { // TODO Auto-generated method stub try { doConnect(); } catch (IOException e) { e.printStackTrace(); System.exit(1); } while(!stop) { try { selector.select(1000); Set<SelectionKey> selectedKeys = selector.selectedKeys(); Iterator<SelectionKey> it = selectedKeys.iterator(); SelectionKey key = null; while(it.hasNext()) { key = it.next(); it.remove(); try { handleInput(key); }catch(Exception e) { if (key != null) { key.cancel(); if (key.channel() != null) key.channel().close(); } } } }catch(Exception e){ } } // 多路复用器关闭后,所有注册在上面的Channel和Pipe等资源都会被自动去注册并关闭,所以不需要重复释放资源 if (selector != null) try { selector.close(); } catch (IOException e) { e.printStackTrace(); } } private void handleInput(SelectionKey key) throws IOException { if (key.isValid()) { // 判断是否连接成功 SocketChannel sc = (SocketChannel) key.channel(); if (key.isConnectable()) { if (sc.finishConnect()) { sc.register(selector, SelectionKey.OP_READ); doWrite(sc); } else System.exit(1);// 连接失败,进程退出 } if (key.isReadable()) { ByteBuffer readBuffer = ByteBuffer.allocate(1024); int readBytes = sc.read(readBuffer); if (readBytes > 0) { readBuffer.flip(); byte[] bytes = new byte[readBuffer.remaining()]; readBuffer.get(bytes); String body = new String(bytes, "UTF-8"); System.out.println("Now is : " + body); this.stop = true; } else if (readBytes < 0) { // 对端链路关闭 key.cancel(); sc.close(); } else ; // 读到0字节,忽略 } } } private void doConnect() throws IOException { // 如果直接连接成功,则注册到多路复用器上,发送请求消息,读应答 if (socketChannel.connect(new InetSocketAddress(host, port))) { socketChannel.register(selector, SelectionKey.OP_READ); doWrite(socketChannel); } else socketChannel.register(selector, SelectionKey.OP_CONNECT); } private void doWrite(SocketChannel sc) throws IOException { byte[] req = "QUERY TIME ORDER".getBytes(); ByteBuffer writeBuffer = ByteBuffer.allocate(req.length); writeBuffer.put(req); writeBuffer.flip(); sc.write(writeBuffer); if (!writeBuffer.hasRemaining()) System.out.println("Send order 2 server succeed."); } }
相关文章推荐
- Netty权威指南-NIO实现TimeServer服务器端源代码
- JAVA设计模式(DESIGN PATTERNS IN JAVA)读书摘要 第1部分接口型模式——第4章 外观(Facade)模式
- SpringMVC 多文件上传
- C++之路进阶——splay树(序列终结者)
- Python 插件安装
- Django后台管理中上传的图片访问不了问题
- .NET Core 1.0、ASP.NET Core 1.0和EF Core 1.0简介
- 简单理解python下的字符串
- python fabric模块
- Php发送post请求方法
- php 上传大文件主要涉及配置upload_max_filesize和post_max_size两个选项。
- PHP最全防止sql注入方法
- php包含那点事情[WOOYUN]
- 掌握下面常用函数,学php不再难
- 解决ThinkPHP中开启调试模式无法加载模块的问题。
- Spring 3.x jar 包详解 与 依赖关系
- Php发送post请求方法
- php 上传大文件主要涉及配置upload_max_filesize和post_max_size两个选项。
- PHP最全防止sql注入方法
- php包含那点事情[WOOYUN]