文档章节

NodeJs的TCP中的粘包、分包问题的解决方案!

-西门吹牛
 -西门吹牛
发布于 2017/04/06 09:03
字数 262
阅读 51
收藏 0

StickPackage,https://github.com/lvgithub/stickPackage  NodeJs中TCP粘包、分包解决方案!配置介绍提供对TCP粘包处理的解决方案默认缓冲512个字节,当接收数据超过512字节,自动以512倍数扩大缓冲空间本默认采用包头两个字节表示包长度默认采用大端接模式接收数据可以配置自定义包头长度[后期迭代]可以配置大端小端读取[后期迭代]

源码地址:https://github.com/lvgithub/stickPackage

使用方法

var Stick = require('./stickPackage');

let stick = new Stick();

// 设置收到完整数据触发器
stick.onData(function (data) {
console.log('receive data,length:' + data.length);
console.log('receive data,contents:' + JSON.stringify(data));
});

// 构造一个buffer,包含两个数据包,10个字节
let bytes = Buffer.from([0x00, 0x02, 0x66, 0x66, 0x00, 0x04, 0x88, 0x02, 0x11, 0x11]);
console.log('log:传入两个包,一次Put[验证一次性Put数据包]');

// 处理粘包
stick.putData(bytes);

// 结果显示
// receive data,length:4
// receive data,contents:{"type":"Buffer","data":[0,2,102,102]}
// receive data,length:6
// receive data,contents:{"type":"Buffer","data":[0,4,136,2,17,17]}

 

© 著作权归作者所有

共有 人打赏支持
-西门吹牛
粉丝 0
博文 1
码字总数 262
作品 0
Node.js 中 TCP 粘包、分包解决方案 - Stick

StickPackage,NodeJs 中 TCP 粘包、分包解决方案! 配置介绍 提供对TCP粘包处理的解决方案 默认缓冲512个字节,当接收数据超过512字节,自动以512倍数扩大缓冲空间 本默认采用包头两个字节表...

匿名
2017/10/11
55
0
基于Nodejs的Tcp封包和解包

苏格团队 作者:Jonny   我们知道,TCP是面向连接流传输的,其采用Nagle算法,在缓冲区对上层数据进行了处理。避免触发自动分片机制和网络上大量小数据包的同时也造成了粘包(小包合并)和...

苏格团队
昨天
0
0
Socket/WebSocket应用及IM粘包 分包等

> Socket/WebSocket应用 WebSocket的frame?google的protobuf在IM中的使用? IM、金融、股价、视频会议等这样一些应用来说,所需要的不过是高实时、低延时。比较好的可选方案呢?比较流行的是...

shareus
04/28
0
0
TCP通信中的粘包问题

TCP通信中的粘包问题 尹德位 2015 西安 关键词 : TCP 网络通信 粘包 Linux C/S 一 粘包问题概述 二 粘包回避设计 第一章 粘包问题概述 1.1 描述背景 采用TCP协议进行网络数据传送的软件设计...

cnyinlinux
2015/11/29
422
3
JAVA网络编程:解决TCP网络传输“粘包”问题

当前在网络传输应用中,广泛采用的是TCP/IP通信协议及其标准的socket应用开发编程接口(API)。TCP/IP传输层有两个并列的协议:TCP和UDP。其中TCP(transport control protocol,传输控制协议...

HenrySun
2016/07/23
435
0

没有更多内容

加载失败,请刷新页面

加载更多

70.shell的函数 数组 告警系统需求分析

20.16/20.17 shell中的函数 20.18 shell中的数组 20.19 告警系统需求分析 20.16/20.17 shell中的函数: ~1. 函数就是把一段代码整理到了一个小单元中,并给这个小单元起一个名字,当用到这段...

王鑫linux
44分钟前
0
0
分布式框架spring-session实现session一致性使用问题

前言:项目中使用到spring-session来缓存用户信息,保证服务之间session一致性,但是获取session信息为什么不能再服务层获取? 一、spring-session实现session一致性方式 用户每一次请求都会...

WALK_MAN
今天
5
0
C++ yield()与sleep_for()

C++11 标准库提供了yield()和sleep_for()两个方法。 (1)std::this_thread::yield(): 线程调用该方法时,主动让出CPU,并且不参与CPU的本次调度,从而让其他线程有机会运行。在后续的调度周...

yepanl
今天
4
0
Java并发编程实战(chapter_3)(线程池ThreadPoolExecutor源码分析)

这个系列一直没再写,很多原因,中间经历了换工作,熟悉项目,熟悉新团队等等一系列的事情。并发课题对于Java来说是一个又重要又难的一大块,除非气定神闲、精力满满,否则我本身是不敢随便写...

心中的理想乡
今天
27
0
shell学习之获取用户的输入命令read

在运行脚本的时候,命令行参数是可以传入参数,还有就是在脚本运行过程中需要用户输入参数,比如你想要在脚本运行时问个问题,并等待运行脚本的人来回答。bash shell为此提 供了read命令。 ...

woshixin
今天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部