window 10
telnet
JDK 1.6+
用OIO实现一个简单客户端。具体代码如下:package com.zhshl.nio; import java.io.IOException; 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(); } } } }
一、测试,此处采用telnet 来进行测试1、 window + R键,调出如下图的对话框
2、 输入cmd打开,点击确定。在CMD中输入telnet 127.0.0.1 10010 后按下回车键。然后按ctrl + ] 键,出现如下界面
未能成功连接,请检测telnet 是否已经开启开启方法:确保下图所示的Telnet 客户端已经开启
发送消息在telnet输入 send hello
在服务端的控制台看到有hello 打印出来。
测试前记得先启动服务端 OIO的阻塞点有: 1、 serverSocket.accept(); 2、 inputStream.read(bytes);