NioSocket，包括server端和client端

package com.qdzl.core.socket; import java.io.IOException; import java.net.InetSocketAddress; import java.net.ServerSocket; import java.nio.ByteBuffer; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; import java.util.HashMap; import java.util.Iterator; import java.util.Map; //服务器 public class NioSocketServer { // 通道管理器 private Selector selector; // 检测时间 private int detect = 10000; // 客户端连接监听 private OnConnectionListener onConnectedListener; public void setOnConnectedListener(OnConnectionListener onConnectedListener) { this.onConnectedListener = onConnectedListener; } // 存放客户端通道(用于发消息) Map<String, SocketChannel> map = null; // 单例 private static NioSocketServer nioSocketServer; private NioSocketServer() { map = new HashMap<String, SocketChannel>(); } public static NioSocketServer getInit() { if (nioSocketServer == null) { nioSocketServer = new NioSocketServer(); } return nioSocketServer; } public void init(int port) throws IOException { new Thread(new Runnable() { @Override public void run() { try { // 获取ServerSocketChannel通道 ServerSocketChannel serverSocketChannel = ServerSocketChannel.open(); // 非阻塞模式 serverSocketChannel.configureBlocking(false); ServerSocket socket = serverSocketChannel.socket(); socket.bind(new InetSocketAddress("0.0.0.0", port)); // 获取通道管理器 selector = Selector.open(); // 将通道和通道管理器绑定，并为通道注册SelectionKey.OP_ACCEPT(服务端接收客户端连接事件，对应值为SelectionKey.OP_ACCEPT(16)) // 只有当该事件到达时，Selector.select()会返回，否则一直阻塞。 serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT); System.out.println("服务器:" + socket.getLocalSocketAddress().toString()); listen(); } catch (Exception e) { e.printStackTrace(); } } }).start(); } @SuppressWarnings("static-access") public void listen() throws IOException { while (true) { // 当有注册访问时 int select = selector.select(); if (select > 0) { // 获取迭代器 Iterator<SelectionKey> iterator = selector.selectedKeys().iterator(); while (iterator.hasNext()) { // 选中key SelectionKey key = iterator.next(); // 删除已选key，防止重复处理 iterator.remove(); // 客户端连接事件 if (key.isAcceptable()) { // 获取客户端通道 ServerSocketChannel server = (ServerSocketChannel) key.channel(); // 获取客户端通道连接 SocketChannel channel = server.accept(); // 非阻塞模式 channel.configureBlocking(false); // 为客户端注册SelectionKey.OP_READ(读事件,对应值为SelectionKey.OP_READ(1)) channel.register(selector, SelectionKey.OP_READ); InetSocketAddress inetSocketAddress = (InetSocketAddress) channel.getRemoteAddress(); String host = inetSocketAddress.getHostString(); int port = inetSocketAddress.getPort(); onConnectedListener.onConnected(host + ":" + port); map.put(host + ":" + port, channel); //设置和手机的心跳包 new Thread(new Runnable() { @Override public void run() { while (true) { try { Thread.sleep(detect); channel.write(ByteBuffer.wrap(new String("server_connection").getBytes())); } catch (Exception e) { try { channel.close(); map.remove(host + ":" + port); } catch (Exception e1) { e1.printStackTrace(); } break; } } } }).start(); } else if (key.isReadable()) {// 客户端数据 InetSocketAddress inetSocketAddress = null; SocketChannel channel = null; String host = null; int port = 0; try { // 获取客户端通道连接，读取数据 channel = (SocketChannel) key.channel(); // 读取数据缓冲器 ByteBuffer buffer = ByteBuffer.allocate(1024); inetSocketAddress = (InetSocketAddress) channel.getRemoteAddress(); host = inetSocketAddress.getHostString(); port = inetSocketAddress.getPort(); int count = channel.read(buffer); if (count < 0) { // 客户端正常关闭 channel.close(); onConnectedListener.onDisconnected(host + ":" + port); map.remove(host + ":" + port); break; } Integer[] tt = new Integer[count]; for (int i = 0; i < count; i++) { int t = buffer.get(i); tt[i] = t >= 0 ? t : 256 + t; } String ms = ""; for (int i = 0; i < tt.length; i++) { String a = tt[i].toHexString(tt[i]); if (a.length() == 1) { a = "0" + a; } ms += a; } String startStr = ""; try { startStr = ms.substring(0, 2); } catch (Exception e) { e.printStackTrace(); } byte[] data = buffer.array(); buffer.clear(); String message = new String(data); if (startStr.equals("EF") || startStr.equals("ef") || startStr.equals("FE") || startStr.equals("fe")) { message = ms; } if (!message.trim().equals("server_connection")&&message.trim().indexOf("serv