1 基本概括
?
2 主要介绍
2.1 Java (Socket,ServerSocket)与(SocketChannel,ServerSocketChannel)区别和联系
Socket 和ServerSocke 是一对 他们是java.net下面实现socket通信的类SocketChannel 和ServerSocketChannel是一对 他们是java.nio下面实现通信的类 支持异步通信
服务器必须先建立ServerSocket或者ServerSocketChannel 来等待客户端的连接客户端必须建立相对应的Socket或者SocketChannel来与服务器建立连接服务器接受到客户端的连接受，再生成一个Socket或者 SocketChannel与此客户端通信
不过Socket和SocketChannel可以通过 socket.channel() SocketChannel.socket() 方法相互转换同理ServerSocket 和ServerSocketChannel 也可以相互转换
2.2 channel的介绍
在Java NIO的世界中，Selector是中央控制器，Buffer是承载数据的容器，而Channel可以说是最基础的
门面，它是本地I/O设备、网络I/O的通信桥梁，只有搭建了这座桥梁，数据才能被写入Buffer，连接才能被Selector控制。
Channel这座桥梁分别为本地I/O设备和网络I/O提供了以下实现，并且和Java IO体系的类是一一对应的：
网络I/O设备：
DatagramChannel:读写UDP通信的数据，对应DatagramSocket类
SocketChannel:读写TCP通信的数据，对应Socket类
ServerSocketChannel:监听新的TCP连接，并且会创建一个可读写的SocketChannel，对应ServerSocket类
本地I/O设备：
FileChannel:读写本地文件的数据,不支持Selector控制，对应File类
2.3 Socket简单介绍
什么是 TCP/IP 和UDP
TCP/IP（Transmission Control Protocol/Internet Protocol）即传输控制协议/网间协议，是一个工业标准的协议集，它是为广域网（WANs）设计的。
UDP（User Data Protocol，用户数据报协议）是与TCP相对应的协议。它是属于TCP/IP协议族中的一种。
socket：Socket是应用层与TCP/IP协议族通信的中间软件抽象层，它是一组接口。在设计模式中，Socket其实就是一个门面模式，它把复杂的TCP/IP协议族隐藏在Socket接口后面，对用户来说，一组简单的接口就是全部，让Socket去组织数据，以符合指定的协议。
2.4 Channel和流的区别
1 Channel 可以是双向的，既可以通过Channel读数据，也可以写数据，流的话要么是输入流，要么是输出流
2 不能直接通过 Channel 读写数据，必须通过buffer操作，程序通过Buffer间接的和Channel打交道，程序永远不能绕过buffer直接操作Channel，而流是可以直接读写的
3 Channel的读写可以是非阻塞的，而流是阻塞的
3 用例
3.1 SocketChannel通信代码
/**
* 服务端,接收数据
*/
public class NioServer{
public static void main(String[] args) throws IOException {
//打开一个服务连接通道
ServerSocketChannel channel = ServerSocketChannel.open();
//创建服务连接地址
InetSocketAddress socketAddress = new InetSocketAddress(8888);
//通道绑定服务地址
channel.bind(socketAddress);
//设置服务端通道非阻塞
channel.configureBlocking(false);
//打开选择处理器
Selector selector = Selector.open();
//模拟多个用户,使用selector选择器进行响应
//首先第一步进来的所有连接都是为了接入
channel.register(selector,SelectionKey.OP_ACCEPT);
//selector 处理接入
while (selector.select()>0){ //阻塞体现在Selector上
//可能客户到请求一次进来多个,进行判断
Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();
while (iterator.hasNext()){
//获取其中的每个请求
SelectionKey next = iterator.next();
//判断请求是属于 连接过的还是未连接过的
if(next.isAcceptable()){ //没连接过,直接跟踪,设置为读取状态
SocketChannel accept = channel.accept();//通道允许接入请求
accept.configureBlocking(false);//设置非阻塞
accept.register(selector,SelectionKey.OP_READ); //设置为读取数据
}
if(next.isReadable()){ //连接过,直接读取
SelectableChannel channel2 = next.channel();
channel2.configureBlocking(false);
//读取通道信息
readMsg(channel2);
}
iterator.remove();
}
}
}
private static void readMsg(SelectableChannel channel2) throws IOException {
SocketChannel channel = (SocketChannel) channel2;
SocketAddress localAddress = channel.getLocalAddress();
//设置缓存区
ByteBuffer buffer = ByteBuffer.allocate(1024);
//读取数据
int len;
byte[] b = new byte[1024];
while ((len = channel.read(buffer))>0){
buffer.flip();//刷新缓存区
buffer.get(b, 0, len);
System.out.println("服务端接受到数据为:"+new String(b,0,len));
}
}
}
/**
* 客户端 发送数据
*/
public class NioClient {
public static void main(String[] args) throws IOException {
//声明连接地址对象 nio框架使用tcp协议绑定ip和端口
InetSocketAddress socketAddress = new InetSocketAddress("127.0.0.1", 8888);
//打开一个和服务端连接的通道
SocketChannel channel = SocketChannel.open();
channel.connect(socketAddress);
//设置通道为非阻塞
channel.configureBlocking(false);
//设置缓存区大小
ByteBuffer buffer = ByteBuffer.allocate(1024);
//控制台的输入数据输出
Scanner scanner = new Scanner(System.in);
while (scanner.hasNext()){
//清除缓存区的数据
buffer.clear();
//获取控制台的数据
String data = scanner.nextLine();
buffer.put(data.getBytes());
//刷新 缓存区的数据,与IO流的flush类似
buffer.flip();
channel.write(buffer);
}
}