diff --git a/platform-operate-api/src/main/java/com/lyms/hospitalapi/NIOServer.java b/platform-operate-api/src/main/java/com/lyms/hospitalapi/NIOServer.java
index 265cb86..6c6ea82 100644
--- a/platform-operate-api/src/main/java/com/lyms/hospitalapi/NIOServer.java
+++ b/platform-operate-api/src/main/java/com/lyms/hospitalapi/NIOServer.java
@@ -99,21 +99,26 @@ public class NIOServer {
      * @param key
      * @throws IOException
      */
-    public int read(SelectionKey key) throws IOException{
+    public int read(SelectionKey key) {
         // 服务器可读取消息:得到事件发生的Socket通道
         SocketChannel channel = (SocketChannel) key.channel();
         // 创建读取的缓冲区
-        ByteBuffer buffer = ByteBuffer.allocate(10);
-        channel.read(buffer);
-        byte[] data = buffer.array();
-        String msg = new String(data).trim();
-        if (msg.length() == 0) {
+        try {
+            ByteBuffer buffer = ByteBuffer.allocate(10);
+            channel.read(buffer);
+            byte[] data = buffer.array();
+            String msg = new String(data).trim();
+            if (msg.length() == 0) {
+                return 0;
+            }
+            System.out.println("服务端收到信息：" + msg);
+            ByteBuffer outBuffer = ByteBuffer.wrap("success".getBytes());
+            channel.write(outBuffer);// 将消息回送给客户端
+            return msg.length();
+        } catch (Exception e) {
+            e.printStackTrace();
             return 0;
         }
-        System.out.println("服务端收到信息："+msg);
-        ByteBuffer outBuffer = ByteBuffer.wrap("success".getBytes());
-        channel.write(outBuffer);// 将消息回送给客户端
-        return msg.length();
     }
 
     class BeatTask extends Thread {
diff --git a/platform-operate-api/src/main/java/com/lyms/hospitalapi/NioClient.java b/platform-operate-api/src/main/java/com/lyms/hospitalapi/NioClient.java
index bee74f7..a553df8 100644
--- a/platform-operate-api/src/main/java/com/lyms/hospitalapi/NioClient.java
+++ b/platform-operate-api/src/main/java/com/lyms/hospitalapi/NioClient.java
@@ -5,6 +5,15 @@ import org.springframework.stereotype.Service;
 
 import javax.annotation.PostConstruct;
 import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.nio.ByteBuffer;
+import java.nio.channels.SelectionKey;
+import java.nio.channels.Selector;
+import java.nio.channels.SocketChannel;
+import java.nio.charset.Charset;
+import java.util.Iterator;
+import java.util.Scanner;
+import java.util.Set;
 
 /**
  * Created by riecard on 2016/11/24.
@@ -14,9 +23,92 @@ public class NioClient {
 
     public static final String NIO_CLIENT_START = PropertiesUtils.getPropertyValue("nio_client_start");
 
+    private Selector selector = null;
+    static final int port = 8000;
+    private Charset charset = Charset.forName("UTF-8");
+    private SocketChannel sc = null;
+    private String name = "";
+    private static String USER_EXIST = "system message: user exist, please change a name";
+    private static String USER_CONTENT_SPILIT = "#@#";
+
     @PostConstruct
     public void init() throws IOException {
         if ("1".equals(NIO_CLIENT_START)) {
         }
+        selector = Selector.open();
+        //连接远程主机的IP和端口
+        sc = SocketChannel.open(new InetSocketAddress("192.168.5.250",port));
+        sc.configureBlocking(false);
+        sc.register(selector, SelectionKey.OP_READ);
+        //开辟一个新线程来读取从服务器端的数据
+        new Thread(new ClientThread()).start();
+        //在主线程中 从键盘读取数据输入到服务器端
+        Scanner scan = new Scanner(System.in);
+        while(scan.hasNextLine())
+        {
+            String line = scan.nextLine();
+            if("".equals(line)) continue; //不允许发空消息
+            if("".equals(name)) {
+                name = line;
+                line = name+USER_CONTENT_SPILIT;
+            } else {
+                line = name+USER_CONTENT_SPILIT+line;
+            }
+            sc.write(charset.encode(line));//sc既能写也能读，这边是写
+        }
     }
+
+    private class ClientThread implements Runnable
+    {
+        public void run()
+        {
+            try
+            {
+                while(true) {
+                    int readyChannels = selector.select();
+                    if(readyChannels == 0) continue;
+                    Set selectedKeys = selector.selectedKeys();  //可以通过这个方法，知道可用通道的集合
+                    Iterator keyIterator = selectedKeys.iterator();
+                    while(keyIterator.hasNext()) {
+                        SelectionKey sk = (SelectionKey) keyIterator.next();
+                        keyIterator.remove();
+                        dealWithSelectionKey(sk);
+                    }
+                }
+            }
+            catch (IOException io)
+            {}
+        }
+
+        private void dealWithSelectionKey(SelectionKey sk) throws IOException {
+            if(sk.isReadable())
+            {
+                //使用 NIO 读取 Channel中的数据，这个和全局变量sc是一样的，因为只注册了一个SocketChannel
+                //sc既能写也能读，这边是读
+                SocketChannel sc = (SocketChannel)sk.channel();
+
+                ByteBuffer buff = ByteBuffer.allocate(1024);
+                String content = "";
+                while(sc.read(buff) > 0)
+                {
+                    buff.flip();
+                    content += charset.decode(buff);
+                }
+                //若系统发送通知名字已经存在，则需要换个昵称
+                if(USER_EXIST.equals(content)) {
+                    name = "";
+                }
+                System.out.println(content);
+                sk.interestOps(SelectionKey.OP_READ);
+            }
+        }
+    }
+
+
+
+    public static void main(String[] args) throws IOException
+    {
+        new NioClient().init();
+    }
+
 }