设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

JAVA NIO 基础学习

2016-12-20 13:15| 发布者: zhangjf| 查看: 492| 评论: 0

摘要: 服务端 监听 package com.hrd.netty.demo.jnio;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.net.InetSocketAddress;import java.nio.ByteBuffer; ...
服务端 监听
  1. package com.hrd.netty.demo.jnio;
  3. import java.io.BufferedReader;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.net.InetSocketAddress;
  7. import java.nio.ByteBuffer;
  8. import java.nio.channels.SelectionKey;
  9. import java.nio.channels.Selector;
  10. import java.nio.channels.ServerSocketChannel;
  11. import java.nio.channels.SocketChannel;
  12. import java.util.Iterator;
  14. /**
  15. * Created by hurd on 2016/1/26.
  16. */
  17. public class NioServerListener extends Thread {
  19. protected Selector selector;
  20. protected SocketChannel socketChannel;
  22. public NioServerListener(Selector selector){
  23. this.selector = selector;
  24. }
  26. @Override
  27. public void run(){
  29. try {
  30. //while循环监听事件
  31. while(true){
  32. //阻塞
  33. selector.select();
  34. //获取选择器中已经就绪的SelectionKey集合
  35. Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();
  36. //遍历
  37. while (iterator.hasNext()){
  38. SelectionKey key = iterator.next();
  39. //删除
  40. iterator.remove();
  41. //接受连接就绪事件
  42. if(key.isAcceptable()){
  43. ServerSocketChannel ssc = (ServerSocketChannel) key.channel();
  44. socketChannel = ssc.accept();
  45. //套接字通道设置为非阻塞模式
  46. socketChannel.configureBlocking(false);
  47. //向socket通道 注册读就绪事件
  48. socketChannel.register(selector, SelectionKey.OP_READ);
  49. }else if(key.isReadable()){
  50. //SocketChannel socketChannel = (SocketChannel) key.channel();
  51. ByteBuffer byteBuffer = ByteBuffer.allocate(100);
  52. int len = socketChannel.read(byteBuffer);
  53. /*StringBuffer dataBuffer= new StringBuffer();
  54. while( -1 != len){
  55. //将写模式变为读模式
  56. byteBuffer.flip();
  57. CharBuffer charBuffer = byteBuffer.asCharBuffer();
  58. dataBuffer.append(charBuffer.array());
  59. byteBuffer.clear();
  60. len = socketChannel.read(byteBuffer);
  61. }*/
  62. byteBuffer.flip();
  63. //读取完毕
  64. if(byteBuffer.limit()>0){
  65. System.out.println("来自服务端消息:" + new String(byteBuffer.array()).trim());
  66. }
  67. }else if(key.isWritable()){
  68. //暂时还没想明白这个写就绪事件干嘛用的。。。
  69. System.out.println("暂不处理");
  70. }
  71. }
  72. }
  73. } catch (IOException e) {
  74. e.printStackTrace();
  75. }
  76. }
  79. public static void main(String[] args) throws IOException {
  81. //打开一个 ServerSocketChannel实例 并设置为false
  82. ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
  83. serverSocketChannel.configureBlocking(false);
  84. //绑定ip +端口
  85. serverSocketChannel.socket().bind(new InetSocketAddress("127.0.0.1",1024));
  86. //打开一个选择器
  87. Selector selector = Selector.open();
  88. //向 serverSocketChannel 注册 接收就绪事件
  89. serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
  90. //开启线程进行监听
  91. NioServerListener listener = new NioServerListener (selector);
  92. listener.start();
  93. //进行控制太输入 写事件 进行通讯
  94. BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
  95. while(true){
  96. //java IO 阻塞读取数据
  97. String data = bufferedReader.readLine();
  98. if("exit".equals(data)){
  99. if(null != listener.socketChannel){
  100. listener.socketChannel.close();
  101. }
  102. System.out.println("主线程关闭.....");
  103. System.exit(0);
  104. }
  105. ByteBuffer buffer = ByteBuffer.wrap(data.getBytes());
  106. listener.socketChannel.write(buffer);
  107. }
  108. }
  109. }
