初识NIO之Java小Demo

Java中的IO、NIO、AIO：

BIO：在Java1.4之前，我们建立网络连接均使用BIO，属于同步阻塞IO。默认情况下，当有一条请求接入就有一条线程专门接待。所以，在客户端向服务端请求时，会询问是否有空闲线程进行接待，如若没有则一直等待或拒接。当并发量小时还可以接受，当请求量一多起来则会有许多线程生成，在Java中，多线程的上下文切换会消耗计算机有限的资源和性能，造成资源浪费。

NIO：NIO的出现是为了解决再BIO下的大并发量问题。其特点是能用一条线程管理所有连接。如下图所示：

NIO是同步非阻塞模型，通过一条线程控制选择器（Selector）来管理多个Channel，减少创建线程和上下文切换的浪费。当线程通过选择器向某条Channel请求数据但其没有数据时，是不会阻塞的，直接返回，继续干其他事。而一旦某Channel就绪，线程就能去调用请求数据等操作。当该线程对某条Channel进行写操作时同样不会被阻塞，所以该线程能够对多个Channel进行管理。

NIO是面向缓冲流的，即数据写入写出都是通过 Channel —— Buffer 这一途径。（双向流通）

AIO：与之前两个IO模型不同的是，AIO属于异步非阻塞模型。当进行读写操作时只须调用api的read方法和write方法，这两种方法均是异步。对于读方法来说，当有流可读取时，操作系统会将可读的流传入read方法的缓冲区，并通知应用程序；对于写操作而言，当操作系统将write方法传递的流写入完毕时，操作系统主动通知应用程序。换言之就是当调用完api后，操作系统完成后会调用回调函数。

总结：一般IO分为同步阻塞模型（BIO），同步非阻塞模型（NIO），异步阻塞模型，异步非阻塞模型（AIO）

同步阻塞模型指的是当调用io操作时必须等到其io操作结束

同步非阻塞模型指当调用io操作时不必等待可以继续干其他事，但必须不断询问io操作是否完成。

异步阻塞模型指应用调用io操作后，由操作系统完成io操作，但应用必须等待或去询问操作系统是否完成。

异步非阻塞指应用调用io操作后，由操作系统完成io操作并调用回调函数，应用完成放手不管。

NIO的小Demo之服务端

首先，先看下服务端的大体代码

public class ServerHandle implements Runnable{//带参数构造函数public ServerHandle(int port){}//停止方法public void shop(){}//写方法private void write(SocketChannel socketChannel, String  response)throws IOException{}//当有连接进来时的处理方法private void handleInput(SelectionKey key) throws IOException{} //服务端运行主体方法@Overridepublic void run() {}
}
复制代码

首先我们先看看该服务端的构造函数的实现：

