ByteBuffer
例
package com.peng.socket;
import java.nio.ByteBuffer;
import org.junit.Test;
public class TestByteBuffer {
@Test
public void testByteBuffer() {
// 属性
// 1.capacity容量位--表示缓冲区的容量
// 2.position操作位--表示要操作的位--当缓冲区刚刚创建的时候,默认为0--每添加一个字节的数据的时候,就 向后移一位
// 3.limit限制位--表示position所能达到的最大位置--当缓冲区刚刚创建的时候,limit设置为何容量的大小一样
// 创建缓存区,并且指定了 大小:1024字节
ByteBuffer bb = ByteBuffer.allocate(1024);
// 向缓冲区添加数据
bb.put("hello".getBytes());
System.err.println("当前的位置:" + bb.position());
bb.position(0);// 操作位移到最前面
System.err.println("第一个字节:" + bb.get());
// 方法--翻转缓冲区flip:先将限制位设置为操作位,再将操作位设置为0
// bb.flip();
// 方法--rewind:重绕缓冲区--只是将操作位归零
// 分界
System.err.println("============分解符=============");
// 如果知道具体的数据,建议使用这种方法
ByteBuffer bb2 = ByteBuffer.wrap("hello".getBytes());
System.err.println(bb2.get());
while (bb2.hasRemaining()) {// 是否还有剩余数据
System.err.println(bb2.get());
}
}
}
@Test
public void test() throws Exception {
// 打开通道--默认为阻塞连接
SocketChannel s = SocketChannel.open();
// 设置为非阻塞
s.configureBlocking(false);
// 发起连接
s.connect(new InetSocketAddress("localhost", 8090));
// 人为阻塞--连接失败则会继续连接
while (!s.finishConnect()) {
}
// 写数据
s.write(ByteBuffer.wrap("hello".getBytes()));
System.out.println("写出成功!");
}
@Test
public void testServerSocketChannel() throws Exception {
// 打开通道--默认为阻塞连接
ServerSocketChannel ss = ServerSocketChannel.open();
// 设置为非阻塞
ss.configureBlocking(false);
// 绑定监听的端口
ss.bind(new InetSocketAddress(8090));
SocketChannel channel = ss.accept();
// 人为阻塞
while (channel == null) {
channel = ss.accept();
}
// 设置为非阻塞
// channel.configureBlocking(false);
// 准备缓冲区
ByteBuffer buffer = ByteBuffer.allocate(100);
// 读出数据
channel.read(buffer);
// 反转缓冲区--方便之后处理数据
buffer.flip();
System.out.println("数据:" + new String(buffer.array(), 0, buffer.limit()));
System.out.println("接收成功!");
}
例子
package com.peng.socket;
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;
import org.junit.Test;
public class TestSelect {
@Test
public void test1() throws Exception {
// 打开客户端通道
SocketChannel sc = SocketChannel.open();
// 非阻塞
sc.configureBlocking(false);
// 获取选择器
Selector selc = Selector.open();
// 将通道注册到选择器上
sc.register(selc, SelectionKey.OP_CONNECT);// 注册connect权力
// 发起连接
sc.connect(new InetSocketAddress("localhost", 8090));
while (true) {
// 筛选--进行选择--是否包含发放的权力
selc.select();
// 获取筛选之后的 有用的事件
Set<SelectionKey> keys = selc.selectedKeys();
// 获取迭代器
Iterator<SelectionKey> it = keys.iterator();
// 遍历
while (it.hasNext()) {
// 将遍历到的这个事件获取出来
SelectionKey key = it.next();
// 可能会发起连接
if (key.isConnectable()) {
// 获取到对应的通道
SocketChannel scx = (SocketChannel) key.channel();
// 判断连接是否成功
while (!scx.finishConnect()) {
}
// 重新注册写的权限
scx.register(selc, SelectionKey.OP_WRITE | SelectionKey.OP_READ);// 将会将原来的权限覆盖掉
}
// 可能会写数据
if (key.isWritable()) {
// 从事件身上获取通道
SocketChannel scx = (SocketChannel) key.channel();
// 写数据
String msg = "hello,hello";
scx.write(ByteBuffer.wrap(msg.getBytes()));
// 将权限进行修改
scx.register(selc, key.interestOps() & ~SelectionKey.OP_WRITE);// 取消写的权限
}
// 可能从服务器获取数据
if (key.isReadable()) {
// 从事件身上获取通道
SocketChannel scx = (SocketChannel) key.channel();
// 读数据
ByteBuffer buffer = ByteBuffer.allocate(1024);
scx.read(buffer);
buffer.flip();
System.out.println(new String(buffer.array(), 0, buffer.limit()));
// 将读的事件
scx.register(selc, key.interestOps() & ~SelectionKey.OP_READ);// 取消读的权限
}
// 防止事件处理失败--防止重复事件
it.remove();
}
}
}
/**
* 服务器端
*
*/
@Test
public void serverTest() throws Exception {
// 打开服务器的通道
ServerSocketChannel ssc = ServerSocketChannel.open();
// 绑定端口号
ssc.bind(new InetSocketAddress(8090));
// 设置为非阻塞
ssc.configureBlocking(false);
// 打开选择器
Selector selc = Selector.open();
// 注册到选择器上
ssc.register(selc, SelectionKey.OP_ACCEPT);
while (true) {
// 进行选择
selc.select();
// 将时间获取出来
Set<SelectionKey> keys = selc.selectedKeys();
// 获取到迭代器
Iterator<SelectionKey> it = keys.iterator();
// 遍历
while (it.hasNext()) {
SelectionKey key = it.next();
// 可能是接受事件
if (key.isAcceptable()) {
// 从事件身上获取通道
ServerSocketChannel scx = (ServerSocketChannel) key.channel();
// 判断连接是否成功
SocketChannel sc = scx.accept();
while (sc == null) {
sc = scx.accept();
}
sc.configureBlocking(false);
// 注册写的权限
sc.register(selc, SelectionKey.OP_WRITE | SelectionKey.OP_READ);// 将会将原来的权限覆盖掉}
}
// 可能是可写事件
if (key.isWritable()) {
// 从事件身上获取通道
SocketChannel scx = (SocketChannel) key.channel();
// 写数据
String msg = "hello,hello---------I'm Server ";
scx.write(ByteBuffer.wrap(msg.getBytes()));
// 将权限进行修改
scx.register(selc, key.interestOps() & ~SelectionKey.OP_WRITE);// 取消写的权限
}
// 可能是可读事件
if (key.isReadable()) {
// 从事件身上获取通道
SocketChannel scx = (SocketChannel) key.channel();
// 读数据
ByteBuffer buffer = ByteBuffer.allocate(1024);
scx.read(buffer);
buffer.flip();
System.out.println(new String(buffer.array(), 0, buffer.limit()));
// 修改权限
scx.register(selc, key.interestOps() & ~SelectionKey.OP_READ);// 取消读的权限
}
// 防止事件处理失败--防止重复事件
it.remove();
}
}
}
}
bio | nio |
---|---|
流有方向 | 通道,在一个通道上可以进行数据的输入和输出 |
流的数据数连续不断地,不能很灵活的操作数据 | Buffer传输数据的载体,是一个缓冲区,本质上是一个数组结构,缓冲区的大小可以自由控制(注意:实际大小不要超过32GB) |
阻塞通信模型--一个请求产生一个线程 | 非阻塞性通讯模型--一个线程或几个线程处理多用户的请求 |
不适合高并发和高访问,适合长请求 | 适合做高并发和高访的场景,短请求的场景 |
关键技术:buffer,channel |
文章浏览阅读905次。本说明以NVP6324为例。1、首先在drivers\media\i2c中修改Kconfig和Makefile,如下: 在Kconfig中添加如下:config VIDEO_NVP6324 tristate "NVP6324 AHD sensor support" depends on I2C ---help--- This is a V4L2 sensor-le..._nvp6324 驱动
文章浏览阅读2.7w次,点赞9次,收藏80次。理论请参考博客OpenCV源码的本地路径: %OPENCV%\opencv\sources\modules\imgproc\src\clahe.cppclahe.cpp// ----------------------------------------------------------------------// CLAHEnamespace{ class C_自适应双平台直方图均衡算法代码
文章浏览阅读3.1k次,点赞3次,收藏22次。点击上方“小白学视觉”,选择加"星标"或“置顶”重磅干货,第一时间送达作者丨吃猫的鱼python @CSDN编辑丨3D视觉开发者社区目录content一、什么是计算机视觉二、图片处理基础操作图片处理:读入图像图片处理:显示图像图片处理:图像保存三、图像处理入门基础图像成像原理介绍图像分类四、像素处理操作读取像素修改像素使用python中的numpy修改像素点五、获取图像属性形状像素数目图像类型六..._计算机视觉与图像处理
文章浏览阅读7.4k次,点赞6次,收藏112次。@创建于:2022.05.27@修改于:2022.05.27文章目录1、过拟合与欠拟合2、欠拟合2.1 出现的原因2.2 解决的办法3、过拟合3.1 出现的原因3.2 解决的办法4. Early stopping5、Dropout6、L1 和 L2 正则化7、参考资料1、过拟合与欠拟合机器学习中模型的泛化能力强的模型才是好模型。对于训练好的模型:若在训练集表现差,不必说在测试集表现同样会很差,这可能是欠拟合导致;若模型在训练集表现非常好,却在测试集上差强人意,则这便是过拟合导致的。过拟合_svm过拟合怎么解决
文章浏览阅读102次。【代码】go上传文件。
文章浏览阅读2.9k次。_分辨率0.5的ad芯片
文章浏览阅读215次。 成为JavaGC专家Part II :如何监控Java垃圾回收机制 本文是成为Java GC专家系列文章的第二篇。在第一篇《深入浅出Java垃圾回收机制》中我们学习了不同GC算法的执行过程,GC是如何工作的,什么是新生代和老年代,你应该了解的JDK7中的5种GC类型,以及这5种类型对于应用性能的影响。 在本文中,我将解释JVM到底是如何执行垃圾回收处理..._成为javagc专家part ii — 如何监控java垃圾回收机制。
文章浏览阅读122次。文章目录python学习导航线一、seleniumpython-selenium二、python基础知识python的聊天室python学习导航线一、seleniumpython-selenium二、python基础知识python的聊天室_python点线导航
文章浏览阅读3.4k次,点赞4次,收藏22次。静态成员静态成员都是用static修饰,它的特点是不论创建多少个对象,程序都只创建一个静态成员。最主要的特点:共享什么是共享呢?例如:统计超市中所有商品数量的总和,商品数量的总和是随着每一个数量的变化而变化的,这是我们就可以用静态成员处理。(代码下面有写)静态成员又分为静态成员变量和静态成员函数。(一)静态成员变量特点:1、所有对象共享一份数据。 2、在编译阶段分配内存。 3、类内声明,类外初始化。#include<io..._静态成员变量
文章浏览阅读879次,点赞21次,收藏20次。1 网页简介:基于HTML+CSS+JavaScript 制作七夕情人节表白网页、生日祝福、七夕告白、 求婚、浪漫爱情3D相册、炫酷代码,快来制作一款高端的表白网页送(他/她)浪漫的告白,制作修改简单,可自行更换背景音乐,文字和图片即可使用等任意html编辑软件进行运行及修改编辑等操作)。_html 满屏爱心
文章浏览阅读492次,点赞9次,收藏5次。【代码】【易飞】易飞ERP自动审核程序功能。_易飞单据审批设置
文章浏览阅读1.6k次,点赞15次,收藏30次。文件打开是一个print数组v4的地址和read函数,并且nx好像可写,输入长度可以利用,进行一个栈上写好自己的shell,然后在构造一个回到v4的地址,这样子就可以重新读取到写buf段上的shell,这里要注意shell的隔断用/00截断然后构造好栈上数据。一个sql注入题目,尝试使用二分查找,但只能爆出表名和列名,值一直出不来,后来采用布尔盲注,fuzz测试后发现没有加任何过滤,直接写脚本。第二题:为了求解方程 (5 + sqrt{x} = 8),我们可以分离平方根项,然后求解 (x)。_xyctf高校新生联合赛 2024