复制代码
客户端 监听
  1. package com.hrd.netty.demo.jnio;
  3. import java.io.BufferedReader;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.net.InetSocketAddress;
  7. import java.nio.ByteBuffer;
  8. import java.nio.channels.SelectionKey;
  9. import java.nio.channels.Selector;
  10. import java.nio.channels.SocketChannel;
  11. import java.util.Iterator;
  13. /**
  14. * Created by hurd on 2016/1/26.
  15. */
  16. public class NioClientListener extends Thread {
  18. public Selector selector;
  19. public SocketChannel socketChannel;
  21. public NioClientListener(Selector selector){
  22. this.selector = selector;
  23. }
  25. @Override
  26. public void run(){
  28. try {
  29. //while循环监听事件
  30. while(true){
  31. //阻塞
  32. selector.select();
  33. //获取选择器中已经就绪的SelectionKey集合
  34. Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();
  35. //遍历
  36. while (iterator.hasNext()){
  37. SelectionKey key = iterator.next();
  38. //删除
  39. iterator.remove();
  40. socketChannel = (SocketChannel) key.channel();
  41. //套接字通道设置为非阻塞模式
  42. socketChannel.configureBlocking(false);
  44. //连接就绪事件
  45. if(key.isConnectable()){
  46. socketChannel = (SocketChannel) key.channel();
  47. //判断连接是否完成
  48. int i =0;
  49. while(! socketChannel.finishConnect()){
  50. if(++i>10){
  51. throw new RuntimeException("socket连接超时");
  52. }
  53. System.out.println("sock连接未完成,等待中....");
  54. try {
  55. Thread.sleep(1000);
  56. } catch (InterruptedException e) {
  57. e.printStackTrace();
  58. }
  59. }
  60. //向socket通道 注册读就绪事件
  61. socketChannel.register(selector, SelectionKey.OP_READ);
  62. }else if(key.isReadable()){
  63. //SocketChannel socketChannel = (SocketChannel) key.channel();
  64. ByteBuffer byteBuffer = ByteBuffer.allocate(100);
  65. int len = socketChannel.read(byteBuffer);
  66. /*StringBuffer dataBuffer= new StringBuffer();
  67. while( -1 != len){
  68. //将写模式变为读模式
  69. byteBuffer.flip();
  70. CharBuffer charBuffer = byteBuffer.asCharBuffer();
  71. dataBuffer.append(charBuffer.array());
  72. byteBuffer.clear();
  73. len = socketChannel.read(byteBuffer);
  74. }*/
  75. byteBuffer.flip();
  76. //读取完毕
  77. if(byteBuffer.limit()>0){
  78. System.out.println("来自服务端消息:" + new String(byteBuffer.array()).trim());
  79. }
  80. }else if(key.isWritable()){
  81. //暂时还没想明白这个写就绪事件干嘛用的。。。
  82. System.out.println("暂不处理");
  83. }
  84. }
  85. }
  86. } catch (IOException e) {
  87. e.printStackTrace();
  88. }
  89. }
  91. public static void main(String[] args) throws IOException {
  93. //打开一个SocketChannel实例 并设置为false
  94. SocketChannel socketChannel = SocketChannel.open();
  95. socketChannel.configureBlocking(false);
  96. //绑定ip +端口
  97. socketChannel.connect(new InetSocketAddress("127.0.0.1",1024));
  98. //打开一个选择器
  99. Selector selector = Selector.open();
  100. //向 serverSocketChannel 注册 连接就绪事件
  101. socketChannel.register(selector, SelectionKey.OP_CONNECT);
  102. //开启线程进行监听
  103. NioClientListener listener = new NioClientListener (selector);
  104. listener.start();
  105. //进行控制太输入 写事件 进行通讯
  106. BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
  107. while(true){
  108. //java IO 阻塞读取数据
  109. String data = bufferedReader.readLine();
  110. if("exit".equals(data)){
  111. socketChannel.close();
  112. System.out.println("主线程关闭.....");
  113. System.exit(0);
  114. }
  115. ByteBuffer buffer = ByteBuffer.wrap(data.getBytes());
  116. socketChannel.write(buffer);
  117. }
  118. }
  119. }
复制代码
收藏 邀请
上一篇：Java一个简单的线程池实现下一篇：java在线预览txt、word、ppt、execel，pdf代码

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-7-8 08:30

Copyright 2015-2025 djqfx

返回顶部