1、用OIO实现一个简单客户端。具体代码如下：package com.zhshl.nio; import java.io.IOExc髫潋啜缅eption; import java.io.InputStream; import java.io.OutputStream; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /** * zhshl 2018/10/5 */ public class OIOServer { public static void main(String[] args) throws IOException { ServerSocket serverSocket = new ServerSocket(10010); ExecutorService executorService = Executors.newCachedThreadPool(); System.out.println("服务器启动成功"); while(true){ //获取一个套字节(阻塞) final Socket socket = serverSocket.accept(); System.out.println("来了一个新的客户端"); executorService.execute(new Runnable() { public void run() { handler(socket); } }); } } /** * 读取数据 * @param socket */ public static void handler(Socket socket) { try { byte[] bytes = new byte[1024]; InputStream inputStream = socket.getInputStream(); OutputStream outputStream = socket.getOutputStream(); PrintWriter printWriter = new PrintWriter(outputStream); while(true){ //读取数据（阻塞） int read = inputStream.read(bytes); if(read != -1){ System.out.println(new String(bytes, 0, read,"GBK")); printWriter.print("你好："+socket.getInetAddress()+"，" + "你刚刚发送的消息我已经接收到了。发送的内容为：" + new String(bytes, 0, read,"GBK")); printWriter.flush(); }else{ break; } } } catch (Exception e) { e.printStackTrace(); }finally{ try { System.out.println("socket关闭"); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }
2、一、测试，此处采用telnet 来进行测试1、 window + R键，调出如下图的对话框
3、 输入cmd打开，点击确定。在CMD中输入telnet 127.0.0.1 10010 后按下回车键。然后按ctrl + ] 键，出现如下界面
4、未能成功连接，请检测telnet 是否已经开启开启方法：确保下图所示的Telnet 客户端已经开启
5、发送消息在telnet输入 send hello
6、在服务端的控制台看到有hello 打印出来。
