客户端
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 }