java nio网络编程服务篇入门

 1 /**
 2  * 初始化网络连接
 3  */
 4 public void run() {
 5 
 6     // 开启网络连接
 7     try {
 8         channel = SocketUtils.connect("127.0.0.1",8080);
 9         selector = Selector.open();
10         channel.register(selector, SelectionKey.OP_CONNECT);
11         while(running) {
12             selector.select();
13             Iterator ite = selector.selectedKeys().iterator();
14             while (ite.hasNext()) {
15                 SelectionKey key = (SelectionKey) ite.next();
16                 ite.remove();
17                 readData(key);
18             }
19         }
20     } catch (Throwable e) {
21         logger.error(" socket or other fail!",e);
22     } finally {
23         // 关闭channel
24         if (channel != null) {
25             try {
26                 channel.close();
27             } catch (IOException e) {
28                 e.printStackTrace();
29             }
30         }
31         // 关闭selector
32         if (selector != null) {
33             try {
34                 selector.close();
35             } catch (IOException e) {
36                 e.printStackTrace();
37             }
38         }
39     }
40 }

 1 public void run(){
 2     byte[] buffer = new byte[512];
 3     running = true;
 4     while(running) {
 5         try {
 6             socket = new Socket("127.0.0.1", 8080);
 7             InputStream inputStream = socket.getInputStream();
 8             OutputStream outputStream = socket.getOutputStream();
 9             handleConnectListener(ConnectListener.ConnectStatus.connected);
10             // 读取数据
11             int bufferCount = -1;
12             ByteBuffer byteBuffer = ByteBuffer.allocate(buffer.length*2);
13             messageHandler.initByteBufferSize(byteBuffer.capacity());
14             while ((bufferCount = inputStream.read(buffer))>=0){
15                 byteBuffer.put(buffer,0,bufferCount);
16                 // TODO 解析 
17             }
18         } catch (Exception e) {
19             e.printStackTrace();
20         }
21     }
22 }