public ServerHandle(int port){try {//创建选择器selector = Selector.open();//打开监听通道serverSocketChannel = ServerSocketChannel.open();//设置为非阻塞模式serverSocketChannel.configureBlocking(false);//传入端口，并设定连接队列最大为1024serverSocketChannel.socket().bind(new InetSocketAddress(port),1024);//监听客户端请求serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);//标记启动标志started = true;System.out.println("服务器已启动，端口号为：" + port);} catch (IOException e){e.printStackTrace();System.exit(1);}}
复制代码

在这里创建了选择器和监听通道，并将该监听通道注册到选择器上并选择其感兴趣的事件（accept）。后续其他接入的连接都将通过该 监听通道 传入。

然后就是写方法的实现：

    private void doWrite(SocketChannel channel, String response) throws IOException {byte[] bytes = response.getBytes();ByteBuffer wirteBuffer = ByteBuffer.allocate(bytes.length);wirteBuffer.put(bytes);//将写模式改为读模式wirteBuffer.flip();//写入管道channel.write(wirteBuffer);}
复制代码

其次是当由事件传入时，即对连接进来的链接的处理方法

    private void handleInput(SelectionKey key) throws IOException{//当该键可用时if (key.isValid()){if (key.isAcceptable()){//返回该密钥创建的通道。ServerSocketChannel serverSocketChannel = (ServerSocketChannel) key.channel();通过该通道获取链接进来的通道SocketChannel socketChannel = serverSocketChannel.accept();socketChannel.configureBlocking(false);socketChannel.register(selector, SelectionKey.OP_READ);}if (key.isReadable()){//返回该密钥创建的通道。SocketChannel socketChannel = (SocketChannel) key.channel();ByteBuffer byteBuffer = ByteBuffer.allocate(1024);int readBytes = socketChannel.read(byteBuffer);if (readBytes > 0){byteBuffer.flip();byte[] bytes = new byte[byteBuffer.remaining()];byteBuffer.get(bytes);String expression = new String(bytes, "UTF-8");System.out.println("服务器收到的信息：" + expression);//此处是为了区别打印在工作台上的数据是由客户端产生还是服务端产生doWrite(socketChannel, "+++++" + expression + "+++++");} else if(readBytes == 0){//无数据，忽略}else if (readBytes < 0){//资源关闭key.cancel();socketChannel.close();}}}}
复制代码

这里要说明的是，只要ServerSocketChannel及SocketChannel向Selector注册了特定的事件，Selector就会监控这些事件是否发生。 如在构造方法中有一通道serverSocketChannel注册了accept事件。当其就绪时就可以通过调用selector的selectorKeys()方法，访问”已选择键集“中的就绪通道。

压轴方法：

    @Overridepublic void run() {//循环遍历while (started) {try {//当没有就绪事件时阻塞selector.select();//返回就绪通道的键Set<SelectionKey> keys = selector.selectedKeys();Iterator<SelectionKey> iterator = keys.iterator();SelectionKey key;while (iterator.hasNext()){key = iterator.next();//获取后必须移除，否则会陷入死循环iterator.remove();try {//对就绪通道的处理方法，上述有描述handleInput(key);} catch (Exception e){if (key != null){key.cancel();if (key.channel() != null) {key.channel().close();}}}}}catch (Throwable throwable){throwable.printStackTrace();}}}
复制代码

此方法为服务端的主体方法。大致流程如下：

  1. 打开ServerSocketChannel，监听客户端连接
  2. 绑定监听端口，设置连接为非阻塞模式（阻塞模式下不能注册到选择器）
  3. 创建Reactor线程，创建选择器并启动线程
  4. 将ServerSocketChannel注册到Reactor线程中的Selector上，监听ACCEPT事件
  5. Selector轮询准备就绪的key
  6. Selector监听到新的客户端接入，处理新的接入请求，完成TCP三次握手，简历物理链路
  7. 设置客户端链路为非阻塞模式
  8. 将新接入的客户端连接注册到Reactor线程的Selector上，监听读操作，读取客户端发送的网络消息 异步读取客户端消息到缓冲区
  9. 调用write将消息异步发送给客户端

NIO的小Demo之客户端

public class ClientHandle implements Runnable{//构造函数，构造时顺便绑定public ClientHandle(String ip, int port){}//处理就绪通道private void handleInput(SelectionKey key) throws IOException{}//写方法（与服务端的写方法一致）private void doWrite(SocketChannel channel,String request) throws IOException{}//连接到服务端private void doConnect() throws IOException{}//发送信息public void sendMsg(String msg) throws Exception{}
}
复制代码

首先先看构造函数的实现：

    public ClientHandle(String ip,int port) {this.host = ip;this.port = port;try{//创建选择器selector = Selector.open();//打开监听通道socketChannel = SocketChannel.open();//如果为 true，则此通道将被置于阻塞模式；如果为 false，则此通道将被置于非阻塞模式socketChannel.configureBlocking(false);started = true;}catch(IOException e){e.printStackTrace();System.exit(1);}}
复制代码

接下来看对就绪通道的处理办法：

    private void handleInput(SelectionKey key) throws IOException{if(key.isValid()){SocketChannel sc = (SocketChannel) key.channel();if(key.isConnectable()){//这里的作用将在后面的代码（doConnect方法）说明if(sc.finishConnect()){System.out.println("已连接事件");}else{System.exit(1);}}//读消息if(key.isReadable()){//创建ByteBuffer，并开辟一个1k的缓冲区ByteBuffer buffer = ByteBuffer.allocate(1024);//读取请求码流，返回读取到的字节数int readBytes = sc.read(buffer);//读取到字节，对字节进行编解码if(readBytes>0){buffer.flip();//根据缓冲区可读字节数创建字节数组byte[] bytes = new byte[buffer.remaining()];//将缓冲区可读字节数组复制到新建的数组中buffer.get(bytes);String result = new String(bytes,"UTF-8");System.out.println("客户端收到消息：" + result);}lse if(readBytes==0){//忽略}else if(readBytes<0){//链路已经关闭，释放资源key.cancel();sc.close();}}}}
复制代码

在run方法之前需先看下此方法的实现：

    private void doConnect() throws IOException{if(socketChannel.connect(new InetSocketAddress(host,port))){System.out.println("connect");}else {socketChannel.register(selector, SelectionKey.OP_CONNECT);System.out.println("register");}}
复制代码

当SocketChannel工作于非阻塞模式下时，调用connect()时会立即返回： 如果连接建立成功则返回的是true(比如连接localhost时，能立即建立起连接)，否则返回false。

在非阻塞模式下，返回false后，必须要在随后的某个地方调用finishConnect()方法完成连接。 当SocketChannel处于阻塞模式下时，调用connect()时会进入阻塞，直至连接建立成功或者发生IO错误时，才从阻塞状态中退出。

所以该代码在connect服务端后返回false（但还是有作用的），并在else语句将该通道注册在选择器上并选择connect事件。

客户端的run方法：

    @Overridepublic void run() {try{doConnect();}catch(IOException e){e.printStackTrace();System.exit(1);}//循环遍历selectorwhile(started){try{selector.select();Set<SelectionKey> keys = selector.selectedKeys();Iterator<SelectionKey> it = keys.iterator();SelectionKey key ;while(it.hasNext()){key = it.next();it.remove();try{handleInput(key);}catch(Exception e){if(key != null){key.cancel();if(key.channel() != null){key.channel().close();}}}}}catch(Exception e){e.printStackTrace();System.exit(1);}}//selector关闭后会自动释放里面管理的资源if(selector != null){try{selector.close();}catch (Exception e) {e.printStackTrace();}}}
复制代码

发送信息到服务端的方法：

    public void sendMsg(String msg) throws Exception{//覆盖其之前感兴趣的事件(connect），将其更改为OP_READsocketChannel.register(selector, SelectionKey.OP_READ);doWrite(socketChannel, msg);}
复制代码

完整代码：

服务端：

/*** Created by innoyiya on 2018/8/20.*/
public class Service {private static int DEFAULT_POST = 12345;private static ServerHandle serverHandle;public static void start(){start(DEFAULT_POST);}public static synchronized void start(int post) {if (serverHandle != null){serverHandle.shop();}serverHandle = new ServerHandle(post);new Thread(serverHandle,"server").start();}
}
复制代码

服务端主体：

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.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.Set;/*** Created by innoyiya on 2018/8/20.*/
public class ServerHandle implements Runnable{private Selector selector;private ServerSocketChannel serverSocketChannel;private volatile boolean started;public ServerHandle(int port){try {//创建选择器selector = Selector.open();//打开监听通道serverSocketChannel = ServerSocketChannel.open();//设置为非阻塞模式serverSocketChannel.configureBlocking(false);//判定端口，并设定连接队列最大为1024serverSocketChannel.socket().bind(new InetSocketAddress(port),1024);//监听客户端请求serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);//标记启动标志started = true;System.out.println("服务器已启动，端口号为：" + port);} catch (IOException e){e.printStackTrace();System.exit(1);}}public void shop(){started = false;}private void doWrite(SocketChannel channel, String response) throws IOException {byte[] bytes = response.getBytes();ByteBuffer wirteBuffer = ByteBuffer.allocate(bytes.length);wirteBuffer.put(bytes);wirteBuffer.flip();channel.write(wirteBuffer);}private void handleInput(SelectionKey key) throws IOException{if (key.isValid()){if (key.isAcceptable()){ServerSocketChannel serverSocketChannel = (ServerSocketChannel) key.channel();SocketChannel socketChannel = serverSocketChannel.accept();socketChannel.configureBlocking(false);socketChannel.register(selector, SelectionKey.OP_READ);}if (key.isReadable()){SocketChannel socketChannel = (SocketChannel) key.channel();ByteBuffer byteBuffer = ByteBuffer.allocate(1024);int readBytes = socketChannel.read(byteBuffer);if (readBytes > 0){byteBuffer.flip();byte[] bytes = new byte[byteBuffer.remaining()];byteBuffer.get(bytes);String expression = new String(bytes, "UTF-8");System.out.println("服务器收到的信息：" + expression);doWrite(socketChannel, "+++++" + expression + "+++++");} else if (readBytes < 0){key.cancel();socketChannel.close();}}}}@Overridepublic void run() {//循环遍历while (started) {try {selector.select();//System.out.println(selector.select());Set<SelectionKey> keys = selector.selectedKeys();//System.out.println(keys.size());Iterator<SelectionKey> iterator = keys.iterator();SelectionKey key;while (iterator.hasNext()){key = iterator.next();iterator.remove();try {handleInput(key);} catch (Exception e){if (key != null){key.cancel();if (key.channel() != null) {key.channel().close();}}}}}catch (Throwable throwable){throwable.printStackTrace();}}}
}
复制代码

客户端：

/*** Created by innoyiya on 2018/8/20.*/
public class Client {private static String DEFAULT_HOST = "localhost";private static int DEFAULT_PORT = 12345;private static ClientHandle clientHandle;private static final String EXIT = "exit";public static void start() {start(DEFAULT_HOST, DEFAULT_PORT);}public static synchronized void start(String ip, int port) {if (clientHandle != null){clientHandle.stop();}clientHandle = new ClientHandle(ip, port);new Thread(clientHandle, "Server").start();}//向服务器发送消息public static boolean sendMsg(String msg) throws Exception {if (msg.equals(EXIT)){return false;}clientHandle.sendMsg(msg);return true;}}
复制代码

客户端主体代码：

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.util.Iterator;
import java.util.Set;/*** Created by innoyiya on 2018/8/20.*/public class ClientHandle implements Runnable{private String host;private int port;private Selector selector;private SocketChannel socketChannel;private volatile boolean started;public ClientHandle(String ip,int port) {this.host = ip;this.port = port;try{//创建选择器selector = Selector.open();//打开监听通道socketChannel = SocketChannel.open();//如果为 true，则此通道将被置于阻塞模式；如果为 false，则此通道将被置于非阻塞模式socketChannel.configureBlocking(false);started = true;}catch(IOException e){e.printStackTrace();System.exit(1);}}public void stop(){started = false;}private void handleInput(SelectionKey key) throws IOException{if(key.isValid()){SocketChannel sc = (SocketChannel) key.channel();if(key.isConnectable()){if(sc.finishConnect()){System.out.println("已连接事件");}else{System.exit(1);}}//读消息if(key.isReadable()){//创建ByteBuffer，并开辟一个1M的缓冲区ByteBuffer buffer = ByteBuffer.allocate(1024);//读取请求码流，返回读取到的字节数int readBytes = sc.read(buffer);//读取到字节，对字节进行编解码if(readBytes>0){//将缓冲区当前的limit设置为position=0，用于后续对缓冲区的读取操作buffer.flip();//根据缓冲区可读字节数创建字节数组byte[] bytes = new byte[buffer.remaining()];//将缓冲区可读字节数组复制到新建的数组中buffer.get(bytes);String result = new String(bytes,"UTF-8");System.out.println("客户端收到消息：" + result);} else if(readBytes<0){key.cancel();sc.close();}}}}//异步发送消息private void doWrite(SocketChannel channel,String request) throws IOException{byte[] bytes = request.getBytes();ByteBuffer writeBuffer = ByteBuffer.allocate(bytes.length);writeBuffer.put(bytes);//flip操作writeBuffer.flip();//发送缓冲区的字节数组channel.write(writeBuffer);}private void doConnect() throws IOException{if(socketChannel.connect(new InetSocketAddress(host,port))){System.out.println("connect");}else {socketChannel.register(selector, SelectionKey.OP_CONNECT);System.out.println("register");}}public void sendMsg(String msg) throws Exception{//覆盖其之前感兴趣的事件，将其更改为OP_READsocketChannel.register(selector, SelectionKey.OP_READ);doWrite(socketChannel, msg);}@Overridepublic void run() {try{doConnect();}catch(IOException e){e.printStackTrace();System.exit(1);}//循环遍历selectorwhile(started){try{selector.select();Set<SelectionKey> keys = selector.selectedKeys();Iterator<SelectionKey> it = keys.iterator();SelectionKey key ;while(it.hasNext()){key = it.next();it.remove();try{handleInput(key);}catch(Exception e){if(key != null){key.cancel();if(key.channel() != null){key.channel().close();}}}}}catch(Exception e){e.printStackTrace();System.exit(1);}}//selector关闭后会自动释放里面管理的资源if(selector != null){try{selector.close();}catch (Exception e) {e.printStackTrace();}}}
}
复制代码

测试类：

import java.util.Scanner;/*** Created by innoyiya on 2018/8/20.*/
public class Test {public static void main(String[] args) throws Exception {Service.start();Thread.sleep(1000);Client.start();while(Client.sendMsg(new Scanner(System.in).nextLine()));}
}
复制代码

控制台打印：

服务器已启动，端口号为：12345
register
已连接事件
1234
服务器收到的信息：1234
客户端收到消息：+++++1234+++++
5678
服务器收到的信息：5678
客户端收到消息：+++++5678+++++
复制代码

如有不妥之处，请告诉我。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/450866.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

RTP协议详解

RTP协议详解

RTP协议分析 第1章. RTP概述 1.1. RTP是什么 RTP全名是Real-time Transport Protocol&#xff08;实时传输协议&#xff09;。它是IETF提出的一个标准&#xff0c;对应的RFC文档为RFC3550&#xff08;RFC1889为其过期版本&#xff09;。RFC3550不仅定义了RTP&#xff0…
阅读更多...
线程状态转换

线程状态转换

一、线程状态转换 新建&#xff08;New&#xff09; 创建后尚未启动。 可运行&#xff08;Runnable&#xff09; 可能正在运行&#xff0c;也可能正在等待 CPU 时间片。 包含了操作系统线程状态中的 Running 和 Ready。 阻塞&#xff08;Blocking&#xff09; 等待获取一个排它…
阅读更多...
Eclipse中启动tomcat报错java.lang.OutOfMemoryError: PermGen space的解决方法

Eclipse中启动tomcat报错java.lang.OutOfMemoryError: PermGen space的解决方法

见&#xff1a;http://outofmemory.cn/java/OutOfMemoryError/outofmemoryerror-permgen-space-in-tomcat-with-eclipse 有的项目引用了太多的jar包&#xff0c;或者反射生成了太多的类&#xff0c;异或有太多的常量池&#xff0c;就有可能会报java.lang.OutOfMemoryError: Per…
阅读更多...
MPEG-4 AVC/H.264 信息

MPEG-4 AVC/H.264 信息

作者&#xff1a;haibara 来源&#xff1a;pcicp.com 本FAQ由&#xff08;haibara&#xff09;翻译&#xff0c;期间受到kaito_mkid&#xff08;pcicp&#xff09;帮助&#xff0c;在此感谢&#xff0c;由于Newbie的关系&#xff0c;如有翻译错误&#xff0c;还请各位指出&…
阅读更多...
eclipse搜索关键字

eclipse搜索关键字

见&#xff1a;https://jingyan.baidu.com/article/e6c8503c1a60d2e54f1a18e3.html
阅读更多...
装饰器语法糖运用

装饰器语法糖运用

装饰器语法糖运用 前言&#xff1a;函数名是一个特性的变量&#xff0c;可以作为容器的元素&#xff0c;也可以作为函数的参数&#xff0c;也可以当做返回值。闭包定义&#xff1a; 内层函数对外层函数&#xff08;非全局&#xff09;变量的引用&#xff0c;这个内层函数就可以…
阅读更多...
fb 4.7英文版 显示行数

fb 4.7英文版 显示行数

窗口&#xff08;window&#xff09;首选项&#xff08;Preference&#xff09;—>常规&#xff08;General&#xff09;—>编辑器&#xff08;Editors&#xff09;—>文本编辑器&#xff08;Text Editors&#xff09;—>“显示行号”&#xff08;Show line number…
阅读更多...
集市中迷失的一代：FreeBSD核心开发者反思开源软件质量

集市中迷失的一代：FreeBSD核心开发者反思开源软件质量

摘要&#xff1a;本文作者Poul-Henning Kamp (phkFreeBSD.org) &#xff0c;26年的计算机程序员&#xff0c;他编写的软件以底层构建块的形式广泛被开源和商业产品采用。讲述作者在看完《设计原本》这本书后所引发的共鸣&#xff01; 13年前&#xff0c;新兴的草根开源软件运动…
阅读更多...
点击表格弹窗获取另外一套数据之后，原表格相关数据的调用

点击表格弹窗获取另外一套数据之后，原表格相关数据的调用

用H5新属性&#xff0c;data-*&#xff0c; $获取方式&#xff1a; 待续。。。。。。。 转载于:https://www.cnblogs.com/He-tao-yuan/p/9888316.html
阅读更多...
谷歌浏览器如何如何禁用弹出窗口阻止程序

谷歌浏览器如何如何禁用弹出窗口阻止程序

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到教程。 在工具栏上使用 Google Chrome 菜单。工具栏上的菜单位于浏览器右上角。 选择“设置”。 在页面底端找到并点击“显示高级设置”。 在“隐…
阅读更多...
Python 3 入门，看这篇就够了

Python 3 入门，看这篇就够了

文章目录 简介基础语法运算符变量数据类型流程控制迭代器生成器函数 自定义函数参数传递 可更改与不可更改对象参数匿名函数变量作用域模块面向对象错误和异常文件操作序列化命名规范参考资料简介 Python 是一种高层次的结合了解释性、编译性、互动性和面向对象的脚本语言。Pyt…
阅读更多...
面试经历(二)

面试经历(二)

前面说到用数据库中的锁机制对并发事务进行控制&#xff0c;这节来说说事务方法和事务方法发生嵌套调用时事务如何进行传播。例如&#xff1a;方法可能继续在现有事务中运行&#xff0c;也可能开启一个新事务&#xff0c;并在自己的事务中运行。例如&#xff1a;方法可能继续在…
阅读更多...
最有价值的编程忠告

最有价值的编程忠告

摘要&#xff1a;本文是来自贝尔实验室Plan 9操作系统的创始人Rob Pike给大家分享的编程忠告&#xff01;Rob Pike&#xff0c;目前谷歌公司最著名的软件工程师之一&#xff0c;曾是贝尔实验室Unix开发团队成员&#xff0c;缔造Go语言和Limbo语言的核心人物。 Rob Pike&#xf…
阅读更多...
Column count doesn't match value count at row 1 原因

Column count doesn't match value count at row 1 原因

mysql 提示 &#xff1a; Column count doesnt match value count at row 1错误&#xff0c;SQL语句中列的个数和值的个数不等&#xff0c; 如&#xff1a; insert into table1 (field1,field2) values(值1&#xff0c;值2&#xff0c;值3 ) 列只有2个&#xff0c;值 却有3个…
阅读更多...
MarkDowm快捷键大全

MarkDowm快捷键大全

文章目录一&#xff1a;菜单栏二&#xff1a;文件三&#xff1a;编辑四&#xff1a;段落五&#xff1a;格式六&#xff1a;视图一&#xff1a;菜单栏 文件&#xff1a;altF 编辑&#xff1a;altE 段落&#xff1a;altP 格式&#xff1a;altO 视图&#xff1a;altV 主题&#x…
阅读更多...
Kinect2.0-空间长度测量

Kinect2.0-空间长度测量

1. 鼠标左键按下选择起点&#xff0c;拖动鼠标&#xff0c;左键放开&#xff0c;确定终点。 实现效果1实现效果22. 在linux下使用libfreenect2开源多平台驱动来获取kinect2.0的传感器信息&#xff0c;得到深度信息&#xff0c;并通过libfreenect2提供的getPointXYZ函数&#xf…
阅读更多...
带数据库的智能合约

带数据库的智能合约

编写使用数据库的智能合约 前面一直在捣鼓EOS网络搭建的相关东西。然而今天比较不走运的是&#xff0c;兴致勃勃的把源码版本升到4.0&#xff0c;在编译的时候如我所猜想的出现了一系列问题&#xff0c;正一筹莫展的时候&#xff0c;导师突然问了我一个关于合约如何操作数据库的…
阅读更多...
没有完美的软件：编程永远不容易

没有完美的软件：编程永远不容易

摘要&#xff1a;很多人想用十全十美来修饰一样东西&#xff0c;比如软件&#xff0c;对于客户来说&#xff0c;当然希望他们的软件能做到完美。虽然很多专家说利用一些规范可以让软件达到更好&#xff01;但是在现实开发中&#xff0c;真的会有那么完美的软件吗&#xff1f; 最…
阅读更多...
Eclipse断点调试出现Source not found

Eclipse断点调试出现Source not found

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到教程。 我的情况是和网上说的都不一样&#xff0c;我真的也没有想到这么坑&#xff0c; 我居然无意写了一个死循环&#xff0c;dao/mapper调sql…
阅读更多...
Memory Compression这到底是个什么东西？

Memory Compression这到底是个什么东西？

Memory Compression这到底是个什么东西&#xff1f; Memory Compression这个进程&#xff0c;经过我的查询说是内存压缩功能&#xff0c;作用是压缩内存让内存占用更低&#xff0c;但是为什么这个进程疯狂占用我的内存&#xff0c;我用的Win10 8G&#xff0c;通过资源监视器查看…
阅读更多...
最新文章

Copyright @ 2022~2023