android 分包粘包_Android Socket 发送与接收数据问题处理: 发送后的数据接收到总是粘包...
先说明一下粘包的概念: 发送时是两个单独的包、两次发送,但接收时两个包连在一起被一次接收到。
在以前 WinCE 下 Socket 编程,确实也要处理粘包的问题,没想到在 Android 下也遇到了。
首先想从发送端能否避免这样的问题,例如: (1) 调用强制刷数据完成发送的函数;(2) 设置发送超时。
1 先试了调用 flush() 函数,但运行后现象依旧
2 设置发送超时是 Windows 平台的做法,但在 Android 平台下是否有类似的设置呢?
查看 Socket 类的实现代码:java.net.socket socket.class 文件后发现,还是有函数可以完成这样的设置的。请看如下函数和变量的说明:/**
* Sets this socket's {@link SocketOptions#TCP_NODELAY} option.
*/
public void setTcpNoDelay(boolean on) throws SocketException {
checkOpenAndCreate(true);
impl.setOption(SocketOptions.TCP_NODELAY, Boolean.valueOf(on));
}
和/**
* This boolean option specifies whether data is sent immediately on this socket.
* As a side-effect this could lead to low packet efficiency. The
* socket implementation uses the Nagle's algorithm to try to reach a higher
* packet efficiency if this option is disabled.
*/
public static final int TCP_NODELAY = 1;
一般情况下,只需要调用如下的代码即可:public Socket clientSocket = null;
// 实例化对象并连接到服务器
clientSocket = new Socket("172.25.103.1",12589);
不用做任何设置就可以完成与服务器/客户端的通讯,刚开始我也是这样做的。所以,遇到了上面的问题。// 发送数据包,默认为 false,即客户端发送数据采用 Nagle 算法;
// 但是对于实时交互性高的程序,建议其改为 true,即关闭 Nagle 算法,客户端每发送一次数据,无论数据包大小都会将这些数据发送出去
clientSocket.setTcpNoDelay(true);
看以下较完整的 Socket 初始化与设置过程:/* * * * * * * * * * 客户端 Socket 通过构造方法连接服务器 * * * * * * * * * */
try {
// 客户端 Socket 可以通过指定 IP 地址或域名两种方式来连接服务器端,实际最终都是通过 IP 地址来连接服务器
// 新建一个Socket,指定其IP地址及端口号
Socket clientSocket = new Socket("172.25.103.1",12589);
// 客户端socket在接收数据时,有两种超时:1. 连接服务器超时,即连接超时;2. 连接服务器成功后,接收服务器数据超时,即接收超时
// 设置 socket 读取数据流的超时时间
clientSocket.setSoTimeout(5000);
// 发送数据包,默认为 false,即客户端发送数据采用 Nagle 算法;
// 但是对于实时交互性高的程序,建议其改为 true,即关闭 Nagle 算法,客户端每发送一次数据,无论数据包大小都会将这些数据发送出去
clientSocket.setTcpNoDelay(true);
// 设置客户端 socket 关闭时,close() 方法起作用时延迟 30 秒关闭,如果 30 秒内尽量将未发送的数据包发送出去
clientSocket.setSoLinger(true, 30);
// 设置输出流的发送缓冲区大小,默认是4KB,即4096字节
clientSocket.setSendBufferSize(4096);
// 设置输入流的接收缓冲区大小,默认是4KB,即4096字节
clientSocket.setReceiveBufferSize(4096);
// 作用:每隔一段时间检查服务器是否处于活动状态,如果服务器端长时间没响应,自动关闭客户端socket
// 防止服务器端无效时,客户端长时间处于连接状态
clientSocket.setKeepAlive(true);
// 客户端向服务器端发送数据,获取客户端向服务器端输出流
OutputStream osSend = clientSocket.getOutputStream();
OutputStreamWriter osWrite = new OutputStreamWriter(osSend);
BufferedWriter bufWrite = new BufferedWriter(osWrite);
// 代表可以立即向服务器端发送单字节数据
clientSocket.setOOBInline(true);
// 数据不经过输出缓冲区,立即发送
clientSocket.sendUrgentData(0x44);//"D"
// 向服务器端写数据,写入一个缓冲区
// 注:此处字符串最后必须包含“rnrn”,告诉服务器HTTP头已经结束,可以处理数据,否则会造成下面的读取数据出现阻塞
// 在write() 方法中可以定义规则,与后台匹配来识别相应的功能,例如登录Login() 方法,可以写为write("Login|LeoZheng,0603 rnrn"),供后台识别;
bufWrite.write("Login|LeoZheng,0603 rnrn");
// 发送缓冲区中数据 - 前面说调用 flush() 无效,可能是调用的方法不对吧!
bufWrite.flush();
}
catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
/* * * * * * * * * * Socket 客户端读取服务器端响应数据 * * * * * * * * * */
try {
// serverSocket.isConnected 代表是否连接成功过
// 判断 Socket 是否处于连接状态
if(true == serverSocket.isConnected() && false == serverSocket.isClosed()) {
// 客户端接收服务器端的响应,读取服务器端向客户端的输入流
InputStream isRead = serverSocket.getInputStream();
// 缓冲区
byte[] buffer = new byte[isRead.available()];
// 读取缓冲区
isRead.read(buffer);
// 转换为字符串
String responseInfo = new String(buffer);
// 日志中输出
Log.i("Socket Server", responseInfo);
}
// 关闭网络
serverSocket.close();
}
catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
/* * * * * * * * * * Socket 客户端通过 connect 方法连接服务器 * * * * * * * * * */
try {
Socket serverSocket = new Socket();
// 使用默认的连接超时
serverSocket.connect(new InetSocketAddress("172.25.103.1",12589));// 连接超时 3 秒: serverSocket.connect(new InetSocketAddress("172.25.103.1",12589),3000);
// 关闭 socket
serverSocket.close();
}
catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
最后说明一点: 无论 Socket 如何设置,接收方是一定要处理粘包的问题的。即在接收时,对接收到的数据进行分析,看是否存在数据不全或粘包的现象。
android 分包粘包_Android Socket 发送与接收数据问题处理: 发送后的数据接收到总是粘包...相关推荐
- Android 手机采集摄像头视频 socket 视频传输实时传播
这里搜集了两种实现Android 手机采集摄像头视频 socket 视频传输实时传播的方法,两种都可以使用. 第一种如下: 1.通过客户端socket请求,服务端接受到请求后,获取socket的输出流 ...
- android 手机采集摄像头视频 socket 视频传输 实时传播
一.具体流程: 1.通过客户端socket请求,服务端接受到请求后,获取socket的输出流对象outs. 2.服务端通过Camera的setPreviewCallback方法回调采集摄像头视频数据, ...
- android 分包粘包_TCP粘包和拆包问题
1)产生TCP粘包和拆包问题的主要原因是,操作系统在发送TCP数据的时候,底层会有一个缓冲区,例如1024个字节大小,如果一次请求发送的数据量比较小,没达到缓冲区大小,TCP则会将多个请求合并为同一个 ...
- qt 串口粘包_Qt Socket 传输图片——图像拆包、组包、粘包处理
之前给大家分享了一个使用python发图片数据.Qt server接收图片的Demo.之前的Demo用于传输小字节的图片是可以的,但如果是传输大的图片,使用socket无法一次完成发送该怎么办呢?本次 ...
- python socket.socket()函数 套接字详解及TCP、UDP程序示例(粘包等)
文章目录 socket的定义 套接字的工作流程 socket函数使用 socket函数用法 服务端套接字函数 客户端套接字函数 公共用途的套接字函数 面向文件的套接字方法 打电话的流程演示 服务端.p ...
- java android消息推送_Android中使用socket通信实现消息推送的方法详解
原理最近用socket写了一个消息推送的demo,在这里和大家分享一下. 主要实现了:一台手机向另外一台手机发送消息,这两台手机可以随时自由发送文本消息进行通信,类似我们常用的QQ. 效果图: 原理: ...
- android按住录音按钮_Android模仿微信录音、发送语音效果实现
在项目开发中,有个需求:实现模仿微信录音,发送语音的功能.长按按钮录音,弹框显示语音时间,以及上滑取消发送.我重写了一个发送语音的控件,以实现该功能. 首先添加权限: AudioRecorderBut ...
- android 判断byte值_Android开发之UDP可靠性传输
轩羽:Android开发之UDPzhuanlan.zhihu.com 在这一篇文章里,小编说到UDP是不可靠的,故,我们要自己写一套协议,来使UDP实现可靠性传输,这里,小编和小编的小伙伴一起,写了 ...
- Android中关于Socket通信数据大小,内存缓冲区和数据可靠性的一点调查
关于TCP和UDP Socket通信的区别: 应用场景: UDP传输协议效率高,但不可靠: TCP传输效率低,但可靠. 传输数据大小: UDP传输数据限定在64K以下: TCP传输数据无大小限制,可进 ...
最新文章
- 按位与 matlab,c# 按位与,按位或
- 你真正的去了解过Linux吗?不单单是一些命令操作,比如它的系统架构!!!
- .net core i上 K8S(四).netcore程序的pod管理,重启策略与健康检查
- 如何绘制逻辑图 — 5. 要素的属性:系统与模块
- 五大智能软硬件技术,赋予智慧健康无限可能
- [转]:xmake工程描述编写之选择性编译
- OpenStack 存储服务 Cinder介绍和控制节点部署 (十三)
- HG255D刷flash记录
- Big5和Gb编码转换
- 思科交换机接口配置trunk_Cisco交换机Trunk配置命令是什么?
- 图片怎么转换成pdf格式?手把手教你图片转PDF怎么转
- 数钥科技遭用户投诉:“招集令”被指息费高,曾有助贷平台被处罚
- 网络实名认证接口认证形式有哪些?
- 配置OSPF负载分担
- BUUCTF 每日打卡 2021-4-5
- 身份证归属地查询软件(离线版)
- Web安全之CTF测试赛
- Java 生态圈中的嵌入式数据库,哪家强?
- 法学论文应该注重论证形式
- linux 安装cvs,在Linux中安装CVS
热门文章
- 前端怎么携带cookie发送php,PHP如何执行传递cookie的http请求并将结果保存到字符串...
- 华为lab-rs-v1-2.4_OSPF提升
- android自动化必备之界面元素
- Visual Studio 常用快捷键(一)
- Eclipse 插件之间互相依赖, 导出Jar包安装, 报错“java.lang.NoClassDefFoundError”
- 事半功倍系列之javascript (转载)
- YOLO 检测算法分析
- wireshark常用选项与功能总结【10分钟成为抓包大师】
- Android Media Framework(1): 总纲
- educoder MongoDB 文档的高级查询操作