JavaSE：NIO编程实例

2021-07-02 14:00:06 阅读：166 来源： 互联网

标签：ssc3 ssc2 java NIO 编程 import JavaSE SelectionKey ServerSocketChannel

客户端

 1 public static void main(String[] args) throws IOException {
 2 
 3 
 4 
 5 　　// 创建客户端
 6 
 7 　　SocketChannel sc = SocketChannel.open();
 8 
 9 
10 
11 　　// 指定要连接的服务器ip和端口
12 
13 　　sc.connect(new InetSocketAddress("127.0.0.1", 9000) );
14 
15 
16 
17 　　// 创建缓冲输出
18 
19 　   ByteBuffer buffer = ByteBuffer.allocate(1024);
20 
21 
22 
23 　　// 给数组添加数据
24 
25 　　buffer.put ("Hi你好啊".getBytes());
26 
27 
28 
29 　　// 切换
30 
31 　　buffer.flip();
32 
33 
34 
35 　　// 输出数据
36 
37 　　sc.write(buffer);
38 
39 
40 
41 　　// 关闭资源
42 
43 　　sc.close();
44 
45 }

Demo服务端

 1 import java.io.IOException;
 2 
 3 import java.net.InetSocketAddress;
 4 
 5 import java.nio.channels.SelectionKey;
 6 
 7 import java.nio.channels.Selector;
 8 
 9 import java.nio.channels.ServerSocketChannel;
10 
11 import java.util.Set;
12 
13 
14 
15 public class Demo服务端 {
16 
17 　　main() throws IOException {
18 
19 　　　　// 创建服务端对象
20 
21 　　　　ServerSocketChannel ssc1 = ServerSocketChannel.open();
22 
23 　　　　ssc1.bind(new InetSocketAddress(8000));
24 
25 
26 
27 　　　　// 设置非阻塞
28 　　　　ssc1.configureBlocking(false);
29 　　　　
30 　　　　// 创建服务器端对象
31 　　　　ServerSocketChannel ssc2 = ServerSocketChannel.open();
32 　　　　ssc2.bind(new InetSocketAddress(9000));
33 　　　　ssc2.configureBlocking(false);
34 
35 
36 
37 　　　　// 创建服务器端对象 
38 　　　　ServerSocketChannel ssc3 = ServerSocketChannel.open();
39 　　　　ssc3.bind(new InetSocketAddress(10001));
40 　　　　ssc3.configureBlocking(false);
41 
42 
43 
44 　　　　// 创建选择器对象
45 
46 　　　　Selector s = Selector.open();
47 
48 
49 
50 　　　　// 两个服务器，都要交给选择器来管理
51 
52 　　　　ssc1.register(s, SelectionKey.OP_ACCEPT);
53 
54 　　　　ssc2.register(s, SelectionKey.OP_ACCEPT);
55 
56 　　　　ssc3.register(s, SelectionKey.OP_ACCEPT);
57 
58 
59 
60 　　　　// 获取集合
61 　　　　// selectedKeys()： 返回集合，集合作用存放的是被连接的服务对象的key
62 　　　　Set<SelectionKey> set = s.selectedKeys();
63 　　　　print("集合中元素的个数：" + set.size() );　　// 0 (没有服务器被访问的时候，显示0)
64 　　　　
65 　　　　// select()： 这是选择器连接客户端的方法
66 　　　　s.select();
67 
68 
69 　　　　print("集合中元素的个数：" + set.size() );　　// 1 (有一个服务端被访问的时候，显示1)
70  
71 　　}
72 
73 }

