当前位置: 首页 > news >正文

做java面试题网站网络营销产品概念

做java面试题网站,网络营销产品概念,北京站网站建设,wordpress传不上站点处理消息边界 为什么要处理边界 因为会存在半包和粘包的问题 1.客户端和服务端约定一个固定长度 优点:简单 缺点:可能造成浪费 2.客户端与服务端约定一个固定分割符 *缺点 效率低 3.先发送长度,再发送数据 TLV格式: type…

处理消息边界

为什么要处理边界

因为会存在半包和粘包的问题

1.客户端和服务端约定一个固定长度

  • 优点:简单

  • 缺点:可能造成浪费

2.客户端与服务端约定一个固定分割符

*缺点 效率低

3.先发送长度,再发送数据

TLV格式: type类型,length长度,Value数据,类型和长度已知的情况下,就可以方便获取消息大小

http1.1是TLV格式
http2.0是LTV格式

4.自动扩容解决消息边界问题

在这里插入图片描述

第一次read事件未能读完全部的输入,那么会产生第二个读事件,那么在第一次读的时候进行扩容,
并复制之前的内容至新的buffer中,
在第二个读事件触发以后使用扩容后的buffer,读取剩余的数据

buffer应当和各自的channel绑定,如何绑定,需要用到附件attachment,
attachment需要在注册时放到selectionKey中。

// 绑定附件
SelectionKey scKey = channel.register(selector,0,byteBuffer);// 获取附件
scKey.attachment();// 指定新的附件(覆盖附件)
scKey.attach(bytebuffer);

示例代码:

package com.ysf;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.nio.charset.Charset;
import java.util.Iterator;public class BorderSelectorServer {/*** 读取到 '\n'时打印* @param byteBuffer 缓冲字节*/public static void handle(ByteBuffer byteBuffer) {byteBuffer.flip();for (int i = 0; i < byteBuffer.limit(); i++) {if (byteBuffer.get(i) == '\n') {int length = i + 1 - byteBuffer.position();ByteBuffer allocate = ByteBuffer.allocate(length);for (int j=0;j<length;j++){allocate.put(byteBuffer.get());}allocate.flip();System.out.println(Charset.defaultCharset().decode(allocate));}}byteBuffer.compact();}public static void main(String[] args) throws IOException {// 声明一个选择器Selector selector = Selector.open();// 声明一个serverServerSocketChannel ssc = ServerSocketChannel.open();ssc.bind(new InetSocketAddress(11027));ssc.configureBlocking(false);// 注册这个server到selectorSelectionKey sscKey = ssc.register(selector, 0, null);// 添加sscKey关心的事件,因为是serverChannel,所以应当关心accept事件sscKey.interestOps(SelectionKey.OP_ACCEPT);while (true) {selector.select();Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();while (iterator.hasNext()) {SelectionKey key = iterator.next();iterator.remove();if (key.isAcceptable()) {ServerSocketChannel serverChannel = (ServerSocketChannel) key.channel();SocketChannel socketChannel = serverChannel.accept();socketChannel.configureBlocking(false);// 声明一个buffer缓冲区和socketChannel绑定ByteBuffer byteBuffer = ByteBuffer.allocate(16);SelectionKey scKey = socketChannel.register(selector, 0, byteBuffer);scKey.interestOps(SelectionKey.OP_READ);} else if (key.isReadable()) {// 当客户端异常断开链接是需要处理IOExceptiontry {SocketChannel channel = (SocketChannel) key.channel();ByteBuffer byteBuffer = (ByteBuffer) key.attachment();int read = channel.read(byteBuffer);if (read == -1) {// 客户端close()了key.cancel();}else{// 调用处理逻辑handle(byteBuffer);if (byteBuffer.position() == byteBuffer.limit()){// buffer满了,需要扩容ByteBuffer bufferEx = ByteBuffer.allocate(byteBuffer.capacity() * 2);byteBuffer.flip();bufferEx.put(byteBuffer);key.attach(bufferEx);}}}catch (IOException e){
//                        e.printStackTrace();key.cancel();}}}}}
}
http://www.15wanjia.com/news/37698.html

相关文章:

  • 数据库检索网站建设免费创建个人网页
  • 试玩做任务赚钱的网站百度指数如何分析
  • 中国有哪些网站可以做兼职网站提交入口链接
  • 响应式网站一般做几个尺寸网络营销网站建设案例
  • 七牛云存储代替WordPress百度seo流量
  • php 建设网站汕头seo服务
  • 企业建站网站认证互联网营销案例
  • 医疗科技网站建设做网站需要哪些技术
  • 华久网站建设5g影讯5g天线在线观看免费视频
  • 在线客服链接网站优化公司哪家好
  • 一个网站值多少钱营销策划方案内容
  • 爱民网站制作建立一个网站需要多少钱?
  • 淄博企业网站设计公司友情链接实例
  • 湖南餐饮网站建设n127网推广
  • 供应邯郸专业做网站网站seo搜索引擎的原理是什么
  • 做一个网站多久今日全国疫情一览表
  • 优秀个人网站设计成都网站建设企业
  • 网站建设方案有哪几种谷歌浏览器网页版入口手机版
  • 学什么可以做响应式网站菏泽地网站seo
  • 织梦大气婚纱影楼网站源码 dedecms摄影工作室网站模板seo实战视频
  • 房产网站制作方案国外黄冈网站推广软件
  • 欧美做的爱爱网站十大网站管理系统
  • 做信息类网站有哪些网站运营及推广方案
  • 南京网络推广网站免费自助建站哪个最好
  • 怎么查网站的icp备案哪个公司的网站制作
  • b2c网络商城seo sem推广
  • 怎么在视频网站做淘宝客怎么让客户主动找你
  • 公司做网站费用国外b站视频推广网站
  • 开发建设信息的网站2345网址导航大全
  • qq推广官网济南seo官网优化