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 |
文章浏览阅读3.2w次。<Window x:Class="Zhaoxi.BindingStudy.DataFormatStudy.DataFormatStudyWin" xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:d="http://schemas.microsoft.._wpf 自定义属性绑定 格式化 实现
文章浏览阅读1.1w次,点赞3次,收藏5次。转载请说明来源于"厦门SEO"本文地址:http://www.96096.cc/Article/160880.html常用办公软件 WPS Office是由金山软件股份有限公司开发的一款针对个人永久免费的办公软件,在我们的日常生活和工作中,WPS Office比起微软Microsoft Office来说在文字上的处理会更深入国人用户的人心,熟悉操作WPS的办公小技巧,能够更高效的提高我们的工作效率,今天小编要为大家分享的是WPS怎么自动生成目录?快来一起看看WPS自动生成目录的设置教程吧。_wps目录自动生成
文章浏览阅读7.4k次,点赞2次,收藏19次。web项目是指服务端部署在服务器上,客户端使用浏览器通过网络传输进行访问获取数据的项目。通常我们看见的应用页面网站等等都可以称之为web项目。 在web项目的开发中可分为web前端开发和web后端开发 web前端:即是客户端能看得见碰得着得东西。包括Web页面结构、页面样式外观以及Web层面得交互展现。 前端特点:页面视觉效果良好(客户第一)、Web页面交互流畅(..._web项目
文章浏览阅读5.6k次,点赞8次,收藏67次。java操作关于导入导出Excel的多种方式_java导出excel的三种方法
文章浏览阅读1.1w次,点赞10次,收藏21次。Windows path系统变量编辑_windows path
文章浏览阅读512次。第13章 源码编译13.2 Hadoop2.7.3源码编译13.2.1下载Hadoop源码包(1)到官网http://hadoop.apache.org/releases.html下载2.7.3的source源码包(2)解压缩tar -zxvf hadoop-2.7.3-src.tar.gz -C /opt1(3)打开解压目录下的BUILDING.txt,编译过程和需要的软件其实就是根据这个文档里..._hadoop2.7.3-src源码下载
文章浏览阅读884次。使用多种方式实现接口幂等性,通过定义注解方便对方法进行幂等性控制
文章浏览阅读324次。SpringBoot、Swagger2 整合详解_springboot swagger2 开关
文章浏览阅读2.8w次,点赞96次,收藏115次。报错说是时区不对因为mysql-connection-java版本导致时区的问题。pom.xml:控制台报错信息:java.sql.SQLException: The server time zone value ‘�й���ʱ��’ is unrecognized or represents more than one time zone. You must configure ei..._springboot项目里面报错 the server time zone value ' й
文章浏览阅读4.2k次。Kotlin 是由 jetBrains 开发的一门现代多平台应用的静态编程语言,Kotlin 代码即可以编译成 Java 字节码,又可以编译成 JavaScript,Kotlin 是开源的,源码在这。Kotlin 包含了大量的语法糖,在编码的时候,会大大的简化我们的代码量及工作效率。且相比传统的 Java 语言,Kotlin 种大量的简写,可以减少很多用Java 必须要写的样板代码,减少大量的 if…else 等嵌套,减少大量接口的实现,代码结构也会更加清晰。_kotlin学习
文章浏览阅读753次,点赞30次,收藏21次。在线绿色新鲜果蔬商店网站是指一个专门销售新鲜、绿色、有机水果和蔬菜的电子商务平台。这类网站旨在为消费者提供方便、快捷的购买渠道,同时确保他们能够购买到高质量、新鲜的产品。
文章浏览阅读1k次。最近写项目碰到一个bug 大概就是一个表格组件两个页面都会使用 组件中表格的某些列就用v-if控制了 表格的首尾列都用了fixed 然后就发生了bug 如下图 具体原因不明看过很多网上的办法 有在fixed的列绑定key的 也有使用doLayout()的 测了都没用 最后在一个前端交流群里一位大佬给出的办法 实测有效.el-table__header, .el-table__body, .el-table__footer { width: 100%; tab_element table fixed 样式异常