Selector服务端

  1 import java.io.IOException;
  2 
  3 import java.net.InetSocketAddress;
  4 
  5 import java.nio.ByteBuffer;
  6 
  7 import java.nio.channels.SelectionKey;
  8 
  9 import java.nio.channels.Selector;
 10 
 11 import java.nio.channels.ServerSocketChannel;
 12 
 13 import java.nio.channels.SocketChannel;
 14 
 15 import java.util.Iterator;
 16 
 17 
 18 
 19 public class Selector服务端 {
 20 
 21 　　main() throws IOException {
 22 
 23 　　　　//　　1. 获取Selector选择器
 24 
 25 　　　　Selector selector = Selector.open();
 26 
 27 
 28 
 29 　　　　//　　2. 获取通道
 30 
 31 　　　　ServerSocketChannel ssc1 = ServerSocketChannel.open();
 32 
 33 　　　　ServerSocketChannel ssc2 = ServerSocketChannel.open();
 34 
 35 　　　　ServerSocketChannel ssc3 = ServerSocketChannel.open();
 36 
 37 
 38 
 39 　　　　//　　3. 设置为非阻塞
 40 
 41 　　　　ssc1.configureBlocking(false);
 42 
 43 　　　　ssc2.configureBlocking(false);
 44 
 45 　　　　ssc3.configureBlocking(false);
 46 
 47 
 48 
 49 　　　　//　　4.绑定连接
 50 
 51 　　　　ssc1.bind (new InetSocketAddress(8000));
 52 
 53 　　　　ssc2.bind (new InetSocketAddress(9000));
 54 
 55 　　　　ssc3.bind (new InetSocketAddress(10000));
 56 
 57 
 58 
 59 　　　　//　　5.将通道注册到选择器上，并注册的操作为："接收"操作
 60 　　　　ssc1.register(selector, SelectionKey.OP_ACCEPT);
 61 　　　　ssc2.register(selector, SelectionKey.OP_ACCEPT);
 62 　　　　ssc3.register(selector, SelectionKey.OP_ACCEPT);
 63 
 64 
 65 　　　　//　　6.采用轮询的方式，查询获取"准备就绪"的注册过的操作
 66 　　　　while (selector.select() > 0 ) {
 67 
 68 　　　　　　//　　7. 获取当前选择器中，所有的选择键 （“已经准备就绪的操作”）
 69 　　　　　　Iterator<SelectionKey> selectedKeys = selector.selectedKeys().iterator();
 70 　　　　　　while (selectedKeys.hasNext() ){
 71 
 72 
 73 
 74 　　　　　　　　//　　8.　　获取"准备就绪"的事件
 75 　　　　　　　　SelectionKey selectedKey = selectedKeys.next();
 76 
 77 
 78 　　　　　　　　//　　9.　　获取ServerSocketChannel
 79 　　　　　　　　ServerSocketChannel serverSocketChannel = (ServerSocketChannel) selectedKey.channel();
 80 
 81 
 82 　　　　　　　　//　　10.　　接收客户端发来的数据
 83 　　　　　　　　SocketChannel socketChannel = serverSocketChannel.accept();
 84 
 85 
 86 　　　　　　　　//　　11.　　读取数据
 87 　　　　　　　　ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
 88 　　　　　　　　int length = 0;
 89 　　　　　　　　while ( (length = socketChannel.read(byteBuffer)) != -1 ){
 90 
 91 　　　　　　　　　　byteBuffer.flip();
 92 　　　　　　　　　　print (new String(byteBuffer.array(),0,length) );
 93 　　　　　　　　　　byteBuffer.clear();
 94 　　　　　　　　}
 95 　　　　　　　　socketChannel.close();
 96 
 97 　　　　　　}
 98 　　　　　　//　　12.　　移除选择键
 99 　　　　　　selectedKeys.remove();
100 　　　　}
101 　　　　//　　13.　　关闭连接
102 　　　　ssc1.close();
103 　　　　ssc2.close();
104 　　　　ssc3.close();
105 　　}
106 
107 }

标签：ssc3,ssc2,java,NIO,编程,import,JavaSE,SelectionKey,ServerSocketChannel
来源： https://www.cnblogs.com/JasperZhao/p/14962994.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

JavaSE：NIO编程实例